update sources to v12.1.1

[ceph.git] / ceph / src / osdc / Objecter.h

diff --git a/ceph/src/osdc/Objecter.h b/ceph/src/osdc/Objecter.h
index 4efdb9d08b0690b4845dee37c2cfa807430348d8..ee40e76a5307e8e8a2bd8479c5889fe36e92c518 100644 (file)
--- a/ceph/src/osdc/Objecter.h
+++ b/ceph/src/osdc/Objecter.h
@@ -2083,7 +2083,9 @@ private:
     }
   }
   void ms_fast_dispatch(Message *m) override {
-    ms_dispatch(m);
+    if (!ms_dispatch(m)) {
+      m->put();
+    }
   }
 
   void handle_osd_op_reply(class MOSDOpReply *m);
@@ -2201,7 +2203,7 @@ public:
       onfinish);
     submit_command(c, ptid);
   }
-  void pg_command(pg_t pgid, vector<string>& cmd,
+  void pg_command(pg_t pgid, const vector<string>& cmd,
                 const bufferlist& inbl, ceph_tid_t *ptid,
                 bufferlist *poutbl, string *prs, Context *onfinish) {
     CommandOp *c = new CommandOp(