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