Commit 958c79f4 authored by duanjinfei's avatar duanjinfei

update reconn nm

parent f07757b3
...@@ -94,7 +94,6 @@ func StartMonitor() { ...@@ -94,7 +94,6 @@ func StartMonitor() {
log.Warn("The managerClient is not exist:", managerClient.Endpoint) log.Warn("The managerClient is not exist:", managerClient.Endpoint)
continue continue
} }
if !managerClient.IsDel {
// TODO: 重试连接三次 // TODO: 重试连接三次
//managerClient.UpdateLastHeartTime(time.Now()) //managerClient.UpdateLastHeartTime(time.Now())
managerClient.IsDel = true managerClient.IsDel = true
...@@ -104,7 +103,6 @@ func StartMonitor() { ...@@ -104,7 +103,6 @@ func StartMonitor() {
log.Info("Connect node manager client success:", manager.Info.Endpoint) log.Info("Connect node manager client success:", manager.Info.Endpoint)
continue continue
} }
}
//managerClient.IsDel = true //managerClient.IsDel = true
log.WithField("Endpoint", managerClient.Endpoint).Warn("Node manager client is deleted") log.WithField("Endpoint", managerClient.Endpoint).Warn("Node manager client is deleted")
unUsedNodeManagers := getUnUsedNodeManagers() unUsedNodeManagers := getUnUsedNodeManagers()
......
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