Lines Matching refs:tid
490 int log_start_commit(journal_t *journal, tid_t tid) in log_start_commit() argument
495 ret = __log_start_commit(journal, tid); in log_start_commit()
513 tid_t tid; in journal_force_commit_nested() local
527 tid = transaction->t_tid; in journal_force_commit_nested()
529 log_wait_commit(journal, tid); in journal_force_commit_nested()
544 tid_t tid = journal->j_running_transaction->t_tid; in journal_start_commit() local
546 __log_start_commit(journal, tid); in journal_start_commit()
550 *ptid = tid; in journal_start_commit()
569 int log_wait_commit(journal_t *journal, tid_t tid) in log_wait_commit() argument
575 if (!tid_geq(journal->j_commit_request, tid)) { in log_wait_commit()
578 __func__, journal->j_commit_request, tid); in log_wait_commit()
588 journal->j_running_transaction->t_tid == tid) || in log_wait_commit()
590 journal->j_committing_transaction->t_tid == tid))) in log_wait_commit()
593 if (!tid_geq(journal->j_commit_waited, tid)) in log_wait_commit()
594 journal->j_commit_waited = tid; in log_wait_commit()
595 while (tid_gt(tid, journal->j_commit_sequence)) { in log_wait_commit()
597 tid, journal->j_commit_sequence); in log_wait_commit()
601 !tid_gt(tid, journal->j_commit_sequence)); in log_wait_commit()
618 int journal_trans_will_send_data_barrier(journal_t *journal, tid_t tid) in journal_trans_will_send_data_barrier() argument
627 if (tid_geq(journal->j_commit_sequence, tid)) in journal_trans_will_send_data_barrier()
634 if (commit_trans && commit_trans->t_tid == tid && in journal_trans_will_send_data_barrier()
1565 tid_t tid = transaction->t_tid; in journal_flush() local
1568 log_wait_commit(journal, tid); in journal_flush()