summaryrefslogtreecommitdiff
path: root/libbcachefs/journal_seq_blacklist.c
diff options
context:
space:
mode:
authorKent Overstreet <kent.overstreet@gmail.com>2021-10-20 12:33:59 -0400
committerKent Overstreet <kent.overstreet@gmail.com>2021-10-20 12:36:50 -0400
commit3db6ec44c5c7c39cb0067a6b02ef22090ecbaa98 (patch)
treec23c334375e5a3ecea30131f94f2fd9866035420 /libbcachefs/journal_seq_blacklist.c
parent1fe24a0e836503026529a692ccd214331c29d224 (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.c23
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;