map<int, set<hobject_t> > pull_from_peer;
void sub_op_push(OpRequestRef op);
- void sub_op_push_reply(OpRequestRef op) {}
+ void sub_op_push_reply(OpRequestRef op);
void sub_op_pull(OpRequestRef op) {}
void _do_push(OpRequestRef op) {}
op->soid = soid;
}
-void ReplicatedPG::sub_op_push_reply(OpRequestRef op)
+void ReplicatedBackend::sub_op_push_reply(OpRequestRef op)
{
MOSDSubOpReply *reply = static_cast<MOSDSubOpReply*>(op->request);
const hobject_t& soid = reply->get_poid();
void _committed_pushed_object(epoch_t epoch, eversion_t lc);
void recover_got(hobject_t oid, eversion_t v);
void _failed_push(int from, const hobject_t &soid);
- void sub_op_push_reply(OpRequestRef op);
bool handle_push_reply(int peer, PushReplyOp &op, PushOp *reply);
void sub_op_pull(OpRequestRef op);
void handle_pull(int peer, PullOp &op, PushOp *reply);