From: Samuel Just Date: Thu, 15 Apr 2021 08:56:36 +0000 (+0000) Subject: crimson/os/seastore/cache: swap dirty_from users to get_dirty_from() X-Git-Tag: v17.1.0~2174^2~7 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=9b5d2042ee1c29f96b32f1e9fe73f3a187a68db4;p=ceph.git crimson/os/seastore/cache: swap dirty_from users to get_dirty_from() Signed-off-by: Samuel Just --- diff --git a/src/crimson/os/seastore/cache.cc b/src/crimson/os/seastore/cache.cc index 4745b7d14f1..ed5c065631e 100644 --- a/src/crimson/os/seastore/cache.cc +++ b/src/crimson/os/seastore/cache.cc @@ -114,7 +114,7 @@ void Cache::replace_extent(CachedExtentRef next, CachedExtentRef prev) intrusive_ptr_release(&*prev); add_to_dirty(next); } else if (prev->is_dirty()) { - assert(prev->dirty_from == next->dirty_from); + assert(prev->get_dirty_from() == next->get_dirty_from()); assert(prev->primary_ref_list_hook.is_linked()); auto prev_it = dirty.iterator_to(*prev); dirty.insert(prev_it, *next); @@ -454,17 +454,18 @@ Cache::get_next_dirty_extents_ret Cache::get_next_dirty_extents( i != dirty.end() && bytes_so_far < max_bytes; ++i) { CachedExtentRef cand; - if (i->dirty_from != journal_seq_t() && i->dirty_from < seq) { + if (i->get_dirty_from() != journal_seq_t() && i->get_dirty_from() < seq) { logger().debug( "Cache::get_next_dirty_extents: next {}", *i); - if (!(ret.empty() || ret.back()->dirty_from <= i->dirty_from)) { + if (!(ret.empty() || + ret.back()->get_dirty_from() <= i->get_dirty_from())) { logger().debug( "Cache::get_next_dirty_extents: last {}, next {}", *ret.back(), *i); } - assert(ret.empty() || ret.back()->dirty_from <= i->dirty_from); + assert(ret.empty() || ret.back()->get_dirty_from() <= i->get_dirty_from()); bytes_so_far += i->get_length(); ret.push_back(&*i); } else { diff --git a/src/crimson/os/seastore/cache.h b/src/crimson/os/seastore/cache.h index c48f27eaa51..bfb2248f961 100644 --- a/src/crimson/os/seastore/cache.h +++ b/src/crimson/os/seastore/cache.h @@ -496,7 +496,7 @@ public: return out; } - /// returns extents with dirty_from < seq + /// returns extents with get_dirty_from() < seq using get_next_dirty_extents_ertr = crimson::errorator<>; using get_next_dirty_extents_ret = get_next_dirty_extents_ertr::future< std::vector>; @@ -504,12 +504,12 @@ public: journal_seq_t seq, size_t max_bytes); - /// returns std::nullopt if no dirty extents or dirty_from for oldest + /// returns std::nullopt if no dirty extents or get_dirty_from() for oldest std::optional get_oldest_dirty_from() const { if (dirty.empty()) { return std::nullopt; } else { - auto oldest = dirty.begin()->dirty_from; + auto oldest = dirty.begin()->get_dirty_from(); if (oldest == journal_seq_t()) { return std::nullopt; } else { @@ -526,7 +526,7 @@ private: /** * dirty * - * holds refs to dirty extents. Ordered by CachedExtent::dirty_from. + * holds refs to dirty extents. Ordered by CachedExtent::get_dirty_from(). */ CachedExtent::list dirty;