93 static int journal_join(struct reiserfs_transaction_handle *th,
111 static int do_journal_begin_r(struct reiserfs_transaction_handle *th,
1905 static int do_journal_release(struct reiserfs_transaction_handle *th,  in do_journal_release()  argument
1917 		BUG_ON(!th->t_trans_id);  in do_journal_release()
1918 		do_journal_end(th, FLUSH_ALL);  in do_journal_release()
1969 int journal_release(struct reiserfs_transaction_handle *th,  in journal_release()  argument
1972 	return do_journal_release(th, sb, 0);  in journal_release()
1976 int journal_release_error(struct reiserfs_transaction_handle *th,  in journal_release_error()  argument
1979 	return do_journal_release(th, sb, 1);  in journal_release_error()
2904 int journal_transaction_should_end(struct reiserfs_transaction_handle *th,  in journal_transaction_should_end()  argument
2907 	struct reiserfs_journal *journal = SB_JOURNAL(th->t_super);  in journal_transaction_should_end()
2910 	BUG_ON(!th->t_trans_id);  in journal_transaction_should_end()
2911 	if (th->t_refcount > 1)  in journal_transaction_should_end()
2922 	th->t_blocks_allocated += new_alloc ;  in journal_transaction_should_end()
2927 void reiserfs_block_writes(struct reiserfs_transaction_handle *th)  in reiserfs_block_writes()  argument
2929 	struct reiserfs_journal *journal = SB_JOURNAL(th->t_super);  in reiserfs_block_writes()
2930 	BUG_ON(!th->t_trans_id);  in reiserfs_block_writes()
3013 static int do_journal_begin_r(struct reiserfs_transaction_handle *th,  in do_journal_begin_r()  argument
3030 	th->t_refcount = 1;  in do_journal_begin_r()
3031 	th->t_super = sb;  in do_journal_begin_r()
3117 	th->t_blocks_logged = 0;  in do_journal_begin_r()
3118 	th->t_blocks_allocated = nblocks;  in do_journal_begin_r()
3119 	th->t_trans_id = journal->j_trans_id;  in do_journal_begin_r()
3121 	INIT_LIST_HEAD(&th->t_list);  in do_journal_begin_r()
3125 	memset(th, 0, sizeof(*th));  in do_journal_begin_r()
3131 	th->t_super = sb;  in do_journal_begin_r()
3141 	struct reiserfs_transaction_handle *th;  in reiserfs_persistent_transaction()  local
3148 		th = current->journal_info;  in reiserfs_persistent_transaction()
3149 		th->t_refcount++;  in reiserfs_persistent_transaction()
3150 		BUG_ON(th->t_refcount < 2);  in reiserfs_persistent_transaction()
3152 		return th;  in reiserfs_persistent_transaction()
3154 	th = kmalloc(sizeof(struct reiserfs_transaction_handle), GFP_NOFS);  in reiserfs_persistent_transaction()
3155 	if (!th)  in reiserfs_persistent_transaction()
3157 	ret = journal_begin(th, s, nblocks);  in reiserfs_persistent_transaction()
3159 		kfree(th);  in reiserfs_persistent_transaction()
3164 	return th;  in reiserfs_persistent_transaction()
3167 int reiserfs_end_persistent_transaction(struct reiserfs_transaction_handle *th)  in reiserfs_end_persistent_transaction()  argument
3169 	struct super_block *s = th->t_super;  in reiserfs_end_persistent_transaction()
3171 	if (th->t_trans_id)  in reiserfs_end_persistent_transaction()
3172 		ret = journal_end(th);  in reiserfs_end_persistent_transaction()
3175 	if (th->t_refcount == 0) {  in reiserfs_end_persistent_transaction()
3177 		kfree(th);  in reiserfs_end_persistent_transaction()
3182 static int journal_join(struct reiserfs_transaction_handle *th,  in journal_join()  argument
3191 	th->t_handle_save = cur_th;  in journal_join()
3193 	return do_journal_begin_r(th, sb, 1, JBEGIN_JOIN);  in journal_join()
3196 int journal_join_abort(struct reiserfs_transaction_handle *th,  in journal_join_abort()  argument
3205 	th->t_handle_save = cur_th;  in journal_join_abort()
3207 	return do_journal_begin_r(th, sb, 1, JBEGIN_ABORT);  in journal_join_abort()
3210 int journal_begin(struct reiserfs_transaction_handle *th,  in journal_begin()  argument
3216 	th->t_handle_save = NULL;  in journal_begin()
3222 			memcpy(th, cur_th, sizeof(*th));  in journal_begin()
3223 			if (th->t_refcount <= 1)  in journal_begin()
3236 			th->t_handle_save = current->journal_info;  in journal_begin()
3237 			current->journal_info = th;  in journal_begin()
3240 		current->journal_info = th;  in journal_begin()
3242 	ret = do_journal_begin_r(th, sb, nblocks, JBEGIN_REG);  in journal_begin()
3243 	BUG_ON(current->journal_info != th);  in journal_begin()
3250 		current->journal_info = th->t_handle_save;  in journal_begin()
3252 		BUG_ON(!th->t_refcount);  in journal_begin()
3267 int journal_mark_dirty(struct reiserfs_transaction_handle *th,  in journal_mark_dirty()  argument
3270 	struct super_block *sb = th->t_super;  in journal_mark_dirty()
3275 	BUG_ON(!th->t_trans_id);  in journal_mark_dirty()
3278 	if (th->t_trans_id != journal->j_trans_id) {  in journal_mark_dirty()
3279 		reiserfs_panic(th->t_super, "journal-1577",  in journal_mark_dirty()
3281 			       th->t_trans_id, journal->j_trans_id);  in journal_mark_dirty()
3320 		reiserfs_panic(th->t_super, "journal-1413",  in journal_mark_dirty()
3344 		if (th->t_blocks_logged == th->t_blocks_allocated) {  in journal_mark_dirty()
3345 			th->t_blocks_allocated += JOURNAL_PER_BALANCE_CNT;  in journal_mark_dirty()
3348 		th->t_blocks_logged++;  in journal_mark_dirty()
3374 int journal_end(struct reiserfs_transaction_handle *th)  in journal_end()  argument
3376 	struct super_block *sb = th->t_super;  in journal_end()
3377 	if (!current->journal_info && th->t_refcount > 1)  in journal_end()
3379 				 "th NULL, refcount %d", th->t_refcount);  in journal_end()
3381 	if (!th->t_trans_id) {  in journal_end()
3386 	th->t_refcount--;  in journal_end()
3387 	if (th->t_refcount > 0) {  in journal_end()
3395 		BUG_ON(cur_th->t_super != th->t_super);  in journal_end()
3397 		if (th != cur_th) {  in journal_end()
3398 			memcpy(current->journal_info, th, sizeof(*th));  in journal_end()
3399 			th->t_trans_id = 0;  in journal_end()
3403 		return do_journal_end(th, 0);  in journal_end()
3511 int journal_end_sync(struct reiserfs_transaction_handle *th)  in journal_end_sync()  argument
3513 	struct super_block *sb = th->t_super;  in journal_end_sync()
3516 	BUG_ON(!th->t_trans_id);  in journal_end_sync()
3518 	BUG_ON(th->t_refcount > 1);  in journal_end_sync()
3522 		journal_mark_dirty(th, SB_BUFFER_WITH_SB(sb));  in journal_end_sync()
3524 	return do_journal_end(th, COMMIT_NOW | WAIT);  in journal_end_sync()
3553 	struct reiserfs_transaction_handle th;  in reiserfs_flush_old_commits()  local
3572 		if (!journal_join(&th, sb)) {  in reiserfs_flush_old_commits()
3576 			journal_mark_dirty(&th, SB_BUFFER_WITH_SB(sb));  in reiserfs_flush_old_commits()
3583 			do_journal_end(&th, COMMIT_NOW | WAIT);  in reiserfs_flush_old_commits()
3603 static int check_journal_end(struct reiserfs_transaction_handle *th, int flags)  in check_journal_end()  argument
3611 	struct super_block *sb = th->t_super;  in check_journal_end()
3614 	BUG_ON(!th->t_trans_id);  in check_journal_end()
3616 	if (th->t_trans_id != journal->j_trans_id) {  in check_journal_end()
3617 		reiserfs_panic(th->t_super, "journal-1577",  in check_journal_end()
3619 			       th->t_trans_id, journal->j_trans_id);  in check_journal_end()
3622 	journal->j_len_alloc -= (th->t_blocks_allocated - th->t_blocks_logged);  in check_journal_end()
3728 int journal_mark_freed(struct reiserfs_transaction_handle *th,  in journal_mark_freed()  argument
3736 	BUG_ON(!th->t_trans_id);  in journal_mark_freed()
3833 	struct reiserfs_transaction_handle th;  in __commit_trans_jl()  local
3853 		ret = journal_begin(&th, sb, 1);  in __commit_trans_jl()
3861 			journal_mark_dirty(&th, SB_BUFFER_WITH_SB(sb));  in __commit_trans_jl()
3862 			ret = journal_end(&th);  in __commit_trans_jl()
3866 		ret = journal_end_sync(&th);  in __commit_trans_jl()
3972 static int do_journal_end(struct reiserfs_transaction_handle *th, int flags)  in do_journal_end()  argument
3974 	struct super_block *sb = th->t_super;  in do_journal_end()
3993 	BUG_ON(th->t_refcount > 1);  in do_journal_end()
3994 	BUG_ON(!th->t_trans_id);  in do_journal_end()
3995 	BUG_ON(!th->t_super);  in do_journal_end()
4001 	if (th->t_trans_id == ~0U)  in do_journal_end()
4006 	current->journal_info = th->t_handle_save;  in do_journal_end()
4011 		journal_mark_dirty(th, SB_BUFFER_WITH_SB(sb));  in do_journal_end()
4029 	if (!check_journal_end(th, flags)) {  in do_journal_end()
4053 	current->journal_info = th;  in do_journal_end()
4054 	th->t_refcount++;  in do_journal_end()
4057 	reiserfs_discard_all_prealloc(th);  in do_journal_end()
4059 	th->t_refcount--;  in do_journal_end()
4060 	current->journal_info = th->t_handle_save;  in do_journal_end()
4366 	memset(th, 0, sizeof(*th));  in do_journal_end()
4372 	th->t_super = sb;  in do_journal_end()