Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
Signed-off-by: kpango <[email protected]>
  • Loading branch information
kpango committed Jan 30, 2020
1 parent 4ef6534 commit 1cab9d4
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pkg/gateway/vald/service/gateway.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 1cab9d4

Please sign in to comment.