Merge pull request #16 from TheoMcGinley/infinite-retries-fix

Fixed infinite retries for failed TCP dial
5 years ago · 91a7cc9c64
parent ffcde39ba6 adf2c13a8c
commit 91a7cc9c64
1 changed files with 1 additions and 1 deletions
--- a/client.go
+++ b/client.go
@ -119,7 +119,7 @@ func (c *Client) Connect() (*Session, error) {
 	var try = 0
 	var success bool
 	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 {
 			c.Metrics.setConnectTime()
 			success = true