Commit 9cd19d68 authored by duanjinfei's avatar duanjinfei

add nm heartbeat time monitor

parent 5d2af3e2
......@@ -83,11 +83,13 @@ func StartMonitor() {
log.Info("Monitoring node manager client thread start......")
for _, managerClient := range usedNodeManagerClient {
log.WithField("Status", managerClient.Status).WithField("Is Del", managerClient.IsDel).WithField("EndPoint", managerClient.Endpoint).Info("Monitoring node manager client thread")
if managerClient.GetStatus() {
sub := time.Now().Sub(managerClient.GetLastHeartTime()).Seconds()
log.WithField("time(uint seconds)", sub).Info("Main thread monitor nm heartbeat time")
if int64(sub) > conf.GetConfig().HeartRespTimeSecond {
managerClient.UpdateStatus(false)
}
}
if !managerClient.GetStatus() && !managerClient.IsDel {
log.Warn("The Node manager client is failed:", managerClient.Endpoint)
manager := getNodeManager(managerClient.Endpoint)
......
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