Lines Matching refs:commit_transaction
116 transaction_t *commit_transaction)
135 header->h_sequence = cpu_to_be32(commit_transaction->t_tid);
191 transaction_t *commit_transaction,
213 while (commit_transaction->t_sync_datalist) {
214 jh = commit_transaction->t_sync_datalist;
245 || jh->b_transaction != commit_transaction
257 __journal_file_buffer(jh, commit_transaction,
267 __journal_file_buffer(jh, commit_transaction,
305 transaction_t *commit_transaction;
345 commit_transaction = journal->j_running_transaction;
346 J_ASSERT(commit_transaction->t_state == T_RUNNING);
349 commit_transaction->t_tid);
352 commit_transaction->t_state = T_LOCKED;
359 if (commit_transaction->t_synchronous_commit)
361 spin_lock(&commit_transaction->t_handle_lock);
362 while (commit_transaction->t_updates) {
367 if (commit_transaction->t_updates) {
368 spin_unlock(&commit_transaction->t_handle_lock);
372 spin_lock(&commit_transaction->t_handle_lock);
376 spin_unlock(&commit_transaction->t_handle_lock);
378 J_ASSERT (commit_transaction->t_outstanding_credits <=
397 while (commit_transaction->t_reserved_list) {
398 jh = commit_transaction->t_reserved_list;
431 commit_transaction->t_state = T_FLUSH;
432 journal->j_committing_transaction = commit_transaction;
435 commit_transaction->t_log_start = journal->j_head;
445 err = journal_submit_data_buffers(journal, commit_transaction,
452 while (commit_transaction->t_locked_list) {
455 jh = commit_transaction->t_locked_list->b_tprev;
482 jh->b_transaction == commit_transaction &&
507 journal_write_revoke_records(journal, commit_transaction, write_op);
515 J_ASSERT (commit_transaction->t_sync_datalist == NULL);
525 commit_transaction->t_state = T_COMMIT;
528 J_ASSERT(commit_transaction->t_nr_buffers <=
529 commit_transaction->t_outstanding_credits);
533 while (commit_transaction->t_buffers) {
537 jh = commit_transaction->t_buffers;
550 if (!commit_transaction->t_buffers)
577 header->h_sequence = cpu_to_be32(commit_transaction->t_tid);
589 journal_file_buffer(descriptor, commit_transaction,
609 commit_transaction->t_outstanding_credits--;
623 * new_bh->b_transaction to commit_transaction.
628 flags = journal_write_metadata_buffer(commit_transaction,
659 commit_transaction->t_buffers == NULL ||
706 while (commit_transaction->t_iobuf_list != NULL) {
709 jh = commit_transaction->t_iobuf_list->b_tprev;
738 jh = commit_transaction->t_shadow_list->b_tprev;
748 journal_file_buffer(jh, commit_transaction, BJ_Forget);
756 J_ASSERT (commit_transaction->t_shadow_list == NULL);
762 while (commit_transaction->t_log_list != NULL) {
765 jh = commit_transaction->t_log_list->b_tprev;
792 J_ASSERT(commit_transaction->t_state == T_COMMIT);
793 commit_transaction->t_state = T_COMMIT_RECORD;
796 if (journal_write_commit_record(journal, commit_transaction))
809 J_ASSERT(commit_transaction->t_sync_datalist == NULL);
810 J_ASSERT(commit_transaction->t_buffers == NULL);
811 J_ASSERT(commit_transaction->t_checkpoint_list == NULL);
812 J_ASSERT(commit_transaction->t_iobuf_list == NULL);
813 J_ASSERT(commit_transaction->t_shadow_list == NULL);
814 J_ASSERT(commit_transaction->t_log_list == NULL);
822 while (commit_transaction->t_forget) {
826 jh = commit_transaction->t_forget;
830 J_ASSERT_JH(jh, jh->b_transaction == commit_transaction ||
883 __journal_insert_checkpoint(jh, commit_transaction);
923 if (commit_transaction->t_forget) {
933 J_ASSERT(commit_transaction->t_state == T_COMMIT_RECORD);
935 commit_transaction->t_state = T_FINISHED;
936 J_ASSERT(commit_transaction == journal->j_committing_transaction);
937 journal->j_commit_sequence = commit_transaction->t_tid;
953 if (commit_transaction->t_checkpoint_list == NULL &&
954 commit_transaction->t_checkpoint_io_list == NULL) {
955 __journal_drop_transaction(journal, commit_transaction);
958 journal->j_checkpoint_transactions = commit_transaction;
959 commit_transaction->t_cpnext = commit_transaction;
960 commit_transaction->t_cpprev = commit_transaction;
962 commit_transaction->t_cpnext =
964 commit_transaction->t_cpprev =
965 commit_transaction->t_cpnext->t_cpprev;
966 commit_transaction->t_cpnext->t_cpprev =
967 commit_transaction;
968 commit_transaction->t_cpprev->t_cpnext =
969 commit_transaction;