in client/session.go [1101:1120]
func (s *Session) reconnect() bool {
var err error
var connectedSuccess = false
for i := 0; i < s.config.ConnectRetryMax; i++ {
for e := endPointList.Front(); e != nil; e = e.Next() {
err = s.initClusterConn(e.Value.(endPoint))
if err == nil {
connectedSuccess = true
break
} else {
log.Println("Connection refused:", e.Value.(endPoint))
}
}
if connectedSuccess {
break
}
}
return connectedSuccess
}