originalRequestCount, p.needRequestUpdate))
}
for requestHeap.Len() != 0 && maxRequests(current.Requests.GetCardinality()+current.Cancelled.GetCardinality()) < p.nominalMaxRequests() {
originalRequestCount, p.needRequestUpdate))
}
for requestHeap.Len() != 0 && maxRequests(current.Requests.GetCardinality()+current.Cancelled.GetCardinality()) < p.nominalMaxRequests() {
existing := t.requestingPeer(req)
if existing != nil && existing != p {
// Don't steal from the poor.
existing := t.requestingPeer(req)
if existing != nil && existing != p {
// Don't steal from the poor.