diff options
| author | Kent Overstreet <kent.overstreet@gmail.com> | 2022-07-11 23:07:34 -0400 |
|---|---|---|
| committer | Kent Overstreet <kent.overstreet@gmail.com> | 2022-07-11 23:07:34 -0400 |
| commit | dce1de5426edaeca8350810f8707eafdb4dd36c2 (patch) | |
| tree | 9850b8a7be8482c13c4a076e85739c85ef232849 /libbcachefs/move.c | |
| parent | a29cb4b9f88af9905c0ab9497330eac64456dfdd (diff) | |
Update bcachefs sources to a059319fee bcachefs: Put some repair messages behind opts->verbose
Diffstat (limited to 'libbcachefs/move.c')
| -rw-r--r-- | libbcachefs/move.c | 17 |
1 files changed, 10 insertions, 7 deletions
diff --git a/libbcachefs/move.c b/libbcachefs/move.c index 093efb09..9748b865 100644 --- a/libbcachefs/move.c +++ b/libbcachefs/move.c @@ -148,13 +148,15 @@ void bch2_moving_ctxt_exit(struct moving_context *ctxt) { move_ctxt_wait_event(ctxt, NULL, list_empty(&ctxt->reads)); closure_sync(&ctxt->cl); - progress_list_del(ctxt->c, ctxt->stats); - EBUG_ON(atomic_read(&ctxt->write_sectors)); - trace_move_data(ctxt->c, - atomic64_read(&ctxt->stats->sectors_moved), - atomic64_read(&ctxt->stats->keys_moved)); + if (ctxt->stats) { + progress_list_del(ctxt->c, ctxt->stats); + + trace_move_data(ctxt->c, + atomic64_read(&ctxt->stats->sectors_moved), + atomic64_read(&ctxt->stats->keys_moved)); + } } void bch2_moving_ctxt_init(struct moving_context *ctxt, @@ -172,13 +174,14 @@ void bch2_moving_ctxt_init(struct moving_context *ctxt, ctxt->wp = wp; ctxt->wait_on_copygc = wait_on_copygc; - progress_list_add(c, stats); closure_init_stack(&ctxt->cl); INIT_LIST_HEAD(&ctxt->reads); init_waitqueue_head(&ctxt->wait); - if (stats) + if (stats) { + progress_list_add(c, stats); stats->data_type = BCH_DATA_user; + } } void bch_move_stats_init(struct bch_move_stats *stats, char *name) |