X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=requesting.go;h=59f6693c26dc84725d3a5ab448e2fba1ac65fe73;hb=c0a888ee179dd044c99cef7ffc2c8fe18b9243b2;hp=a3a7e1c3a9d5c5b35b7885274ac021d83193a41d;hpb=9d9556c97f0a6d8c805fc3724674122dbb706d5a;p=btrtrc.git diff --git a/requesting.go b/requesting.go index a3a7e1c3..59f6693c 100644 --- a/requesting.go +++ b/requesting.go @@ -171,9 +171,6 @@ func (p *Peer) getDesiredRequestState() (desired desiredRequestState) { allowedFast := p.peerAllowedFast.ContainsInt(pieceIndex) p.t.piece(pieceIndex).undirtiedChunksIter.Iter(func(ci request_strategy.ChunkIndex) { r := p.t.pieceRequestIndexOffset(pieceIndex) + ci - // if p.t.pendingRequests.Get(r) != 0 && !p.requestState.Requests.Contains(r) { - // return - // } if !allowedFast { // We must signal interest to request this. TODO: We could set interested if the // peers pieces (minus the allowed fast set) overlap with our missing pieces if @@ -189,7 +186,7 @@ func (p *Peer) getDesiredRequestState() (desired desiredRequestState) { } } if p.requestState.Cancelled.Contains(r) { - // Can't re-request. + // Can't re-request while awaiting acknowledgement. return } requestHeap.requestIndexes = append(requestHeap.requestIndexes, r)