liuxiaolong
2020-09-16 b04c3b2bf52d57550e8bfdc7f09859962b7c1396
rm log
1个文件已修改
6 ■■■■ 已修改文件
serf/serf.go 6 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
serf/serf.go
@@ -1212,7 +1212,6 @@
    // Check if this message is too old
    curTime := s.eventClock.Time()
    s.logger.Printf("[WARN] serf: curTime %d", curTime)
    if curTime > LamportTime(len(s.eventBuffer)) &&
        eventMsg.LTime < curTime-LamportTime(len(s.eventBuffer)) {
        s.logger.Printf(
@@ -1230,7 +1229,6 @@
    if seen != nil && seen.LTime == eventMsg.LTime {
        for _, previous := range seen.Events {
            if previous.Equals(&userEvent) {
                s.logger.Printf("[WARN] serf: previous.Equals(&useEvent)")
                return false
            }
        }
@@ -1247,15 +1245,13 @@
    metrics.IncrCounter([]string{"serf", "events", eventMsg.Name}, 1)
    if s.config.EventCh != nil {
        s.logger.Printf("[WARN] serf: s.config.EventCh != nil")
        s.logger.Printf("[WARN] serf: s.config.EventCh <- UserEvent")
        s.config.EventCh <- UserEvent{
            LTime:    eventMsg.LTime,
            Name:     eventMsg.Name,
            Payload:  eventMsg.Payload,
            Coalesce: eventMsg.CC,
        }
    } else {
        s.logger.Printf("[WARN] serf: s.config.EventCh == nil")
    }
    return true
}