From adc63e283c658478c2f5b8afa5d75ca76f1ce047 Mon Sep 17 00:00:00 2001 From: Samuel Just Date: Thu, 31 Oct 2024 15:43:25 -0700 Subject: [PATCH] crimson/.../client_request: move log line to complete_request callback Signed-off-by: Samuel Just --- src/crimson/osd/osd_operations/client_request.cc | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/src/crimson/osd/osd_operations/client_request.cc b/src/crimson/osd/osd_operations/client_request.cc index a4f48b72318b3..ee78b56321002 100644 --- a/src/crimson/osd/osd_operations/client_request.cc +++ b/src/crimson/osd/osd_operations/client_request.cc @@ -238,10 +238,6 @@ ClientRequest::interruptible_future<> ClientRequest::with_pg_process_interruptib DEBUGDPP("{}.{}: process[_pg]_op complete, completing handle", *pgref, *this, this_instance_id); co_await interruptor::make_interruptible(ihref.handle.complete()); - - DEBUGDPP("{}.{}: process[_pg]_op complete," - "removing request from orderer", - *pgref, *this, this_instance_id); } seastar::future<> ClientRequest::with_pg_process( @@ -257,10 +253,13 @@ seastar::future<> ClientRequest::with_pg_process( auto instance_handle = get_instance_handle(); auto &ihref = *instance_handle; return interruptor::with_interruption( - [this, pgref, this_instance_id, &ihref]() mutable { + [FNAME, this, pgref, this_instance_id, &ihref]() mutable { return with_pg_process_interruptible( pgref, this_instance_id, ihref - ).then_interruptible([this, pgref] { + ).then_interruptible([FNAME, this, this_instance_id, pgref] { + DEBUGDPP("{}.{}: with_pg_process_interruptible complete," + " completing request", + *pgref, *this, this_instance_id); complete_request(*pgref); }); }, [FNAME, this, this_instance_id, pgref](std::exception_ptr eptr) { -- 2.39.5