]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/osd_operations: Use crimson::net::make_message() in client_request
authorAmnon Hanuhov <ahanukov@redhat.com>
Tue, 13 Apr 2021 11:59:43 +0000 (14:59 +0300)
committerAmnon Hanuhov <ahanukov@redhat.com>
Thu, 6 May 2021 17:22:05 +0000 (20:22 +0300)
Signed-off-by: Amnon Hanuhov <ahanukov@redhat.com>
src/crimson/osd/osd_operations/client_request.cc

index 09e10a1a7b4d86720556e40141375693b936bebf..a1df23b6a1dccde1bfc54d35c2763cc488c593c3 100644 (file)
@@ -172,7 +172,7 @@ ClientRequest::process_op(Ref<PG> &pg)
       [this, pg](bool completed, int ret) mutable
       -> PG::load_obc_iertr::future<> {
       if (completed) {
-        auto reply = make_message<MOSDOpReply>(
+        auto reply = crimson::net::make_message<MOSDOpReply>(
           m.get(), ret, pg->get_osdmap_epoch(),
           CEPH_OSD_FLAG_ACK | CEPH_OSD_FLAG_ONDISK, false);
         return conn->send(std::move(reply));
@@ -231,7 +231,7 @@ ClientRequest::do_process(Ref<PG>& pg, crimson::osd::ObjectContextRef obc)
       return seastar::now();
     } else if (const hobject_t& hoid = m->get_hobj();
                !pg->get_peering_state().can_serve_replica_read(hoid)) {
-      auto reply = make_message<MOSDOpReply>(
+      auto reply = crimson::net::make_message<MOSDOpReply>(
        m.get(), -EAGAIN, pg->get_osdmap_epoch(),
        m->get_flags() & (CEPH_OSD_FLAG_ACK|CEPH_OSD_FLAG_ONDISK),
        !m->has_flag(CEPH_OSD_FLAG_RETURNVEC));