crimson/osd: reindent

for less indent, hence better readability

Signed-off-by: Kefu Chai <kchai@redhat.com>

diff --git a/src/crimson/osd/osd_operations/client_request.cc b/src/crimson/osd/osd_operations/client_request.cc
index 637dd9d598ad7bad8c56160c01cc3f20c265d08f..93b633afb5ac836b4c83b416c80b0c23d33cd1e1 100644 (file)
--- a/src/crimson/osd/osd_operations/client_request.cc
+++ b/src/crimson/osd/osd_operations/client_request.cc
@@ -88,33 +88,34 @@ seastar::future<> ClientRequest::start()
           epoch_t same_interval_since = pgref->get_interval_start_epoch();
           logger().debug("{} same_interval_since: {}", *this, same_interval_since);
           const bool has_pg_op = is_pg_op();
-          auto interruptible_do_op =
-            interruptor::wrap_function([this, has_pg_op, pgref] {
-              PG &pg = *pgref;
-              if (pg.can_discard_op(*m)) {
-                return interruptible_future<>(
-                  osd.send_incremental_map(conn, m->get_map_epoch()));
-              }
+          auto interruptible_do_op = interruptor::wrap_function([=] {
+            PG &pg = *pgref;
+            if (pg.can_discard_op(*m)) {
+              return interruptible_future<>(
+                osd.send_incremental_map(conn, m->get_map_epoch()));
+            }
+            return with_blocking_future_interruptible<IOInterruptCondition>(
+              handle.enter(pp(pg).await_map)
+            ).then_interruptible([this, &pg] {
+              return with_blocking_future_interruptible<IOInterruptCondition>(
+                pg.osdmap_gate.wait_for_map(m->get_min_epoch()));
+            }).then_interruptible([this, &pg](auto map) {
               return with_blocking_future_interruptible<IOInterruptCondition>(
-                handle.enter(pp(pg).await_map)
-              ).then_interruptible([this, &pg] {
-                return with_blocking_future_interruptible<IOInterruptCondition>(
-                    pg.osdmap_gate.wait_for_map(m->get_min_epoch()));
-              }).then_interruptible([this, &pg](auto map) {
-                return with_blocking_future_interruptible<IOInterruptCondition>(
-                    handle.enter(pp(pg).wait_for_active));
-              }).then_interruptible([this, &pg]() {
-                return with_blocking_future_interruptible<IOInterruptCondition>(
-                    pg.wait_for_active_blocker.wait());
-              }).then_interruptible([this, has_pg_op, pgref=std::move(pgref)]() mutable {
-                if (m->finish_decode()) {
-                  m->clear_payload();
-                }
-                return (has_pg_op ?
-                        process_pg_op(pgref) :
-                        process_op(pgref));
-              });
+                handle.enter(pp(pg).wait_for_active));
+            }).then_interruptible([this, &pg]() {
+              return with_blocking_future_interruptible<IOInterruptCondition>(
+                pg.wait_for_active_blocker.wait());
+            }).then_interruptible([this,
+                                   has_pg_op,
+                                   pgref=std::move(pgref)]() mutable {
+              if (m->finish_decode()) {
+                m->clear_payload();
+              }
+              return (has_pg_op ?
+                      process_pg_op(pgref) :
+                      process_op(pgref));
             });
+          });
           // keep the ordering of non-pg ops when across pg internvals
           return (has_pg_op ?
                   interruptible_do_op() :