summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authormyoungwon oh <ohmyoungwon@gmail.com>2021-12-03 16:18:10 +0900
committermyoungwon oh <ohmyoungwon@gmail.com>2022-01-18 18:24:43 +0900
commitc93d0b7b1e7be2e3879ec384a951edb247a9f775 (patch)
treefb5a42b7ffaff4d4187fb08cc2baf4992ce09477
parent51a347456dead2c327a08926a7042bfa685b397c (diff)
downloadceph-c93d0b7b1e7be2e3879ec384a951edb247a9f775.tar.gz
seastore: rename segment_off_t to seastore_off_t
Signed-off-by: Myoungwon Oh <myoungwon.oh@samsung.com>
-rw-r--r--src/crimson/os/seastore/cache.cc6
-rw-r--r--src/crimson/os/seastore/cache.h20
-rw-r--r--src/crimson/os/seastore/cached_extent.h2
-rw-r--r--src/crimson/os/seastore/collection_manager/flat_collection_manager.cc4
-rw-r--r--src/crimson/os/seastore/extent_placement_manager.cc2
-rw-r--r--src/crimson/os/seastore/extent_placement_manager.h18
-rw-r--r--src/crimson/os/seastore/extent_reader.cc4
-rw-r--r--src/crimson/os/seastore/extent_reader.h3
-rw-r--r--src/crimson/os/seastore/journal.cc2
-rw-r--r--src/crimson/os/seastore/journal.h10
-rw-r--r--src/crimson/os/seastore/lba_manager.h2
-rw-r--r--src/crimson/os/seastore/lba_manager/btree/btree_lba_manager.cc2
-rw-r--r--src/crimson/os/seastore/lba_manager/btree/btree_lba_manager.h2
-rw-r--r--src/crimson/os/seastore/lba_manager/btree/lba_btree.cc4
-rw-r--r--src/crimson/os/seastore/lba_manager/btree/lba_btree.h4
-rw-r--r--src/crimson/os/seastore/root_block.h2
-rw-r--r--src/crimson/os/seastore/seastore_types.cc4
-rw-r--r--src/crimson/os/seastore/seastore_types.h48
-rw-r--r--src/crimson/os/seastore/segment_cleaner.cc4
-rw-r--r--src/crimson/os/seastore/segment_cleaner.h28
-rw-r--r--src/crimson/os/seastore/segment_manager.h10
-rw-r--r--src/crimson/os/seastore/segment_manager/block.cc6
-rw-r--r--src/crimson/os/seastore/segment_manager/block.h14
-rw-r--r--src/crimson/os/seastore/segment_manager/ephemeral.cc4
-rw-r--r--src/crimson/os/seastore/segment_manager/ephemeral.h12
-rw-r--r--src/crimson/os/seastore/transaction.h4
-rw-r--r--src/crimson/os/seastore/transaction_manager.cc2
-rw-r--r--src/crimson/os/seastore/transaction_manager.h2
-rw-r--r--src/test/crimson/seastore/test_block.h4
-rw-r--r--src/test/crimson/seastore/test_btree_lba_manager.cc2
-rw-r--r--src/test/crimson/seastore/test_seastore_cache.cc4
-rw-r--r--src/test/crimson/seastore/test_seastore_journal.cc2
-rw-r--r--src/test/crimson/seastore/transaction_manager_test_state.h4
33 files changed, 121 insertions, 120 deletions
diff --git a/src/crimson/os/seastore/cache.cc b/src/crimson/os/seastore/cache.cc
index 0597a0315ab..4b7ab5495af 100644
--- a/src/crimson/os/seastore/cache.cc
+++ b/src/crimson/os/seastore/cache.cc
@@ -842,7 +842,7 @@ void Cache::on_transaction_destruct(Transaction& t)
CachedExtentRef Cache::alloc_new_extent_by_type(
Transaction &t, ///< [in, out] current transaction
extent_types_t type, ///< [in] type tag
- segment_off_t length, ///< [in] length
+ seastore_off_t length, ///< [in] length
bool delay ///< [in] whether to delay paddr alloc
)
{
@@ -974,7 +974,7 @@ record_t Cache::prepare_record(Transaction &t)
: L_ADDR_NULL),
i->last_committed_crc,
final_crc,
- (segment_off_t)i->get_length(),
+ (seastore_off_t)i->get_length(),
i->get_version() - 1,
i->get_delta()
});
@@ -1386,7 +1386,7 @@ Cache::get_extent_ertr::future<CachedExtentRef> Cache::_get_extent_by_type(
extent_types_t type,
paddr_t offset,
laddr_t laddr,
- segment_off_t length,
+ seastore_off_t length,
const Transaction::src_t* p_src,
extent_init_func_t &&extent_init_func)
{
diff --git a/src/crimson/os/seastore/cache.h b/src/crimson/os/seastore/cache.h
index ba8faaea4fb..0b4a50afed7 100644
--- a/src/crimson/os/seastore/cache.h
+++ b/src/crimson/os/seastore/cache.h
@@ -181,7 +181,7 @@ public:
template <typename T, typename Func>
get_extent_ret<T> get_extent(
paddr_t offset, ///< [in] starting addr
- segment_off_t length, ///< [in] length
+ seastore_off_t length, ///< [in] length
const src_ext_t* p_metric_key, ///< [in] cache query metric key
Func &&extent_init_func ///< [in] init func for extent
) {
@@ -230,7 +230,7 @@ public:
template <typename T>
get_extent_ret<T> get_extent(
paddr_t offset, ///< [in] starting addr
- segment_off_t length, ///< [in] length
+ seastore_off_t length, ///< [in] length
const src_ext_t* p_metric_key ///< [in] cache query metric key
) {
return get_extent<T>(
@@ -302,7 +302,7 @@ public:
get_extent_iertr::future<TCachedExtentRef<T>> get_extent(
Transaction &t,
paddr_t offset,
- segment_off_t length,
+ seastore_off_t length,
Func &&extent_init_func) {
CachedExtentRef ret;
LOG_PREFIX(Cache::get_extent);
@@ -343,7 +343,7 @@ public:
get_extent_iertr::future<TCachedExtentRef<T>> get_extent(
Transaction &t,
paddr_t offset,
- segment_off_t length) {
+ seastore_off_t length) {
return get_extent<T>(t, offset, length, [](T &){});
}
@@ -385,7 +385,7 @@ private:
extent_types_t type,
paddr_t offset,
laddr_t laddr,
- segment_off_t length,
+ seastore_off_t length,
const Transaction::src_t* p_src,
extent_init_func_t &&extent_init_func
);
@@ -398,7 +398,7 @@ private:
extent_types_t type,
paddr_t offset,
laddr_t laddr,
- segment_off_t length,
+ seastore_off_t length,
extent_init_func_t &&extent_init_func) {
CachedExtentRef ret;
auto status = t.get_extent(offset, &ret);
@@ -436,7 +436,7 @@ public:
extent_types_t type, ///< [in] type tag
paddr_t offset, ///< [in] starting addr
laddr_t laddr, ///< [in] logical address if logical
- segment_off_t length, ///< [in] length
+ seastore_off_t length, ///< [in] length
Func &&extent_init_func ///< [in] extent init func
) {
return _get_extent_by_type(
@@ -452,7 +452,7 @@ public:
extent_types_t type,
paddr_t offset,
laddr_t laddr,
- segment_off_t length
+ seastore_off_t length
) {
return get_extent_by_type(
t, type, offset, laddr, length, [](CachedExtent &) {});
@@ -467,7 +467,7 @@ public:
template <typename T>
TCachedExtentRef<T> alloc_new_extent(
Transaction &t, ///< [in, out] current transaction
- segment_off_t length, ///< [in] length
+ seastore_off_t length, ///< [in] length
bool delayed = false ///< [in] whether the paddr allocation of extent is delayed
) {
auto ret = CachedExtent::make_cached_extent_ref<T>(
@@ -502,7 +502,7 @@ public:
CachedExtentRef alloc_new_extent_by_type(
Transaction &t, ///< [in, out] current transaction
extent_types_t type, ///< [in] type tag
- segment_off_t length, ///< [in] length
+ seastore_off_t length, ///< [in] length
bool delayed = false ///< [in] whether delay addr allocation
);
diff --git a/src/crimson/os/seastore/cached_extent.h b/src/crimson/os/seastore/cached_extent.h
index 99efa039140..906a7272eb5 100644
--- a/src/crimson/os/seastore/cached_extent.h
+++ b/src/crimson/os/seastore/cached_extent.h
@@ -546,7 +546,7 @@ class ExtentIndex {
friend class Cache;
CachedExtent::index extent_index;
public:
- auto get_overlap(paddr_t addr, segment_off_t len) {
+ auto get_overlap(paddr_t addr, seastore_off_t len) {
auto bottom = extent_index.upper_bound(addr, paddr_cmp());
if (bottom != extent_index.begin())
--bottom;
diff --git a/src/crimson/os/seastore/collection_manager/flat_collection_manager.cc b/src/crimson/os/seastore/collection_manager/flat_collection_manager.cc
index 6d762844eb9..7b0cb1f9c90 100644
--- a/src/crimson/os/seastore/collection_manager/flat_collection_manager.cc
+++ b/src/crimson/os/seastore/collection_manager/flat_collection_manager.cc
@@ -18,8 +18,8 @@ namespace {
namespace crimson::os::seastore::collection_manager {
-constexpr static segment_off_t MIN_FLAT_BLOCK_SIZE = 4<<10;
-[[maybe_unused]] constexpr static segment_off_t MAX_FLAT_BLOCK_SIZE = 4<<20;
+constexpr static seastore_off_t MIN_FLAT_BLOCK_SIZE = 4<<10;
+[[maybe_unused]] constexpr static seastore_off_t MAX_FLAT_BLOCK_SIZE = 4<<20;
FlatCollectionManager::FlatCollectionManager(
TransactionManager &tm)
diff --git a/src/crimson/os/seastore/extent_placement_manager.cc b/src/crimson/os/seastore/extent_placement_manager.cc
index c4d5d285668..0da195f2326 100644
--- a/src/crimson/os/seastore/extent_placement_manager.cc
+++ b/src/crimson/os/seastore/extent_placement_manager.cc
@@ -217,7 +217,7 @@ SegmentedAllocator::Writer::write(
return write_func();
}
-bool SegmentedAllocator::Writer::_needs_roll(segment_off_t length) const {
+bool SegmentedAllocator::Writer::_needs_roll(seastore_off_t length) const {
return allocated_to + length > current_segment->segment->get_write_capacity();
}
diff --git a/src/crimson/os/seastore/extent_placement_manager.h b/src/crimson/os/seastore/extent_placement_manager.h
index 687c4514684..50c2a081523 100644
--- a/src/crimson/os/seastore/extent_placement_manager.h
+++ b/src/crimson/os/seastore/extent_placement_manager.h
@@ -61,14 +61,14 @@ public:
assert(extents.size() == record.extents.size());
assert(!record.deltas.size());
auto record_group = record_group_t(std::move(record), block_size);
- segment_off_t extent_offset = base + record_group.size.get_mdlength();
+ seastore_off_t extent_offset = base + record_group.size.get_mdlength();
for (auto& extent : extents) {
extent.set_ool_paddr(
paddr_t::make_seg_paddr(segment, extent_offset));
extent_offset += extent.get_bptr().length();
}
assert(extent_offset ==
- (segment_off_t)(base + record_group.size.get_encoded_length()));
+ (seastore_off_t)(base + record_group.size.get_encoded_length()));
return encode_records(record_group, journal_seq_t(), nonce);
}
void add_extent(LogicalCachedExtentRef& extent) {
@@ -83,10 +83,10 @@ public:
std::vector<OolExtent>& get_extents() {
return extents;
}
- void set_base(segment_off_t b) {
+ void set_base(seastore_off_t b) {
base = b;
}
- segment_off_t get_base() const {
+ seastore_off_t get_base() const {
return base;
}
void clear() {
@@ -102,7 +102,7 @@ private:
std::vector<OolExtent> extents;
record_t record;
size_t block_size;
- segment_off_t base = MAX_SEG_OFF;
+ seastore_off_t base = MAX_SEG_OFF;
};
/**
@@ -209,7 +209,7 @@ class SegmentedAllocator : public ExtentAllocator {
finish_record_ret finish_write(
Transaction& t,
ool_record_t& record);
- bool _needs_roll(segment_off_t length) const;
+ bool _needs_roll(seastore_off_t length) const;
write_iertr::future<> _write(
Transaction& t,
@@ -231,7 +231,7 @@ class SegmentedAllocator : public ExtentAllocator {
SegmentManager& segment_manager;
open_segment_wrapper_ref current_segment;
std::list<open_segment_wrapper_ref> open_segments;
- segment_off_t allocated_to = 0;
+ seastore_off_t allocated_to = 0;
LBAManager& lba_manager;
Journal& journal;
crimson::condition_variable segment_rotation_guard;
@@ -301,7 +301,7 @@ public:
CachedExtentRef alloc_new_extent_by_type(
Transaction& t,
extent_types_t type,
- segment_off_t length,
+ seastore_off_t length,
placement_hint_t hint) {
// only logical extents should fall in this path
assert(is_logical_type(type));
@@ -322,7 +322,7 @@ public:
std::enable_if_t<std::is_base_of_v<LogicalCachedExtent, T>, int> = 0>
TCachedExtentRef<T> alloc_new_extent(
Transaction& t,
- segment_off_t length,
+ seastore_off_t length,
placement_hint_t hint) {
// only logical extents should fall in this path
static_assert(is_logical_type(T::TYPE));
diff --git a/src/crimson/os/seastore/extent_reader.cc b/src/crimson/os/seastore/extent_reader.cc
index 8b66ffffd31..15ca6cad765 100644
--- a/src/crimson/os/seastore/extent_reader.cc
+++ b/src/crimson/os/seastore/extent_reader.cc
@@ -253,7 +253,7 @@ ExtentReader::read_validate_record_metadata(
auto rest_start = paddr_t::make_seg_paddr(
seg_addr.get_segment_id(),
- seg_addr.get_segment_off() + (segment_off_t)block_size
+ seg_addr.get_segment_off() + (seastore_off_t)block_size
);
auto rest_len = header.mdlength - block_size;
TRACE("reading record group header rest {}~{}", rest_start, rest_len);
@@ -315,7 +315,7 @@ ExtentReader::consume_next_records(
cursor.seq.segment_seq,
next.offset
},
- static_cast<segment_off_t>(total_length)
+ static_cast<seastore_off_t>(total_length)
}
};
DEBUG("processing {} at {}, budget_used={}",
diff --git a/src/crimson/os/seastore/extent_reader.h b/src/crimson/os/seastore/extent_reader.h
index b6e5013cba7..697adb47aa8 100644
--- a/src/crimson/os/seastore/extent_reader.h
+++ b/src/crimson/os/seastore/extent_reader.h
@@ -6,6 +6,7 @@
#include "crimson/common/errorator.h"
#include "crimson/os/seastore/seastore_types.h"
#include "crimson/os/seastore/segment_manager.h"
+#include "crimson/os/seastore/logging.h"
namespace crimson::os::seastore {
@@ -14,7 +15,7 @@ class TransactionManager;
class ExtentReader {
public:
- segment_off_t get_block_size() const {
+ seastore_off_t get_block_size() const {
assert(segment_managers.size());
// assume all segment managers have the same block size
return segment_managers[0]->get_block_size();
diff --git a/src/crimson/os/seastore/journal.cc b/src/crimson/os/seastore/journal.cc
index 39a9063d62a..173a6c8124c 100644
--- a/src/crimson/os/seastore/journal.cc
+++ b/src/crimson/os/seastore/journal.cc
@@ -424,7 +424,7 @@ Journal::JournalSegmentManager::write(ceph::bufferlist to_write)
written_to += write_length;
auto write_result = write_result_t{
write_start_seq,
- static_cast<segment_off_t>(write_length)
+ static_cast<seastore_off_t>(write_length)
};
return current_journal_segment->write(
write_start_offset, to_write
diff --git a/src/crimson/os/seastore/journal.h b/src/crimson/os/seastore/journal.h
index 4a68a9a9308..538e8f7a973 100644
--- a/src/crimson/os/seastore/journal.h
+++ b/src/crimson/os/seastore/journal.h
@@ -140,7 +140,7 @@ private:
return segment_manager.get_device_id();
}
- segment_off_t get_block_size() const {
+ seastore_off_t get_block_size() const {
return segment_manager.get_block_size();
}
@@ -219,7 +219,7 @@ private:
segment_nonce_t current_segment_nonce;
SegmentRef current_journal_segment;
- segment_off_t written_to;
+ seastore_off_t written_to;
// committed_to may be in a previous journal segment
journal_seq_t committed_to;
};
@@ -332,12 +332,12 @@ private:
record_group_t pending;
std::size_t submitting_size = 0;
- segment_off_t submitting_length = 0;
- segment_off_t submitting_mdlength = 0;
+ seastore_off_t submitting_length = 0;
+ seastore_off_t submitting_mdlength = 0;
struct promise_result_t {
write_result_t write_result;
- segment_off_t mdlength;
+ seastore_off_t mdlength;
};
using maybe_promise_result_t = std::optional<promise_result_t>;
std::optional<seastar::shared_promise<maybe_promise_result_t> > io_promise;
diff --git a/src/crimson/os/seastore/lba_manager.h b/src/crimson/os/seastore/lba_manager.h
index 406cf8a35ff..c98302371ed 100644
--- a/src/crimson/os/seastore/lba_manager.h
+++ b/src/crimson/os/seastore/lba_manager.h
@@ -190,7 +190,7 @@ public:
extent_types_t type,
paddr_t addr,
laddr_t laddr,
- segment_off_t len) = 0;
+ seastore_off_t len) = 0;
virtual void add_pin(LBAPin &pin) = 0;
diff --git a/src/crimson/os/seastore/lba_manager/btree/btree_lba_manager.cc b/src/crimson/os/seastore/lba_manager/btree/btree_lba_manager.cc
index 971d018a319..f15582733f7 100644
--- a/src/crimson/os/seastore/lba_manager/btree/btree_lba_manager.cc
+++ b/src/crimson/os/seastore/lba_manager/btree/btree_lba_manager.cc
@@ -402,7 +402,7 @@ BtreeLBAManager::get_physical_extent_if_live(
extent_types_t type,
paddr_t addr,
laddr_t laddr,
- segment_off_t len)
+ seastore_off_t len)
{
ceph_assert(is_lba_node(type));
auto c = get_context(t);
diff --git a/src/crimson/os/seastore/lba_manager/btree/btree_lba_manager.h b/src/crimson/os/seastore/lba_manager/btree/btree_lba_manager.h
index a036b337b81..7194019d62a 100644
--- a/src/crimson/os/seastore/lba_manager/btree/btree_lba_manager.h
+++ b/src/crimson/os/seastore/lba_manager/btree/btree_lba_manager.h
@@ -113,7 +113,7 @@ public:
extent_types_t type,
paddr_t addr,
laddr_t laddr,
- segment_off_t len) final;
+ seastore_off_t len) final;
void add_pin(LBAPin &pin) final {
auto *bpin = reinterpret_cast<BtreeLBAPin*>(&pin);
diff --git a/src/crimson/os/seastore/lba_manager/btree/lba_btree.cc b/src/crimson/os/seastore/lba_manager/btree/lba_btree.cc
index 4bfb5edf474..84358df08da 100644
--- a/src/crimson/os/seastore/lba_manager/btree/lba_btree.cc
+++ b/src/crimson/os/seastore/lba_manager/btree/lba_btree.cc
@@ -343,7 +343,7 @@ LBABtree::get_internal_if_live(
op_context_t c,
paddr_t addr,
laddr_t laddr,
- segment_off_t len)
+ seastore_off_t len)
{
LOG_PREFIX(BtreeLBAManager::get_leaf_if_live);
return lower_bound(
@@ -379,7 +379,7 @@ LBABtree::get_leaf_if_live(
op_context_t c,
paddr_t addr,
laddr_t laddr,
- segment_off_t len)
+ seastore_off_t len)
{
LOG_PREFIX(BtreeLBAManager::get_leaf_if_live);
return lower_bound(
diff --git a/src/crimson/os/seastore/lba_manager/btree/lba_btree.h b/src/crimson/os/seastore/lba_manager/btree/lba_btree.h
index ab604e302ae..5caf0940474 100644
--- a/src/crimson/os/seastore/lba_manager/btree/lba_btree.h
+++ b/src/crimson/os/seastore/lba_manager/btree/lba_btree.h
@@ -391,7 +391,7 @@ public:
op_context_t c,
paddr_t addr,
laddr_t laddr,
- segment_off_t len);
+ seastore_off_t len);
/// get_internal_if_live: get internal node at laddr/addr if still live
using get_internal_if_live_iertr = base_iertr;
@@ -400,7 +400,7 @@ public:
op_context_t c,
paddr_t addr,
laddr_t laddr,
- segment_off_t len);
+ seastore_off_t len);
/**
* rewrite_lba_extent
diff --git a/src/crimson/os/seastore/root_block.h b/src/crimson/os/seastore/root_block.h
index 3144edb8251..e0484c1cb05 100644
--- a/src/crimson/os/seastore/root_block.h
+++ b/src/crimson/os/seastore/root_block.h
@@ -33,7 +33,7 @@ namespace crimson::os::seastore {
* mutation which changes the journal trim bound.
*/
struct RootBlock : CachedExtent {
- constexpr static segment_off_t SIZE = 4<<10;
+ constexpr static seastore_off_t SIZE = 4<<10;
using Ref = TCachedExtentRef<RootBlock>;
root_t root;
diff --git a/src/crimson/os/seastore/seastore_types.cc b/src/crimson/os/seastore/seastore_types.cc
index 8befb9f1eed..dc17aeae8cb 100644
--- a/src/crimson/os/seastore/seastore_types.cc
+++ b/src/crimson/os/seastore/seastore_types.cc
@@ -29,7 +29,7 @@ std::ostream &segment_to_stream(std::ostream &out, const segment_id_t &t)
return out << t;
}
-std::ostream &offset_to_stream(std::ostream &out, const segment_off_t &t)
+std::ostream &offset_to_stream(std::ostream &out, const seastore_off_t &t)
{
if (t == NULL_SEG_OFF)
return out << "NULL_OFF";
@@ -546,7 +546,7 @@ paddr_t convert_blk_paddr_to_paddr(blk_paddr_t addr, size_t block_size,
d_id,
(device_segment_id_t)(addr / (block_size * blocks_per_segment))
};
- segment_off_t off = addr % (block_size * blocks_per_segment);
+ seastore_off_t off = addr % (block_size * blocks_per_segment);
return paddr_t::make_seg_paddr(id, off);
}
diff --git a/src/crimson/os/seastore/seastore_types.h b/src/crimson/os/seastore/seastore_types.h
index 29ea8159d76..0a14b2f2cb8 100644
--- a/src/crimson/os/seastore/seastore_types.h
+++ b/src/crimson/os/seastore/seastore_types.h
@@ -178,13 +178,13 @@ std::ostream &segment_to_stream(std::ostream &, const segment_id_t &t);
// Offset within a segment on disk, see SegmentManager
// may be negative for relative offsets
-using segment_off_t = int32_t;
-constexpr segment_off_t NULL_SEG_OFF =
- std::numeric_limits<segment_off_t>::max();
-constexpr segment_off_t MAX_SEG_OFF =
- std::numeric_limits<segment_off_t>::max();
+using seastore_off_t = int32_t;
+constexpr seastore_off_t NULL_SEG_OFF =
+ std::numeric_limits<seastore_off_t>::max();
+constexpr seastore_off_t MAX_SEG_OFF =
+ std::numeric_limits<seastore_off_t>::max();
-std::ostream &offset_to_stream(std::ostream &, const segment_off_t &t);
+std::ostream &offset_to_stream(std::ostream &, const seastore_off_t &t);
/* Monotonically increasing segment seq, uniquely identifies
* the incarnation of a segment */
@@ -419,19 +419,19 @@ protected:
using common_addr_t = uint64_t;
common_addr_t dev_addr;
private:
- constexpr paddr_t(segment_id_t seg, segment_off_t offset)
+ constexpr paddr_t(segment_id_t seg, seastore_off_t offset)
: dev_addr((static_cast<common_addr_t>(seg.segment)
<< SEG_OFF_LEN_BITS) | static_cast<uint32_t>(offset)) {}
constexpr paddr_t(common_addr_t val) : dev_addr(val) {}
public:
static constexpr paddr_t make_seg_paddr(
- segment_id_t seg, segment_off_t offset) {
+ segment_id_t seg, seastore_off_t offset) {
return paddr_t(seg, offset);
}
static constexpr paddr_t make_seg_paddr(
device_id_t device,
device_segment_id_t seg,
- segment_off_t offset) {
+ seastore_off_t offset) {
return paddr_t(segment_id_t(device, seg), offset);
}
constexpr paddr_t() : paddr_t(NULL_SEG_ID, 0) {}
@@ -524,21 +524,21 @@ struct seg_paddr_t : public paddr_t {
segment_id_t get_segment_id() const {
return segment_id_t((dev_addr & SEG_ID_MASK) >> SEG_OFF_LEN_BITS);
}
- segment_off_t get_segment_off() const {
- return segment_off_t(dev_addr & SEG_OFF_MASK);
+ seastore_off_t get_segment_off() const {
+ return seastore_off_t(dev_addr & SEG_OFF_MASK);
}
void set_segment_id(const segment_id_t id) {
dev_addr &= static_cast<common_addr_t>(
std::numeric_limits<device_segment_id_t>::max());
dev_addr |= static_cast<common_addr_t>(id.segment) << SEG_OFF_LEN_BITS;
}
- void set_segment_off(const segment_off_t off) {
+ void set_segment_off(const seastore_off_t off) {
dev_addr &= static_cast<common_addr_t>(
std::numeric_limits<device_segment_id_t>::max()) << SEG_OFF_LEN_BITS;
dev_addr |= (uint32_t)off;
}
- paddr_t add_offset(segment_off_t o) const {
+ paddr_t add_offset(seastore_off_t o) const {
return paddr_t::make_seg_paddr(get_segment_id(), get_segment_off() + o);
}
@@ -598,24 +598,24 @@ constexpr paddr_t P_ADDR_NULL = paddr_t{};
constexpr paddr_t P_ADDR_MIN = paddr_t::make_seg_paddr(segment_id_t(0, 0), 0);
constexpr paddr_t P_ADDR_MAX = paddr_t::make_seg_paddr(
segment_id_t(DEVICE_ID_MAX, DEVICE_SEGMENT_ID_MAX),
- std::numeric_limits<segment_off_t>::max());
+ std::numeric_limits<seastore_off_t>::max());
constexpr paddr_t P_ADDR_ZERO = paddr_t::make_seg_paddr(
DEVICE_ID_ZERO, 0, 0);
-constexpr paddr_t make_record_relative_paddr(segment_off_t off) {
+constexpr paddr_t make_record_relative_paddr(seastore_off_t off) {
return paddr_t::make_seg_paddr(
segment_id_t{DEVICE_ID_RECORD_RELATIVE, 0},
off);
}
-constexpr paddr_t make_block_relative_paddr(segment_off_t off) {
+constexpr paddr_t make_block_relative_paddr(seastore_off_t off) {
return paddr_t::make_seg_paddr(
segment_id_t{DEVICE_ID_BLOCK_RELATIVE, 0},
off);
}
-constexpr paddr_t make_fake_paddr(segment_off_t off) {
+constexpr paddr_t make_fake_paddr(seastore_off_t off) {
return paddr_t::make_seg_paddr(FAKE_SEG_ID, off);
}
-constexpr paddr_t delayed_temp_paddr(segment_off_t off) {
+constexpr paddr_t delayed_temp_paddr(seastore_off_t off) {
return paddr_t::make_seg_paddr(
segment_id_t{DEVICE_ID_DELAYED, 0},
off);
@@ -666,7 +666,7 @@ struct journal_seq_t {
segment_seq_t segment_seq = 0;
paddr_t offset;
- journal_seq_t add_offset(segment_off_t o) const {
+ journal_seq_t add_offset(seastore_off_t o) const {
return {segment_seq, offset.add_offset(o)};
}
@@ -807,7 +807,7 @@ struct delta_info_t {
laddr_t laddr = L_ADDR_NULL; ///< logical address
uint32_t prev_crc = 0;
uint32_t final_crc = 0;
- segment_off_t length = NULL_SEG_OFF; ///< extent length
+ seastore_off_t length = NULL_SEG_OFF; ///< extent length
extent_version_t pversion; ///< prior version
ceph::bufferlist bl; ///< payload
@@ -1066,7 +1066,7 @@ class __attribute__((packed)) coll_root_le_t {
public:
coll_root_le_t() = default;
- coll_root_le_t(laddr_t laddr, segment_off_t size)
+ coll_root_le_t(laddr_t laddr, seastore_off_t size)
: addr(laddr), size(init_extent_len_le(size)) {}
@@ -1434,7 +1434,7 @@ try_decode_deltas(
struct write_result_t {
journal_seq_t start_seq;
- segment_off_t length;
+ seastore_off_t length;
journal_seq_t get_end_seq() const {
return start_seq.add_offset(length);
@@ -1476,11 +1476,11 @@ struct scan_valid_records_cursor {
return seq.offset.as_seg_paddr().get_segment_id();
}
- segment_off_t get_segment_offset() const {
+ seastore_off_t get_segment_offset() const {
return seq.offset.as_seg_paddr().get_segment_off();
}
- void increment_seq(segment_off_t off) {
+ void increment_seq(seastore_off_t off) {
auto& seg_addr = seq.offset.as_seg_paddr();
seg_addr.set_segment_off(
seg_addr.get_segment_off() + off);
diff --git a/src/crimson/os/seastore/segment_cleaner.cc b/src/crimson/os/seastore/segment_cleaner.cc
index d296a958562..42ca4d0a64a 100644
--- a/src/crimson/os/seastore/segment_cleaner.cc
+++ b/src/crimson/os/seastore/segment_cleaner.cc
@@ -59,7 +59,7 @@ bool SpaceTrackerSimple::equals(const SpaceTrackerI &_other) const
int64_t SpaceTrackerDetailed::SegmentMap::allocate(
device_segment_id_t segment,
- segment_off_t offset,
+ seastore_off_t offset,
extent_len_t len,
const extent_len_t block_size)
{
@@ -91,7 +91,7 @@ int64_t SpaceTrackerDetailed::SegmentMap::allocate(
int64_t SpaceTrackerDetailed::SegmentMap::release(
device_segment_id_t segment,
- segment_off_t offset,
+ seastore_off_t offset,
extent_len_t len,
const extent_len_t block_size)
{
diff --git a/src/crimson/os/seastore/segment_cleaner.h b/src/crimson/os/seastore/segment_cleaner.h
index f958cd31826..accd3baece1 100644
--- a/src/crimson/os/seastore/segment_cleaner.h
+++ b/src/crimson/os/seastore/segment_cleaner.h
@@ -28,8 +28,8 @@ class segment_info_set_t {
segment_manager_info_t(
device_id_t device_id,
device_segment_id_t num_segments,
- segment_off_t segment_size,
- segment_off_t block_size,
+ seastore_off_t segment_size,
+ seastore_off_t block_size,
size_t empty_segments,
size_t size)
: device_id(device_id),
@@ -43,12 +43,12 @@ class segment_info_set_t {
device_id_t device_id = 0;
device_segment_id_t num_segments = 0;
- segment_off_t segment_size = 0;
- segment_off_t block_size = 0;
+ seastore_off_t segment_size = 0;
+ seastore_off_t block_size = 0;
size_t empty_segments = 0;
size_t size = 0;
size_t avail_bytes = 0;
- std::map<segment_id_t, segment_off_t> open_segment_avails;
+ std::map<segment_id_t, seastore_off_t> open_segment_avails;
};
struct segment_info_t {
@@ -301,12 +301,12 @@ class SpaceTrackerI {
public:
virtual int64_t allocate(
segment_id_t segment,
- segment_off_t offset,
+ seastore_off_t offset,
extent_len_t len) = 0;
virtual int64_t release(
segment_id_t segment,
- segment_off_t offset,
+ seastore_off_t offset,
extent_len_t len) = 0;
virtual int64_t get_usage(
@@ -352,14 +352,14 @@ public:
int64_t allocate(
segment_id_t segment,
- segment_off_t offset,
+ seastore_off_t offset,
extent_len_t len) final {
return update_usage(segment, len);
}
int64_t release(
segment_id_t segment,
- segment_off_t offset,
+ seastore_off_t offset,
extent_len_t len) final {
return update_usage(segment, -(int64_t)len);
}
@@ -400,13 +400,13 @@ class SpaceTrackerDetailed : public SpaceTrackerI {
int64_t allocate(
device_segment_id_t segment,
- segment_off_t offset,
+ seastore_off_t offset,
extent_len_t len,
const extent_len_t block_size);
int64_t release(
device_segment_id_t segment,
- segment_off_t offset,
+ seastore_off_t offset,
extent_len_t len,
const extent_len_t block_size);
@@ -451,7 +451,7 @@ public:
int64_t allocate(
segment_id_t segment,
- segment_off_t offset,
+ seastore_off_t offset,
extent_len_t len) final {
return segment_usage[segment].allocate(
segment.device_segment_id(),
@@ -462,7 +462,7 @@ public:
int64_t release(
segment_id_t segment,
- segment_off_t offset,
+ seastore_off_t offset,
extent_len_t len) final {
return segment_usage[segment].release(
segment.device_segment_id(),
@@ -605,7 +605,7 @@ public:
extent_types_t type,
paddr_t addr,
laddr_t laddr,
- segment_off_t len) = 0;
+ seastore_off_t len) = 0;
/**
* release_segment
diff --git a/src/crimson/os/seastore/segment_manager.h b/src/crimson/os/seastore/segment_manager.h
index 5a7c48a00a5..c0c421e5fd6 100644
--- a/src/crimson/os/seastore/segment_manager.h
+++ b/src/crimson/os/seastore/segment_manager.h
@@ -131,12 +131,12 @@ public:
/**
* min next write location
*/
- virtual segment_off_t get_write_ptr() const = 0;
+ virtual seastore_off_t get_write_ptr() const = 0;
/**
* max capacity
*/
- virtual segment_off_t get_write_capacity() const = 0;
+ virtual seastore_off_t get_write_capacity() const = 0;
/**
* close
@@ -165,7 +165,7 @@ public:
crimson::ct_error::enospc // write exceeds segment size
>;
virtual write_ertr::future<> write(
- segment_off_t offset, ceph::bufferlist bl) = 0;
+ seastore_off_t offset, ceph::bufferlist bl) = 0;
virtual ~Segment() {}
};
@@ -232,8 +232,8 @@ public:
/* Methods for discovering device geometry, segmentid set, etc */
virtual size_t get_size() const = 0;
- virtual segment_off_t get_block_size() const = 0;
- virtual segment_off_t get_segment_size() const = 0;
+ virtual seastore_off_t get_block_size() const = 0;
+ virtual seastore_off_t get_segment_size() const = 0;
virtual device_segment_id_t get_num_segments() const {
ceph_assert(get_size() % get_segment_size() == 0);
return ((device_segment_id_t)(get_size() / get_segment_size()));
diff --git a/src/crimson/os/seastore/segment_manager/block.cc b/src/crimson/os/seastore/segment_manager/block.cc
index f27942d5d3e..aac9376cc7f 100644
--- a/src/crimson/os/seastore/segment_manager/block.cc
+++ b/src/crimson/os/seastore/segment_manager/block.cc
@@ -360,7 +360,7 @@ BlockSegment::BlockSegment(
BlockSegmentManager &manager, segment_id_t id)
: manager(manager), id(id) {}
-segment_off_t BlockSegment::get_write_capacity() const
+seastore_off_t BlockSegment::get_write_capacity() const
{
return manager.get_segment_size();
}
@@ -371,7 +371,7 @@ Segment::close_ertr::future<> BlockSegment::close()
}
Segment::write_ertr::future<> BlockSegment::write(
- segment_off_t offset, ceph::bufferlist bl)
+ seastore_off_t offset, ceph::bufferlist bl)
{
LOG_PREFIX(BlockSegment::write);
auto paddr = paddr_t::make_seg_paddr(id, offset);
@@ -410,7 +410,7 @@ Segment::write_ertr::future<> BlockSegment::write(
}
Segment::close_ertr::future<> BlockSegmentManager::segment_close(
- segment_id_t id, segment_off_t write_pointer)
+ segment_id_t id, seastore_off_t write_pointer)
{
LOG_PREFIX(BlockSegmentManager::segment_close);
auto s_id = id.device_segment_id();
diff --git a/src/crimson/os/seastore/segment_manager/block.h b/src/crimson/os/seastore/segment_manager/block.h
index 7dc7d99141b..8008c4bd4e3 100644
--- a/src/crimson/os/seastore/segment_manager/block.h
+++ b/src/crimson/os/seastore/segment_manager/block.h
@@ -88,15 +88,15 @@ class BlockSegment final : public Segment {
friend class BlockSegmentManager;
BlockSegmentManager &manager;
const segment_id_t id;
- segment_off_t write_pointer = 0;
+ seastore_off_t write_pointer = 0;
public:
BlockSegment(BlockSegmentManager &manager, segment_id_t id);
segment_id_t get_segment_id() const final { return id; }
- segment_off_t get_write_capacity() const final;
- segment_off_t get_write_ptr() const final { return write_pointer; }
+ seastore_off_t get_write_capacity() const final;
+ seastore_off_t get_write_ptr() const final { return write_pointer; }
close_ertr::future<> close() final;
- write_ertr::future<> write(segment_off_t offset, ceph::bufferlist bl) final;
+ write_ertr::future<> write(seastore_off_t offset, ceph::bufferlist bl) final;
~BlockSegment() {}
};
@@ -134,10 +134,10 @@ public:
size_t get_size() const final {
return superblock.size;
}
- segment_off_t get_block_size() const {
+ seastore_off_t get_block_size() const {
return superblock.block_size;
}
- segment_off_t get_segment_size() const {
+ seastore_off_t get_segment_size() const {
return superblock.segment_size;
}
@@ -230,7 +230,7 @@ private:
char *buffer = nullptr;
Segment::close_ertr::future<> segment_close(
- segment_id_t id, segment_off_t write_pointer);
+ segment_id_t id, seastore_off_t write_pointer);
};
}
diff --git a/src/crimson/os/seastore/segment_manager/ephemeral.cc b/src/crimson/os/seastore/segment_manager/ephemeral.cc
index 4aff7a3e34c..2123e3afb2c 100644
--- a/src/crimson/os/seastore/segment_manager/ephemeral.cc
+++ b/src/crimson/os/seastore/segment_manager/ephemeral.cc
@@ -33,7 +33,7 @@ EphemeralSegment::EphemeralSegment(
EphemeralSegmentManager &manager, segment_id_t id)
: manager(manager), id(id) {}
-segment_off_t EphemeralSegment::get_write_capacity() const
+seastore_off_t EphemeralSegment::get_write_capacity() const
{
return manager.get_segment_size();
}
@@ -46,7 +46,7 @@ Segment::close_ertr::future<> EphemeralSegment::close()
}
Segment::write_ertr::future<> EphemeralSegment::write(
- segment_off_t offset, ceph::bufferlist bl)
+ seastore_off_t offset, ceph::bufferlist bl)
{
if (offset < write_pointer || offset % manager.config.block_size != 0)
return crimson::ct_error::invarg::make();
diff --git a/src/crimson/os/seastore/segment_manager/ephemeral.h b/src/crimson/os/seastore/segment_manager/ephemeral.h
index 7083c08c89b..d9c786815ff 100644
--- a/src/crimson/os/seastore/segment_manager/ephemeral.h
+++ b/src/crimson/os/seastore/segment_manager/ephemeral.h
@@ -41,15 +41,15 @@ class EphemeralSegment final : public Segment {
friend class EphemeralSegmentManager;
EphemeralSegmentManager &manager;
const segment_id_t id;
- segment_off_t write_pointer = 0;
+ seastore_off_t write_pointer = 0;
public:
EphemeralSegment(EphemeralSegmentManager &manager, segment_id_t id);
segment_id_t get_segment_id() const final { return id; }
- segment_off_t get_write_capacity() const final;
- segment_off_t get_write_ptr() const final { return write_pointer; }
+ seastore_off_t get_write_capacity() const final;
+ seastore_off_t get_write_ptr() const final { return write_pointer; }
close_ertr::future<> close() final;
- write_ertr::future<> write(segment_off_t offset, ceph::bufferlist bl) final;
+ write_ertr::future<> write(seastore_off_t offset, ceph::bufferlist bl) final;
~EphemeralSegment() {}
};
@@ -115,10 +115,10 @@ public:
size_t get_size() const final {
return config.size;
}
- segment_off_t get_block_size() const final {
+ seastore_off_t get_block_size() const final {
return config.block_size;
}
- segment_off_t get_segment_size() const final {
+ seastore_off_t get_segment_size() const final {
return config.segment_size;
}
diff --git a/src/crimson/os/seastore/transaction.h b/src/crimson/os/seastore/transaction.h
index fd14acbd515..92971b44df6 100644
--- a/src/crimson/os/seastore/transaction.h
+++ b/src/crimson/os/seastore/transaction.h
@@ -352,8 +352,8 @@ private:
RootBlockRef root; ///< ref to root if read or written by transaction
- segment_off_t offset = 0; ///< relative offset of next block
- segment_off_t delayed_temp_offset = 0;
+ seastore_off_t offset = 0; ///< relative offset of next block
+ seastore_off_t delayed_temp_offset = 0;
/**
* read_set
diff --git a/src/crimson/os/seastore/transaction_manager.cc b/src/crimson/os/seastore/transaction_manager.cc
index c9dc00e4ead..3dfb8977af6 100644
--- a/src/crimson/os/seastore/transaction_manager.cc
+++ b/src/crimson/os/seastore/transaction_manager.cc
@@ -418,7 +418,7 @@ TransactionManager::get_extent_if_live_ret TransactionManager::get_extent_if_liv
extent_types_t type,
paddr_t addr,
laddr_t laddr,
- segment_off_t len)
+ seastore_off_t len)
{
LOG_PREFIX(TransactionManager::get_extent_if_live);
DEBUGT("type {}, addr {}, laddr {}, len {}", t, type, addr, laddr, len);
diff --git a/src/crimson/os/seastore/transaction_manager.h b/src/crimson/os/seastore/transaction_manager.h
index 82c825c284c..82d08ea40b6 100644
--- a/src/crimson/os/seastore/transaction_manager.h
+++ b/src/crimson/os/seastore/transaction_manager.h
@@ -400,7 +400,7 @@ public:
extent_types_t type,
paddr_t addr,
laddr_t laddr,
- segment_off_t len) final;
+ seastore_off_t len) final;
using release_segment_ret =
SegmentCleaner::ExtentCallbackInterface::release_segment_ret;
diff --git a/src/test/crimson/seastore/test_block.h b/src/test/crimson/seastore/test_block.h
index 4df99784ad4..c6f88b8cd88 100644
--- a/src/test/crimson/seastore/test_block.h
+++ b/src/test/crimson/seastore/test_block.h
@@ -44,7 +44,7 @@ inline std::ostream &operator<<(
}
struct TestBlock : crimson::os::seastore::LogicalCachedExtent {
- constexpr static segment_off_t SIZE = 4<<10;
+ constexpr static seastore_off_t SIZE = 4<<10;
using Ref = TCachedExtentRef<TestBlock>;
std::vector<test_block_delta_t> delta = {};
@@ -83,7 +83,7 @@ struct TestBlock : crimson::os::seastore::LogicalCachedExtent {
using TestBlockRef = TCachedExtentRef<TestBlock>;
struct TestBlockPhysical : crimson::os::seastore::CachedExtent{
- constexpr static segment_off_t SIZE = 4<<10;
+ constexpr static seastore_off_t SIZE = 4<<10;
using Ref = TCachedExtentRef<TestBlockPhysical>;
std::vector<test_block_delta_t> delta = {};
diff --git a/src/test/crimson/seastore/test_btree_lba_manager.cc b/src/test/crimson/seastore/test_btree_lba_manager.cc
index 19c36edb492..f9d5d195057 100644
--- a/src/test/crimson/seastore/test_btree_lba_manager.cc
+++ b/src/test/crimson/seastore/test_btree_lba_manager.cc
@@ -347,7 +347,7 @@ struct btree_lba_manager_test : btree_test_base {
);
}
- segment_off_t next_off = 0;
+ seastore_off_t next_off = 0;
paddr_t get_paddr() {
next_off += block_size;
return make_fake_paddr(next_off);
diff --git a/src/test/crimson/seastore/test_seastore_cache.cc b/src/test/crimson/seastore/test_seastore_cache.cc
index 0bb8213786b..4b49f020acf 100644
--- a/src/test/crimson/seastore/test_seastore_cache.cc
+++ b/src/test/crimson/seastore/test_seastore_cache.cc
@@ -37,9 +37,9 @@ struct cache_test_t : public seastar_test_suite_t {
bl.append(block.bl);
}
- ceph_assert((segment_off_t)bl.length() <
+ ceph_assert((seastore_off_t)bl.length() <
segment_manager->get_segment_size());
- if (current.as_seg_paddr().get_segment_off() + (segment_off_t)bl.length() >
+ if (current.as_seg_paddr().get_segment_off() + (seastore_off_t)bl.length() >
segment_manager->get_segment_size())
current = paddr_t::make_seg_paddr(
segment_id_t(
diff --git a/src/test/crimson/seastore/test_seastore_journal.cc b/src/test/crimson/seastore/test_seastore_journal.cc
index eaeb8cd2d0c..00e1944b790 100644
--- a/src/test/crimson/seastore/test_seastore_journal.cc
+++ b/src/test/crimson/seastore/test_seastore_journal.cc
@@ -74,7 +74,7 @@ struct journal_test_t : seastar_test_suite_t, SegmentProvider {
std::default_random_engine generator;
- segment_off_t block_size;
+ seastore_off_t block_size;
ExtentReaderRef scanner;
diff --git a/src/test/crimson/seastore/transaction_manager_test_state.h b/src/test/crimson/seastore/transaction_manager_test_state.h
index 6323f72729e..9213d2b8243 100644
--- a/src/test/crimson/seastore/transaction_manager_test_state.h
+++ b/src/test/crimson/seastore/transaction_manager_test_state.h
@@ -251,8 +251,8 @@ public:
}
size_t get_size() const final { return sm.get_size(); }
- segment_off_t get_block_size() const final { return sm.get_block_size(); }
- segment_off_t get_segment_size() const final {
+ seastore_off_t get_block_size() const final { return sm.get_block_size(); }
+ seastore_off_t get_segment_size() const final {
return sm.get_segment_size();
}
const seastore_meta_t &get_meta() const final {