mirrors/linux
1
0
Fork 0
mirror of https://git.kernel.org/pub/scm/linux/kernel/git/torvalds/linux.git synced 2026-01-22 09:55:16 -05:00
Code Issues Packages Projects Releases Wiki Activity

bcachefs: prepare journal buf put to handle pin put

Browse Source 
bcachefs freeze testing has uncovered some raciness between journal
entry open/close and pin list reference count management. The
details of the problem are described in a separate patch. In
preparation for the associated fix, refactor the journal buffer put
path a bit to allow it to eventually handle dropping the pin list
reference currently held by an open journal entry.

Retain the journal write dispatch helper since the closure code is
inlined and we don't want to increase the amount of inline code in
the transaction commit path, but rename the function to reflect
the purpose of final processing of the journal buffer.

Signed-off-by: Brian Foster <bfoster@redhat.com>
Signed-off-by: Kent Overstreet <kent.overstreet@linux.dev>
This commit is contained in:
Brian Foster
2023-09-15 08:51:52 -04:00
committed by Kent Overstreet
parent 92b63f5bf0
commit fc08031bb8
2 changed files with 18 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fs/bcachefs/journal.c
View File

@@ -134,7 +134,7 @@ journal_error_check_stuck(struct journal *j, int error, unsigned flags)
/* journal entry close/open: */
void __bch2_journal_buf_put(struct journal *j)
void bch2_journal_buf_put_final(struct journal *j)
{
struct bch_fs *c = container_of(j, struct bch_fs, journal);

22
fs/bcachefs/journal.h
View File

@@ -252,9 +252,10 @@ static inline bool journal_entry_empty(struct jset *j)
return true;
}
void __bch2_journal_buf_put(struct journal *);
static inline void bch2_journal_buf_put(struct journal *j, unsigned idx)
/*
* Drop reference on a buffer index and return true if the count has hit zero.
*/
static inline union journal_res_state journal_state_buf_put(struct journal *j, unsigned idx)
{
union journal_res_state s;
@@ -264,9 +265,20 @@ static inline void bch2_journal_buf_put(struct journal *j, unsigned idx)
.buf2_count = idx == 2,
.buf3_count = idx == 3,
}).v, &j->reservations.counter);
return s;
}
if (!journal_state_count(s, idx) && idx == s.unwritten_idx)
__bch2_journal_buf_put(j);
void bch2_journal_buf_put_final(struct journal *);
static inline void bch2_journal_buf_put(struct journal *j, unsigned idx)
{
union journal_res_state s;
s = journal_state_buf_put(j, idx);
if (!journal_state_count(s, idx)) {
if (idx == s.unwritten_idx)
bch2_journal_buf_put_final(j);
}
}
/*