crimson/.../client_request: convert ClientRequest::process_pg_op to coroutine

Signed-off-by: Samuel Just <sjust@redhat.com>

diff --git a/src/crimson/osd/osd_operations/client_request.cc b/src/crimson/osd/osd_operations/client_request.cc
index a3c895d9654107e89265e741ec81641774bfbe52..0574a1bcfe5e29deb54b8128b38ed6c6b2606333 100644 (file)
--- a/src/crimson/osd/osd_operations/client_request.cc
+++ b/src/crimson/osd/osd_operations/client_request.cc
@@ -203,12 +203,10 @@ ClientRequest::interruptible_future<>
 ClientRequest::process_pg_op(
   Ref<PG> pg)
 {
-  return pg->do_pg_ops(
-    m
-  ).then_interruptible([this, pg=std::move(pg)](MURef<MOSDOpReply> reply) {
-    // TODO: gate the crosscore sending
-    return get_foreign_connection().send_with_throttling(std::move(reply));
-  });
+  auto reply = co_await pg->do_pg_ops(m);
+  // TODO: gate the crosscore sending
+  co_await interruptor::make_interruptible(
+    get_foreign_connection().send_with_throttling(std::move(reply)));
 }
 
 auto ClientRequest::reply_op_error(const Ref<PG>& pg, int err)