From 1cab9d40384f576b0909b8be0da224da35452eb5 Mon Sep 17 00:00:00 2001 From: kpango Date: Thu, 30 Jan 2020 14:21:50 +0900 Subject: [PATCH] fix Signed-off-by: kpango --- pkg/gateway/vald/service/gateway.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/gateway/vald/service/gateway.go b/pkg/gateway/vald/service/gateway.go index 24246a494e..b07b985086 100644 --- a/pkg/gateway/vald/service/gateway.go +++ b/pkg/gateway/vald/service/gateway.go @@ -342,14 +342,14 @@ func (g *gateway) DoMulti(ctx context.Context, } err = f(cctx, addr, agent.NewAgentClient(conn), copts...) if err != nil { - log.Debug(err) + log.Debug(addr, err) return err } atomic.AddUint32(&cur, 1) } return nil }) - if err != nil && atomic.LoadUint32(&cur) < limit { + if err != nil && cur < limit { return err } return nil