From a7830814b59174c9447989d61061e7b811bd17bc Mon Sep 17 00:00:00 2001 From: Yingxin Cheng Date: Mon, 25 Nov 2024 14:35:22 +0800 Subject: [PATCH] crimson/os/seastore/transaction_manager: add log in get_extents_if_live() Signed-off-by: Yingxin Cheng --- src/crimson/os/seastore/transaction_manager.cc | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/crimson/os/seastore/transaction_manager.cc b/src/crimson/os/seastore/transaction_manager.cc index 45fb54f2726c2..745df70235b72 100644 --- a/src/crimson/os/seastore/transaction_manager.cc +++ b/src/crimson/os/seastore/transaction_manager.cc @@ -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 -- {}", @@ -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(), std::move(pin_list), - [=, this, &t] + [this, FNAME, type, paddr, laddr, len, &t] (std::list &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(); -- 2.39.5