handleUserEvent add log in serf.go

liuxiaolong

2020-09-16 83055166cfa596ef6a91cbb1fdbde40c1c7298a0

 serf/serf.go

@@ -1206,11 +1206,13 @@

   // Ignore if it is before our minimum event time
   if eventMsg.LTime < s.eventMinTime {
      s.logger.Printf("[WARN] serf: eventMsg.LTime: %d < s.eventMinTime:%d",eventMsg.LTime, s.eventMinTime)
      return false
   }

   // 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(
@@ -1228,6 +1230,7 @@
   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
         }
      }
@@ -1244,12 +1247,15 @@
   metrics.IncrCounter([]string{"serf", "events", eventMsg.Name}, 1)

   if s.config.EventCh != nil {
      s.logger.Printf("[WARN] serf: s.config.EventCh != nil")
      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
}