skip node OnUpdate events (#391)

cloudnativelabs · Apr 13, 2018 · 945a13c · 945a13c
1 parent 6ba2e94
commit 945a13c
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/app/controllers/network_routes_controller.go b/app/controllers/network_routes_controller.go
@@ -1716,17 +1716,19 @@ func (nrc *NetworkRoutingController) newNodeEventHandler() cache.ResourceEventHa
 			nodeIP, _ := utils.GetNodeIP(node)
 
 			glog.V(2).Infof("Received node %s added update from watch API so peer with new node", nodeIP)
+			nrc.OnNodeUpdate(obj)
 		},
 		UpdateFunc: func(oldObj, newObj interface{}) {
-			nrc.OnNodeUpdate(newObj)
+			// we are interested only node add/delete, so skip update
+			return
 
 		},
 		DeleteFunc: func(obj interface{}) {
 			node := obj.(*v1core.Node)
 			nodeIP, _ := utils.GetNodeIP(node)
 
 			glog.Infof("Received node %s removed update from watch API, so remove node from peer", nodeIP)
-
+			nrc.OnNodeUpdate(obj)
 		},
 	}
 }