ignore node back to alive, because agent will update it

projecteru2 · Oct 11, 2022 · ff9e284 · ff9e284
1 parent bde8d38
commit ff9e284
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/selfmon/selfmon.go b/selfmon/selfmon.go
@@ -200,14 +200,18 @@ func (n *NodeStatusWatcher) dealNodeStatusMessage(ctx context.Context, message *
 		log.Errorf(ctx, "[NodeStatusWatcher] deal with node status stream message failed %+v", message)
 		return
 	}
+	// here we ignore node back to alive status because it will updated by agent
+	if message.Alive {
+		return
+	}
 
 	ctx, cancel := context.WithCancel(ctx)
 	defer cancel()
 
 	// TODO maybe we need a distributed lock to control concurrency
 	opts := &types.SetNodeOptions{
 		Nodename:      message.Nodename,
-		WorkloadsDown: !message.Alive,
+		WorkloadsDown: true,
 	}
 	if _, err := n.cluster.SetNode(ctx, opts); err != nil {
 		log.Errorf(ctx, "[NodeStatusWatcher] set node %s failed %v", message.Nodename, err)