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         __wait_event((_ctxt)->wait,                                     \
  49                      bch2_moving_ctxt_next_pending_write(_ctxt) ||      \
  50                      (cond_finished = (_cond)));                        \
  51         if (cond_finished)                                              \
  52                 break;                                                  \
  53 } while (1)
  54
  55 typedef bool (*move_pred_fn)(struct bch_fs *, void *, struct bkey_s_c,
  56                              struct bch_io_opts *, struct data_update_opts *);
  57
  58 void bch2_moving_ctxt_exit(struct moving_context *);
  59 void bch2_moving_ctxt_init(struct moving_context *, struct bch_fs *,
  60                            struct bch_ratelimit *, struct bch_move_stats *,
  61                            struct write_point_specifier, bool);
  62 struct moving_io *bch2_moving_ctxt_next_pending_write(struct moving_context *);
  63 void bch2_moving_ctxt_do_pending_writes(struct moving_context *);
  64 void bch2_move_ctxt_wait_for_io(struct moving_context *);
  65 int bch2_move_ratelimit(struct moving_context *);
  66
  67 /* Inodes in different snapshots may have different IO options: */
  68 struct snapshot_io_opts_entry {
  69         u32                     snapshot;
  70         struct bch_io_opts      io_opts;
  71 };
  72
  73 struct per_snapshot_io_opts {
  74         u64                     cur_inum;
  75         struct bch_io_opts      fs_io_opts;
  76         DARRAY(struct snapshot_io_opts_entry) d;
  77 };
  78
  79 static inline void per_snapshot_io_opts_init(struct per_snapshot_io_opts *io_opts, struct bch_fs *c)
  80 {
  81         memset(io_opts, 0, sizeof(*io_opts));
  82         io_opts->fs_io_opts = bch2_opts_to_inode_opts(c->opts);
  83 }
  84
  85 static inline void per_snapshot_io_opts_exit(struct per_snapshot_io_opts *io_opts)
  86 {
  87         darray_exit(&io_opts->d);
  88 }
  89
  90 struct bch_io_opts *bch2_move_get_io_opts(struct btree_trans *,
  91                                 struct per_snapshot_io_opts *, struct bkey_s_c);
  92 int bch2_move_get_io_opts_one(struct btree_trans *, struct bch_io_opts *, struct bkey_s_c);
  93
  94 int bch2_scan_old_btree_nodes(struct bch_fs *, struct bch_move_stats *);
  95
  96 int bch2_move_extent(struct moving_context *,
  97                      struct move_bucket_in_flight *,
  98                      struct btree_iter *,
  99                      struct bkey_s_c,
 100                      struct bch_io_opts,
 101                      struct data_update_opts);
 102
 103 int __bch2_move_data(struct moving_context *,
 104                      struct bbpos,
 105                      struct bbpos,
 106                      move_pred_fn, void *);
 107 int bch2_move_data(struct bch_fs *,
 108                    struct bbpos start,
 109                    struct bbpos end,
 110                    struct bch_ratelimit *,
 111                    struct bch_move_stats *,
 112                    struct write_point_specifier,
 113                    bool,
 114                    move_pred_fn, void *);
 115
 116 int __bch2_evacuate_bucket(struct moving_context *,
 117                            struct move_bucket_in_flight *,
 118                            struct bpos, int,
 119                            struct data_update_opts);
 120 int bch2_evacuate_bucket(struct bch_fs *, struct bpos, int,
 121                          struct data_update_opts,
 122                          struct bch_ratelimit *,
 123                          struct bch_move_stats *,
 124                          struct write_point_specifier,
 125                          bool);
 126 int bch2_data_job(struct bch_fs *,
 127                   struct bch_move_stats *,
 128                   struct bch_ioctl_data);
 129
 130 void bch2_move_stats_to_text(struct printbuf *, struct bch_move_stats *);
 131 void bch2_move_stats_exit(struct bch_move_stats *, struct bch_fs *);
 132 void bch2_move_stats_init(struct bch_move_stats *, char *);
 133
 134 void bch2_fs_moving_ctxts_to_text(struct printbuf *, struct bch_fs *);
 135
 136 void bch2_fs_move_init(struct bch_fs *);
 137
 138 #endif /* _BCACHEFS_MOVE_H */