fix: change peerPacketReady to buffer channel (#256)

Signed-off-by: Jim Ma <majinjing3@gmail.com>
dragonflyoss · Jun 28, 2023 · 8198af0 · 8198af0
1 parent a033e5f
commit 8198af0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/client/daemon/peer/peertask_file.go b/client/daemon/peer/peertask_file.go
@@ -164,7 +164,7 @@ func newFilePeerTask(ctx context.Context,
 			request:          request,
 			peerPacketStream: peerPacketStream,
 			pieceManager:     pieceManager,
-			peerPacketReady:  make(chan bool),
+			peerPacketReady:  make(chan bool, 1),
 			peerID:           request.PeerId,
 			taskID:           result.TaskId,
 			singlePiece:      singlePiece,

diff --git a/client/daemon/peer/peertask_stream.go b/client/daemon/peer/peertask_stream.go
@@ -143,7 +143,7 @@ func newStreamPeerTask(ctx context.Context,
 			request:          request,
 			peerPacketStream: peerPacketStream,
 			pieceManager:     pieceManager,
-			peerPacketReady:  make(chan bool),
+			peerPacketReady:  make(chan bool, 1),
 			peerID:           request.PeerId,
 			taskID:           result.TaskId,
 			singlePiece:      singlePiece,