93 static int journal_join(struct reiserfs_transaction_handle *th,
111 static int do_journal_begin_r(struct reiserfs_transaction_handle *th,
1912 static int do_journal_release(struct reiserfs_transaction_handle *th,  in do_journal_release()  argument
1925 		BUG_ON(!th->t_trans_id);  in do_journal_release()
1926 		do_journal_end(th, FLUSH_ALL);  in do_journal_release()
1978 int journal_release(struct reiserfs_transaction_handle *th,  in journal_release()  argument
1981 	return do_journal_release(th, sb, 0);  in journal_release()
1985 int journal_release_error(struct reiserfs_transaction_handle *th,  in journal_release_error()  argument
1988 	return do_journal_release(th, sb, 1);  in journal_release_error()
2913 int journal_transaction_should_end(struct reiserfs_transaction_handle *th,  in journal_transaction_should_end()  argument
2916 	struct reiserfs_journal *journal = SB_JOURNAL(th->t_super);  in journal_transaction_should_end()
2919 	BUG_ON(!th->t_trans_id);  in journal_transaction_should_end()
2920 	if (th->t_refcount > 1)  in journal_transaction_should_end()
2931 	th->t_blocks_allocated += new_alloc ;  in journal_transaction_should_end()
2936 void reiserfs_block_writes(struct reiserfs_transaction_handle *th)  in reiserfs_block_writes()  argument
2938 	struct reiserfs_journal *journal = SB_JOURNAL(th->t_super);  in reiserfs_block_writes()
2939 	BUG_ON(!th->t_trans_id);  in reiserfs_block_writes()
3022 static int do_journal_begin_r(struct reiserfs_transaction_handle *th,  in do_journal_begin_r()  argument
3039 	th->t_refcount = 1;  in do_journal_begin_r()
3040 	th->t_super = sb;  in do_journal_begin_r()
3126 	th->t_blocks_logged = 0;  in do_journal_begin_r()
3127 	th->t_blocks_allocated = nblocks;  in do_journal_begin_r()
3128 	th->t_trans_id = journal->j_trans_id;  in do_journal_begin_r()
3130 	INIT_LIST_HEAD(&th->t_list);  in do_journal_begin_r()
3134 	memset(th, 0, sizeof(*th));  in do_journal_begin_r()
3140 	th->t_super = sb;  in do_journal_begin_r()
3150 	struct reiserfs_transaction_handle *th;  in reiserfs_persistent_transaction()  local
3157 		th = current->journal_info;  in reiserfs_persistent_transaction()
3158 		th->t_refcount++;  in reiserfs_persistent_transaction()
3159 		BUG_ON(th->t_refcount < 2);  in reiserfs_persistent_transaction()
3161 		return th;  in reiserfs_persistent_transaction()
3163 	th = kmalloc(sizeof(struct reiserfs_transaction_handle), GFP_NOFS);  in reiserfs_persistent_transaction()
3164 	if (!th)  in reiserfs_persistent_transaction()
3166 	ret = journal_begin(th, s, nblocks);  in reiserfs_persistent_transaction()
3168 		kfree(th);  in reiserfs_persistent_transaction()
3173 	return th;  in reiserfs_persistent_transaction()
3176 int reiserfs_end_persistent_transaction(struct reiserfs_transaction_handle *th)  in reiserfs_end_persistent_transaction()  argument
3178 	struct super_block *s = th->t_super;  in reiserfs_end_persistent_transaction()
3180 	if (th->t_trans_id)  in reiserfs_end_persistent_transaction()
3181 		ret = journal_end(th);  in reiserfs_end_persistent_transaction()
3184 	if (th->t_refcount == 0) {  in reiserfs_end_persistent_transaction()
3186 		kfree(th);  in reiserfs_end_persistent_transaction()
3191 static int journal_join(struct reiserfs_transaction_handle *th,  in journal_join()  argument
3200 	th->t_handle_save = cur_th;  in journal_join()
3202 	return do_journal_begin_r(th, sb, 1, JBEGIN_JOIN);  in journal_join()
3205 int journal_join_abort(struct reiserfs_transaction_handle *th,  in journal_join_abort()  argument
3214 	th->t_handle_save = cur_th;  in journal_join_abort()
3216 	return do_journal_begin_r(th, sb, 1, JBEGIN_ABORT);  in journal_join_abort()
3219 int journal_begin(struct reiserfs_transaction_handle *th,  in journal_begin()  argument
3225 	th->t_handle_save = NULL;  in journal_begin()
3231 			memcpy(th, cur_th, sizeof(*th));  in journal_begin()
3232 			if (th->t_refcount <= 1)  in journal_begin()
3245 			th->t_handle_save = current->journal_info;  in journal_begin()
3246 			current->journal_info = th;  in journal_begin()
3249 		current->journal_info = th;  in journal_begin()
3251 	ret = do_journal_begin_r(th, sb, nblocks, JBEGIN_REG);  in journal_begin()
3252 	BUG_ON(current->journal_info != th);  in journal_begin()
3259 		current->journal_info = th->t_handle_save;  in journal_begin()
3261 		BUG_ON(!th->t_refcount);  in journal_begin()
3276 int journal_mark_dirty(struct reiserfs_transaction_handle *th,  in journal_mark_dirty()  argument
3279 	struct super_block *sb = th->t_super;  in journal_mark_dirty()
3284 	BUG_ON(!th->t_trans_id);  in journal_mark_dirty()
3287 	if (th->t_trans_id != journal->j_trans_id) {  in journal_mark_dirty()
3288 		reiserfs_panic(th->t_super, "journal-1577",  in journal_mark_dirty()
3290 			       th->t_trans_id, journal->j_trans_id);  in journal_mark_dirty()
3329 		reiserfs_panic(th->t_super, "journal-1413",  in journal_mark_dirty()
3353 		if (th->t_blocks_logged == th->t_blocks_allocated) {  in journal_mark_dirty()
3354 			th->t_blocks_allocated += JOURNAL_PER_BALANCE_CNT;  in journal_mark_dirty()
3357 		th->t_blocks_logged++;  in journal_mark_dirty()
3383 int journal_end(struct reiserfs_transaction_handle *th)  in journal_end()  argument
3385 	struct super_block *sb = th->t_super;  in journal_end()
3386 	if (!current->journal_info && th->t_refcount > 1)  in journal_end()
3388 				 "th NULL, refcount %d", th->t_refcount);  in journal_end()
3390 	if (!th->t_trans_id) {  in journal_end()
3395 	th->t_refcount--;  in journal_end()
3396 	if (th->t_refcount > 0) {  in journal_end()
3404 		BUG_ON(cur_th->t_super != th->t_super);  in journal_end()
3406 		if (th != cur_th) {  in journal_end()
3407 			memcpy(current->journal_info, th, sizeof(*th));  in journal_end()
3408 			th->t_trans_id = 0;  in journal_end()
3412 		return do_journal_end(th, 0);  in journal_end()
3521 int journal_end_sync(struct reiserfs_transaction_handle *th)  in journal_end_sync()  argument
3523 	struct super_block *sb = th->t_super;  in journal_end_sync()
3526 	BUG_ON(!th->t_trans_id);  in journal_end_sync()
3528 	BUG_ON(th->t_refcount > 1);  in journal_end_sync()
3532 		journal_mark_dirty(th, SB_BUFFER_WITH_SB(sb));  in journal_end_sync()
3534 	return do_journal_end(th, COMMIT_NOW | WAIT);  in journal_end_sync()
3563 	struct reiserfs_transaction_handle th;  in reiserfs_flush_old_commits()  local
3582 		if (!journal_join(&th, sb)) {  in reiserfs_flush_old_commits()
3586 			journal_mark_dirty(&th, SB_BUFFER_WITH_SB(sb));  in reiserfs_flush_old_commits()
3593 			do_journal_end(&th, COMMIT_NOW | WAIT);  in reiserfs_flush_old_commits()
3613 static int check_journal_end(struct reiserfs_transaction_handle *th, int flags)  in check_journal_end()  argument
3621 	struct super_block *sb = th->t_super;  in check_journal_end()
3624 	BUG_ON(!th->t_trans_id);  in check_journal_end()
3626 	if (th->t_trans_id != journal->j_trans_id) {  in check_journal_end()
3627 		reiserfs_panic(th->t_super, "journal-1577",  in check_journal_end()
3629 			       th->t_trans_id, journal->j_trans_id);  in check_journal_end()
3632 	journal->j_len_alloc -= (th->t_blocks_allocated - th->t_blocks_logged);  in check_journal_end()
3738 int journal_mark_freed(struct reiserfs_transaction_handle *th,  in journal_mark_freed()  argument
3746 	BUG_ON(!th->t_trans_id);  in journal_mark_freed()
3843 	struct reiserfs_transaction_handle th;  in __commit_trans_jl()  local
3863 		ret = journal_begin(&th, sb, 1);  in __commit_trans_jl()
3871 			journal_mark_dirty(&th, SB_BUFFER_WITH_SB(sb));  in __commit_trans_jl()
3872 			ret = journal_end(&th);  in __commit_trans_jl()
3876 		ret = journal_end_sync(&th);  in __commit_trans_jl()
3982 static int do_journal_end(struct reiserfs_transaction_handle *th, int flags)  in do_journal_end()  argument
3984 	struct super_block *sb = th->t_super;  in do_journal_end()
4004 	BUG_ON(th->t_refcount > 1);  in do_journal_end()
4005 	BUG_ON(!th->t_trans_id);  in do_journal_end()
4006 	BUG_ON(!th->t_super);  in do_journal_end()
4012 	if (th->t_trans_id == ~0U)  in do_journal_end()
4017 	current->journal_info = th->t_handle_save;  in do_journal_end()
4022 		journal_mark_dirty(th, SB_BUFFER_WITH_SB(sb));  in do_journal_end()
4040 	if (!check_journal_end(th, flags)) {  in do_journal_end()
4064 	current->journal_info = th;  in do_journal_end()
4065 	th->t_refcount++;  in do_journal_end()
4068 	reiserfs_discard_all_prealloc(th);  in do_journal_end()
4070 	th->t_refcount--;  in do_journal_end()
4071 	current->journal_info = th->t_handle_save;  in do_journal_end()
4378 	memset(th, 0, sizeof(*th));  in do_journal_end()
4384 	th->t_super = sb;  in do_journal_end()