1 /* SPDX-License-Identifier: GPL-2.0 */
2 #ifndef _BCACHEFS_ALLOC_FOREGROUND_H
3 #define _BCACHEFS_ALLOC_FOREGROUND_H
6 #include "alloc_types.h"
8 #include <linux/hash.h>
15 struct dev_alloc_list {
17 u8 devs[BCH_SB_MEMBERS_MAX];
20 struct dev_alloc_list bch2_dev_alloc_list(struct bch_fs *,
21 struct dev_stripe_state *,
22 struct bch_devs_mask *);
23 void bch2_dev_stripe_increment(struct bch_fs *, struct bch_dev *,
24 struct dev_stripe_state *);
26 long bch2_bucket_alloc_new_fs(struct bch_dev *);
28 struct open_bucket *bch2_bucket_alloc(struct bch_fs *, struct bch_dev *,
29 enum alloc_reserve, bool,
32 static inline void ob_push(struct bch_fs *c, struct open_buckets *obs,
33 struct open_bucket *ob)
35 BUG_ON(obs->nr >= ARRAY_SIZE(obs->v));
37 obs->v[obs->nr++] = ob - c->open_buckets;
40 #define open_bucket_for_each(_c, _obs, _ob, _i) \
42 (_i) < (_obs)->nr && \
43 ((_ob) = (_c)->open_buckets + (_obs)->v[_i], true); \
46 static inline struct open_bucket *ec_open_bucket(struct bch_fs *c,
47 struct open_buckets *obs)
49 struct open_bucket *ob;
52 open_bucket_for_each(c, obs, ob, i)
59 void bch2_open_bucket_write_error(struct bch_fs *,
60 struct open_buckets *, unsigned);
62 void __bch2_open_bucket_put(struct bch_fs *, struct open_bucket *);
64 static inline void bch2_open_bucket_put(struct bch_fs *c, struct open_bucket *ob)
66 if (atomic_dec_and_test(&ob->pin))
67 __bch2_open_bucket_put(c, ob);
70 static inline void bch2_open_buckets_put(struct bch_fs *c,
71 struct open_buckets *ptrs)
73 struct open_bucket *ob;
76 open_bucket_for_each(c, ptrs, ob, i)
77 bch2_open_bucket_put(c, ob);
81 static inline void bch2_open_bucket_get(struct bch_fs *c,
82 struct write_point *wp,
83 struct open_buckets *ptrs)
85 struct open_bucket *ob;
88 open_bucket_for_each(c, &wp->ptrs, ob, i) {
94 struct write_point *bch2_alloc_sectors_start(struct bch_fs *,
96 struct write_point_specifier,
97 struct bch_devs_list *,
103 void bch2_alloc_sectors_append_ptrs(struct bch_fs *, struct write_point *,
104 struct bkey_i *, unsigned);
105 void bch2_alloc_sectors_done(struct bch_fs *, struct write_point *);
107 void bch2_open_buckets_stop_dev(struct bch_fs *, struct bch_dev *,
108 struct open_buckets *, enum bch_data_type);
110 void bch2_writepoint_stop(struct bch_fs *, struct bch_dev *,
111 struct write_point *);
113 static inline struct write_point_specifier writepoint_hashed(unsigned long v)
115 return (struct write_point_specifier) { .v = v | 1 };
118 static inline struct write_point_specifier writepoint_ptr(struct write_point *wp)
120 return (struct write_point_specifier) { .v = (unsigned long) wp };
123 static inline void writepoint_init(struct write_point *wp,
124 enum bch_data_type type)
126 mutex_init(&wp->lock);
130 void bch2_fs_allocator_foreground_init(struct bch_fs *);
132 #endif /* _BCACHEFS_ALLOC_FOREGROUND_H */