From 1d2a5371cebea3bbe46a5ac0414311702cfea1da Mon Sep 17 00:00:00 2001 From: aliamerj Date: Wed, 12 Nov 2025 18:48:53 +0300 Subject: [PATCH] remove EOF skipping --- shared/management/client/grpc.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/shared/management/client/grpc.go b/shared/management/client/grpc.go index 5c298dcc6..1ab880d1b 100644 --- a/shared/management/client/grpc.go +++ b/shared/management/client/grpc.go @@ -180,7 +180,7 @@ func (c *GrpcClient) handleJobStream( // Main loop: receive, process, respond for { jobReq, err := c.receiveJobRequest(ctx, stream, serverPubKey) - if err != nil && err != io.EOF { + if err != nil { c.notifyDisconnected(err) s, _ := gstatus.FromError(err) switch s.Code() { @@ -309,7 +309,7 @@ func (c *GrpcClient) handleSyncStream(ctx context.Context, serverPubKey wgtypes. // blocking until error err = c.receiveUpdatesEvents(stream, serverPubKey, msgHandler) - if err != nil && err != io.EOF { + if err != nil { c.notifyDisconnected(err) s, _ := gstatus.FromError(err) switch s.Code() {