Lines Matching refs:transaction
60 void jbd2_journal_free_transaction(transaction_t *transaction) in jbd2_journal_free_transaction() argument
62 if (unlikely(ZERO_OR_NULL_PTR(transaction))) in jbd2_journal_free_transaction()
64 kmem_cache_free(transaction_cache, transaction); in jbd2_journal_free_transaction()
83 jbd2_get_transaction(journal_t *journal, transaction_t *transaction) in jbd2_get_transaction() argument
85 transaction->t_journal = journal; in jbd2_get_transaction()
86 transaction->t_state = T_RUNNING; in jbd2_get_transaction()
87 transaction->t_start_time = ktime_get(); in jbd2_get_transaction()
88 transaction->t_tid = journal->j_transaction_sequence++; in jbd2_get_transaction()
89 transaction->t_expires = jiffies + journal->j_commit_interval; in jbd2_get_transaction()
90 spin_lock_init(&transaction->t_handle_lock); in jbd2_get_transaction()
91 atomic_set(&transaction->t_updates, 0); in jbd2_get_transaction()
92 atomic_set(&transaction->t_outstanding_credits, in jbd2_get_transaction()
94 atomic_set(&transaction->t_handle_count, 0); in jbd2_get_transaction()
95 INIT_LIST_HEAD(&transaction->t_inode_list); in jbd2_get_transaction()
96 INIT_LIST_HEAD(&transaction->t_private_list); in jbd2_get_transaction()
99 journal->j_commit_timer.expires = round_jiffies_up(transaction->t_expires); in jbd2_get_transaction()
103 journal->j_running_transaction = transaction; in jbd2_get_transaction()
104 transaction->t_max_wait = 0; in jbd2_get_transaction()
105 transaction->t_start = jiffies; in jbd2_get_transaction()
106 transaction->t_requested = 0; in jbd2_get_transaction()
108 return transaction; in jbd2_get_transaction()
129 static inline void update_t_max_wait(transaction_t *transaction, in update_t_max_wait() argument
134 time_after(transaction->t_start, ts)) { in update_t_max_wait()
135 ts = jbd2_time_diff(ts, transaction->t_start); in update_t_max_wait()
136 spin_lock(&transaction->t_handle_lock); in update_t_max_wait()
137 if (ts > transaction->t_max_wait) in update_t_max_wait()
138 transaction->t_max_wait = ts; in update_t_max_wait()
139 spin_unlock(&transaction->t_handle_lock); in update_t_max_wait()
274 transaction_t *transaction, *new_transaction = NULL; in start_this_handle() local
353 transaction = journal->j_running_transaction; in start_this_handle()
372 update_t_max_wait(transaction, ts); in start_this_handle()
373 handle->h_transaction = transaction; in start_this_handle()
376 atomic_inc(&transaction->t_updates); in start_this_handle()
377 atomic_inc(&transaction->t_handle_count); in start_this_handle()
380 atomic_read(&transaction->t_outstanding_credits), in start_this_handle()
561 transaction_t *transaction = handle->h_transaction; in jbd2_journal_extend() local
568 journal = transaction->t_journal; in jbd2_journal_extend()
575 if (transaction->t_state != T_RUNNING) { in jbd2_journal_extend()
581 spin_lock(&transaction->t_handle_lock); in jbd2_journal_extend()
583 &transaction->t_outstanding_credits); in jbd2_journal_extend()
588 atomic_sub(nblocks, &transaction->t_outstanding_credits); in jbd2_journal_extend()
596 atomic_sub(nblocks, &transaction->t_outstanding_credits); in jbd2_journal_extend()
601 transaction->t_tid, in jbd2_journal_extend()
612 spin_unlock(&transaction->t_handle_lock); in jbd2_journal_extend()
636 transaction_t *transaction = handle->h_transaction; in jbd2__journal_restart() local
645 journal = transaction->t_journal; in jbd2__journal_restart()
651 J_ASSERT(atomic_read(&transaction->t_updates) > 0); in jbd2__journal_restart()
655 spin_lock(&transaction->t_handle_lock); in jbd2__journal_restart()
657 &transaction->t_outstanding_credits); in jbd2__journal_restart()
662 if (atomic_dec_and_test(&transaction->t_updates)) in jbd2__journal_restart()
664 tid = transaction->t_tid; in jbd2__journal_restart()
665 spin_unlock(&transaction->t_handle_lock); in jbd2__journal_restart()
716 transaction_t *transaction = journal->j_running_transaction; in jbd2_journal_lock_updates() local
718 if (!transaction) in jbd2_journal_lock_updates()
721 spin_lock(&transaction->t_handle_lock); in jbd2_journal_lock_updates()
724 if (!atomic_read(&transaction->t_updates)) { in jbd2_journal_lock_updates()
725 spin_unlock(&transaction->t_handle_lock); in jbd2_journal_lock_updates()
729 spin_unlock(&transaction->t_handle_lock); in jbd2_journal_lock_updates()
815 transaction_t *transaction = handle->h_transaction; in do_get_write_access() local
823 journal = transaction->t_journal; in do_get_write_access()
863 jh->b_transaction == transaction || in do_get_write_access()
868 transaction); in do_get_write_access()
894 if (jh->b_transaction == transaction || in do_get_write_access()
895 jh->b_next_transaction == transaction) in do_get_write_access()
920 __jbd2_journal_file_buffer(jh, transaction, BJ_Reserved); in do_get_write_access()
992 jh->b_next_transaction = transaction; in do_get_write_access()
1114 transaction_t *transaction = handle->h_transaction; in jbd2_journal_get_create_access() local
1123 journal = transaction->t_journal; in jbd2_journal_get_create_access()
1135 J_ASSERT_JH(jh, (jh->b_transaction == transaction || in jbd2_journal_get_create_access()
1158 __jbd2_journal_file_buffer(jh, transaction, BJ_Reserved); in jbd2_journal_get_create_access()
1165 jh->b_next_transaction = transaction; in jbd2_journal_get_create_access()
1330 transaction_t *transaction = handle->h_transaction; in jbd2_journal_dirty_metadata() local
1352 if (jh->b_transaction != transaction && in jbd2_journal_dirty_metadata()
1353 jh->b_next_transaction != transaction) { in jbd2_journal_dirty_metadata()
1355 J_ASSERT_JH(jh, jh->b_transaction == transaction || in jbd2_journal_dirty_metadata()
1356 jh->b_next_transaction == transaction); in jbd2_journal_dirty_metadata()
1361 if (jh->b_transaction == transaction && in jbd2_journal_dirty_metadata()
1364 J_ASSERT_JH(jh, jh->b_transaction != transaction || in jbd2_journal_dirty_metadata()
1371 journal = transaction->t_journal; in jbd2_journal_dirty_metadata()
1398 if (jh->b_transaction == transaction && jh->b_jlist == BJ_Metadata) { in jbd2_journal_dirty_metadata()
1425 if (jh->b_transaction != transaction) { in jbd2_journal_dirty_metadata()
1429 (jh->b_next_transaction != transaction))) { in jbd2_journal_dirty_metadata()
1437 transaction, transaction->t_tid, in jbd2_journal_dirty_metadata()
1458 __jbd2_journal_file_buffer(jh, transaction, BJ_Metadata); in jbd2_journal_dirty_metadata()
1486 transaction_t *transaction = handle->h_transaction; in jbd2_journal_forget() local
1495 journal = transaction->t_journal; in jbd2_journal_forget()
1522 if (jh->b_transaction == transaction) { in jbd2_journal_forget()
1555 __jbd2_journal_file_buffer(jh, transaction, BJ_Forget); in jbd2_journal_forget()
1576 J_ASSERT(jh->b_next_transaction == transaction); in jbd2_journal_forget()
1619 transaction_t *transaction = handle->h_transaction; in jbd2_journal_stop() local
1625 if (!transaction) { in jbd2_journal_stop()
1641 journal = transaction->t_journal; in jbd2_journal_stop()
1648 J_ASSERT(atomic_read(&transaction->t_updates) > 0); in jbd2_journal_stop()
1658 transaction->t_tid, in jbd2_journal_stop()
1706 transaction->t_start_time)); in jbd2_journal_stop()
1722 transaction->t_synchronous_commit = 1; in jbd2_journal_stop()
1725 &transaction->t_outstanding_credits); in jbd2_journal_stop()
1734 (atomic_read(&transaction->t_outstanding_credits) > in jbd2_journal_stop()
1736 time_after_eq(jiffies, transaction->t_expires)) { in jbd2_journal_stop()
1744 jbd2_log_start_commit(journal, transaction->t_tid); in jbd2_journal_stop()
1760 tid = transaction->t_tid; in jbd2_journal_stop()
1761 if (atomic_dec_and_test(&transaction->t_updates)) { in jbd2_journal_stop()
1845 transaction_t *transaction; in __jbd2_journal_temp_unlink_buffer() local
1849 transaction = jh->b_transaction; in __jbd2_journal_temp_unlink_buffer()
1850 if (transaction) in __jbd2_journal_temp_unlink_buffer()
1851 assert_spin_locked(&transaction->t_journal->j_list_lock); in __jbd2_journal_temp_unlink_buffer()
1855 J_ASSERT_JH(jh, transaction != NULL); in __jbd2_journal_temp_unlink_buffer()
1861 transaction->t_nr_buffers--; in __jbd2_journal_temp_unlink_buffer()
1862 J_ASSERT_JH(jh, transaction->t_nr_buffers >= 0); in __jbd2_journal_temp_unlink_buffer()
1863 list = &transaction->t_buffers; in __jbd2_journal_temp_unlink_buffer()
1866 list = &transaction->t_forget; in __jbd2_journal_temp_unlink_buffer()
1869 list = &transaction->t_shadow_list; in __jbd2_journal_temp_unlink_buffer()
1872 list = &transaction->t_reserved_list; in __jbd2_journal_temp_unlink_buffer()
2026 static int __dispose_buffer(struct journal_head *jh, transaction_t *transaction) in __dispose_buffer() argument
2040 __jbd2_journal_file_buffer(jh, transaction, BJ_Forget); in __dispose_buffer()
2099 transaction_t *transaction; in journal_unmap_buffer() local
2146 transaction = jh->b_transaction; in journal_unmap_buffer()
2147 if (transaction == NULL) { in journal_unmap_buffer()
2193 } else if (transaction == journal->j_committing_transaction) { in journal_unmap_buffer()
2228 J_ASSERT_JH(jh, transaction == journal->j_running_transaction); in journal_unmap_buffer()
2230 may_free = __dispose_buffer(jh, transaction); in journal_unmap_buffer()
2328 transaction_t *transaction, int jlist) in __jbd2_journal_file_buffer() argument
2335 assert_spin_locked(&transaction->t_journal->j_list_lock); in __jbd2_journal_file_buffer()
2338 J_ASSERT_JH(jh, jh->b_transaction == transaction || in __jbd2_journal_file_buffer()
2364 jh->b_transaction = transaction; in __jbd2_journal_file_buffer()
2372 transaction->t_nr_buffers++; in __jbd2_journal_file_buffer()
2373 list = &transaction->t_buffers; in __jbd2_journal_file_buffer()
2376 list = &transaction->t_forget; in __jbd2_journal_file_buffer()
2379 list = &transaction->t_shadow_list; in __jbd2_journal_file_buffer()
2382 list = &transaction->t_reserved_list; in __jbd2_journal_file_buffer()
2394 transaction_t *transaction, int jlist) in jbd2_journal_file_buffer() argument
2397 spin_lock(&transaction->t_journal->j_list_lock); in jbd2_journal_file_buffer()
2398 __jbd2_journal_file_buffer(jh, transaction, jlist); in jbd2_journal_file_buffer()
2399 spin_unlock(&transaction->t_journal->j_list_lock); in jbd2_journal_file_buffer()
2481 transaction_t *transaction = handle->h_transaction; in jbd2_journal_file_inode() local
2486 journal = transaction->t_journal; in jbd2_journal_file_inode()
2489 transaction->t_tid); in jbd2_journal_file_inode()
2504 if (jinode->i_transaction == transaction || in jbd2_journal_file_inode()
2505 jinode->i_next_transaction == transaction) in jbd2_journal_file_inode()
2510 if (jinode->i_transaction == transaction || in jbd2_journal_file_inode()
2511 jinode->i_next_transaction == transaction) in jbd2_journal_file_inode()
2519 if (!transaction->t_need_data_flush) in jbd2_journal_file_inode()
2520 transaction->t_need_data_flush = 1; in jbd2_journal_file_inode()
2527 jinode->i_next_transaction = transaction; in jbd2_journal_file_inode()
2532 jinode->i_transaction = transaction; in jbd2_journal_file_inode()
2533 list_add(&jinode->i_list, &transaction->t_inode_list); in jbd2_journal_file_inode()