diff options
Diffstat (limited to 'edge/hack/keepalivefunction.txt')
| -rw-r--r-- | edge/hack/keepalivefunction.txt | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/edge/hack/keepalivefunction.txt b/edge/hack/keepalivefunction.txt new file mode 100644 index 000000000..1a8a28b08 --- /dev/null +++ b/edge/hack/keepalivefunction.txt @@ -0,0 +1,15 @@ + +func (ehc *Controller) keepalive() { + for { + msg := model.NewMessage(""). + BuildRouter(ModuleNameEdgeHub, "resource", "node", "keepalive"). + FillBody("ping") + err := ehc.chClient.Send(*msg) + if err != nil { + log.LOGGER.Errorf("websocket write error: %v", err) + ehc.stopChan <- struct{}{} + return + } + time.Sleep(ehc.config.HeartbeatPeriod) + } +} |
