commit ea1ead790ab11adec907a6877edb24c5db8a5638
author Jian Li <pyguni@gmail.com> Fri May 28 11:00:07 2021 +0900
committer Jian Li <pyguni@gmail.com> Fri May 28 06:29:16 2021 +0000
tree adb876269c42d33fab9daae28f73b732720e0032
parent 394bef59a0e106ed679188a9dca3b09d51212a83

Fix: add the kubevirt port to the store only if it is not existed

Remove all flows before remove bridge and ports

Change-Id: I8027bc19b70dce10612f8bc32da6062937299d89
(cherry picked from commit e66ed69033b65ad8ec1c6e1405f87b9be304cfd7)

apps/kubevirt-networking/app/src/main/java/org/onosproject/kubevirtnetworking/impl/KubevirtVmWatcher.java

diff --git a/apps/kubevirt-networking/app/src/main/java/org/onosproject/kubevirtnetworking/impl/KubevirtVmWatcher.java b/apps/kubevirt-networking/app/src/main/java/org/onosproject/kubevirtnetworking/impl/KubevirtVmWatcher.java
index 43d3e64..fc3baab 100644
--- a/apps/kubevirt-networking/app/src/main/java/org/onosproject/kubevirtnetworking/impl/KubevirtVmWatcher.java
+++ b/apps/kubevirt-networking/app/src/main/java/org/onosproject/kubevirtnetworking/impl/KubevirtVmWatcher.java
@@ -248,7 +248,9 @@
                     port = port.updateDeviceId(deviceId);
                 }
 
-                portAdminService.createPort(port);
+                if (portAdminService.port(port.macAddress()) == null) {
+                    portAdminService.createPort(port);
+                }
             });
         }