]> git.sesse.net Git - bcachefs-tools-debian/blobdiff - libbcachefs/buckets.h
New upstream release
[bcachefs-tools-debian] / libbcachefs / buckets.h
index 7c6c59c7762c55cb4626af78aff84d55a9c5ded1..56c06ccde14f8a39a19ded9475d6861624f35d63 100644 (file)
@@ -9,58 +9,39 @@
 #define _BUCKETS_H
 
 #include "buckets_types.h"
+#include "extents.h"
 #include "super.h"
 
 #define for_each_bucket(_b, _buckets)                          \
        for (_b = (_buckets)->b + (_buckets)->first_bucket;     \
             _b < (_buckets)->b + (_buckets)->nbuckets; _b++)
 
-#define bucket_cmpxchg(g, new, expr)                           \
-({                                                             \
-       struct bucket *_g = g;                                  \
-       u64 _v = atomic64_read(&(g)->_mark.v);                  \
-       struct bucket_mark _old;                                \
-                                                               \
-       do {                                                    \
-               (new).v.counter = _old.v.counter = _v;          \
-               expr;                                           \
-       } while ((_v = atomic64_cmpxchg(&(_g)->_mark.v,         \
-                              _old.v.counter,                  \
-                              (new).v.counter)) != _old.v.counter);\
-       _old;                                                   \
-})
-
-static inline struct bucket_array *__bucket_array(struct bch_dev *ca,
-                                                 bool gc)
+static inline void bucket_unlock(struct bucket *b)
 {
-       return rcu_dereference_check(ca->buckets[gc],
-                                    !ca->fs ||
-                                    percpu_rwsem_is_held(&ca->fs->mark_lock) ||
-                                    lockdep_is_held(&ca->fs->gc_lock) ||
-                                    lockdep_is_held(&ca->bucket_lock));
+       smp_store_release(&b->lock, 0);
 }
 
-static inline struct bucket_array *bucket_array(struct bch_dev *ca)
+static inline void bucket_lock(struct bucket *b)
 {
-       return __bucket_array(ca, false);
+       while (xchg(&b->lock, 1))
+               cpu_relax();
 }
 
-static inline struct bucket *__bucket(struct bch_dev *ca, size_t b, bool gc)
+static inline struct bucket_array *gc_bucket_array(struct bch_dev *ca)
 {
-       struct bucket_array *buckets = __bucket_array(ca, gc);
-
-       BUG_ON(b < buckets->first_bucket || b >= buckets->nbuckets);
-       return buckets->b + b;
+       return rcu_dereference_check(ca->buckets_gc,
+                                    !ca->fs ||
+                                    percpu_rwsem_is_held(&ca->fs->mark_lock) ||
+                                    lockdep_is_held(&ca->fs->gc_lock) ||
+                                    lockdep_is_held(&ca->bucket_lock));
 }
 
 static inline struct bucket *gc_bucket(struct bch_dev *ca, size_t b)
 {
-       return __bucket(ca, b, true);
-}
+       struct bucket_array *buckets = gc_bucket_array(ca);
 
-static inline struct bucket *bucket(struct bch_dev *ca, size_t b)
-{
-       return __bucket(ca, b, false);
+       BUG_ON(b < buckets->first_bucket || b >= buckets->nbuckets);
+       return buckets->b + b;
 }
 
 static inline struct bucket_gens *bucket_gens(struct bch_dev *ca)
@@ -70,7 +51,6 @@ static inline struct bucket_gens *bucket_gens(struct bch_dev *ca)
                                     percpu_rwsem_is_held(&ca->fs->mark_lock) ||
                                     lockdep_is_held(&ca->fs->gc_lock) ||
                                     lockdep_is_held(&ca->bucket_lock));
-
 }
 
 static inline u8 *bucket_gen(struct bch_dev *ca, size_t b)
@@ -81,20 +61,27 @@ static inline u8 *bucket_gen(struct bch_dev *ca, size_t b)
        return gens->b + b;
 }
 
-/*
- * bucket_gc_gen() returns the difference between the bucket's current gen and
- * the oldest gen of any pointer into that bucket in the btree.
- */
-
-static inline u8 bucket_gc_gen(struct bucket *g)
+static inline size_t PTR_BUCKET_NR(const struct bch_dev *ca,
+                                  const struct bch_extent_ptr *ptr)
 {
-       return g->mark.gen - g->oldest_gen;
+       return sector_to_bucket(ca, ptr->offset);
 }
 
