]> git.apps.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
crimson/osd: move ClientRequest::reply_op_error() up
authorRadoslaw Zarzynski <rzarzyns@redhat.com>
Tue, 11 Oct 2022 14:32:02 +0000 (14:32 +0000)
committerRadoslaw Zarzynski <rzarzyns@redhat.com>
Tue, 11 Oct 2022 14:40:59 +0000 (14:40 +0000)
It's because it's return type is `auto`.

Signed-off-by: Radoslaw Zarzynski <rzarzyns@redhat.com>
src/crimson/osd/osd_operations/client_request.cc

index 1bf35331ebe053db9448f687fe5a51eb6c98f19a..1d234e23ac2fe368696891fb7b7259cd5fa3243c 100644 (file)
@@ -194,6 +194,21 @@ ClientRequest::process_pg_op(
   });
 }
 
+auto ClientRequest::reply_op_error(const Ref<PG>& pg, int err)
+{
+  logger().debug("{}: replying with error {}", *this, err);
+  auto reply = crimson::make_message<MOSDOpReply>(
+    m.get(), err, pg->get_osdmap_epoch(),
+    m->get_flags() & (CEPH_OSD_FLAG_ACK|CEPH_OSD_FLAG_ONDISK),
+    !m->has_flag(CEPH_OSD_FLAG_RETURNVEC));
+  reply->set_reply_versions(eversion_t(), 0);
+  reply->set_op_returns(std::vector<pg_log_op_return_item_t>{});
+  return conn->send(std::move(reply)).then([] {
+    return seastar::make_ready_future<ClientRequest::seq_mode_t>
+      (seq_mode_t::OUT_OF_ORDER);
+  });
+}
+
 ClientRequest::interruptible_future<ClientRequest::seq_mode_t>
 ClientRequest::process_op(instance_handle_t &ihref, Ref<PG> &pg)
 {
@@ -253,21 +268,6 @@ ClientRequest::process_op(instance_handle_t &ihref, Ref<PG> &pg)
   }));
 }
 
-auto ClientRequest::reply_op_error(const Ref<PG>& pg, int err)
-{
-  logger().debug("{}: replying with error {}", *this, err);
-  auto reply = crimson::make_message<MOSDOpReply>(
-    m.get(), err, pg->get_osdmap_epoch(),
-    m->get_flags() & (CEPH_OSD_FLAG_ACK|CEPH_OSD_FLAG_ONDISK),
-    !m->has_flag(CEPH_OSD_FLAG_RETURNVEC));
-  reply->set_reply_versions(eversion_t(), 0);
-  reply->set_op_returns(std::vector<pg_log_op_return_item_t>{});
-  return conn->send(std::move(reply)).then([] {
-    return seastar::make_ready_future<ClientRequest::seq_mode_t>
-      (seq_mode_t::OUT_OF_ORDER);
-  });
-}
-
 ClientRequest::interruptible_future<ClientRequest::seq_mode_t>
 ClientRequest::do_process(
   instance_handle_t &ihref,