Browse Source
Update weed/worker/client.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
pull/7838/head
Chris Lu
2 months ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with
1 additions and
1 deletions
-
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 { |
|
|
|
|
