Lines Matching refs:transaction
58 void jbd2_journal_free_transaction(transaction_t *transaction) in jbd2_journal_free_transaction() argument
60 if (unlikely(ZERO_OR_NULL_PTR(transaction))) in jbd2_journal_free_transaction()
62 kmem_cache_free(transaction_cache, transaction); in jbd2_journal_free_transaction()
103 transaction_t *transaction) in jbd2_get_transaction() argument
105 transaction->t_journal = journal; in jbd2_get_transaction()
106 transaction->t_state = T_RUNNING; in jbd2_get_transaction()
107 transaction->t_start_time = ktime_get(); in jbd2_get_transaction()
108 transaction->t_tid = journal->j_transaction_sequence++; in jbd2_get_transaction()
109 transaction->t_expires = jiffies + journal->j_commit_interval; in jbd2_get_transaction()
110 spin_lock_init(&transaction->t_handle_lock); in jbd2_get_transaction()
111 atomic_set(&transaction->t_updates, 0); in jbd2_get_transaction()
112 atomic_set(&transaction->t_outstanding_credits, in jbd2_get_transaction()
115 atomic_set(&transaction->t_outstanding_revokes, 0); in jbd2_get_transaction()
116 atomic_set(&transaction->t_handle_count, 0); in jbd2_get_transaction()
117 INIT_LIST_HEAD(&transaction->t_inode_list); in jbd2_get_transaction()
118 INIT_LIST_HEAD(&transaction->t_private_list); in jbd2_get_transaction()
121 journal->j_commit_timer.expires = round_jiffies_up(transaction->t_expires); in jbd2_get_transaction()
125 journal->j_running_transaction = transaction; in jbd2_get_transaction()
126 transaction->t_max_wait = 0; in jbd2_get_transaction()
127 transaction->t_start = jiffies; in jbd2_get_transaction()
128 transaction->t_requested = 0; in jbd2_get_transaction()
149 static inline void update_t_max_wait(transaction_t *transaction, in update_t_max_wait() argument
154 time_after(transaction->t_start, ts)) { in update_t_max_wait()
155 ts = jbd2_time_diff(ts, transaction->t_start); in update_t_max_wait()
156 spin_lock(&transaction->t_handle_lock); in update_t_max_wait()
157 if (ts > transaction->t_max_wait) in update_t_max_wait()
158 transaction->t_max_wait = ts; in update_t_max_wait()
159 spin_unlock(&transaction->t_handle_lock); in update_t_max_wait()
328 transaction_t *transaction, *new_transaction = NULL; in start_this_handle() local
412 transaction = journal->j_running_transaction; in start_this_handle()
426 if (transaction->t_state == T_SWITCH) { in start_this_handle()
437 update_t_max_wait(transaction, ts); in start_this_handle()
438 handle->h_transaction = transaction; in start_this_handle()
442 atomic_inc(&transaction->t_updates); in start_this_handle()
443 atomic_inc(&transaction->t_handle_count); in start_this_handle()
446 atomic_read(&transaction->t_outstanding_credits), in start_this_handle()
650 transaction_t *transaction = handle->h_transaction; in jbd2_journal_extend() local
657 journal = transaction->t_journal; in jbd2_journal_extend()
664 if (transaction->t_state != T_RUNNING) { in jbd2_journal_extend()
676 spin_lock(&transaction->t_handle_lock); in jbd2_journal_extend()
678 &transaction->t_outstanding_credits); in jbd2_journal_extend()
683 atomic_sub(nblocks, &transaction->t_outstanding_credits); in jbd2_journal_extend()
688 transaction->t_tid, in jbd2_journal_extend()
701 spin_unlock(&transaction->t_handle_lock); in jbd2_journal_extend()
709 transaction_t *transaction = handle->h_transaction; in stop_this_handle() local
710 journal_t *journal = transaction->t_journal; in stop_this_handle()
714 J_ASSERT(atomic_read(&transaction->t_updates) > 0); in stop_this_handle()
730 &transaction->t_outstanding_revokes); in stop_this_handle()
737 &transaction->t_outstanding_credits); in stop_this_handle()
740 transaction); in stop_this_handle()
741 if (atomic_dec_and_test(&transaction->t_updates)) in stop_this_handle()
772 transaction_t *transaction = handle->h_transaction; in jbd2__journal_restart() local
782 journal = transaction->t_journal; in jbd2__journal_restart()
783 tid = transaction->t_tid; in jbd2__journal_restart()
851 transaction_t *transaction = journal->j_running_transaction; in jbd2_journal_lock_updates() local
853 if (!transaction) in jbd2_journal_lock_updates()
856 spin_lock(&transaction->t_handle_lock); in jbd2_journal_lock_updates()
859 if (!atomic_read(&transaction->t_updates)) { in jbd2_journal_lock_updates()
860 spin_unlock(&transaction->t_handle_lock); in jbd2_journal_lock_updates()
864 spin_unlock(&transaction->t_handle_lock); in jbd2_journal_lock_updates()
948 transaction_t *transaction = handle->h_transaction; in do_get_write_access() local
954 journal = transaction->t_journal; in do_get_write_access()
994 jh->b_transaction == transaction || in do_get_write_access()
999 transaction); in do_get_write_access()
1025 if (jh->b_transaction == transaction || in do_get_write_access()
1026 jh->b_next_transaction == transaction) in do_get_write_access()
1051 __jbd2_journal_file_buffer(jh, transaction, BJ_Reserved); in do_get_write_access()
1117 jh->b_next_transaction = transaction; in do_get_write_access()
1243 transaction_t *transaction = handle->h_transaction; in jbd2_journal_get_create_access() local
1252 journal = transaction->t_journal; in jbd2_journal_get_create_access()
1264 J_ASSERT_JH(jh, (jh->b_transaction == transaction || in jbd2_journal_get_create_access()
1287 __jbd2_journal_file_buffer(jh, transaction, BJ_Reserved); in jbd2_journal_get_create_access()
1295 jh->b_next_transaction = transaction; in jbd2_journal_get_create_access()
1458 transaction_t *transaction = handle->h_transaction; in jbd2_journal_dirty_metadata() local
1482 if (data_race(jh->b_transaction != transaction && in jbd2_journal_dirty_metadata()
1483 jh->b_next_transaction != transaction)) { in jbd2_journal_dirty_metadata()
1485 J_ASSERT_JH(jh, jh->b_transaction == transaction || in jbd2_journal_dirty_metadata()
1486 jh->b_next_transaction == transaction); in jbd2_journal_dirty_metadata()
1491 if (data_race(jh->b_transaction == transaction && in jbd2_journal_dirty_metadata()
1494 if (jh->b_transaction == transaction && in jbd2_journal_dirty_metadata()
1501 J_ASSERT_JH(jh, jh->b_transaction != transaction || in jbd2_journal_dirty_metadata()
1508 journal = transaction->t_journal; in jbd2_journal_dirty_metadata()
1532 if (jh->b_transaction == transaction && jh->b_jlist == BJ_Metadata) { in jbd2_journal_dirty_metadata()
1559 if (jh->b_transaction != transaction) { in jbd2_journal_dirty_metadata()
1563 (jh->b_next_transaction != transaction))) { in jbd2_journal_dirty_metadata()
1571 transaction, transaction->t_tid, in jbd2_journal_dirty_metadata()
1592 __jbd2_journal_file_buffer(jh, transaction, BJ_Metadata); in jbd2_journal_dirty_metadata()
1620 transaction_t *transaction = handle->h_transaction; in jbd2_journal_forget() local
1629 journal = transaction->t_journal; in jbd2_journal_forget()
1658 if (jh->b_transaction == transaction) { in jbd2_journal_forget()
1691 __jbd2_journal_file_buffer(jh, transaction, BJ_Forget); in jbd2_journal_forget()
1714 jh->b_next_transaction = transaction; in jbd2_journal_forget()
1717 J_ASSERT(jh->b_next_transaction == transaction); in jbd2_journal_forget()
1756 __jbd2_journal_file_buffer(jh, transaction, BJ_Forget); in jbd2_journal_forget()
1788 transaction_t *transaction = handle->h_transaction; in jbd2_journal_stop() local
1801 if (!transaction) { in jbd2_journal_stop()
1809 journal = transaction->t_journal; in jbd2_journal_stop()
1810 tid = transaction->t_tid; in jbd2_journal_stop()
1864 transaction->t_start_time)); in jbd2_journal_stop()
1880 transaction->t_synchronous_commit = 1; in jbd2_journal_stop()
1888 time_after_eq(jiffies, transaction->t_expires)) { in jbd2_journal_stop()
1990 transaction_t *transaction; in __jbd2_journal_temp_unlink_buffer() local
1994 transaction = jh->b_transaction; in __jbd2_journal_temp_unlink_buffer()
1995 if (transaction) in __jbd2_journal_temp_unlink_buffer()
1996 assert_spin_locked(&transaction->t_journal->j_list_lock); in __jbd2_journal_temp_unlink_buffer()
2000 J_ASSERT_JH(jh, transaction != NULL); in __jbd2_journal_temp_unlink_buffer()
2006 transaction->t_nr_buffers--; in __jbd2_journal_temp_unlink_buffer()
2007 J_ASSERT_JH(jh, transaction->t_nr_buffers >= 0); in __jbd2_journal_temp_unlink_buffer()
2008 list = &transaction->t_buffers; in __jbd2_journal_temp_unlink_buffer()
2011 list = &transaction->t_forget; in __jbd2_journal_temp_unlink_buffer()
2014 list = &transaction->t_shadow_list; in __jbd2_journal_temp_unlink_buffer()
2017 list = &transaction->t_reserved_list; in __jbd2_journal_temp_unlink_buffer()
2023 if (transaction && is_journal_aborted(transaction->t_journal)) in __jbd2_journal_temp_unlink_buffer()
2169 static int __dispose_buffer(struct journal_head *jh, transaction_t *transaction) in __dispose_buffer() argument
2183 __jbd2_journal_file_buffer(jh, transaction, BJ_Forget); in __dispose_buffer()
2243 transaction_t *transaction; in journal_unmap_buffer() local
2287 transaction = jh->b_transaction; in journal_unmap_buffer()
2288 if (transaction == NULL) { in journal_unmap_buffer()
2334 } else if (transaction == journal->j_committing_transaction) { in journal_unmap_buffer()
2371 J_ASSERT_JH(jh, transaction == journal->j_running_transaction); in journal_unmap_buffer()
2373 may_free = __dispose_buffer(jh, transaction); in journal_unmap_buffer()
2470 transaction_t *transaction, int jlist) in __jbd2_journal_file_buffer() argument
2477 assert_spin_locked(&transaction->t_journal->j_list_lock); in __jbd2_journal_file_buffer()
2480 J_ASSERT_JH(jh, jh->b_transaction == transaction || in __jbd2_journal_file_buffer()
2506 jh->b_transaction = transaction; in __jbd2_journal_file_buffer()
2514 transaction->t_nr_buffers++; in __jbd2_journal_file_buffer()
2515 list = &transaction->t_buffers; in __jbd2_journal_file_buffer()
2518 list = &transaction->t_forget; in __jbd2_journal_file_buffer()
2521 list = &transaction->t_shadow_list; in __jbd2_journal_file_buffer()
2524 list = &transaction->t_reserved_list; in __jbd2_journal_file_buffer()
2536 transaction_t *transaction, int jlist) in jbd2_journal_file_buffer() argument
2539 spin_lock(&transaction->t_journal->j_list_lock); in jbd2_journal_file_buffer()
2540 __jbd2_journal_file_buffer(jh, transaction, jlist); in jbd2_journal_file_buffer()
2541 spin_unlock(&transaction->t_journal->j_list_lock); in jbd2_journal_file_buffer()
2633 transaction_t *transaction = handle->h_transaction; in jbd2_journal_file_inode() local
2638 journal = transaction->t_journal; in jbd2_journal_file_inode()
2641 transaction->t_tid); in jbd2_journal_file_inode()
2655 if (jinode->i_transaction == transaction || in jbd2_journal_file_inode()
2656 jinode->i_next_transaction == transaction) in jbd2_journal_file_inode()
2664 if (!transaction->t_need_data_flush) in jbd2_journal_file_inode()
2665 transaction->t_need_data_flush = 1; in jbd2_journal_file_inode()
2672 jinode->i_next_transaction = transaction; in jbd2_journal_file_inode()
2677 jinode->i_transaction = transaction; in jbd2_journal_file_inode()
2678 list_add(&jinode->i_list, &transaction->t_inode_list); in jbd2_journal_file_inode()