Lines Matching refs:th
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()
2915 int journal_transaction_should_end(struct reiserfs_transaction_handle *th, in journal_transaction_should_end() argument
2918 struct reiserfs_journal *journal = SB_JOURNAL(th->t_super); in journal_transaction_should_end()
2921 BUG_ON(!th->t_trans_id); in journal_transaction_should_end()
2922 if (th->t_refcount > 1) in journal_transaction_should_end()
2933 th->t_blocks_allocated += new_alloc ; in journal_transaction_should_end()
2938 void reiserfs_block_writes(struct reiserfs_transaction_handle *th) in reiserfs_block_writes() argument
2940 struct reiserfs_journal *journal = SB_JOURNAL(th->t_super); in reiserfs_block_writes()
2941 BUG_ON(!th->t_trans_id); in reiserfs_block_writes()
3024 static int do_journal_begin_r(struct reiserfs_transaction_handle *th, in do_journal_begin_r() argument
3041 th->t_refcount = 1; in do_journal_begin_r()
3042 th->t_super = sb; in do_journal_begin_r()
3128 th->t_blocks_logged = 0; in do_journal_begin_r()
3129 th->t_blocks_allocated = nblocks; in do_journal_begin_r()
3130 th->t_trans_id = journal->j_trans_id; in do_journal_begin_r()
3132 INIT_LIST_HEAD(&th->t_list); in do_journal_begin_r()
3136 memset(th, 0, sizeof(*th)); in do_journal_begin_r()
3142 th->t_super = sb; in do_journal_begin_r()
3152 struct reiserfs_transaction_handle *th; in reiserfs_persistent_transaction() local
3159 th = current->journal_info; in reiserfs_persistent_transaction()
3160 th->t_refcount++; in reiserfs_persistent_transaction()
3161 BUG_ON(th->t_refcount < 2); in reiserfs_persistent_transaction()
3163 return th; in reiserfs_persistent_transaction()
3165 th = kmalloc(sizeof(struct reiserfs_transaction_handle), GFP_NOFS); in reiserfs_persistent_transaction()
3166 if (!th) in reiserfs_persistent_transaction()
3168 ret = journal_begin(th, s, nblocks); in reiserfs_persistent_transaction()
3170 kfree(th); in reiserfs_persistent_transaction()
3175 return th; in reiserfs_persistent_transaction()
3178 int reiserfs_end_persistent_transaction(struct reiserfs_transaction_handle *th) in reiserfs_end_persistent_transaction() argument
3180 struct super_block *s = th->t_super; in reiserfs_end_persistent_transaction()
3182 if (th->t_trans_id) in reiserfs_end_persistent_transaction()
3183 ret = journal_end(th); in reiserfs_end_persistent_transaction()
3186 if (th->t_refcount == 0) { in reiserfs_end_persistent_transaction()
3188 kfree(th); in reiserfs_end_persistent_transaction()
3193 static int journal_join(struct reiserfs_transaction_handle *th, in journal_join() argument
3202 th->t_handle_save = cur_th; in journal_join()
3204 return do_journal_begin_r(th, sb, 1, JBEGIN_JOIN); in journal_join()
3207 int journal_join_abort(struct reiserfs_transaction_handle *th, in journal_join_abort() argument
3216 th->t_handle_save = cur_th; in journal_join_abort()
3218 return do_journal_begin_r(th, sb, 1, JBEGIN_ABORT); in journal_join_abort()
3221 int journal_begin(struct reiserfs_transaction_handle *th, in journal_begin() argument
3227 th->t_handle_save = NULL; in journal_begin()
3233 memcpy(th, cur_th, sizeof(*th)); in journal_begin()
3234 if (th->t_refcount <= 1) in journal_begin()
3247 th->t_handle_save = current->journal_info; in journal_begin()
3248 current->journal_info = th; in journal_begin()
3251 current->journal_info = th; in journal_begin()
3253 ret = do_journal_begin_r(th, sb, nblocks, JBEGIN_REG); in journal_begin()
3254 BUG_ON(current->journal_info != th); in journal_begin()
3261 current->journal_info = th->t_handle_save; in journal_begin()
3263 BUG_ON(!th->t_refcount); in journal_begin()
3278 int journal_mark_dirty(struct reiserfs_transaction_handle *th, in journal_mark_dirty() argument
3281 struct super_block *sb = th->t_super; in journal_mark_dirty()
3286 BUG_ON(!th->t_trans_id); in journal_mark_dirty()
3289 if (th->t_trans_id != journal->j_trans_id) { in journal_mark_dirty()
3290 reiserfs_panic(th->t_super, "journal-1577", in journal_mark_dirty()
3292 th->t_trans_id, journal->j_trans_id); in journal_mark_dirty()
3331 reiserfs_panic(th->t_super, "journal-1413", in journal_mark_dirty()
3355 if (th->t_blocks_logged == th->t_blocks_allocated) { in journal_mark_dirty()
3356 th->t_blocks_allocated += JOURNAL_PER_BALANCE_CNT; in journal_mark_dirty()
3359 th->t_blocks_logged++; in journal_mark_dirty()
3385 int journal_end(struct reiserfs_transaction_handle *th) in journal_end() argument
3387 struct super_block *sb = th->t_super; in journal_end()
3388 if (!current->journal_info && th->t_refcount > 1) in journal_end()
3390 "th NULL, refcount %d", th->t_refcount); in journal_end()
3392 if (!th->t_trans_id) { in journal_end()
3397 th->t_refcount--; in journal_end()
3398 if (th->t_refcount > 0) { in journal_end()
3406 BUG_ON(cur_th->t_super != th->t_super); in journal_end()
3408 if (th != cur_th) { in journal_end()
3409 memcpy(current->journal_info, th, sizeof(*th)); in journal_end()
3410 th->t_trans_id = 0; in journal_end()
3414 return do_journal_end(th, 0); in journal_end()
3522 int journal_end_sync(struct reiserfs_transaction_handle *th) in journal_end_sync() argument
3524 struct super_block *sb = th->t_super; in journal_end_sync()
3527 BUG_ON(!th->t_trans_id); in journal_end_sync()
3529 BUG_ON(th->t_refcount > 1); in journal_end_sync()
3533 journal_mark_dirty(th, SB_BUFFER_WITH_SB(sb)); in journal_end_sync()
3535 return do_journal_end(th, COMMIT_NOW | WAIT); in journal_end_sync()
3564 struct reiserfs_transaction_handle th; in reiserfs_flush_old_commits() local
3583 if (!journal_join(&th, sb)) { in reiserfs_flush_old_commits()
3587 journal_mark_dirty(&th, SB_BUFFER_WITH_SB(sb)); in reiserfs_flush_old_commits()
3594 do_journal_end(&th, COMMIT_NOW | WAIT); in reiserfs_flush_old_commits()
3614 static int check_journal_end(struct reiserfs_transaction_handle *th, int flags) in check_journal_end() argument
3622 struct super_block *sb = th->t_super; in check_journal_end()
3625 BUG_ON(!th->t_trans_id); in check_journal_end()
3627 if (th->t_trans_id != journal->j_trans_id) { in check_journal_end()
3628 reiserfs_panic(th->t_super, "journal-1577", in check_journal_end()
3630 th->t_trans_id, journal->j_trans_id); in check_journal_end()
3633 journal->j_len_alloc -= (th->t_blocks_allocated - th->t_blocks_logged); in check_journal_end()
3739 int journal_mark_freed(struct reiserfs_transaction_handle *th, in journal_mark_freed() argument
3747 BUG_ON(!th->t_trans_id); in journal_mark_freed()
3844 struct reiserfs_transaction_handle th; in __commit_trans_jl() local
3864 ret = journal_begin(&th, sb, 1); in __commit_trans_jl()
3872 journal_mark_dirty(&th, SB_BUFFER_WITH_SB(sb)); in __commit_trans_jl()
3873 ret = journal_end(&th); in __commit_trans_jl()
3877 ret = journal_end_sync(&th); in __commit_trans_jl()
3983 static int do_journal_end(struct reiserfs_transaction_handle *th, int flags) in do_journal_end() argument
3985 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()
4377 memset(th, 0, sizeof(*th)); in do_journal_end()
4383 th->t_super = sb; in do_journal_end()