liuxiaolong
2020-09-16 b04c3b2bf52d57550e8bfdc7f09859962b7c1396
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
}