diff options
author | Kent Overstreet <kent.overstreet@gmail.com> | 2021-10-20 12:33:59 -0400 |
---|---|---|
committer | Kent Overstreet <kent.overstreet@gmail.com> | 2021-10-20 12:36:50 -0400 |
commit | 3db6ec44c5c7c39cb0067a6b02ef22090ecbaa98 (patch) | |
tree | c23c334375e5a3ecea30131f94f2fd9866035420 /libbcachefs/journal_seq_blacklist.c | |
parent | 1fe24a0e836503026529a692ccd214331c29d224 (diff) |
Update bcachefs sources to d9d1235f3c bcachefs: Handle transaction restarts in bch2_blacklist_entries_gc()
Diffstat (limited to 'libbcachefs/journal_seq_blacklist.c')
-rw-r--r-- | libbcachefs/journal_seq_blacklist.c | 23 |
1 files changed, 16 insertions, 7 deletions
diff --git a/libbcachefs/journal_seq_blacklist.c b/libbcachefs/journal_seq_blacklist.c index 68fb2ebd..79bc0e49 100644 --- a/libbcachefs/journal_seq_blacklist.c +++ b/libbcachefs/journal_seq_blacklist.c @@ -253,16 +253,25 @@ void bch2_blacklist_entries_gc(struct work_struct *work) struct btree_iter iter; struct btree *b; - for_each_btree_node(&trans, iter, i, POS_MIN, - BTREE_ITER_PREFETCH, b) - if (test_bit(BCH_FS_STOPPING, &c->flags)) { - bch2_trans_exit(&trans); - return; - } + bch2_trans_node_iter_init(&trans, &iter, i, POS_MIN, + 0, 0, BTREE_ITER_PREFETCH); +retry: + bch2_trans_begin(&trans); + + b = bch2_btree_iter_peek_node(&iter); + + while (!(ret = PTR_ERR_OR_ZERO(b)) && + b && + !test_bit(BCH_FS_STOPPING, &c->flags)) + b = bch2_btree_iter_next_node(&iter); + + if (ret == -EINTR) + goto retry; + bch2_trans_iter_exit(&trans, &iter); } - ret = bch2_trans_exit(&trans); + bch2_trans_exit(&trans); if (ret) return; |