Fixed infinite retries for failed TCP dial

This commit is contained in:
Theo McGinley 2019-02-09 14:35:31 +00:00
parent c0f3d20440
commit adf2c13a8c

View file

@ -119,7 +119,7 @@ func (c *Client) Connect() (*Session, error) {
var try = 0 var try = 0
var success bool var success bool
c.Metrics = initMetrics() c.Metrics = initMetrics()
for try <= c.config.Retry || !success { for try <= c.config.Retry && !success {
if tcpconn, err = net.DialTimeout("tcp", c.config.Address, time.Duration(c.config.ConnectTimeout)*time.Second); err == nil { if tcpconn, err = net.DialTimeout("tcp", c.config.Address, time.Duration(c.config.ConnectTimeout)*time.Second); err == nil {
c.Metrics.setConnectTime() c.Metrics.setConnectTime()
success = true success = true