commit fee8642f29e4f32e081ab8d628de7bd600a767fe
author Andrea Campanella <andrea@opennetworking.org> Thu Jun 04 16:01:27 2020 +0200
committer Andrea Campanella <andrea@opennetworking.org> Thu Jun 04 16:02:05 2020 +0200
tree 4e4e897e81312771c923b321a8b2f1b6ae20aab6
parent 0c3309db28dae730f081b3527db6cd5642354293

[VOL-3169] Removing needless mastership check when provisioning IGMP rules for subscriber

Change-Id: I94badd009c871fa7f2e0b647025219f12bd38fda

app/src/main/java/org/opencord/olt/impl/OltFlowService.java

diff --git a/app/src/main/java/org/opencord/olt/impl/OltFlowService.java b/app/src/main/java/org/opencord/olt/impl/OltFlowService.java
index 88c4adc..83032c0 100644
--- a/app/src/main/java/org/opencord/olt/impl/OltFlowService.java
+++ b/app/src/main/java/org/opencord/olt/impl/OltFlowService.java
@@ -162,14 +162,14 @@
         subsService = sadisService.getSubscriberInfoService();
         componentConfigService.registerProperties(getClass());
         appId = coreService.getAppId(APP_NAME);
-        log.info("Olt Flow Service started");
+        log.info("started");
     }
 
 
     @Deactivate
     public void deactivate(ComponentContext context) {
         componentConfigService.unregisterProperties(getClass(), false);
-        log.info("Olt flow service stopped");
+        log.info("stopped");
     }
 
     @Modified
@@ -205,6 +205,12 @@
         String tpId = get(properties, DEFAULT_TP_ID);
         defaultTechProfileId = isNullOrEmpty(tpId) ? DEFAULT_TP_ID_DEFAULT : Integer.parseInt(tpId.trim());
 
+        log.info("modified. Values = enableDhcpOnProvisioning: {}, enableDhcpV4: {}, " +
+                         "enableDhcpV6:{}, enableIgmpOnProvisioning:{}, " +
+                         "enableEapol{}, defaultTechProfileId: {}",
+                 enableDhcpOnProvisioning, enableDhcpV4, enableDhcpV6,
+                 enableIgmpOnProvisioning, enableEapol, defaultTechProfileId);
+
     }
 
     @Override
@@ -319,10 +325,8 @@
             return;
         }
 
-        if (!mastershipService.isLocalMaster(devId)) {
-            return;
-        }
-
+        log.debug("{} IGMP flows on {}:{}", (install) ?
+                "Installing" : "Removing", devId, port);
         DefaultFilteringObjective.Builder builder = DefaultFilteringObjective.builder();
         TrafficTreatment.Builder treatmentBuilder = DefaultTrafficTreatment.builder();
         if (upstream) {