diff options
| author | Samuel Just <sam.just@inktank.com> | 2013-09-01 13:49:53 -0700 |
|---|---|---|
| committer | Samuel Just <sam.just@inktank.com> | 2013-09-14 00:45:32 -0700 |
| commit | b0511134e8ef40aec61f19bab9d771d85ece6f30 (patch) | |
| tree | e9669983f085c40b6259d6ba5551fa2e7f48eb54 | |
| parent | 1c040d59cc92499b496836e80f7da80bd66ab267 (diff) | |
| download | ceph-b0511134e8ef40aec61f19bab9d771d85ece6f30.tar.gz | |
ReplicatedPG/Backend: shuffle do_pull/do_push_reply
Signed-off-by: Samuel Just <sam.just@inktank.com>
| -rw-r--r-- | src/osd/ReplicatedBackend.h | 4 | ||||
| -rw-r--r-- | src/osd/ReplicatedPG.cc | 4 | ||||
| -rw-r--r-- | src/osd/ReplicatedPG.h | 2 |
3 files changed, 4 insertions, 6 deletions
diff --git a/src/osd/ReplicatedBackend.h b/src/osd/ReplicatedBackend.h index ec73f0469d2..beeb7dc6636 100644 --- a/src/osd/ReplicatedBackend.h +++ b/src/osd/ReplicatedBackend.h @@ -205,8 +205,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 181b5cc9cb6..7dbcea234dc 100644 --- a/src/osd/ReplicatedPG.cc +++ b/src/osd/ReplicatedPG.cc @@ -1623,7 +1623,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); @@ -1639,7 +1639,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 7e513e6bbdd..9b0d1d61f8d 100644 --- a/src/osd/ReplicatedPG.h +++ b/src/osd/ReplicatedPG.h @@ -899,8 +899,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); |