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()
260 	transaction_t	*transaction, *new_transaction = NULL;  in start_this_handle()  local
341 	transaction = journal->j_running_transaction;  in start_this_handle()
360 	update_t_max_wait(transaction, ts);  in start_this_handle()
361 	handle->h_transaction = transaction;  in start_this_handle()
364 	atomic_inc(&transaction->t_updates);  in start_this_handle()
365 	atomic_inc(&transaction->t_handle_count);  in start_this_handle()
368 		  atomic_read(&transaction->t_outstanding_credits),  in start_this_handle()
549 	transaction_t *transaction = handle->h_transaction;  in jbd2_journal_extend()  local
556 	journal = transaction->t_journal;  in jbd2_journal_extend()
563 	if (transaction->t_state != T_RUNNING) {  in jbd2_journal_extend()
569 	spin_lock(&transaction->t_handle_lock);  in jbd2_journal_extend()
571 				   &transaction->t_outstanding_credits);  in jbd2_journal_extend()
576 		atomic_sub(nblocks, &transaction->t_outstanding_credits);  in jbd2_journal_extend()
584 		atomic_sub(nblocks, &transaction->t_outstanding_credits);  in jbd2_journal_extend()
589 				 transaction->t_tid,  in jbd2_journal_extend()
600 	spin_unlock(&transaction->t_handle_lock);  in jbd2_journal_extend()
624 	transaction_t *transaction = handle->h_transaction;  in jbd2__journal_restart()  local
633 	journal = transaction->t_journal;  in jbd2__journal_restart()
639 	J_ASSERT(atomic_read(&transaction->t_updates) > 0);  in jbd2__journal_restart()
643 	spin_lock(&transaction->t_handle_lock);  in jbd2__journal_restart()
645 		   &transaction->t_outstanding_credits);  in jbd2__journal_restart()
650 	if (atomic_dec_and_test(&transaction->t_updates))  in jbd2__journal_restart()
652 	tid = transaction->t_tid;  in jbd2__journal_restart()
653 	spin_unlock(&transaction->t_handle_lock);  in jbd2__journal_restart()
704 		transaction_t *transaction = journal->j_running_transaction;  in jbd2_journal_lock_updates()  local
706 		if (!transaction)  in jbd2_journal_lock_updates()
709 		spin_lock(&transaction->t_handle_lock);  in jbd2_journal_lock_updates()
712 		if (!atomic_read(&transaction->t_updates)) {  in jbd2_journal_lock_updates()
713 			spin_unlock(&transaction->t_handle_lock);  in jbd2_journal_lock_updates()
717 		spin_unlock(&transaction->t_handle_lock);  in jbd2_journal_lock_updates()
779 	transaction_t *transaction = handle->h_transaction;  in do_get_write_access()  local
788 	journal = transaction->t_journal;  in do_get_write_access()
828 				jh->b_transaction == transaction ||  in do_get_write_access()
833 							transaction);  in do_get_write_access()
859 	if (jh->b_transaction == transaction ||  in do_get_write_access()
860 	    jh->b_next_transaction == transaction)  in do_get_write_access()
876 		jh->b_next_transaction = transaction;  in do_get_write_access()
882 	if (jh->b_transaction && jh->b_transaction != transaction) {  in do_get_write_access()
942 		jh->b_next_transaction = transaction;  in do_get_write_access()
956 		__jbd2_journal_file_buffer(jh, transaction, BJ_Reserved);  in do_get_write_access()
1045 	transaction_t *transaction = handle->h_transaction;  in jbd2_journal_get_create_access()  local
1054 	journal = transaction->t_journal;  in jbd2_journal_get_create_access()
1066 	J_ASSERT_JH(jh, (jh->b_transaction == transaction ||  in jbd2_journal_get_create_access()
1089 		__jbd2_journal_file_buffer(jh, transaction, BJ_Reserved);  in jbd2_journal_get_create_access()
1096 		jh->b_next_transaction = transaction;  in jbd2_journal_get_create_access()
1260 	transaction_t *transaction = handle->h_transaction;  in jbd2_journal_dirty_metadata()  local
1267 	journal = transaction->t_journal;  in jbd2_journal_dirty_metadata()
1299 	if (jh->b_transaction == transaction && jh->b_jlist == BJ_Metadata) {  in jbd2_journal_dirty_metadata()
1326 	if (jh->b_transaction != transaction) {  in jbd2_journal_dirty_metadata()
1330 			     (jh->b_next_transaction != transaction))) {  in jbd2_journal_dirty_metadata()
1338 			       transaction, transaction->t_tid,  in jbd2_journal_dirty_metadata()
1359 	__jbd2_journal_file_buffer(jh, transaction, BJ_Metadata);  in jbd2_journal_dirty_metadata()
1388 	transaction_t *transaction = handle->h_transaction;  in jbd2_journal_forget()  local
1397 	journal = transaction->t_journal;  in jbd2_journal_forget()
1424 	if (jh->b_transaction == transaction) {  in jbd2_journal_forget()
1457 			__jbd2_journal_file_buffer(jh, transaction, BJ_Forget);  in jbd2_journal_forget()
1478 			J_ASSERT(jh->b_next_transaction == transaction);  in jbd2_journal_forget()
1521 	transaction_t *transaction = handle->h_transaction;  in jbd2_journal_stop()  local
1527 	if (!transaction) {  in jbd2_journal_stop()
1543 	journal = transaction->t_journal;  in jbd2_journal_stop()
1550 		J_ASSERT(atomic_read(&transaction->t_updates) > 0);  in jbd2_journal_stop()
1560 				transaction->t_tid,  in jbd2_journal_stop()
1608 						   transaction->t_start_time));  in jbd2_journal_stop()
1624 		transaction->t_synchronous_commit = 1;  in jbd2_journal_stop()
1627 		   &transaction->t_outstanding_credits);  in jbd2_journal_stop()
1636 	    (atomic_read(&transaction->t_outstanding_credits) >  in jbd2_journal_stop()
1638 	    time_after_eq(jiffies, transaction->t_expires)) {  in jbd2_journal_stop()
1646 		jbd2_log_start_commit(journal, transaction->t_tid);  in jbd2_journal_stop()
1662 	tid = transaction->t_tid;  in jbd2_journal_stop()
1663 	if (atomic_dec_and_test(&transaction->t_updates)) {  in jbd2_journal_stop()
1747 	transaction_t *transaction;  in __jbd2_journal_temp_unlink_buffer()  local
1751 	transaction = jh->b_transaction;  in __jbd2_journal_temp_unlink_buffer()
1752 	if (transaction)  in __jbd2_journal_temp_unlink_buffer()
1753 		assert_spin_locked(&transaction->t_journal->j_list_lock);  in __jbd2_journal_temp_unlink_buffer()
1757 		J_ASSERT_JH(jh, transaction != NULL);  in __jbd2_journal_temp_unlink_buffer()
1763 		transaction->t_nr_buffers--;  in __jbd2_journal_temp_unlink_buffer()
1764 		J_ASSERT_JH(jh, transaction->t_nr_buffers >= 0);  in __jbd2_journal_temp_unlink_buffer()
1765 		list = &transaction->t_buffers;  in __jbd2_journal_temp_unlink_buffer()
1768 		list = &transaction->t_forget;  in __jbd2_journal_temp_unlink_buffer()
1771 		list = &transaction->t_shadow_list;  in __jbd2_journal_temp_unlink_buffer()
1774 		list = &transaction->t_reserved_list;  in __jbd2_journal_temp_unlink_buffer()
1928 static int __dispose_buffer(struct journal_head *jh, transaction_t *transaction)  in __dispose_buffer()  argument
1942 		__jbd2_journal_file_buffer(jh, transaction, BJ_Forget);  in __dispose_buffer()
2001 	transaction_t *transaction;  in journal_unmap_buffer()  local
2048 	transaction = jh->b_transaction;  in journal_unmap_buffer()
2049 	if (transaction == NULL) {  in journal_unmap_buffer()
2093 	} else if (transaction == journal->j_committing_transaction) {  in journal_unmap_buffer()
2128 		J_ASSERT_JH(jh, transaction == journal->j_running_transaction);  in journal_unmap_buffer()
2130 		may_free = __dispose_buffer(jh, transaction);  in journal_unmap_buffer()
2228 			transaction_t *transaction, int jlist)  in __jbd2_journal_file_buffer()  argument
2235 	assert_spin_locked(&transaction->t_journal->j_list_lock);  in __jbd2_journal_file_buffer()
2238 	J_ASSERT_JH(jh, jh->b_transaction == transaction ||  in __jbd2_journal_file_buffer()
2264 	jh->b_transaction = transaction;  in __jbd2_journal_file_buffer()
2272 		transaction->t_nr_buffers++;  in __jbd2_journal_file_buffer()
2273 		list = &transaction->t_buffers;  in __jbd2_journal_file_buffer()
2276 		list = &transaction->t_forget;  in __jbd2_journal_file_buffer()
2279 		list = &transaction->t_shadow_list;  in __jbd2_journal_file_buffer()
2282 		list = &transaction->t_reserved_list;  in __jbd2_journal_file_buffer()
2294 				transaction_t *transaction, int jlist)  in jbd2_journal_file_buffer()  argument
2297 	spin_lock(&transaction->t_journal->j_list_lock);  in jbd2_journal_file_buffer()
2298 	__jbd2_journal_file_buffer(jh, transaction, jlist);  in jbd2_journal_file_buffer()
2299 	spin_unlock(&transaction->t_journal->j_list_lock);  in jbd2_journal_file_buffer()
2381 	transaction_t *transaction = handle->h_transaction;  in jbd2_journal_file_inode()  local
2386 	journal = transaction->t_journal;  in jbd2_journal_file_inode()
2389 			transaction->t_tid);  in jbd2_journal_file_inode()
2404 	if (jinode->i_transaction == transaction ||  in jbd2_journal_file_inode()
2405 	    jinode->i_next_transaction == transaction)  in jbd2_journal_file_inode()
2410 	if (jinode->i_transaction == transaction ||  in jbd2_journal_file_inode()
2411 	    jinode->i_next_transaction == transaction)  in jbd2_journal_file_inode()
2419 	if (!transaction->t_need_data_flush)  in jbd2_journal_file_inode()
2420 		transaction->t_need_data_flush = 1;  in jbd2_journal_file_inode()
2427 		jinode->i_next_transaction = transaction;  in jbd2_journal_file_inode()
2432 	jinode->i_transaction = transaction;  in jbd2_journal_file_inode()
2433 	list_add(&jinode->i_list, &transaction->t_inode_list);  in jbd2_journal_file_inode()