]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
OSD: use OpRequestRef& for a few require_* functions
authorGreg Farnum <greg@inktank.com>
Mon, 28 Jul 2014 21:08:30 +0000 (14:08 -0700)
committerSage Weil <sage@redhat.com>
Tue, 12 Aug 2014 22:25:28 +0000 (15:25 -0700)
Signed-off-by: Greg Farnum <greg@inktank.com>
(cherry picked from commit eb2f1ea2c33647934af878b504383829f5a198ce)

src/osd/OSD.cc
src/osd/OSD.h

index 3ccedcb3e83774a754af776b9f09d15a23d73c4d..deca111dd10d81d7f169b2bed41f4b0ac7abb3ed 100644 (file)
@@ -6127,7 +6127,7 @@ bool OSD::require_mon_peer(Message *m)
   return true;
 }
 
-bool OSD::require_osd_peer(OpRequestRef op)
+bool OSD::require_osd_peer(OpRequestRef& op)
 {
   if (!op->get_req()->get_connection()->peer_is_osd()) {
     dout(0) << "require_osd_peer received from non-osd " << op->get_req()->get_connection()->get_peer_addr()
@@ -6171,7 +6171,7 @@ bool OSD::require_up_osd_peer(OpRequestRef& op, OSDMapRef& map,
  * require that we have same (or newer) map, and that
  * the source is the pg primary.
  */
-bool OSD::require_same_or_newer_map(OpRequestRef op, epoch_t epoch)
+bool OSD::require_same_or_newer_map(OpRequestRef& op, epoch_t epoch)
 {
   Message *m = op->get_req();
   dout(15) << "require_same_or_newer_map " << epoch << " (i am " << osdmap->get_epoch() << ") " << m << dendl;
index 080be8c13f4e172859f00630865578b6bc4b9a20..efb3a0c460bd309e76aa0df5300678124fff5ef4 100644 (file)
@@ -1513,11 +1513,11 @@ protected:
   void repeer(PG *pg, map< int, map<spg_t,pg_query_t> >& query_map);
 
   bool require_mon_peer(Message *m);
-  bool require_osd_peer(OpRequestRef op);
+  bool require_osd_peer(OpRequestRef& op);
   bool require_up_osd_peer(OpRequestRef& Op, OSDMapRef& map,
                            epoch_t their_epoch);
 
-  bool require_same_or_newer_map(OpRequestRef op, epoch_t e);
+  bool require_same_or_newer_map(OpRequestRef& op, epoch_t e);
 
   void handle_pg_query(OpRequestRef op);
   void handle_pg_notify(OpRequestRef op);