Skip to content

Commit

Permalink
more
Browse files Browse the repository at this point in the history
  • Loading branch information
shanth96 committed Oct 25, 2024
1 parent 5d38207 commit c019d89
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions go/vt/topo/zk2topo/zk_conn.go
Original file line number Diff line number Diff line change
Expand Up @@ -259,6 +259,7 @@ func (c *ZkConn) withRetry(ctx context.Context, action func(conn *zk.Conn) error
var conn *zk.Conn
conn, err = c.getConn(ctx)
if err != nil {
log.Warningf("withRetry Cant connect. Err:%v", err)
// We can't connect, try again.
continue
}
Expand All @@ -268,6 +269,7 @@ func (c *ZkConn) withRetry(ctx context.Context, action func(conn *zk.Conn) error
if err != zk.ErrConnectionClosed {
// It worked, or it failed for another reason
// than connection related.
log.Warningf("withRetry. Returning error. Err:%v", err)
return
}

Expand Down

0 comments on commit c019d89

Please sign in to comment.