diff options
author | myoungwon oh <ohmyoungwon@gmail.com> | 2021-12-03 16:18:10 +0900 |
---|---|---|
committer | myoungwon oh <ohmyoungwon@gmail.com> | 2022-01-18 18:24:43 +0900 |
commit | c93d0b7b1e7be2e3879ec384a951edb247a9f775 (patch) | |
tree | fb5a42b7ffaff4d4187fb08cc2baf4992ce09477 | |
parent | 51a347456dead2c327a08926a7042bfa685b397c (diff) | |
download | ceph-c93d0b7b1e7be2e3879ec384a951edb247a9f775.tar.gz |
seastore: rename segment_off_t to seastore_off_t
Signed-off-by: Myoungwon Oh <myoungwon.oh@samsung.com>
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 { |