Lines Matching refs:commit_transaction
103 transaction_t *commit_transaction)
124 tmp->h_sequence = cpu_to_be32(commit_transaction->t_tid);
177 transaction_t *commit_transaction)
197 while (commit_transaction->t_sync_datalist) {
198 jh = commit_transaction->t_sync_datalist;
229 || jh->b_transaction != commit_transaction
241 __journal_file_buffer(jh, commit_transaction,
251 __journal_file_buffer(jh, commit_transaction,
285 transaction_t *commit_transaction;
322 commit_transaction = journal->j_running_transaction;
323 J_ASSERT(commit_transaction->t_state == T_RUNNING);
326 commit_transaction->t_tid);
329 commit_transaction->t_state = T_LOCKED;
331 spin_lock(&commit_transaction->t_handle_lock);
332 while (commit_transaction->t_updates) {
337 if (commit_transaction->t_updates) {
338 spin_unlock(&commit_transaction->t_handle_lock);
342 spin_lock(&commit_transaction->t_handle_lock);
346 spin_unlock(&commit_transaction->t_handle_lock);
348 J_ASSERT (commit_transaction->t_outstanding_credits <=
367 while (commit_transaction->t_reserved_list) {
368 jh = commit_transaction->t_reserved_list;
401 commit_transaction->t_state = T_FLUSH;
402 journal->j_committing_transaction = commit_transaction;
404 commit_transaction->t_log_start = journal->j_head;
415 if (commit_transaction->t_buffers) {
416 new_jh = jh = commit_transaction->t_buffers->b_tnext;
431 journal_submit_data_buffers(journal, commit_transaction);
437 while (commit_transaction->t_locked_list) {
440 jh = commit_transaction->t_locked_list->b_tprev;
471 journal_write_revoke_records(journal, commit_transaction);
481 J_ASSERT (commit_transaction->t_sync_datalist == NULL);
490 commit_transaction->t_state = T_COMMIT;
494 while (commit_transaction->t_buffers) {
498 jh = commit_transaction->t_buffers;
510 if (!commit_transaction->t_buffers)
537 header->h_sequence = cpu_to_be32(commit_transaction->t_tid);
549 journal_file_buffer(descriptor, commit_transaction,
569 commit_transaction->t_outstanding_credits--;
583 * new_bh->b_transaction to commit_transaction.
588 flags = journal_write_metadata_buffer(commit_transaction,
619 commit_transaction->t_buffers == NULL ||
666 while (commit_transaction->t_iobuf_list != NULL) {
669 jh = commit_transaction->t_iobuf_list->b_tprev;
698 jh = commit_transaction->t_shadow_list->b_tprev;
708 journal_file_buffer(jh, commit_transaction, BJ_Forget);
716 J_ASSERT (commit_transaction->t_shadow_list == NULL);
722 while (commit_transaction->t_log_list != NULL) {
725 jh = commit_transaction->t_log_list->b_tprev;
747 if (journal_write_commit_record(journal, commit_transaction))
760 J_ASSERT(commit_transaction->t_sync_datalist == NULL);
761 J_ASSERT(commit_transaction->t_buffers == NULL);
762 J_ASSERT(commit_transaction->t_checkpoint_list == NULL);
763 J_ASSERT(commit_transaction->t_iobuf_list == NULL);
764 J_ASSERT(commit_transaction->t_shadow_list == NULL);
765 J_ASSERT(commit_transaction->t_log_list == NULL);
773 while (commit_transaction->t_forget) {
777 jh = commit_transaction->t_forget;
781 J_ASSERT_JH(jh, jh->b_transaction == commit_transaction ||
834 __journal_insert_checkpoint(jh, commit_transaction);
872 if (commit_transaction->t_forget) {
882 J_ASSERT(commit_transaction->t_state == T_COMMIT);
884 commit_transaction->t_state = T_FINISHED;
885 J_ASSERT(commit_transaction == journal->j_committing_transaction);
886 journal->j_commit_sequence = commit_transaction->t_tid;
890 if (commit_transaction->t_checkpoint_list == NULL) {
891 __journal_drop_transaction(journal, commit_transaction);
894 journal->j_checkpoint_transactions = commit_transaction;
895 commit_transaction->t_cpnext = commit_transaction;
896 commit_transaction->t_cpprev = commit_transaction;
898 commit_transaction->t_cpnext =
900 commit_transaction->t_cpprev =
901 commit_transaction->t_cpnext->t_cpprev;
902 commit_transaction->t_cpnext->t_cpprev =
903 commit_transaction;
904 commit_transaction->t_cpprev->t_cpnext =
905 commit_transaction;