Commit e9197869 authored by duanjinfei's avatar duanjinfei

update recv failed err is nil

parent 665e974e
......@@ -202,7 +202,7 @@ func monitorWorker(op *operate.DockerOp) {
rev, err := worker.Recv()
if int64(sub) > conf.GetConfig().HeartRespTimeSecond || err != nil {
log.Error("Rev failed:", err)
params := buildParams(fmt.Sprintf("Rev failed:%s", err.Error()))
params := buildParams(fmt.Sprint("Rev failed:", err))
msgRespWorker.RegisterMsgResp(nodeManager, worker, GoodbyeResp, params)
nodeManager.UpdateStatus(false)
log.Error("Node manager heartbeat is over")
......
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