From c43a8e3e552e00b653e40f45615bf46b2ddd40e2 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期四, 16 一月 2020 14:13:07 +0800
Subject: [PATCH] add log
---
mangos.go | 23 +++++++++++------------
1 files changed, 11 insertions(+), 12 deletions(-)
diff --git a/mangos.go b/mangos.go
index 0272673..dac46e2 100644
--- a/mangos.go
+++ b/mangos.go
@@ -49,6 +49,7 @@
// ch <- msg
// }
//}
+ fmt.Println("<-pub.pubCh,pub.surveyors.Len:",pub.surveyors.Cardinality())
if pub.surveyors.Cardinality() >0 {
sendB, _ := json.Marshal(msg)
discoveryServer.PublishMsg(string(sendB))
@@ -63,21 +64,19 @@
//}
removedNodes := pub.surveyors.Difference(nodeIds)
addedNodes := nodeIds.Difference(pub.surveyors)
- if len(nodeIds.ToSlice()) >0 {
- if addedNodes.Cardinality() >0 { //鏈夋柊鑺傜偣涓婄嚎鐨勬椂鍊欙紝闇�瑕佸彂涓�娆℃秷鎭紝鑺傜偣绂荤嚎鐨勬椂鍊欎笉鐢ㄧ
- fmt.Println("removedNodes:", removedNodes, "addedNodes:", addedNodes)
- if len(msgCache) > 0 {
- for _,cMsg := range msgCache {
- sendB, _ := json.Marshal(cMsg)
- discoveryServer.PublishMsg(string(sendB))
- }
+
+ if addedNodes.Cardinality() >0 { //鏈夋柊鑺傜偣涓婄嚎鐨勬椂鍊欙紝闇�瑕佸彂涓�娆℃秷鎭紝鑺傜偣绂荤嚎鐨勬椂鍊欎笉鐢ㄧ
+ fmt.Println("removedNodes:", removedNodes, "addedNodes:", addedNodes)
+ if len(msgCache) > 0 {
+ for _,cMsg := range msgCache {
+ sendB, _ := json.Marshal(cMsg)
+ discoveryServer.PublishMsg(string(sendB))
}
}
- pub.surveyors = nodeIds
- } else {//璁㈤槄鑰呭叏閮ㄩ樀浜�
- pub.surveyors = nodeIds
- time.Sleep(10 * time.Millisecond)
}
+
+ pub.surveyors = nodeIds
+ time.Sleep(10 * time.Millisecond)
}
}
}()
--
Gitblit v1.8.0