|
|
|
@ -2919,8 +2919,8 @@ namespace nodetool
|
|
|
|
|
const uint32_t index = stripe - 1;
|
|
|
|
|
CRITICAL_REGION_LOCAL(m_used_stripe_peers_mutex);
|
|
|
|
|
MINFO("adding stripe " << stripe << " peer: " << context.m_remote_address.str());
|
|
|
|
|
std::remove_if(m_used_stripe_peers[index].begin(), m_used_stripe_peers[index].end(),
|
|
|
|
|
[&context](const epee::net_utils::network_address &na){ return context.m_remote_address == na; });
|
|
|
|
|
m_used_stripe_peers[index].erase(std::remove_if(m_used_stripe_peers[index].begin(), m_used_stripe_peers[index].end(),
|
|
|
|
|
[&context](const epee::net_utils::network_address &na){ return context.m_remote_address == na; }), m_used_stripe_peers[index].end());
|
|
|
|
|
m_used_stripe_peers[index].push_back(context.m_remote_address);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@ -2933,8 +2933,8 @@ namespace nodetool
|
|
|
|
|
const uint32_t index = stripe - 1;
|
|
|
|
|
CRITICAL_REGION_LOCAL(m_used_stripe_peers_mutex);
|
|
|
|
|
MINFO("removing stripe " << stripe << " peer: " << context.m_remote_address.str());
|
|
|
|
|
std::remove_if(m_used_stripe_peers[index].begin(), m_used_stripe_peers[index].end(),
|
|
|
|
|
[&context](const epee::net_utils::network_address &na){ return context.m_remote_address == na; });
|
|
|
|
|
m_used_stripe_peers[index].erase(std::remove_if(m_used_stripe_peers[index].begin(), m_used_stripe_peers[index].end(),
|
|
|
|
|
[&context](const epee::net_utils::network_address &na){ return context.m_remote_address == na; }), m_used_stripe_peers[index].end());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
template<class t_payload_net_handler>
|
|
|
|
|