Add pending write helpers

[btrtrc.git] / torrent.go

diff --git a/torrent.go b/torrent.go
index 924561cd6d317b0d0eb9ec8cf1f3fb753fab86f7..38990144eef6b587a4200c37c5bd02385b9ceeac 100644 (file)
--- a/torrent.go
+++ b/torrent.go
@@ -645,11 +645,7 @@ func (t *torrent) pieceLength(piece int) (len_ pp.Integer) {
 func (t *torrent) hashPiece(piece int) (ps pieceSum) {
        hash := pieceHash.New()
        p := &t.Pieces[piece]
-       p.pendingWritesMutex.Lock()
-       for p.pendingWrites != 0 {
-               p.noPendingWrites.Wait()
-       }
-       p.pendingWritesMutex.Unlock()
+       p.waitNoPendingWrites()
        pl := t.Info.Piece(int(piece)).Length()
        n, err := t.data.WriteSectionTo(hash, int64(piece)*t.Info.PieceLength, pl)
        if err != nil {