| | |
|---|
| | | f.fnLogger("Face No Running: ", f.rebootUntil) |
|---|
| | | if f.rebootUntil > maxTryBeforeReboot { |
|---|
| | | f.fnLogger("Face Too Long Running, Reboot") |
|---|
| | | f.release() |
|---|
| | | os.Exit(0) |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | ) |
|---|
| | | ipcRcv := sdkhelper.GetIpcAddress(s.shm, s.id+postPull) |
|---|
| | | ipcSnd := sdkhelper.GetIpcAddress(s.shm, s.id+postPush) |
|---|
| | | chRcv := make(chan []byte, 3) |
|---|
| | | chSnd := make(chan sdkstruct.MsgSDK, 3) |
|---|
| | | chRcv := make(chan []byte, s.maxChannel) |
|---|
| | | chSnd := make(chan sdkstruct.MsgSDK, s.maxChannel) |
|---|
| | | |
|---|
| | | rcver := sdkhelper.NewReciever(ipcRcv, chRcv, s.shm, s.fnLogger) |
|---|
| | | snder := sdkhelper.NewSender(ipcSnd, chSnd, s.shm, s.fnLogger) |
|---|
