From c5654846d3b8b002284dee57aa50e95d67649f0e Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期二, 24 十月 2023 18:59:31 +0800
Subject: [PATCH] 集群退出密码
---
system-service/serf/sync.go | 19 ++++++++++++++++++-
1 files changed, 18 insertions(+), 1 deletions(-)
diff --git a/system-service/serf/sync.go b/system-service/serf/sync.go
index 8c831d8..d7338ee 100644
--- a/system-service/serf/sync.go
+++ b/system-service/serf/sync.go
@@ -52,9 +52,11 @@
nodes, e := nodeE.FindNodesByClusterId(c.ClusterId)
if e == nil && nodes != nil && len(nodes) > 0 {
var nodeIps []string
- for _, n := range nodes {
+ for idx, n := range nodes {
if n.NodeId != config.Server.AnalyServerId {
nodeIps = append(nodeIps, n.NodeIp)
+ } else {
+ nodeE = nodes[idx]
}
}
@@ -69,6 +71,21 @@
Agent, err = sdb.Init(c.ClusterId, c.Password, config.Server.AnalyServerId, nodeIps, config.ClusterSet.SerfSnapShotPath, conf)
if Agent != nil {
Agent.RegisterHandleEventFunc(HandleSerfEvent)
+
+ logger.Debugf("local node:", nodeE)
+ if nodeE.DriftState == "slave" {
+ chMsg := protomsg.DbChangeMessage{
+ Id: nodeE.ClusterId,
+ Table: protomsg.TableChanged_T_Cluster,
+ Action: protomsg.DbAction_Insert,
+ Info: "master2slave",
+ }
+ b, _ := json.Marshal(chMsg)
+ err = hms.Publish(bhomeclient.Proc_System_Service, b)
+ if err != nil {
+ logger.Error(err.Error())
+ }
+ }
logger.Debug("sync.Agent init success!")
} else {
logger.Debug("sync.Agent init fail!")
--
Gitblit v1.8.0