From ee1ea6dc3930a07d78c6fd7b6238fa44cde06d79 Mon Sep 17 00:00:00 2001 From: zhangmeng <775834166@qq.com> Date: 星期三, 15 一月 2020 15:41:44 +0800 Subject: [PATCH] update --- run.go | 7 +++++++ 1 files changed, 7 insertions(+), 0 deletions(-) diff --git a/run.go b/run.go index 6fe49b7..d18577a 100644 --- a/run.go +++ b/run.go @@ -30,6 +30,8 @@ ipc2Rule string ruleMsgMaxCacheSize int reserved map[string]interface{} + + stopper *common.Disturber } // Create create sdk @@ -115,6 +117,8 @@ ipc2Rule: ipc2Rule, ruleMsgMaxCacheSize: ruleMaxSize, reserved: reserved, + + stopper: common.NewDisturber(10), } } @@ -148,6 +152,8 @@ go torule.Run(ctx) go s.run(ctx, chRcv, chSnd) + + go s.stopper.MaybeReboot(ctx, s.fnLogger) } ////////////////////////////////////////////////////////////////// @@ -310,6 +316,7 @@ // f.fnLogger("Face~~~EjectResult", dtchn) common.EjectResult(data, rMsg, out) // f.fnLogger("Face~~~EjectResult Over", dtchn) + f.stopper.Prevent() var id, name string if rMsg.Msg.Tasklab != nil { -- Gitblit v1.8.0