<< dendl;
if (pop.version == eversion_t()) {
// replica doesn't have it!
- _failed_push(from, pop.soid);
+ _failed_pull(from, pop.soid);
return false;
}
}
}
-void ReplicatedBackend::_failed_push(pg_shard_t from, const hobject_t &soid)
+void ReplicatedBackend::_failed_pull(pg_shard_t from, const hobject_t &soid)
{
+ dout(20) << __func__ << ": " << soid << " from " << from << dendl;
list<pg_shard_t> fl = { from };
get_parent()->failed_push(fl, soid);
bufferlist data_received,
interval_set<uint64_t> *intervals_usable,
bufferlist *data_usable);
- void _failed_push(pg_shard_t from, const hobject_t &soid);
+ void _failed_pull(pg_shard_t from, const hobject_t &soid);
void send_pushes(int prio, map<pg_shard_t, vector<PushOp> > &pushes);
void prep_push_op_blank(const hobject_t& soid, PushOp *op);