handleUserEvent add log in serf.go

liuxiaolong

2020-09-16 83055166cfa596ef6a91cbb1fdbde40c1c7298a0

handleUserEvent add log in serf.go

 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
}