From 2cd1af13bc4e7aec4c85b9fe88db2d294af6468f Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期日, 08 十月 2023 11:24:37 +0800
Subject: [PATCH] 修复集群同步功能

---
 system-service/serf/sync.go |   25 +++++++++++++++++++++++++
 1 files changed, 25 insertions(+), 0 deletions(-)

diff --git a/system-service/serf/sync.go b/system-service/serf/sync.go
index ed1089c..c5710da 100644
--- a/system-service/serf/sync.go
+++ b/system-service/serf/sync.go
@@ -6,6 +6,7 @@
 	"basic.com/valib/bhomeclient.git"
 	"basic.com/valib/logger.git"
 	"context"
+	"encoding/json"
 	"github.com/gogo/protobuf/proto"
 	"nanomsg.org/go-mangos"
 	"nanomsg.org/go-mangos/protocol/req"
@@ -112,6 +113,30 @@
 			select {
 			case <-ctx.Done():
 				return
+			case b := <-SyncProcMessageChan:
+				{
+					var procMsg ProcMessageEvent
+					err := json.Unmarshal(b, &procMsg)
+					if err != nil {
+						logger.Error("Unmarshal ProcMessageEvent ", err.Error())
+					} else {
+						err = hms.Publish(procMsg.Topic, procMsg.Payload)
+						if err != nil {
+							logger.Error("hms.Publish error ", err.Error())
+						}
+					}
+
+				}
+			default:
+				time.Sleep(50 * time.Millisecond)
+			}
+		}
+	}()
+	go func() {
+		for {
+			select {
+			case <-ctx.Done():
+				return
 			case b := <-syncSdkCompareCacheChan:
 				{
 					logger.Debug("SyncSdkCompareCache in,len(b):", len(b))

--
Gitblit v1.8.0