From: Samuel Just <sam.just@inktank.com>
Date: Sun, 1 Sep 2013 20:49:53 +0000 (-0700)
Subject: ReplicatedPG/Backend: shuffle do_pull/do_push_reply
X-Git-Tag: v0.71~68^2~21
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=666a316d5a8973fbaa2dddbc722c565b9ab83fff;p=ceph.git

ReplicatedPG/Backend: shuffle do_pull/do_push_reply

Signed-off-by: Samuel Just <sam.just@inktank.com>
---

diff --git a/src/osd/ReplicatedBackend.h b/src/osd/ReplicatedBackend.h
index c4f501360d8d..bba797e5ae5e 100644
--- a/src/osd/ReplicatedBackend.h
+++ b/src/osd/ReplicatedBackend.h
@@ -213,8 +213,8 @@ private:
       _do_push(op);
     }
   }
-  void do_pull(OpRequestRef op) {}
-  void do_push_reply(OpRequestRef op) {}
+  void do_pull(OpRequestRef op);
+  void do_push_reply(OpRequestRef op);
 
   bool handle_push_reply(int peer, PushReplyOp &op, PushOp *reply) { return true; }
   void handle_pull(int peer, PullOp &op, PushOp *reply) {}
diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc
index 32a3878242c6..5560813af8e6 100644
--- a/src/osd/ReplicatedPG.cc
+++ b/src/osd/ReplicatedPG.cc
@@ -1633,7 +1633,7 @@ void ReplicatedBackend::_do_pull_response(OpRequestRef op)
   get_parent()->queue_transaction(t);
 }
 
-void ReplicatedPG::do_pull(OpRequestRef op)
+void ReplicatedBackend::do_pull(OpRequestRef op)
 {
   MOSDPGPull *m = static_cast<MOSDPGPull *>(op->request);
   assert(m->get_header().type == MSG_OSD_PG_PULL);
@@ -1649,7 +1649,7 @@ void ReplicatedPG::do_pull(OpRequestRef op)
   send_pushes(m->get_priority(), replies);
 }
 
-void ReplicatedPG::do_push_reply(OpRequestRef op)
+void ReplicatedBackend::do_push_reply(OpRequestRef op)
 {
   MOSDPGPushReply *m = static_cast<MOSDPGPushReply *>(op->request);
   assert(m->get_header().type == MSG_OSD_PG_PUSH_REPLY);
diff --git a/src/osd/ReplicatedPG.h b/src/osd/ReplicatedPG.h
index 8562150fdaa9..cc3f9f571345 100644
--- a/src/osd/ReplicatedPG.h
+++ b/src/osd/ReplicatedPG.h
@@ -906,8 +906,6 @@ public:
     ThreadPool::TPHandle &handle);
   void do_backfill(OpRequestRef op);
 
-  void do_pull(OpRequestRef op);
-  void do_push_reply(OpRequestRef op);
   RepGather *trim_object(const hobject_t &coid);
   void snap_trimmer();
   int do_osd_ops(OpContext *ctx, vector<OSDOp>& ops);