Commit 4e5379f1 authored by duanjinfei's avatar duanjinfei

add nm heartbeat time monitor

parent a0dcfd8c
...@@ -82,7 +82,7 @@ func StartMonitor() { ...@@ -82,7 +82,7 @@ func StartMonitor() {
log.Info("Monitoring node manager client thread start......") log.Info("Monitoring node manager client thread start......")
for _, managerClient := range usedNodeManagerClient { for _, managerClient := range usedNodeManagerClient {
log.WithField("Status", managerClient.Status).WithField("Is Del", managerClient.IsDel).WithField("EndPoint", managerClient.Endpoint).Info("Monitoring node manager client thread") log.WithField("Status", managerClient.Status).WithField("Is Del", managerClient.IsDel).WithField("EndPoint", managerClient.Endpoint).Info("Monitoring node manager client thread")
if managerClient.GetStatus() { if managerClient.GetStatus() && !managerClient.IsDel {
sub := time.Now().Sub(managerClient.GetLastHeartTime()).Seconds() sub := time.Now().Sub(managerClient.GetLastHeartTime()).Seconds()
log.WithField("time(uint seconds)", sub).Info("Main thread monitor nm heartbeat time") log.WithField("time(uint seconds)", sub).Info("Main thread monitor nm heartbeat time")
if int64(sub) > conf.GetConfig().HeartRespTimeSecond { if int64(sub) > conf.GetConfig().HeartRespTimeSecond {
......
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