Lines Matching refs:tid
472 int log_start_commit(journal_t *journal, tid_t tid) in log_start_commit() argument
477 ret = __log_start_commit(journal, tid); in log_start_commit()
495 tid_t tid; in journal_force_commit_nested() local
509 tid = transaction->t_tid; in journal_force_commit_nested()
511 log_wait_commit(journal, tid); in journal_force_commit_nested()
526 tid_t tid = journal->j_running_transaction->t_tid; in journal_start_commit() local
528 __log_start_commit(journal, tid); in journal_start_commit()
532 *ptid = tid; in journal_start_commit()
551 int log_wait_commit(journal_t *journal, tid_t tid) in log_wait_commit() argument
557 if (!tid_geq(journal->j_commit_request, tid)) { in log_wait_commit()
560 __func__, journal->j_commit_request, tid); in log_wait_commit()
570 journal->j_running_transaction->t_tid == tid) || in log_wait_commit()
572 journal->j_committing_transaction->t_tid == tid))) in log_wait_commit()
575 if (!tid_geq(journal->j_commit_waited, tid)) in log_wait_commit()
576 journal->j_commit_waited = tid; in log_wait_commit()
577 while (tid_gt(tid, journal->j_commit_sequence)) { in log_wait_commit()
579 tid, journal->j_commit_sequence); in log_wait_commit()
583 !tid_gt(tid, journal->j_commit_sequence)); in log_wait_commit()
602 int journal_trans_will_send_data_barrier(journal_t *journal, tid_t tid) in journal_trans_will_send_data_barrier() argument
611 if (tid_geq(journal->j_commit_sequence, tid)) in journal_trans_will_send_data_barrier()
618 if (commit_trans && commit_trans->t_tid == tid && in journal_trans_will_send_data_barrier()
1550 tid_t tid = transaction->t_tid; in journal_flush() local
1553 log_wait_commit(journal, tid); in journal_flush()