diff --git a/management/client/grpc.go b/management/client/grpc.go index 956aaebb2..2f4729e23 100644 --- a/management/client/grpc.go +++ b/management/client/grpc.go @@ -128,13 +128,7 @@ func (c *GrpcClient) Sync(ctx context.Context, sysInfo *system.Info, msgHandler return err } - streamErr := c.handleStream(ctx, *serverPubKey, sysInfo, msgHandler) - if c.conn.GetState() != connectivity.Shutdown { - if err := c.conn.Close(); err != nil { - log.Warnf("failed closing connection to Management service: %s", err) - } - } - return streamErr + return c.handleStream(ctx, *serverPubKey, sysInfo, msgHandler) } err := backoff.Retry(operation, defaultBackoff(ctx))