update

zhangmeng

2020-01-15 ee1ea6dc3930a07d78c6fd7b6238fa44cde06d79

 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 {