Commit d155272b authored by Kent Overstreet's avatar Kent Overstreet

bcachefs: bucket_valid()

cut out a branch from doing it the obvious way
Signed-off-by: default avatarKent Overstreet <kent.overstreet@linux.dev>
parent 923ed0ae
...@@ -21,8 +21,7 @@ static inline bool bch2_dev_bucket_exists(struct bch_fs *c, struct bpos pos) ...@@ -21,8 +21,7 @@ static inline bool bch2_dev_bucket_exists(struct bch_fs *c, struct bpos pos)
return false; return false;
ca = bch_dev_bkey_exists(c, pos.inode); ca = bch_dev_bkey_exists(c, pos.inode);
return pos.offset >= ca->mi.first_bucket && return bucket_valid(ca, pos.offset);
pos.offset < ca->mi.nbuckets;
} }
static inline u64 bucket_to_u64(struct bpos bucket) static inline u64 bucket_to_u64(struct bpos bucket)
......
...@@ -470,6 +470,7 @@ enum bch_time_stats { ...@@ -470,6 +470,7 @@ enum bch_time_stats {
#include "quota_types.h" #include "quota_types.h"
#include "rebalance_types.h" #include "rebalance_types.h"
#include "replicas_types.h" #include "replicas_types.h"
#include "sb-members_types.h"
#include "subvolume_types.h" #include "subvolume_types.h"
#include "super_types.h" #include "super_types.h"
#include "thread_with_file_types.h" #include "thread_with_file_types.h"
......
...@@ -12,7 +12,7 @@ ...@@ -12,7 +12,7 @@
#include "extents.h" #include "extents.h"
#include "sb-members.h" #include "sb-members.h"
static inline size_t sector_to_bucket(const struct bch_dev *ca, sector_t s) static inline u64 sector_to_bucket(const struct bch_dev *ca, sector_t s)
{ {
return div_u64(s, ca->mi.bucket_size); return div_u64(s, ca->mi.bucket_size);
} }
...@@ -30,12 +30,16 @@ static inline sector_t bucket_remainder(const struct bch_dev *ca, sector_t s) ...@@ -30,12 +30,16 @@ static inline sector_t bucket_remainder(const struct bch_dev *ca, sector_t s)
return remainder; return remainder;
} }
static inline size_t sector_to_bucket_and_offset(const struct bch_dev *ca, sector_t s, static inline u64 sector_to_bucket_and_offset(const struct bch_dev *ca, sector_t s, u32 *offset)
u32 *offset)
{ {
return div_u64_rem(s, ca->mi.bucket_size, offset); return div_u64_rem(s, ca->mi.bucket_size, offset);
} }
static inline bool bucket_valid(const struct bch_dev *ca, u64 b)
{
return b - ca->mi.first_bucket < ca->mi.nbuckets_minus_first;
}
#define for_each_bucket(_b, _buckets) \ #define for_each_bucket(_b, _buckets) \
for (_b = (_buckets)->b + (_buckets)->first_bucket; \ for (_b = (_buckets)->b + (_buckets)->first_bucket; \
_b < (_buckets)->b + (_buckets)->nbuckets; _b++) _b < (_buckets)->b + (_buckets)->nbuckets; _b++)
...@@ -94,7 +98,7 @@ static inline struct bucket *gc_bucket(struct bch_dev *ca, size_t b) ...@@ -94,7 +98,7 @@ static inline struct bucket *gc_bucket(struct bch_dev *ca, size_t b)
{ {
struct bucket_array *buckets = gc_bucket_array(ca); struct bucket_array *buckets = gc_bucket_array(ca);
BUG_ON(b < buckets->first_bucket || b >= buckets->nbuckets); BUG_ON(!bucket_valid(ca, b));
return buckets->b + b; return buckets->b + b;
} }
...@@ -111,7 +115,7 @@ static inline u8 *bucket_gen(struct bch_dev *ca, size_t b) ...@@ -111,7 +115,7 @@ static inline u8 *bucket_gen(struct bch_dev *ca, size_t b)
{ {
struct bucket_gens *gens = bucket_gens(ca); struct bucket_gens *gens = bucket_gens(ca);
BUG_ON(b < gens->first_bucket || b >= gens->nbuckets); BUG_ON(!bucket_valid(ca, b));
return gens->b + b; return gens->b + b;
} }
......
...@@ -998,9 +998,7 @@ void bch2_extent_ptr_to_text(struct printbuf *out, struct bch_fs *c, const struc ...@@ -998,9 +998,7 @@ void bch2_extent_ptr_to_text(struct printbuf *out, struct bch_fs *c, const struc
prt_str(out, " cached"); prt_str(out, " cached");
if (ptr->unwritten) if (ptr->unwritten)
prt_str(out, " unwritten"); prt_str(out, " unwritten");
if (b >= ca->mi.first_bucket && if (bucket_valid(ca, b) && ptr_stale(ca, ptr))
b < ca->mi.nbuckets &&
ptr_stale(ca, ptr))
prt_printf(out, " stale"); prt_printf(out, " stale");
} }
} }
......
...@@ -210,6 +210,8 @@ static inline struct bch_member_cpu bch2_mi_to_cpu(struct bch_member *mi) ...@@ -210,6 +210,8 @@ static inline struct bch_member_cpu bch2_mi_to_cpu(struct bch_member *mi)
{ {
return (struct bch_member_cpu) { return (struct bch_member_cpu) {
.nbuckets = le64_to_cpu(mi->nbuckets), .nbuckets = le64_to_cpu(mi->nbuckets),
.nbuckets_minus_first = le64_to_cpu(mi->nbuckets) -
le16_to_cpu(mi->first_bucket),
.first_bucket = le16_to_cpu(mi->first_bucket), .first_bucket = le16_to_cpu(mi->first_bucket),
.bucket_size = le16_to_cpu(mi->bucket_size), .bucket_size = le16_to_cpu(mi->bucket_size),
.group = BCH_MEMBER_GROUP(mi), .group = BCH_MEMBER_GROUP(mi),
......
/* SPDX-License-Identifier: GPL-2.0 */
#ifndef _BCACHEFS_SB_MEMBERS_TYPES_H
#define _BCACHEFS_SB_MEMBERS_TYPES_H
struct bch_member_cpu {
u64 nbuckets; /* device size */
u64 nbuckets_minus_first;
u16 first_bucket; /* index of first bucket used */
u16 bucket_size; /* sectors */
u16 group;
u8 state;
u8 discard;
u8 data_allowed;
u8 durability;
u8 freespace_initialized;
u8 valid;
u8 btree_bitmap_shift;
u64 btree_allocated_bitmap;
};
#endif /* _BCACHEFS_SB_MEMBERS_H */
...@@ -26,19 +26,4 @@ struct bch_devs_list { ...@@ -26,19 +26,4 @@ struct bch_devs_list {
u8 data[BCH_BKEY_PTRS_MAX]; u8 data[BCH_BKEY_PTRS_MAX];
}; };
struct bch_member_cpu {
u64 nbuckets; /* device size */
u16 first_bucket; /* index of first bucket used */
u16 bucket_size; /* sectors */
u16 group;
u8 state;
u8 discard;
u8 data_allowed;
u8 durability;
u8 freespace_initialized;
u8 valid;
u8 btree_bitmap_shift;
u64 btree_allocated_bitmap;
};
#endif /* _BCACHEFS_SUPER_TYPES_H */ #endif /* _BCACHEFS_SUPER_TYPES_H */
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment