]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/.../client_request: move log line to complete_request callback
authorSamuel Just <sjust@redhat.com>
Thu, 31 Oct 2024 22:43:25 +0000 (15:43 -0700)
committerSamuel Just <sjust@redhat.com>
Wed, 11 Dec 2024 02:01:57 +0000 (18:01 -0800)
Signed-off-by: Samuel Just <sjust@redhat.com>
src/crimson/osd/osd_operations/client_request.cc

index a4f48b72318b3e8ecbbea1e69dfa4cb3f6df85a3..ee78b5632100221fa4ceda21030a4c04be114136 100644 (file)
@@ -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) {