debug

zhangmeng

2020-01-14 b5b70b1278f0ede6c095d884e92d49df4cc2e060

 run.go

@@ -60,6 +60,7 @@
            f.fnLogger("Face No Running: ", f.rebootUntil)
            if f.rebootUntil > maxTryBeforeReboot {
               f.fnLogger("Face Too Long Running, Reboot")
               f.release()
               os.Exit(0)
            }
         }
@@ -157,6 +158,12 @@
   }
}

func (f *face) release() {
   if f.handle != nil {
      f.handle.Free()
   }
}

// Run run
func Run(ctx context.Context, i interface{}) {
   s := i.(*face)
@@ -167,8 +174,8 @@
   )
   ipcRcv := sdkhelper.GetIpcAddress(s.shm, s.id+postPull)
   ipcSnd := sdkhelper.GetIpcAddress(s.shm, s.id+postPush)
   chRcv := make(chan []byte)
   chSnd := make(chan sdkstruct.MsgSDK)
   chRcv := make(chan []byte, 3)
   chSnd := make(chan sdkstruct.MsgSDK, 3)

   rcver := sdkhelper.NewReciever(ipcRcv, chRcv, s.shm, s.fnLogger)
   snder := sdkhelper.NewSender(ipcSnd, chSnd, s.shm, s.fnLogger)