storagePiece := p.Storage()
var written int64
written, err = storagePiece.WriteTo(w)
- // TODO: Require the correct number of bytes were written to pass hash.
t.countBytesHashed(written)
return
}
if t.pieceAllDirty(piece) {
t.pendAllChunkSpecs(piece)
}
- if !t.wantPieceIndex(piece) {
+ if t.ignorePieceForRequests(piece) {
// t.logger.Printf("piece %d incomplete and unwanted", piece)
return
}
func (t *Torrent) wantReceiveChunk(reqIndex RequestIndex) bool {
pi := t.pieceIndexOfRequestIndex(reqIndex)
- if !t.wantPieceIndex(pi) {
+ if t.ignorePieceForRequests(pi) {
return false
}
if t.haveRequestIndexChunk(reqIndex) {