Commit 067fed09 authored by vicotor's avatar vicotor

add log

parent 76b0c6d7
......@@ -169,7 +169,6 @@ func (wm *WorkerManager) doCallback(hook string, response *odysseus.TaskResponse
func (wm *WorkerManager) manageWorker(worker *Worker) error {
log.WithField("worker", worker.uuid).Info("start manage worker")
defer log.WithField("worker", worker.uuid).Info("exit manage worker")
initialInterval := time.Second * 4
tickerConf := config.GetConfig().Tickers
heartBeatDuration := time.Second * time.Duration(tickerConf.HeartBeat)
......@@ -190,7 +189,14 @@ func (wm *WorkerManager) manageWorker(worker *Worker) error {
deviceUsageTicker := time.NewTicker(initialInterval)
defer deviceUsageTicker.Stop()
defer wm.InActiveWorker(worker.addr)
defer func() {
log.WithFields(log.Fields{
"worker-addr": worker.addr,
"worker-uuid": worker.uuid,
}).Info("exit manage worker")
wm.InActiveWorker(worker.addr)
}()
for {
var msg = new(omanager.ManagerMessage)
......
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