Commit 24ace5c1 authored by duanjinfei's avatar duanjinfei

update nm status

parent 0a98979d
...@@ -140,6 +140,7 @@ func monitorWorker(op *operate.DockerOp) { ...@@ -140,6 +140,7 @@ func monitorWorker(op *operate.DockerOp) {
if err != nil { if err != nil {
log.Error("Registration worker failed", err) log.Error("Registration worker failed", err)
nodeManager.UpdateStatus(false) nodeManager.UpdateStatus(false)
log.Warn("Update nm status is false")
return return
} }
...@@ -357,6 +358,7 @@ func handlerMsg(nodeManager *models.NodeManagerClient, ...@@ -357,6 +358,7 @@ func handlerMsg(nodeManager *models.NodeManagerClient,
reason := goodByeMsg.GetReason() reason := goodByeMsg.GetReason()
log.Infof("Server endpoint:%s , good bye reason : %s", nodeManager.Endpoint, reason) log.Infof("Server endpoint:%s , good bye reason : %s", nodeManager.Endpoint, reason)
nodeManager.UpdateStatus(false) nodeManager.UpdateStatus(false)
log.Warn("Update nm status is false")
continue continue
} }
} }
......
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