Add decay factor for reconnecting

Author: keimoon

conn.go

@@ -107,14 +107,18 @@ func (c *Conn) fail() {
 }
 
 func (c *Conn) reconnect() {
+	sleepTime := Config.ReconnectTime
 	for {
 		c.mutex.Lock()
 		if err := c.connect(c.address, 0); err == nil {
 			c.mutex.Unlock()
 			break
 		}
 		c.mutex.Unlock()
-		time.Sleep(time.Duration(Config.ReconnectTime) * time.Second)
+		time.Sleep(time.Duration(sleepTime) * time.Second)
+		if sleepTime < 30 {
+			sleepTime += 2
+		}
 	}
 
 }

number.go

@@ -44,7 +44,7 @@ type VarInt int64
 
 // Bytes converts a VarInt to a byte array
 func (x VarInt) Bytes() []byte {
-	b := []byte{0, 0, 0, 0, 0, 0, 0, 0, 0}
+	b := []byte{0, 0, 0, 0, 0, 0, 0, 0, 0, 0} // 9.14 bytes are needed
 	ux := uint64(x) << 1
 	if x < 0 {
 		ux = ^ux

sentinel.go

@@ -213,12 +213,16 @@ func (s *Sentinel) reconnect() {
 	s.subs.Close()
 	s.subConn.Close()
 	s.conn.Close()
+	sleepTime := Config.ReconnectTime
 	for {
 		err := s.connect()
 		if err == nil {
 			break
 		}
-		time.Sleep(time.Duration(Config.ReconnectTime) * time.Second)
+		time.Sleep(time.Duration(sleepTime) * time.Second)
+		if sleepTime < 30 {
+			sleepTime += 2
+		}
 	}
 }
 
@@ -267,7 +271,7 @@ func (s *Sentinel) getInstanceAddress(name string) string {
 	for {
 		rep, err := NewCommand("SENTINEL", "get-master-addr-by-name", name).Run(s.conn)
 		if err != nil {
-			time.Sleep(time.Duration(Config.ReconnectTime) * time.Second)
+			time.Sleep(2 * time.Second)
 			continue
 		}
 		if !rep.IsArray() {