commit 8916418b8d6316b3e89af04617fce12e20182532
author Jian Li <pyguni@gmail.com> Fri Sep 04 19:38:37 2020 +0900
committer Jian Li <pyguni@gmail.com> Sat Sep 05 05:34:41 2020 +0000
tree a023b37569472b95b2a904824865ef7360a7e607
parent 55511c47648f45fffc5d38561b27bfaf0389c8d3

Fix: statically add portnumber of intg and ext bridge

1. install service flow rules for all types of services including
ClusterIP, NodePort, LoadBalancer

Change-Id: I9884c7e5dfef66e7af5497403dd3cba6c6b46b61

apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/web/K8sManagementWebResource.java

diff --git a/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/web/K8sManagementWebResource.java b/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/web/K8sManagementWebResource.java
index 5d23fab..1b96e70 100644
--- a/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/web/K8sManagementWebResource.java
+++ b/apps/k8s-networking/app/src/main/java/org/onosproject/k8snetworking/web/K8sManagementWebResource.java
@@ -53,15 +53,8 @@
 public class K8sManagementWebResource extends AbstractWebResource {
     private final Logger log = LoggerFactory.getLogger(getClass());
 
-    private static final String PORT_ID = "portId";
-    private static final String DEVICE_ID = "deviceId";
-    private static final String PORT_NUMBER = "portNumber";
-    private static final String IP_ADDRESS = "ipAddress";
-    private static final String MAC_ADDRESS = "macAddress";
-    private static final String NETWORK_ID = "networkId";
-
-    private static final long SLEEP_MIDDLE_MS = 3000; // we wait 3s
-    private static final long TIMEOUT_MS = 10000; // we wait 10s
+    private static final long SLEEP_MS = 10000; // we wait 10s
+    private static final long TIMEOUT_MS = 30000; // we wait 30s
 
     private final K8sApiConfigService configService = get(K8sApiConfigService.class);
     private final K8sPodAdminService podAdminService = get(K8sPodAdminService.class);
@@ -186,7 +179,7 @@
             long  waitMs = timeoutExpiredMs - System.currentTimeMillis();
 
             try {
-                sleep(SLEEP_MIDDLE_MS);
+                sleep(SLEEP_MS);
             } catch (InterruptedException e) {
                 log.error("Exception caused during node synchronization...");
             }