]> git.sesse.net Git - bcachefs-tools-debian/blobdiff - libbcachefs/rebalance.c
Update bcachefs sources to df6415fefb27 bcachefs: Fixes for rust bindgen
[bcachefs-tools-debian] / libbcachefs / rebalance.c
index 79bd4ad0126521d3719cc16e2a1a96a5420095a8..95f46cb3b5bdfd820e845a8cceda2b3c2fb67cf4 100644 (file)
@@ -177,7 +177,8 @@ static struct bkey_s_c next_rebalance_extent(struct btree_trans *trans,
                prt_str(&buf, "target=");
                bch2_target_to_text(&buf, c, r->target);
                prt_str(&buf, " compression=");
-               prt_str(&buf, bch2_compression_opts[r->compression]);
+               struct bch_compression_opt opt = __bch2_compression_decode(r->compression);
+               prt_str(&buf, bch2_compression_opts[opt.type]);
                prt_str(&buf, " ");
                bch2_bkey_val_to_text(&buf, c, k);
 
@@ -334,7 +335,7 @@ static int do_rebalance(struct moving_context *ctxt)
        while (!bch2_move_ratelimit(ctxt)) {
                if (!r->enabled) {
                        bch2_moving_ctxt_flush_all(ctxt);
-                       kthread_wait_freezable(c->copy_gc_enabled ||
+                       kthread_wait_freezable(r->enabled ||
                                               kthread_should_stop());
                }
 
@@ -469,10 +470,9 @@ int bch2_rebalance_start(struct bch_fs *c)
 
        p = kthread_create(bch2_rebalance_thread, c, "bch-rebalance/%s", c->name);
        ret = PTR_ERR_OR_ZERO(p);
-       if (ret) {
-               bch_err_msg(c, ret, "creating rebalance thread");
+       bch_err_msg(c, ret, "creating rebalance thread");
+       if (ret)
                return ret;
-       }
 
        get_task_struct(p);
        rcu_assign_pointer(c->rebalance.thread, p);