commit | 55f857a02e07bde1001c032f972a6b8eec562f2b | [log] [tgz] |
---|---|---|
author | Jian Li <pyguni@gmail.com> | Thu Jan 21 16:45:02 2021 +0900 |
committer | Jian Li <pyguni@gmail.com> | Thu Jan 21 11:26:04 2021 +0000 |
tree | df20058e85cf677264d889fc2eedcd7a2b3c021c | |
parent | ea58588e334bfb3edb42f43e9a9dee170ee3648d [diff] |
Only provision worker nodes in kubevirt managed case Change-Id: Iccfc2a0d30025a5fe20c76f53b5ebd034e51ec6d
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); + } } }