ceph_assert(!pulling.count(soid));
pull_from_peer[fromshard].insert(soid);
- PullInfo &pi = pulling[soid];
+ pull_info_t &pi = pulling[soid];
pi.from = fromshard;
pi.soid = soid;
pi.head_ctx = headctx;
return false;
}
- PullInfo &pi = piter->second;
+ pull_info_t &pi = piter->second;
if (pi.recovery_info.size == (uint64_t(-1))) {
pi.recovery_info.size = pop.recovery_info.size;
pi.recovery_info.copy_subset.intersection_of(
}
void ReplicatedBackend::clear_pull_from(
- map<hobject_t, PullInfo>::iterator piter)
+ map<hobject_t, pull_info_t>::iterator piter)
{
auto from = piter->second.from;
pull_from_peer[from].erase(piter->second.soid);
}
void ReplicatedBackend::clear_pull(
- map<hobject_t, PullInfo>::iterator piter,
+ map<hobject_t, pull_info_t>::iterator piter,
bool clear_pull_from_peer)
{
if (clear_pull_from_peer) {
std::map<hobject_t, std::map<pg_shard_t, PushInfo>> pushing;
// pull
- struct PullInfo {
+ struct pull_info_t {
pg_shard_t from;
hobject_t soid;
ObjectRecoveryProgress recovery_progress;
}
};
- std::map<hobject_t, PullInfo> pulling;
+ std::map<hobject_t, pull_info_t> pulling;
// Reverse mapping from osd peer to objects being pulled from that peer
std::map<pg_shard_t, std::set<hobject_t> > pull_from_peer;
void clear_pull(
- std::map<hobject_t, PullInfo>::iterator piter,
+ std::map<hobject_t, pull_info_t>::iterator piter,
bool clear_pull_from_peer = true);
void clear_pull_from(
- std::map<hobject_t, PullInfo>::iterator piter);
+ std::map<hobject_t, pull_info_t>::iterator piter);
void _do_push(OpRequestRef op);
void _do_pull_response(OpRequestRef op);