From: Samuel Just <sjust@redhat.com>
Date: Thu, 8 Sep 2022 17:37:18 +0000 (-0700)
Subject: crimson/osd/osd_operations/client_request: fix whitespace on do_process
X-Git-Tag: v18.1.0~1115^2~10
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=5451c93a27e7685668c4b88767fa7a1801f6cea7;p=ceph.git

crimson/osd/osd_operations/client_request: fix whitespace on do_process

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 cb9063af24a..88377546379 100644
--- a/src/crimson/osd/osd_operations/client_request.cc
+++ b/src/crimson/osd/osd_operations/client_request.cc
@@ -301,26 +301,26 @@ ClientRequest::do_process(
 
   return pg->do_osd_ops(m, obc, op_info).safe_then_unpack_interruptible(
     [this, pg, &ihref](auto submitted, auto all_completed) mutable {
-    return submitted.then_interruptible([this, pg, &ihref] {
-      return ihref.enter_stage<interruptor>(pp(*pg).wait_repop, *this);
-    }).then_interruptible(
-      [this, pg, all_completed=std::move(all_completed), &ihref]() mutable {
-      return all_completed.safe_then_interruptible(
-        [this, pg, &ihref](MURef<MOSDOpReply> reply) {
-	return ihref.enter_stage<interruptor>(pp(*pg).send_reply, *this
-	).then_interruptible(
-          [this, reply=std::move(reply)]() mutable {
-          return conn->send(std::move(reply)).then([] {
-            return seastar::make_ready_future<seq_mode_t>(seq_mode_t::IN_ORDER);
-          });
-        });
-      }, crimson::ct_error::eagain::handle([this, pg, &ihref]() mutable {
-        return process_op(ihref, pg);
-      }));
-    });
- }, crimson::ct_error::eagain::handle([this, pg, &ihref]() mutable {
-    return process_op(ihref, pg);
-  }));
+      return submitted.then_interruptible([this, pg, &ihref] {
+	return ihref.enter_stage<interruptor>(pp(*pg).wait_repop, *this);
+      }).then_interruptible(
+	[this, pg, all_completed=std::move(all_completed), &ihref]() mutable {
+	  return all_completed.safe_then_interruptible(
+	    [this, pg, &ihref](MURef<MOSDOpReply> reply) {
+	      return ihref.enter_stage<interruptor>(pp(*pg).send_reply, *this
+	      ).then_interruptible(
+		[this, reply=std::move(reply)]() mutable {
+		  return conn->send(std::move(reply)).then([] {
+		    return seastar::make_ready_future<seq_mode_t>(seq_mode_t::IN_ORDER);
+		  });
+		});
+	    }, crimson::ct_error::eagain::handle([this, pg, &ihref]() mutable {
+	      return process_op(ihref, pg);
+	    }));
+	});
+    }, crimson::ct_error::eagain::handle([this, pg, &ihref]() mutable {
+      return process_op(ihref, pg);
+    }));
 }
 
 bool ClientRequest::is_misdirected(const PG& pg) const