RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-20 10:01:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

crimson/os/seastore/cache: add public, cache aware get_extent_by_type variants

Browse Source 
Signed-off-by: Samuel Just <sjust@redhat.com>
This commit is contained in:
Samuel Just 2020-09-17 15:49:17 -07:00
parent c300ec9630
commit 37783172a6
1 changed files with 57 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

70
src/crimson/os/seastore/cache.h
View File

@ -166,6 +166,28 @@ public:
}
}
/**
* get_extent_if_cached
*
* Returns extent at offset if in cache
*/
Transaction::get_extent_ret get_extent_if_cached(
Transaction &t,
paddr_t offset,
CachedExtentRef *out) {
auto result = t.get_extent(offset, out);
if (result != Transaction::get_extent_ret::ABSENT) {
return result;
} else if (auto iter = extents.find_offset(offset);
iter != extents.end()) {
if (out)
*out = &*iter;
return Transaction::get_extent_ret::PRESENT;
} else {
return Transaction::get_extent_ret::ABSENT;
}
}
/**
* get_extent
*
@ -198,6 +220,41 @@ public:
}
}
/**
* get_extent_by_type
*
* Based on type, instantiate the correct concrete type
* and read in the extent at location offset~length.
*/
get_extent_ertr::future<CachedExtentRef> get_extent_by_type(
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
);
get_extent_ertr::future<CachedExtentRef> get_extent_by_type(
Transaction &t,
extent_types_t type,
paddr_t offset,
laddr_t laddr,
segment_off_t length) {
CachedExtentRef ret;
auto status = get_extent_if_cached(t, offset, &ret);
if (status == Transaction::get_extent_ret::RETIRED) {
return get_extent_ertr::make_ready_future<CachedExtentRef>();
} else if (status == Transaction::get_extent_ret::PRESENT) {
return get_extent_ertr::make_ready_future<CachedExtentRef>(ret);
} else {
return get_extent_by_type(type, offset, laddr, length
).safe_then([=, &t](CachedExtentRef ret) {
t.add_to_read_set(ret);
return get_extent_ertr::make_ready_future<CachedExtentRef>(
std::move(ret));
});
}
}
/**
* get_extents
*
@ -443,19 +500,6 @@ private:
/// Replace prev with next
void replace_extent(CachedExtentRef next, CachedExtentRef prev);
/**
* get_extent_by_type
*
* Based on type, instantiate the correct concrete type
* and read in the extent at location offset~length.
*/
get_extent_ertr::future<CachedExtentRef> get_extent_by_type(
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
);
};
}