91 static int journal_join(struct reiserfs_transaction_handle *th,
109 static int do_journal_begin_r(struct reiserfs_transaction_handle *th,
1904 static int do_journal_release(struct reiserfs_transaction_handle *th,  in do_journal_release()  argument
1916 		BUG_ON(!th->t_trans_id);  in do_journal_release()
1917 		do_journal_end(th, FLUSH_ALL);  in do_journal_release()
1968 int journal_release(struct reiserfs_transaction_handle *th,  in journal_release()  argument
1971 	return do_journal_release(th, sb, 0);  in journal_release()
1975 int journal_release_error(struct reiserfs_transaction_handle *th,  in journal_release_error()  argument
1978 	return do_journal_release(th, sb, 1);  in journal_release_error()
2924 int journal_transaction_should_end(struct reiserfs_transaction_handle *th,  in journal_transaction_should_end()  argument
2927 	struct reiserfs_journal *journal = SB_JOURNAL(th->t_super);  in journal_transaction_should_end()
2930 	BUG_ON(!th->t_trans_id);  in journal_transaction_should_end()
2931 	if (th->t_refcount > 1)  in journal_transaction_should_end()
2942 	th->t_blocks_allocated += new_alloc ;  in journal_transaction_should_end()
2947 void reiserfs_block_writes(struct reiserfs_transaction_handle *th)  in reiserfs_block_writes()  argument
2949 	struct reiserfs_journal *journal = SB_JOURNAL(th->t_super);  in reiserfs_block_writes()
2950 	BUG_ON(!th->t_trans_id);  in reiserfs_block_writes()
3033 static int do_journal_begin_r(struct reiserfs_transaction_handle *th,  in do_journal_begin_r()  argument
3049 	th->t_refcount = 1;  in do_journal_begin_r()
3050 	th->t_super = sb;  in do_journal_begin_r()
3135 	th->t_blocks_logged = 0;  in do_journal_begin_r()
3136 	th->t_blocks_allocated = nblocks;  in do_journal_begin_r()
3137 	th->t_trans_id = journal->j_trans_id;  in do_journal_begin_r()
3139 	INIT_LIST_HEAD(&th->t_list);  in do_journal_begin_r()
3143 	memset(th, 0, sizeof(*th));  in do_journal_begin_r()
3149 	th->t_super = sb;  in do_journal_begin_r()
3159 	struct reiserfs_transaction_handle *th;  in reiserfs_persistent_transaction()  local
3166 		th = current->journal_info;  in reiserfs_persistent_transaction()
3167 		th->t_refcount++;  in reiserfs_persistent_transaction()
3168 		BUG_ON(th->t_refcount < 2);  in reiserfs_persistent_transaction()
3170 		return th;  in reiserfs_persistent_transaction()
3172 	th = kmalloc(sizeof(struct reiserfs_transaction_handle), GFP_NOFS);  in reiserfs_persistent_transaction()
3173 	if (!th)  in reiserfs_persistent_transaction()
3175 	ret = journal_begin(th, s, nblocks);  in reiserfs_persistent_transaction()
3177 		kfree(th);  in reiserfs_persistent_transaction()
3182 	return th;  in reiserfs_persistent_transaction()
3185 int reiserfs_end_persistent_transaction(struct reiserfs_transaction_handle *th)  in reiserfs_end_persistent_transaction()  argument
3187 	struct super_block *s = th->t_super;  in reiserfs_end_persistent_transaction()
3189 	if (th->t_trans_id)  in reiserfs_end_persistent_transaction()
3190 		ret = journal_end(th);  in reiserfs_end_persistent_transaction()
3193 	if (th->t_refcount == 0) {  in reiserfs_end_persistent_transaction()
3195 		kfree(th);  in reiserfs_end_persistent_transaction()
3200 static int journal_join(struct reiserfs_transaction_handle *th,  in journal_join()  argument
3209 	th->t_handle_save = cur_th;  in journal_join()
3211 	return do_journal_begin_r(th, sb, 1, JBEGIN_JOIN);  in journal_join()
3214 int journal_join_abort(struct reiserfs_transaction_handle *th,  in journal_join_abort()  argument
3223 	th->t_handle_save = cur_th;  in journal_join_abort()
3225 	return do_journal_begin_r(th, sb, 1, JBEGIN_ABORT);  in journal_join_abort()
3228 int journal_begin(struct reiserfs_transaction_handle *th,  in journal_begin()  argument
3234 	th->t_handle_save = NULL;  in journal_begin()
3240 			memcpy(th, cur_th, sizeof(*th));  in journal_begin()
3241 			if (th->t_refcount <= 1)  in journal_begin()
3254 			th->t_handle_save = current->journal_info;  in journal_begin()
3255 			current->journal_info = th;  in journal_begin()
3258 		current->journal_info = th;  in journal_begin()
3260 	ret = do_journal_begin_r(th, sb, nblocks, JBEGIN_REG);  in journal_begin()
3261 	BUG_ON(current->journal_info != th);  in journal_begin()
3268 		current->journal_info = th->t_handle_save;  in journal_begin()
3270 		BUG_ON(!th->t_refcount);  in journal_begin()
3285 int journal_mark_dirty(struct reiserfs_transaction_handle *th,  in journal_mark_dirty()  argument
3288 	struct super_block *sb = th->t_super;  in journal_mark_dirty()
3293 	BUG_ON(!th->t_trans_id);  in journal_mark_dirty()
3296 	if (th->t_trans_id != journal->j_trans_id) {  in journal_mark_dirty()
3297 		reiserfs_panic(th->t_super, "journal-1577",  in journal_mark_dirty()
3299 			       th->t_trans_id, journal->j_trans_id);  in journal_mark_dirty()
3338 		reiserfs_panic(th->t_super, "journal-1413",  in journal_mark_dirty()
3362 		if (th->t_blocks_logged == th->t_blocks_allocated) {  in journal_mark_dirty()
3363 			th->t_blocks_allocated += JOURNAL_PER_BALANCE_CNT;  in journal_mark_dirty()
3366 		th->t_blocks_logged++;  in journal_mark_dirty()
3392 int journal_end(struct reiserfs_transaction_handle *th)  in journal_end()  argument
3394 	struct super_block *sb = th->t_super;  in journal_end()
3395 	if (!current->journal_info && th->t_refcount > 1)  in journal_end()
3397 				 "th NULL, refcount %d", th->t_refcount);  in journal_end()
3399 	if (!th->t_trans_id) {  in journal_end()
3404 	th->t_refcount--;  in journal_end()
3405 	if (th->t_refcount > 0) {  in journal_end()
3413 		BUG_ON(cur_th->t_super != th->t_super);  in journal_end()
3415 		if (th != cur_th) {  in journal_end()
3416 			memcpy(current->journal_info, th, sizeof(*th));  in journal_end()
3417 			th->t_trans_id = 0;  in journal_end()
3421 		return do_journal_end(th, 0);  in journal_end()
3529 int journal_end_sync(struct reiserfs_transaction_handle *th)  in journal_end_sync()  argument
3531 	struct super_block *sb = th->t_super;  in journal_end_sync()
3534 	BUG_ON(!th->t_trans_id);  in journal_end_sync()
3536 	BUG_ON(th->t_refcount > 1);  in journal_end_sync()
3540 		journal_mark_dirty(th, SB_BUFFER_WITH_SB(sb));  in journal_end_sync()
3542 	return do_journal_end(th, COMMIT_NOW | WAIT);  in journal_end_sync()
3571 	struct reiserfs_transaction_handle th;  in reiserfs_flush_old_commits()  local
3590 		if (!journal_join(&th, sb)) {  in reiserfs_flush_old_commits()
3594 			journal_mark_dirty(&th, SB_BUFFER_WITH_SB(sb));  in reiserfs_flush_old_commits()
3601 			do_journal_end(&th, COMMIT_NOW | WAIT);  in reiserfs_flush_old_commits()
3621 static int check_journal_end(struct reiserfs_transaction_handle *th, int flags)  in check_journal_end()  argument
3629 	struct super_block *sb = th->t_super;  in check_journal_end()
3632 	BUG_ON(!th->t_trans_id);  in check_journal_end()
3634 	if (th->t_trans_id != journal->j_trans_id) {  in check_journal_end()
3635 		reiserfs_panic(th->t_super, "journal-1577",  in check_journal_end()
3637 			       th->t_trans_id, journal->j_trans_id);  in check_journal_end()
3640 	journal->j_len_alloc -= (th->t_blocks_allocated - th->t_blocks_logged);  in check_journal_end()
3746 int journal_mark_freed(struct reiserfs_transaction_handle *th,  in journal_mark_freed()  argument
3754 	BUG_ON(!th->t_trans_id);  in journal_mark_freed()
3851 	struct reiserfs_transaction_handle th;  in __commit_trans_jl()  local
3871 		ret = journal_begin(&th, sb, 1);  in __commit_trans_jl()
3879 			journal_mark_dirty(&th, SB_BUFFER_WITH_SB(sb));  in __commit_trans_jl()
3880 			ret = journal_end(&th);  in __commit_trans_jl()
3884 		ret = journal_end_sync(&th);  in __commit_trans_jl()
3990 static int do_journal_end(struct reiserfs_transaction_handle *th, int flags)  in do_journal_end()  argument
3992 	struct super_block *sb = th->t_super;  in do_journal_end()
4011 	BUG_ON(th->t_refcount > 1);  in do_journal_end()
4012 	BUG_ON(!th->t_trans_id);  in do_journal_end()
4013 	BUG_ON(!th->t_super);  in do_journal_end()
4019 	if (th->t_trans_id == ~0U)  in do_journal_end()
4024 	current->journal_info = th->t_handle_save;  in do_journal_end()
4029 		journal_mark_dirty(th, SB_BUFFER_WITH_SB(sb));  in do_journal_end()
4047 	if (!check_journal_end(th, flags)) {  in do_journal_end()
4071 	current->journal_info = th;  in do_journal_end()
4072 	th->t_refcount++;  in do_journal_end()
4075 	reiserfs_discard_all_prealloc(th);  in do_journal_end()
4077 	th->t_refcount--;  in do_journal_end()
4078 	current->journal_info = th->t_handle_save;  in do_journal_end()
4384 	memset(th, 0, sizeof(*th));  in do_journal_end()
4390 	th->t_super = sb;  in do_journal_end()