diff --git a/internal/nodes/node.go b/internal/nodes/node.go index 94be1f5..0faa1bf 100644 --- a/internal/nodes/node.go +++ b/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{ diff --git a/internal/nodes/system_services.go b/internal/nodes/system_services.go index 3a7cacf..2294da6 100644 --- a/internal/nodes/system_services.go +++ b/internal/nodes/system_services.go @@ -20,10 +20,12 @@ import ( func init() { var manager = NewSystemServiceManager() events.On(events.EventReload, func() { - err := manager.Setup() - if err != nil { - remotelogs.Error("SYSTEM_SERVICE", "setup system services failed: "+err.Error()) - } + goman.New(func() { + err := manager.Setup() + if err != nil { + remotelogs.Error("SYSTEM_SERVICE", "setup system services failed: "+err.Error()) + } + }) }) }