diff --git a/src/redis-shake/sync.go b/src/redis-shake/sync.go index 636b8ef..5c86495 100644 --- a/src/redis-shake/sync.go +++ b/src/redis-shake/sync.go @@ -425,8 +425,8 @@ func (cmd *CmdSync) SyncCommand(reader *bufio.Reader, target, auth_type, passwd // cmd.SyncStat.Delay.Add(time.Now().Sub(node.t).Nanoseconds()) metric.MetricVar.AddDelay(uint64(time.Now().Sub(node.t).Nanoseconds()) / 1000000) // ms node = nil - } else if node.id > id { - log.Panicf("receive id invalid: node-id[%v] > receive-id[%v]", node.id, id) + } else if node.id < id { + log.Panicf("receive id invalid: node-id[%v] < receive-id[%v]", node.id, id) } } }