commit 34556e5bc2cd0359db471e76ab9c9e864b1930a3
author Matteo Scandolo <teo@opennetworking.org> Fri May 08 12:34:13 2020 -0700
committer Matteo Scandolo <teo@opennetworking.org> Fri May 08 12:36:14 2020 -0700
tree 1fa868a989df78ebbcf1fee2b68dc8919144d6e3
parent 51a34e8473780e92dec29c32edaa8760754831fd

[VOL-3064] Fixing IGMP flows installation

Change-Id: Ia10e9ba4887dad79ae32e15f8f71abd9b9945ede

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 3d41a5b..9db1b40 100644
--- a/app/src/main/java/org/opencord/olt/impl/OltFlowService.java
+++ b/app/src/main/java/org/opencord/olt/impl/OltFlowService.java
@@ -303,11 +303,20 @@
                                                UniTagInformation tagInformation,
                                                boolean install,
                                                boolean upstream) {
-        if (!enableIgmpOnProvisioning && !upstream) {
+        if (!enableIgmpOnProvisioning) {
             log.debug("Igmp provisioning is disabled.");
             return;
         }
 
+        if (!upstream) {
+            log.debug("Direction is not Upstream, ignoring Igmp request");
+            return;
+        }
+
+        if (!mastershipService.isLocalMaster(devId)) {
+            return;
+        }
+
         DefaultFilteringObjective.Builder builder = DefaultFilteringObjective.builder();
         TrafficTreatment.Builder treatmentBuilder = DefaultTrafficTreatment.builder();
         if (upstream) {