Commit 8f706c65 authored by duanjinfei's avatar duanjinfei

Merge branch 'master' into test

parents 62344b0a 958c79f4
......@@ -94,16 +94,14 @@ func StartMonitor() {
log.Warn("The managerClient is not exist:", managerClient.Endpoint)
continue
}
if !managerClient.IsDel {
// TODO: 重试连接三次
//managerClient.UpdateLastHeartTime(time.Now())
managerClient.IsDel = true
isSuccess := inputNodeManagerChan(manager, nil, managerClient.IsSelected, monitorNm)
log.WithField("is success", isSuccess).Warn("Try to connect node manager client:", manager.Info.Endpoint)
if isSuccess {
log.Info("Connect node manager client success:", manager.Info.Endpoint)
continue
}
// TODO: 重试连接三次
//managerClient.UpdateLastHeartTime(time.Now())
managerClient.IsDel = true
isSuccess := inputNodeManagerChan(manager, nil, managerClient.IsSelected, monitorNm)
log.WithField("is success", isSuccess).Warn("Try to connect node manager client:", manager.Info.Endpoint)
if isSuccess {
log.Info("Connect node manager client success:", manager.Info.Endpoint)
continue
}
//managerClient.IsDel = true
log.WithField("Endpoint", managerClient.Endpoint).Warn("Node manager client is deleted")
......
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