diff --git a/client/daemon/peer/peertask_file.go b/client/daemon/peer/peertask_file.go index 959d39a8ef2..1ff537110ff 100644 --- 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 index f7a1c2ee545..fa0cfdc2ad0 100644 --- 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,