log an error and bail out when receiving a piece we have already rece…

…ived instead of aborting
cenkalti · Oct 19, 2021 · 1a158d7 · 1a158d7
1 parent e27ba11
commit 1a158d7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/torrent/torrent_write.go b/torrent/torrent_write.go
@@ -2,7 +2,6 @@ package torrent
 
 import (
 	"errors"
-	"fmt"
 
 	"github.com/cenkalti/rain/internal/peer"
 	"github.com/cenkalti/rain/internal/peerprotocol"
@@ -41,7 +40,8 @@ func (t *torrent) handlePieceWriteDone(pw *piecewriter.PieceWriter) {
 
 	pw.Piece.Done = true
 	if t.bitfield.Test(pw.Piece.Index) {
-		panic(fmt.Sprintf("already have the piece #%d", pw.Piece.Index))
+		t.log.Errorf("already have the piece #%d", pw.Piece.Index)
+		return
 	}
 	t.mBitfield.Lock()
 	t.bitfield.Set(pw.Piece.Index)