commit 2b35ec765f5733cd3cf2cfe8802a7d873691d078
author Jian Li <pyguni@gmail.com> Thu Jan 21 16:45:02 2021 +0900
committer Jian Li <pyguni@gmail.com> Thu Jan 21 16:45:02 2021 +0900
tree 10f7cfcc5f633aff7b790854d2ced42c5a269f9d
parent 9ca07f5ece1ae1c1b2966c6ac8aba42e6c8f0908

Only provision worker nodes in kubevirt managed case

Change-Id: Iccfc2a0d30025a5fe20c76f53b5ebd034e51ec6d

apps/kubevirt-node/app/src/main/java/org/onosproject/kubevirtnode/impl/DefaultKubevirtApiConfigHandler.java

diff --git a/apps/kubevirt-node/app/src/main/java/org/onosproject/kubevirtnode/impl/DefaultKubevirtApiConfigHandler.java b/apps/kubevirt-node/app/src/main/java/org/onosproject/kubevirtnode/impl/DefaultKubevirtApiConfigHandler.java
index 9a6d110..dc3946d 100644
--- a/apps/kubevirt-node/app/src/main/java/org/onosproject/kubevirtnode/impl/DefaultKubevirtApiConfigHandler.java
+++ b/apps/kubevirt-node/app/src/main/java/org/onosproject/kubevirtnode/impl/DefaultKubevirtApiConfigHandler.java
@@ -138,7 +138,11 @@
 
         for (Node node : k8sClient.nodes().list().getItems()) {
             KubevirtNode kubevirtNode = buildKubevirtNode(node);
-            nodeAdminService.createNode(kubevirtNode);
+            // we always provision VMs to worker nodes, so only need to install
+            // flow rules in worker nodes
+            if (kubevirtNode.type() == WORKER) {
+                nodeAdminService.createNode(kubevirtNode);
+            }
         }
     }