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/service/SysService.go | 19 ++++++++++++-------
1 files changed, 12 insertions(+), 7 deletions(-)
diff --git a/system-service/service/SysService.go b/system-service/service/SysService.go
index 779b65e..5a95364 100644
--- a/system-service/service/SysService.go
+++ b/system-service/service/SysService.go
@@ -165,7 +165,7 @@
return true, isComplete, ""
}
-//upgrade
+// upgrade
func (sv SysService) Upgrade(identifier string, filename string) (bool, error) {
if !bakBeforeUpgrade() {
return false, errors.New("鏇存柊鍓嶅浠藉け璐�")
@@ -226,7 +226,7 @@
return true
}
-//鏇存柊绯荤粺绋嬪簭
+// 鏇存柊绯荤粺绋嬪簭
func updatePatch(identifier string, ext string) bool {
configPatchPath := ""
if config.Server.PatchPath != "" {
@@ -349,7 +349,7 @@
return cmd.Output()
}
-//涓婁紶澹伴煶鏂囦欢
+// 涓婁紶澹伴煶鏂囦欢
func (sv SysService) UploadVoice(fileBytes []byte, filename string) (string, error) {
fileExt := path.Ext(filename)
fileExt = strings.ToLower(fileExt)
@@ -382,18 +382,18 @@
return weedFilePath, err
}
-//鑾峰彇鎵�鏈夐厤缃�
+// 鑾峰彇鎵�鏈夐厤缃�
func (sv SysService) GetAllSetting() (settings []models.SysSetting, err error) {
settingModel := models.SysSetting{}
return settingModel.GetAllSetting()
}
-//鏇存柊閰嶇疆
+// 鏇存柊閰嶇疆
func (sv SysService) SaveSetting(setting models.SysSetting) (err error) {
return setting.SaveSetting(true)
}
-//鑾峰彇纭洏鍓╀綑绌洪棿
+// 鑾峰彇纭洏鍓╀綑绌洪棿
func (sv SysService) DiskInfo(dev string) (uint64, uint64) {
var stat syscall.Statfs_t
err := syscall.Statfs(dev, &stat)
@@ -406,13 +406,18 @@
return All, Free
}
-//鍚屾鏇存柊璁剧疆
+// 鍚屾鏇存柊璁剧疆
func PersistentWrapper(topic string, payloads []byte) {
if versionControlS.AuthorizationUpdateTopic == topic {
if err := json.Unmarshal(payloads, &AuthInfo); nil != err {
logger.Error("handleSubMsg failed to persistent:", topic, string(payloads))
}
}
+
+ if "sync-proc-message-to-serf" == topic {
+ logger.Debug("handleSubMsg sync-proc-message-to-serf")
+ ClusterSyncProcMessage(payloads)
+ }
}
// 鑾峰彇鎺堟潈鏂瑰紡鍜屾巿鏉冨瘑鐮�
--
Gitblit v1.8.0