debug

zhangmeng

2020-01-14 b5b70b1278f0ede6c095d884e92d49df4cc2e060

debug

 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)