-static inline size_t PTR_BUCKET_NR(const struct bch_dev *ca,
+static inline struct bpos PTR_BUCKET_POS(const struct bch_fs *c,
                                   const struct bch_extent_ptr *ptr)
 {
-       return sector_to_bucket(ca, ptr->offset);
+       struct bch_dev *ca = bch_dev_bkey_exists(c, ptr->dev);
+
+       return POS(ptr->dev, PTR_BUCKET_NR(ca, ptr));
+}
+
+static inline struct bpos PTR_BUCKET_POS_OFFSET(const struct bch_fs *c,
+                                               const struct bch_extent_ptr *ptr,
+                                               u32 *bucket_offset)
+{
+       struct bch_dev *ca = bch_dev_bkey_exists(c, ptr->dev);
+
+       return POS(ptr->dev, sector_to_bucket_and_offset(ca, ptr->offset, bucket_offset));
 }
 
 static inline struct bucket *PTR_GC_BUCKET(struct bch_dev *ca,
@@ -106,13 +93,22 @@ static inline struct bucket *PTR_GC_BUCKET(struct bch_dev *ca,
 static inline enum bch_data_type ptr_data_type(const struct bkey *k,
                                               const struct bch_extent_ptr *ptr)
 {
-       if (k->type == KEY_TYPE_btree_ptr ||
-           k->type == KEY_TYPE_btree_ptr_v2)
+       if (bkey_is_btree_ptr(k))
                return BCH_DATA_btree;
 
        return ptr->cached ? BCH_DATA_cached : BCH_DATA_user;
 }
 
+static inline s64 ptr_disk_sectors(s64 sectors, struct extent_ptr_decoded p)
+{
+       EBUG_ON(sectors < 0);
+
+       return crc_is_compressed(p.crc)
+               ? DIV_ROUND_UP_ULL(sectors * p.crc.compressed_size,
+                                  p.crc.uncompressed_size)
+               : sectors;
+}
+
 static inline int gen_cmp(u8 a, u8 b)
 {
        return (s8) (a - b);
@@ -141,62 +137,73 @@ static inline u8 ptr_stale(struct bch_dev *ca,
        return ret;
 }
 
-/* bucket gc marks */
+/* Device usage: */
 
-static inline bool is_available_bucket(struct bucket_mark mark)
+void bch2_dev_usage_read_fast(struct bch_dev *, struct bch_dev_usage *);
+static inline struct bch_dev_usage bch2_dev_usage_read(struct bch_dev *ca)
 {
-       return !mark.dirty_sectors && !mark.stripe;
-}
+       struct bch_dev_usage ret;
 
-/* Device usage: */
+       bch2_dev_usage_read_fast(ca, &ret);
+       return ret;
+}
 
-struct bch_dev_usage bch2_dev_usage_read(struct bch_dev *);
+void bch2_dev_usage_init(struct bch_dev *);
 
-static inline u64 __dev_buckets_available(struct bch_dev *ca,
-                                         struct bch_dev_usage stats)
+static inline u64 bch2_dev_buckets_reserved(struct bch_dev *ca, enum alloc_reserve reserve)
 {
-       u64 total = ca->mi.nbuckets - ca->mi.first_bucket;
-
-       if (WARN_ONCE(stats.buckets_unavailable > total,
-                     "buckets_unavailable overflow (%llu > %llu)\n",
-                     stats.buckets_unavailable, total))
-               return 0;
-
-       return total - stats.buckets_unavailable;
+       s64 reserved = 0;
+
+       switch (reserve) {
+       case RESERVE_none:
+               reserved += ca->mi.nbuckets >> 6;
+               fallthrough;
+       case RESERVE_movinggc:
+               reserved += ca->nr_btree_reserve;
+               fallthrough;
+       case RESERVE_btree:
+               reserved += ca->nr_btree_reserve;
+               fallthrough;
+       case RESERVE_btree_movinggc:
+               break;
+       }
+
+       return reserved;
 }
 
-static inline u64 dev_buckets_available(struct bch_dev *ca)
+static inline u64 dev_buckets_free(struct bch_dev *ca,
+                                  struct bch_dev_usage usage,
+                                  enum alloc_reserve reserve)
 {
-       return __dev_buckets_available(ca, bch2_dev_usage_read(ca));
+       return max_t(s64, 0,
+                    usage.d[BCH_DATA_free].buckets -
+                    ca->nr_open_buckets -
+                    bch2_dev_buckets_reserved(ca, reserve));
 }
 
-static inline u64 __dev_buckets_reclaimable(struct bch_dev *ca,
-                                           struct bch_dev_usage stats)
+static inline u64 __dev_buckets_available(struct bch_dev *ca,
+                                         struct bch_dev_usage usage,
+                                         enum alloc_reserve reserve)
 {
-       struct bch_fs *c = ca->fs;
-       s64 available = __dev_buckets_available(ca, stats);
-       unsigned i;
-
-       spin_lock(&c->freelist_lock);
-       for (i = 0; i < RESERVE_NR; i++)
-               available -= fifo_used(&ca->free[i]);
-       available -= fifo_used(&ca->free_inc);
-       available -= ca->nr_open_buckets;
-       spin_unlock(&c->freelist_lock);
-
-       return max(available, 0LL);
+       return max_t(s64, 0,
+                      usage.d[BCH_DATA_free].buckets
+                    + usage.d[BCH_DATA_cached].buckets
+                    + usage.d[BCH_DATA_need_gc_gens].buckets
+                    + usage.d[BCH_DATA_need_discard].buckets
+                    - ca->nr_open_buckets
+                    - bch2_dev_buckets_reserved(ca, reserve));
 }
 
-static inline u64 dev_buckets_reclaimable(struct bch_dev *ca)
+static inline u64 dev_buckets_available(struct bch_dev *ca,
+                                       enum alloc_reserve reserve)
 {
-       return __dev_buckets_reclaimable(ca, bch2_dev_usage_read(ca));
+       return __dev_buckets_available(ca, bch2_dev_usage_read(ca), reserve);
 }
 
 /* Filesystem usage: */
 
 static inline unsigned fs_usage_u64s(struct bch_fs *c)
 {
-
        return sizeof(struct bch_fs_usage) / sizeof(u64) +
                READ_ONCE(c->replicas.nr);
 }
@@ -224,18 +231,23 @@ bch2_fs_usage_read_short(struct bch_fs *);
 
 void bch2_fs_usage_initialize(struct bch_fs *);
 
-void bch2_mark_alloc_bucket(struct bch_fs *, struct bch_dev *, size_t, bool);
-void bch2_mark_metadata_bucket(struct bch_fs *, struct bch_dev *,
-                              size_t, enum bch_data_type, unsigned,
-                              struct gc_pos, unsigned);
+int bch2_mark_metadata_bucket(struct bch_fs *, struct bch_dev *,
+                             size_t, enum bch_data_type, unsigned,
+                             struct gc_pos, unsigned);
 
-int bch2_mark_key(struct btree_trans *, struct bkey_s_c, struct bkey_s_c, unsigned);
+int bch2_mark_alloc(struct btree_trans *, struct bkey_s_c, struct bkey_s_c, unsigned);
+int bch2_mark_extent(struct btree_trans *, struct bkey_s_c, struct bkey_s_c, unsigned);
+int bch2_mark_stripe(struct btree_trans *, struct bkey_s_c, struct bkey_s_c, unsigned);
+int bch2_mark_inode(struct btree_trans *, struct bkey_s_c, struct bkey_s_c, unsigned);
+int bch2_mark_reservation(struct btree_trans *, struct bkey_s_c, struct bkey_s_c, unsigned);
+int bch2_mark_reflink_p(struct btree_trans *, struct bkey_s_c, struct bkey_s_c, unsigned);
 
-int bch2_mark_update(struct btree_trans *, struct btree_path *,
-                    struct bkey_i *, unsigned);
+int bch2_trans_mark_extent(struct btree_trans *, enum btree_id, unsigned, struct bkey_s_c, struct bkey_i *, unsigned);
+int bch2_trans_mark_stripe(struct btree_trans *, enum btree_id, unsigned, struct bkey_s_c, struct bkey_i *, unsigned);
+int bch2_trans_mark_inode(struct btree_trans *, enum btree_id, unsigned, struct bkey_s_c, struct bkey_i *, unsigned);
+int bch2_trans_mark_reservation(struct btree_trans *, enum btree_id, unsigned, struct bkey_s_c, struct bkey_i *, unsigned);
+int bch2_trans_mark_reflink_p(struct btree_trans *, enum btree_id, unsigned, struct bkey_s_c, struct bkey_i *, unsigned);
 
-int bch2_trans_mark_key(struct btree_trans *, struct bkey_s_c,
-                       struct bkey_s_c, unsigned);
 int bch2_trans_fs_usage_apply(struct btree_trans *, struct replicas_delta_list *);
 
 int bch2_trans_mark_metadata_bucket(struct btree_trans *, struct bch_dev *,