Skip to content

Commit

Permalink
crimson/os/seastore/transaction_manager: add log in get_extents_if_li…
Browse files Browse the repository at this point in the history
…ve()

Signed-off-by: Yingxin Cheng <[email protected]>
  • Loading branch information
cyx1231st committed Nov 28, 2024
1 parent 0732a3d commit a783081
Showing 1 changed file with 5 additions and 4 deletions.
9 changes: 5 additions & 4 deletions src/crimson/os/seastore/transaction_manager.cc
Original file line number Diff line number Diff line change
Expand Up @@ -726,7 +726,7 @@ TransactionManager::get_extents_if_live(
ceph_assert(paddr.get_addr_type() == paddr_types_t::SEGMENT);

return cache->get_extent_if_cached(t, paddr, type
).si_then([=, this, &t](auto extent)
).si_then([this, FNAME, type, paddr, laddr, len, &t](auto extent)
-> get_extents_if_live_ret {
if (extent && extent->get_length() == len) {
DEBUGT("{} {}~0x{:x} {} is cached and alive -- {}",
Expand All @@ -743,19 +743,20 @@ TransactionManager::get_extents_if_live(
t,
laddr,
len
).si_then([=, this, &t](lba_pin_list_t pin_list) {
).si_then([this, FNAME, type, paddr, laddr, len, &t](lba_pin_list_t pin_list) {
return seastar::do_with(
std::list<CachedExtentRef>(),
std::move(pin_list),
[=, this, &t]
[this, FNAME, type, paddr, laddr, len, &t]
(std::list<CachedExtentRef> &extent_list, auto& pin_list)
{
auto paddr_seg_id = paddr.as_seg_paddr().get_segment_id();
return trans_intr::parallel_for_each(
pin_list,
[=, this, &extent_list, &t](
[this, FNAME, type, paddr_seg_id, &extent_list, &t](
LBAMappingRef& pin) -> Cache::get_extent_iertr::future<>
{
DEBUGT("got pin, try read in parallel ... -- {}", t, *pin);
auto pin_paddr = pin->get_val();
if (pin_paddr.get_addr_type() != paddr_types_t::SEGMENT) {
return seastar::now();
Expand Down

0 comments on commit a783081

Please sign in to comment.