Skip to content

N
nodemanager
Commit 395cc975 authored by vicotor's avatar vicotor
Browse files
Options

add log

parent c7d888d1
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 0 deletions
server/workerManager.go
View file @ 395cc975
...@@ -229,6 +229,10 @@ func (wm *WorkerManager) manageWorker(worker *Worker) error { ...@@ -229,6 +229,10 @@ func (wm *WorkerManager) manageWorker(worker *Worker) error {
Timestamp: uint64(time.Now().Unix()), Timestamp: uint64(time.Now().Unix()),
} }
msg.Message = hb msg.Message = hb
callback = func(err error) bool {
log.WithField("worker", worker.uuid).Info("send hear beat to worker")
return true
}
case <-deviceInfoTicker.C: case <-deviceInfoTicker.C:
deviceInfo := new(omanager.ManagerMessage_DeviceRequest) deviceInfo := new(omanager.ManagerMessage_DeviceRequest)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment