From 83055166cfa596ef6a91cbb1fdbde40c1c7298a0 Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期三, 16 九月 2020 18:34:58 +0800
Subject: [PATCH] handleUserEvent add log in serf.go
---
serf/serf.go | 6 ++++++
1 files changed, 6 insertions(+), 0 deletions(-)
diff --git a/serf/serf.go b/serf/serf.go
index 5ac54b4..4c85bf3 100644
--- a/serf/serf.go
+++ b/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
}
--
Gitblit v1.8.0