Commit a457bb25 authored by duanjinfei's avatar duanjinfei

update nm status

parent a8576864
...@@ -200,21 +200,15 @@ func monitorWorker(op *operate.DockerOp) { ...@@ -200,21 +200,15 @@ func monitorWorker(op *operate.DockerOp) {
for { for {
sub := time.Now().Sub(nodeManager.GetLastHeartTime()).Seconds() sub := time.Now().Sub(nodeManager.GetLastHeartTime()).Seconds()
log.WithField("time(uint seconds)", sub).Info("The time difference since the last heartbeat") log.WithField("time(uint seconds)", sub).Info("The time difference since the last heartbeat")
if int64(sub) > conf.GetConfig().HeartRespTimeSecond {
if nodeManager.Status {
nodeManager.UpdateStatus(false)
}
log.Error("Node manager heartbeat is over")
return
}
rev, err := worker.Recv() rev, err := worker.Recv()
if err != nil { if int64(sub) > conf.GetConfig().HeartRespTimeSecond || err != nil {
log.Error("Rev failed:", err) log.Error("Rev failed:", err)
params := buildParams(fmt.Sprintf("Rev failed:%s", err.Error())) params := buildParams(fmt.Sprintf("Rev failed:%s", err.Error()))
msgRespWorker.RegisterMsgResp(nodeManager, worker, GoodbyeResp, params) msgRespWorker.RegisterMsgResp(nodeManager, worker, GoodbyeResp, params)
if nodeManager.Status { if nodeManager.Status {
nodeManager.UpdateStatus(false) nodeManager.UpdateStatus(false)
} }
log.Error("Node manager heartbeat is over")
return return
} }
log.Info("---------------------received message success---------------------") log.Info("---------------------received message success---------------------")
......
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