git.sesse.net Git - bcachefs-tools-debian/blob - libbcachefs/move.h

   1 /* SPDX-License-Identifier: GPL-2.0 */
   2 #ifndef _BCACHEFS_MOVE_H
   3 #define _BCACHEFS_MOVE_H
   4
   5 #include "bbpos.h"
   6 #include "bcachefs_ioctl.h"
   7 #include "btree_iter.h"
   8 #include "buckets.h"
   9 #include "data_update.h"
  10 #include "move_types.h"
  11
  12 struct bch_read_bio;
  13
  14 struct moving_context {
  15         struct btree_trans      *trans;
  16         struct list_head        list;
  17         void                    *fn;
  18
  19         struct bch_ratelimit    *rate;
  20         struct bch_move_stats   *stats;
  21         struct write_point_specifier wp;
  22         bool                    wait_on_copygc;
  23         bool                    write_error;
  24
  25         /* For waiting on outstanding reads and writes: */
  26         struct closure          cl;
  27
  28         struct mutex            lock;
  29         struct list_head        reads;
  30         struct list_head        ios;
  31
  32         /* in flight sectors: */
  33         atomic_t                read_sectors;
  34         atomic_t                write_sectors;
  35         atomic_t                read_ios;
  36         atomic_t                write_ios;
  37
  38         wait_queue_head_t       wait;
  39 };
  40
  41 #define move_ctxt_wait_event(_ctxt, _cond)                              \
  42 do {                                                                    \
  43         bool cond_finished = false;                                     \
  44         bch2_moving_ctxt_do_pending_writes(_ctxt);                      \
  45                                                                         \
  46         if (_cond)                                                      \
  47                 break;                                                  \
  48         bch2_trans_unlock_long((_ctxt)->trans);                         \
  49         __wait_event((_ctxt)->wait,                                     \
  50                      bch2_moving_ctxt_next_pending_write(_ctxt) ||      \
  51                      (cond_finished = (_cond)));                        \
  52         if (cond_finished)                                              \
  53                 break;                                                  \
  54 } while (1)
  55
  56 typedef bool (*move_pred_fn)(struct bch_fs *, void *, struct bkey_s_c,
  57                              struct bch_io_opts *, struct data_update_opts *);
  58
  59 extern const char * const bch2_data_ops_strs[];
  60
  61 void bch2_moving_ctxt_exit(struct moving_context *);
  62 void bch2_moving_ctxt_init(struct moving_context *, struct bch_fs *,
  63                            struct bch_ratelimit *, struct bch_move_stats *,
  64                            struct write_point_specifier, bool);
  65 struct moving_io *bch2_moving_ctxt_next_pending_write(struct moving_context *);
  66 void bch2_moving_ctxt_do_pending_writes(struct moving_context *);
  67 void bch2_move_ctxt_wait_for_io(struct moving_context *);
  68 int bch2_move_ratelimit(struct moving_context *);
  69
  70 /* Inodes in different snapshots may have different IO options: */
  71 struct snapshot_io_opts_entry {
  72         u32                     snapshot;
  73         struct bch_io_opts      io_opts;
  74 };
  75
  76 struct per_snapshot_io_opts {
  77         u64                     cur_inum;
  78         struct bch_io_opts      fs_io_opts;
  79         DARRAY(struct snapshot_io_opts_entry) d;
  80 };
  81
  82 static inline void per_snapshot_io_opts_init(struct per_snapshot_io_opts *io_opts, struct bch_fs *c)
  83 {
  84         memset(io_opts, 0, sizeof(*io_opts));
  85         io_opts->fs_io_opts = bch2_opts_to_inode_opts(c->opts);
  86 }
  87
  88 static inline void per_snapshot_io_opts_exit(struct per_snapshot_io_opts *io_opts)
  89 {
  90         darray_exit(&io_opts->d);
  91 }
  92
  93 struct bch_io_opts *bch2_move_get_io_opts(struct btree_trans *,
  94                                 struct per_snapshot_io_opts *, struct bkey_s_c);
  95 int bch2_move_get_io_opts_one(struct btree_trans *, struct bch_io_opts *, struct bkey_s_c);
  96
  97 int bch2_scan_old_btree_nodes(struct bch_fs *, struct bch_move_stats *);
  98
  99 int bch2_move_extent(struct moving_context *,
 100                      struct move_bucket_in_flight *,
 101                      struct btree_iter *,
 102                      struct bkey_s_c,
 103                      struct bch_io_opts,
 104                      struct data_update_opts);
 105
 106 int __bch2_move_data(struct moving_context *,
 107                      struct bbpos,
 108                      struct bbpos,
 109                      move_pred_fn, void *);
 110 int bch2_move_data(struct bch_fs *,
 111                    struct bbpos start,
 112                    struct bbpos end,
 113                    struct bch_ratelimit *,
 114                    struct bch_move_stats *,
 115                    struct write_point_specifier,
 116                    bool,
 117                    move_pred_fn, void *);
 118
 119 int __bch2_evacuate_bucket(struct moving_context *,
 120                            struct move_bucket_in_flight *,
 121                            struct bpos, int,
 122                            struct data_update_opts);
 123 int bch2_evacuate_bucket(struct bch_fs *, struct bpos, int,
 124                          struct data_update_opts,
 125                          struct bch_ratelimit *,
 126                          struct bch_move_stats *,
 127                          struct write_point_specifier,
 128                          bool);
 129 int bch2_data_job(struct bch_fs *,
 130                   struct bch_move_stats *,
 131                   struct bch_ioctl_data);
 132
 133 void bch2_move_stats_to_text(struct printbuf *, struct bch_move_stats *);
 134 void bch2_move_stats_exit(struct bch_move_stats *, struct bch_fs *);
 135 void bch2_move_stats_init(struct bch_move_stats *, const char *);
 136
 137 void bch2_fs_moving_ctxts_to_text(struct printbuf *, struct bch_fs *);
 138
 139 void bch2_fs_move_init(struct bch_fs *);
 140
 141 #endif /* _BCACHEFS_MOVE_H */