Commit 641ab736 authored by Kent Overstreet's avatar Kent Overstreet Committed by Kent Overstreet

bcachefs: improve/clarify ptr_disk_sectors()

Signed-off-by: default avatarKent Overstreet <kent.overstreet@linux.dev>
parent 57cb2142
...@@ -558,36 +558,25 @@ void bch2_mark_metadata_bucket(struct bch_fs *c, struct bch_dev *ca, ...@@ -558,36 +558,25 @@ void bch2_mark_metadata_bucket(struct bch_fs *c, struct bch_dev *ca,
preempt_enable(); preempt_enable();
} }
static int __disk_sectors(struct bch_extent_crc_unpacked crc, unsigned sectors) static s64 ptr_disk_sectors_delta(struct extent_ptr_decoded p,
s64 delta)
{ {
if (!sectors) if (delta > 0) {
return 0; /*
* marking a new extent, which _will have size_ @delta
return max(1U, DIV_ROUND_UP(sectors * crc.compressed_size, *
crc.uncompressed_size)); * in the bch2_mark_update -> BCH_EXTENT_OVERLAP_MIDDLE
} * case, we haven't actually created the key we'll be inserting
* yet (for the split) - so we don't want to be using
static s64 ptr_disk_sectors(const struct bkey *k, * k->size/crc.live_size here:
struct extent_ptr_decoded p, */
s64 sectors) return __ptr_disk_sectors(p, delta);
{
if (p.crc.compression_type) {
unsigned old_sectors, new_sectors;
if (sectors > 0) {
old_sectors = 0;
new_sectors = sectors;
} else { } else {
old_sectors = k->size; BUG_ON(-delta > p.crc.live_size);
new_sectors = k->size + sectors;
}
sectors = -__disk_sectors(p.crc, old_sectors) return (s64) __ptr_disk_sectors(p, p.crc.live_size + delta) -
+__disk_sectors(p.crc, new_sectors); (s64) ptr_disk_sectors(p);
} }
return sectors;
} }
/* /*
...@@ -722,7 +711,9 @@ static int bch2_mark_extent(struct bch_fs *c, struct bkey_s_c k, ...@@ -722,7 +711,9 @@ static int bch2_mark_extent(struct bch_fs *c, struct bkey_s_c k,
BUG_ON(!sectors); BUG_ON(!sectors);
bkey_for_each_ptr_decode(k.k, ptrs, p, entry) { bkey_for_each_ptr_decode(k.k, ptrs, p, entry) {
s64 disk_sectors = ptr_disk_sectors(k.k, p, sectors); s64 disk_sectors = data_type == BCH_DATA_BTREE
? sectors
: ptr_disk_sectors_delta(p, sectors);
s64 adjusted_disk_sectors = disk_sectors; s64 adjusted_disk_sectors = disk_sectors;
bch2_mark_pointer(c, p, disk_sectors, data_type, bch2_mark_pointer(c, p, disk_sectors, data_type,
......
...@@ -136,6 +136,20 @@ static inline u8 ptr_stale(struct bch_dev *ca, ...@@ -136,6 +136,20 @@ static inline u8 ptr_stale(struct bch_dev *ca,
return gen_after(ptr_bucket_mark(ca, ptr).gen, ptr->gen); return gen_after(ptr_bucket_mark(ca, ptr).gen, ptr->gen);
} }
static inline unsigned __ptr_disk_sectors(struct extent_ptr_decoded p,
unsigned live_size)
{
return live_size && p.crc.compression_type
? max(1U, DIV_ROUND_UP(live_size * p.crc.compressed_size,
p.crc.uncompressed_size))
: live_size;
}
static inline unsigned ptr_disk_sectors(struct extent_ptr_decoded p)
{
return __ptr_disk_sectors(p, p.crc.live_size);
}
/* bucket gc marks */ /* bucket gc marks */
static inline unsigned bucket_sectors_used(struct bucket_mark mark) static inline unsigned bucket_sectors_used(struct bucket_mark mark)
......
...@@ -5,14 +5,14 @@ ...@@ -5,14 +5,14 @@
#include "bcachefs_format.h" #include "bcachefs_format.h"
struct bch_extent_crc_unpacked { struct bch_extent_crc_unpacked {
u32 compressed_size;
u32 uncompressed_size;
u32 live_size;
u8 csum_type; u8 csum_type;
u8 compression_type; u8 compression_type;
u16 compressed_size;
u16 uncompressed_size;
u16 offset; u16 offset;
u16 live_size;
u16 nonce; u16 nonce;
......
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