From: Yingxin Cheng Date: Mon, 25 Nov 2024 06:35:22 +0000 (+0800) Subject: crimson/os/seastore/transaction_manager: add log in get_extents_if_live() X-Git-Tag: v20.0.0~617^2 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=refs%2Fpull%2F60817%2Fhead;p=ceph.git crimson/os/seastore/transaction_manager: add log in get_extents_if_live() Signed-off-by: Yingxin Cheng --- diff --git a/src/crimson/os/seastore/transaction_manager.cc b/src/crimson/os/seastore/transaction_manager.cc index 45fb54f2726c..745df70235b7 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();