hotfix : handle nil reply

cmd/syncer.go

@@ -501,7 +501,9 @@ func (sc *SyncerCmd) runSingle(runWait usync.WaitCloser, cfgs []syncer.SyncerCon
 			sc.logger.Infof("start syncer : %v", cfg)
 			err := sy.RunLeader()
 			runWait.Close(err)
-		}, nil)
+		}, func(i interface{}) {
+			runWait.Close(fmt.Errorf("panic : %v", i))
+		})
 
 		usync.SafeGo(func() {
 			<-runWait.Done()

pkg/redis/client/cluster/batch.go

@@ -192,6 +192,9 @@ func (bat *Batch) doBatch(batch *nodeBatch) {
 	for i := range batch.cmds {
 		reply, err := conn.receive()
 		if err != nil {
+			if err == common.ErrNil {
+				continue
+			}
 			batch.err = err
 			conn.shutdown()
 			batch.done <- 1

pkg/redis/client/cluster/conn.go

@@ -251,9 +251,6 @@ func (conn *redisConn) readReply() (interface{}, error) {
 			return string(line[1:]), nil
 		}
 	case '-':
-		if common.IsNilReply(line) {
-			return nil, common.ErrNil
-		}
 		return common.RedisError(string(line[1:])), nil
 	case ':':
 		return parseInt(line[1:])

pkg/redis/client/conn/redis_conn.go

@@ -242,6 +242,10 @@ func (tb *batcher) Exec() ([]interface{}, error) {
 	for i := 0; i < receiveSize; i++ {
 		rpl, err := tb.conn.receive()
 		if err != nil {
+			if err == common.ErrNil {
+				replies = append(replies, nil)
+				continue
+			}
 			tb.conn.Close()
 			return nil, err
 		}

pkg/redis/client/proto/reader.go

@@ -120,7 +120,7 @@ func (r *Reader) ReadLine() ([]byte, error) {
 	}
 
 	// Compatible with RESP2
-	if IsNilReply(line) {
+	if common.IsNilReply(line) {
 		return nil, common.ErrNil
 	}
 
@@ -551,10 +551,3 @@ func replyLen(line []byte) (n int, err error) {
 	}
 	return n, nil
 }
-
-// IsNilReply detects redis.Nil of RESP2.
-func IsNilReply(line []byte) bool {
-	return len(line) == 3 &&
-		(line[0] == RespString || line[0] == RespArray) &&
-		line[1] == '-' && line[2] == '1'
-}