}
for i := range t.pieces {
t.updatePieceCompletion(i)
- t.pieces[i].QueuedForHash = true
+ // t.pieces[i].QueuedForHash = true
}
- go func() {
- for i := range t.pieces {
- t.verifyPiece(i)
- }
- }()
+ // go func() {
+ // for i := range t.pieces {
+ // t.verifyPiece(i)
+ // }
+ // }()
return nil
}
cl.mu.Unlock()
sum := t.hashPiece(piece)
cl.mu.Lock()
+ p.numVerifies++
p.Hashing = false
t.pieceHashed(piece, sum == p.Hash)
}
t.publishPieceChange(pieceIndex)
go t.verifyPiece(pieceIndex)
}
+
+func (t *Torrent) VerifyData() {
+ for i := range iter.N(t.NumPieces()) {
+ t.Piece(i).VerifyData()
+ }
+}