修复集群同步功能

zhangzengfei

2023-10-08 2cd1af13bc4e7aec4c85b9fe88db2d294af6468f

 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))