From 7895021e64a767b425bbae3585cbd1437a2028d9 Mon Sep 17 00:00:00 2001 From: GoEdgeLab Date: Sun, 11 Sep 2022 19:03:53 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/nodes/node.go | 2 +- internal/nodes/system_services.go | 10 ++++++---- 2 files changed, 7 insertions(+), 5 deletions(-) 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()) + } + }) }) }