commit | 8108f22eaf77e18eccc1722476148d513927f3b7 | [log] [tgz] |
---|---|---|
author | Jian Li <pyguni@gmail.com> | Tue Dec 24 15:58:25 2019 +0900 |
committer | Jian Li <pyguni@gmail.com> | Wed Mar 04 08:46:20 2020 +0000 |
tree | c465054b4c4c037c02eb1b22cc9ccacf91bf10ff | |
parent | 1c6156c59a89e74762319a361b3f3481093d290e [diff] [blame] |
Fix: double check resource existence at receiving addition event Change-Id: I80fb2b30201e3e770eb5384ecee2b78b32502936
diff --git a/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/impl/K8sEndpointsWatcher.java b/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/impl/K8sEndpointsWatcher.java index c3139c1..62c15e6 100644 --- a/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/impl/K8sEndpointsWatcher.java +++ b/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/impl/K8sEndpointsWatcher.java
@@ -170,7 +170,10 @@ log.trace("Process endpoints {} creating event from API server.", endpoints.getMetadata().getName()); - k8sEndpointsAdminService.createEndpoints(endpoints); + if (k8sEndpointsAdminService.endpoints( + endpoints.getMetadata().getUid()) == null) { + k8sEndpointsAdminService.createEndpoints(endpoints); + } } private void processModification(Endpoints endpoints) {