91 static int journal_join(struct reiserfs_transaction_handle *th,
109 static int do_journal_begin_r(struct reiserfs_transaction_handle *th,
1903 static int do_journal_release(struct reiserfs_transaction_handle *th,  in do_journal_release()  argument
1915 		BUG_ON(!th->t_trans_id);  in do_journal_release()
1916 		do_journal_end(th, FLUSH_ALL);  in do_journal_release()
1967 int journal_release(struct reiserfs_transaction_handle *th,  in journal_release()  argument
1970 	return do_journal_release(th, sb, 0);  in journal_release()
1974 int journal_release_error(struct reiserfs_transaction_handle *th,  in journal_release_error()  argument
1977 	return do_journal_release(th, sb, 1);  in journal_release_error()
2901 int journal_transaction_should_end(struct reiserfs_transaction_handle *th,  in journal_transaction_should_end()  argument
2904 	struct reiserfs_journal *journal = SB_JOURNAL(th->t_super);  in journal_transaction_should_end()
2907 	BUG_ON(!th->t_trans_id);  in journal_transaction_should_end()
2908 	if (th->t_refcount > 1)  in journal_transaction_should_end()
2919 	th->t_blocks_allocated += new_alloc ;  in journal_transaction_should_end()
2924 void reiserfs_block_writes(struct reiserfs_transaction_handle *th)  in reiserfs_block_writes()  argument
2926 	struct reiserfs_journal *journal = SB_JOURNAL(th->t_super);  in reiserfs_block_writes()
2927 	BUG_ON(!th->t_trans_id);  in reiserfs_block_writes()
3010 static int do_journal_begin_r(struct reiserfs_transaction_handle *th,  in do_journal_begin_r()  argument
3027 	th->t_refcount = 1;  in do_journal_begin_r()
3028 	th->t_super = sb;  in do_journal_begin_r()
3114 	th->t_blocks_logged = 0;  in do_journal_begin_r()
3115 	th->t_blocks_allocated = nblocks;  in do_journal_begin_r()
3116 	th->t_trans_id = journal->j_trans_id;  in do_journal_begin_r()
3118 	INIT_LIST_HEAD(&th->t_list);  in do_journal_begin_r()
3122 	memset(th, 0, sizeof(*th));  in do_journal_begin_r()
3128 	th->t_super = sb;  in do_journal_begin_r()
3138 	struct reiserfs_transaction_handle *th;  in reiserfs_persistent_transaction()  local
3145 		th = current->journal_info;  in reiserfs_persistent_transaction()
3146 		th->t_refcount++;  in reiserfs_persistent_transaction()
3147 		BUG_ON(th->t_refcount < 2);  in reiserfs_persistent_transaction()
3149 		return th;  in reiserfs_persistent_transaction()
3151 	th = kmalloc(sizeof(struct reiserfs_transaction_handle), GFP_NOFS);  in reiserfs_persistent_transaction()
3152 	if (!th)  in reiserfs_persistent_transaction()
3154 	ret = journal_begin(th, s, nblocks);  in reiserfs_persistent_transaction()
3156 		kfree(th);  in reiserfs_persistent_transaction()
3161 	return th;  in reiserfs_persistent_transaction()
3164 int reiserfs_end_persistent_transaction(struct reiserfs_transaction_handle *th)  in reiserfs_end_persistent_transaction()  argument
3166 	struct super_block *s = th->t_super;  in reiserfs_end_persistent_transaction()
3168 	if (th->t_trans_id)  in reiserfs_end_persistent_transaction()
3169 		ret = journal_end(th);  in reiserfs_end_persistent_transaction()
3172 	if (th->t_refcount == 0) {  in reiserfs_end_persistent_transaction()
3174 		kfree(th);  in reiserfs_end_persistent_transaction()
3179 static int journal_join(struct reiserfs_transaction_handle *th,  in journal_join()  argument
3188 	th->t_handle_save = cur_th;  in journal_join()
3190 	return do_journal_begin_r(th, sb, 1, JBEGIN_JOIN);  in journal_join()
3193 int journal_join_abort(struct reiserfs_transaction_handle *th,  in journal_join_abort()  argument
3202 	th->t_handle_save = cur_th;  in journal_join_abort()
3204 	return do_journal_begin_r(th, sb, 1, JBEGIN_ABORT);  in journal_join_abort()
3207 int journal_begin(struct reiserfs_transaction_handle *th,  in journal_begin()  argument
3213 	th->t_handle_save = NULL;  in journal_begin()
3219 			memcpy(th, cur_th, sizeof(*th));  in journal_begin()
3220 			if (th->t_refcount <= 1)  in journal_begin()
3233 			th->t_handle_save = current->journal_info;  in journal_begin()
3234 			current->journal_info = th;  in journal_begin()
3237 		current->journal_info = th;  in journal_begin()
3239 	ret = do_journal_begin_r(th, sb, nblocks, JBEGIN_REG);  in journal_begin()
3240 	BUG_ON(current->journal_info != th);  in journal_begin()
3247 		current->journal_info = th->t_handle_save;  in journal_begin()
3249 		BUG_ON(!th->t_refcount);  in journal_begin()
3264 int journal_mark_dirty(struct reiserfs_transaction_handle *th,  in journal_mark_dirty()  argument
3267 	struct super_block *sb = th->t_super;  in journal_mark_dirty()
3272 	BUG_ON(!th->t_trans_id);  in journal_mark_dirty()
3275 	if (th->t_trans_id != journal->j_trans_id) {  in journal_mark_dirty()
3276 		reiserfs_panic(th->t_super, "journal-1577",  in journal_mark_dirty()
3278 			       th->t_trans_id, journal->j_trans_id);  in journal_mark_dirty()
3317 		reiserfs_panic(th->t_super, "journal-1413",  in journal_mark_dirty()
3341 		if (th->t_blocks_logged == th->t_blocks_allocated) {  in journal_mark_dirty()
3342 			th->t_blocks_allocated += JOURNAL_PER_BALANCE_CNT;  in journal_mark_dirty()
3345 		th->t_blocks_logged++;  in journal_mark_dirty()
3371 int journal_end(struct reiserfs_transaction_handle *th)  in journal_end()  argument
3373 	struct super_block *sb = th->t_super;  in journal_end()
3374 	if (!current->journal_info && th->t_refcount > 1)  in journal_end()
3376 				 "th NULL, refcount %d", th->t_refcount);  in journal_end()
3378 	if (!th->t_trans_id) {  in journal_end()
3383 	th->t_refcount--;  in journal_end()
3384 	if (th->t_refcount > 0) {  in journal_end()
3392 		BUG_ON(cur_th->t_super != th->t_super);  in journal_end()
3394 		if (th != cur_th) {  in journal_end()
3395 			memcpy(current->journal_info, th, sizeof(*th));  in journal_end()
3396 			th->t_trans_id = 0;  in journal_end()
3400 		return do_journal_end(th, 0);  in journal_end()
3508 int journal_end_sync(struct reiserfs_transaction_handle *th)  in journal_end_sync()  argument
3510 	struct super_block *sb = th->t_super;  in journal_end_sync()
3513 	BUG_ON(!th->t_trans_id);  in journal_end_sync()
3515 	BUG_ON(th->t_refcount > 1);  in journal_end_sync()
3519 		journal_mark_dirty(th, SB_BUFFER_WITH_SB(sb));  in journal_end_sync()
3521 	return do_journal_end(th, COMMIT_NOW | WAIT);  in journal_end_sync()
3550 	struct reiserfs_transaction_handle th;  in reiserfs_flush_old_commits()  local
3569 		if (!journal_join(&th, sb)) {  in reiserfs_flush_old_commits()
3573 			journal_mark_dirty(&th, SB_BUFFER_WITH_SB(sb));  in reiserfs_flush_old_commits()
3580 			do_journal_end(&th, COMMIT_NOW | WAIT);  in reiserfs_flush_old_commits()
3600 static int check_journal_end(struct reiserfs_transaction_handle *th, int flags)  in check_journal_end()  argument
3608 	struct super_block *sb = th->t_super;  in check_journal_end()
3611 	BUG_ON(!th->t_trans_id);  in check_journal_end()
3613 	if (th->t_trans_id != journal->j_trans_id) {  in check_journal_end()
3614 		reiserfs_panic(th->t_super, "journal-1577",  in check_journal_end()
3616 			       th->t_trans_id, journal->j_trans_id);  in check_journal_end()
3619 	journal->j_len_alloc -= (th->t_blocks_allocated - th->t_blocks_logged);  in check_journal_end()
3725 int journal_mark_freed(struct reiserfs_transaction_handle *th,  in journal_mark_freed()  argument
3733 	BUG_ON(!th->t_trans_id);  in journal_mark_freed()
3830 	struct reiserfs_transaction_handle th;  in __commit_trans_jl()  local
3850 		ret = journal_begin(&th, sb, 1);  in __commit_trans_jl()
3858 			journal_mark_dirty(&th, SB_BUFFER_WITH_SB(sb));  in __commit_trans_jl()
3859 			ret = journal_end(&th);  in __commit_trans_jl()
3863 		ret = journal_end_sync(&th);  in __commit_trans_jl()
3969 static int do_journal_end(struct reiserfs_transaction_handle *th, int flags)  in do_journal_end()  argument
3971 	struct super_block *sb = th->t_super;  in do_journal_end()
3990 	BUG_ON(th->t_refcount > 1);  in do_journal_end()
3991 	BUG_ON(!th->t_trans_id);  in do_journal_end()
3992 	BUG_ON(!th->t_super);  in do_journal_end()
3998 	if (th->t_trans_id == ~0U)  in do_journal_end()
4003 	current->journal_info = th->t_handle_save;  in do_journal_end()
4008 		journal_mark_dirty(th, SB_BUFFER_WITH_SB(sb));  in do_journal_end()
4026 	if (!check_journal_end(th, flags)) {  in do_journal_end()
4050 	current->journal_info = th;  in do_journal_end()
4051 	th->t_refcount++;  in do_journal_end()
4054 	reiserfs_discard_all_prealloc(th);  in do_journal_end()
4056 	th->t_refcount--;  in do_journal_end()
4057 	current->journal_info = th->t_handle_save;  in do_journal_end()
4363 	memset(th, 0, sizeof(*th));  in do_journal_end()
4369 	th->t_super = sb;  in do_journal_end()