|
|
@ -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())
|
|
|
|
// cmd.SyncStat.Delay.Add(time.Now().Sub(node.t).Nanoseconds())
|
|
|
|
metric.MetricVar.AddDelay(uint64(time.Now().Sub(node.t).Nanoseconds()) / 1000000) // ms
|
|
|
|
metric.MetricVar.AddDelay(uint64(time.Now().Sub(node.t).Nanoseconds()) / 1000000) // ms
|
|
|
|
node = nil |
|
|
|
node = nil |
|
|
|
} else if node.id > id { |
|
|
|
} else if node.id < id { |
|
|
|
log.Panicf("receive id invalid: node-id[%v] > receive-id[%v]", node.id, id) |
|
|
|
log.Panicf("receive id invalid: node-id[%v] < receive-id[%v]", node.id, id) |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|