Commit 0a98979d authored by duanjinfei's avatar duanjinfei

update nm status

parent a457bb25
...@@ -139,9 +139,7 @@ func monitorWorker(op *operate.DockerOp) { ...@@ -139,9 +139,7 @@ func monitorWorker(op *operate.DockerOp) {
worker, err := nodeManager.Client.RegisterWorker(context.Background(), grpc.EmptyCallOption{}) worker, err := nodeManager.Client.RegisterWorker(context.Background(), grpc.EmptyCallOption{})
if err != nil { if err != nil {
log.Error("Registration worker failed", err) log.Error("Registration worker failed", err)
if nodeManager.Status { nodeManager.UpdateStatus(false)
nodeManager.UpdateStatus(false)
}
return return
} }
...@@ -205,9 +203,7 @@ func monitorWorker(op *operate.DockerOp) { ...@@ -205,9 +203,7 @@ func monitorWorker(op *operate.DockerOp) {
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 { nodeManager.UpdateStatus(false)
nodeManager.UpdateStatus(false)
}
log.Error("Node manager heartbeat is over") log.Error("Node manager heartbeat is over")
return return
} }
......
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