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