add node to addNodeQueue if required annations are missing (#2481)

kubeovn · Mar 15, 2023 · 5ffc237 · 5ffc237
1 parent 2db927e
commit 5ffc237
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/pkg/controller/node.go b/pkg/controller/node.go
@@ -64,8 +64,13 @@ func (c *Controller) enqueueUpdateNode(oldObj, newObj interface{}) {
 			utilruntime.HandleError(err)
 			return
 		}
-		klog.V(3).Infof("enqueue update node %s", key)
-		c.updateNodeQueue.Add(key)
+		if len(newNode.Annotations) == 0 || newNode.Annotations[util.AllocatedAnnotation] != "true" {
+			klog.V(3).Infof("enqueue add node %s", key)
+			c.addNodeQueue.Add(key)
+		} else {
+			klog.V(3).Infof("enqueue update node %s", key)
+			c.updateNodeQueue.Add(key)
+		}
 	}
 }