add debug log of sending and receiving command

src/redis-shake/common/common.go

@@ -15,6 +15,12 @@ const (
 	// GolangSecurityTime = "2006-01-02 15:04:05"
 	ReaderBufferSize = bytesize.MB * 32
 	WriterBufferSize = bytesize.MB * 8
+
+	LogLevelNone  = "none"
+	LogLevelError = "error"
+	LogLevelWarn  = "warn"
+	LogLevelInfo  = "info"
+	LogLevelAll   = "all"
 )
 
 var (

src/redis-shake/main/main.go

@@ -230,17 +230,17 @@ func sanitizeOptions(tp string) error {
 	// set log level
 	var logDeepLevel log.LogLevel
 	switch conf.Options.LogLevel {
-	case "none":
+	case utils.LogLevelNone:
 		logDeepLevel = log.LEVEL_NONE
-	case "error":
+	case utils.LogLevelError:
 		logDeepLevel = log.LEVEL_ERROR
-	case "warn":
+	case utils.LogLevelWarn:
 		logDeepLevel = log.LEVEL_WARN
 	case "":
 		fallthrough
-	case "info":
+	case utils.LogLevelInfo:
 		logDeepLevel = log.LEVEL_INFO
-	case "all":
+	case utils.LogLevelAll:
 		logDeepLevel = log.LEVEL_DEBUG
 	default:
 		return fmt.Errorf("invalid log level[%v]", conf.Options.LogLevel)

src/redis-shake/sync.go

@@ -361,6 +361,11 @@ func (cmd *CmdSync) SyncCommand(reader *bufio.Reader, target, auth_type, passwd
 	var sendId, recvId atomic2.Int64
 
 	go func() {
+		if conf.Options.Psync == false {
+			log.Warn("GetFakeSlaveOffset not enable when psync == false")
+			return
+		}
+
 		srcConn := utils.OpenRedisConnWithTimeout(conf.Options.SourceAddress, conf.Options.SourceAuthType,
 			conf.Options.SourcePasswordRaw, time.Duration(10)*time.Minute, time.Duration(10)*time.Minute)
 		ticker := time.NewTicker(10 * time.Second)
@@ -395,7 +400,11 @@ func (cmd *CmdSync) SyncCommand(reader *bufio.Reader, target, auth_type, passwd
 	go func() {
 		var node *delayNode
 		for {
-			_, err := c.Receive()
+			reply, err := c.Receive()
+
+			// print debug log of receive reply
+			log.Debugf("receive reply: [%v], error: [%v]", reply, err)
+
 			if conf.Options.Metric == false {
 				continue
 			}
@@ -465,6 +474,15 @@ func (cmd *CmdSync) SyncCommand(reader *bufio.Reader, target, auth_type, passwd
 				metric.MetricVar.AddPullCmdCount(1)
 
 				if scmd != "ping" {
+					// print debug log of send command
+					if conf.Options.LogLevel == utils.LogLevelAll {
+						strArgv := make([]string, len(argv))
+						for i, ele := range argv {
+							strArgv[i] = string(ele)
+						}
+						log.Debugf("send command: [%s %v]", scmd, strArgv)
+					}
+
 					if strings.EqualFold(scmd, "select") {
 						if len(argv) != 1 {
 							log.Panicf("select command len(args) = %d", len(argv))