diff --git a/weed/worker/client.go b/weed/worker/client.go index 5b8df5763..2545ef5d8 100644 --- a/weed/worker/client.go +++ b/weed/worker/client.go @@ -345,7 +345,7 @@ func handleOutgoing( msgCh := make(chan *worker_pb.WorkerMessage, 1) errCh := make(chan error, 1) // Buffered to prevent blocking if the manager is busy - // Goroutine that performs the blocking stream.Send() calls. + // Goroutine that reads from msgCh and performs the blocking stream.Send() calls. go func() { for msg := range msgCh { if err := stream.Send(msg); err != nil {