]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/osd: do not move op_params_p in fill_op_params_bump_pg_version()
authorKefu Chai <kchai@redhat.com>
Sun, 7 Feb 2021 06:46:12 +0000 (14:46 +0800)
committerKefu Chai <kchai@redhat.com>
Tue, 9 Feb 2021 03:38:22 +0000 (11:38 +0800)
it's confusing to move the parameter for updating it.

Signed-off-by: Kefu Chai <kchai@redhat.com>
src/crimson/osd/pg.cc
src/crimson/osd/pg.h

index 874a8b227030b57400d2e42aed0bca3fcdf64ed3..4aeec8dd6ac5195d1a80d4cee1793438f2196c6b 100644 (file)
@@ -620,8 +620,8 @@ seastar::future<> PG::submit_transaction(const OpInfo& op_info,
   });
 }
 
-osd_op_params_t&& PG::fill_op_params_bump_pg_version(
-  osd_op_params_t&& osd_op_p,
+void PG::fill_op_params_bump_pg_version(
+  osd_op_params_t& osd_op_p,
   Ref<MOSDOp> m,
   const bool user_modify)
 {
@@ -633,7 +633,6 @@ osd_op_params_t&& PG::fill_op_params_bump_pg_version(
   if (user_modify) {
     osd_op_p.user_at_version = osd_op_p.at_version.version;
   }
-  return std::move(osd_op_p);
 }
 
 seastar::future<Ref<MOSDOpReply>> PG::handle_failed_op(
@@ -736,16 +735,13 @@ PG::do_osd_ops(
          "do_osd_ops: {} - object {} submitting txn",
          *m,
          obc->obs.oi.soid);
-        auto filled_osd_op_p = fill_op_params_bump_pg_version(
-          std::move(osd_op_p),
-          std::move(m),
-          user_modify);
+        fill_op_params_bump_pg_version(osd_op_p, std::move(m), user_modify);
        return submit_transaction(
           op_info,
-          filled_osd_op_p.req->ops,
+          osd_op_p.req->ops,
           std::move(obc),
           std::move(txn),
-          std::move(filled_osd_op_p));
+          std::move(osd_op_p));
       });
   }).safe_then([this, m, obc, rvec = op_info.allows_returnvec()] {
     // TODO: should stop at the first op which returns a negative retval,
index 38fb3613aecca90fa2c7a6cc9eeeb61dad3d6e2b..4c9e74d9fcb86547e314dfcea1d71d108bc5bf31 100644 (file)
@@ -518,8 +518,8 @@ private:
   void do_peering_event(
     const boost::statechart::event_base &evt,
     PeeringCtx &rctx);
-  osd_op_params_t&& fill_op_params_bump_pg_version(
-    osd_op_params_t&& osd_op_p,
+  void fill_op_params_bump_pg_version(
+    osd_op_params_t& osd_op_p,
     Ref<MOSDOp> m,
     const bool user_modify);
   seastar::future<Ref<MOSDOpReply>> handle_failed_op(