优化代码

internal/nodes/node.go

@@ -483,7 +483,7 @@ func (this *Node) syncConfig(taskVersion int64) error {
 	}
 
 	// 获取同步任务
-	nodeCtx := rpcClient.Context()
+	var nodeCtx = rpcClient.Context()
 
 	// TODO 这里考虑只同步版本号有变更的
 	configResp, err := rpcClient.NodeRPC.FindCurrentNodeConfig(nodeCtx, &pb.FindCurrentNodeConfigRequest{

internal/nodes/system_services.go

@@ -20,11 +20,13 @@ import (
 func init() {
 	var manager = NewSystemServiceManager()
 	events.On(events.EventReload, func() {
+		goman.New(func() {
 			err := manager.Setup()
 			if err != nil {
 				remotelogs.Error("SYSTEM_SERVICE", "setup system services failed: "+err.Error())
 			}
 		})
+	})
 }
 
 // SystemServiceManager 系统服务管理