commit 88134a45592c8c857626dd027aecb5fffc3d0c9a
author Deepa Vaddireddy <dvaddire@partner.ciena.com> Wed Jul 05 12:16:03 2017 +0530
committer Deepa Vaddireddy <dvaddire@partner.ciena.com> Wed Jul 05 12:16:03 2017 +0530
tree 2e627c865009ec9b6688c4238a3ac7341f58badb
parent 81a38b90e0a2afab4bf4261352e539ae4096c100

CORD_1598 - The Egress VLAN is not configurable in the IGMP proxy outbound packets

Change-Id: Icb6b9a8fb802c6b58b73a84a4d9f9d6238822afe

src/main/java/org/opencord/igmpproxy/IgmpManager.java

diff --git a/src/main/java/org/opencord/igmpproxy/IgmpManager.java b/src/main/java/org/opencord/igmpproxy/IgmpManager.java
index 4194b92..967e467 100644
--- a/src/main/java/org/opencord/igmpproxy/IgmpManager.java
+++ b/src/main/java/org/opencord/igmpproxy/IgmpManager.java
@@ -191,6 +191,7 @@
         McastConfig config = networkConfig.getConfig(coreAppId, MCAST_CONFIG_CLASS);
         if (config != null) {
             mvlan = config.egressVlan().toShort();
+            IgmpSender.getInstance().setMvlan(mvlan);
         }
         deviceService.addListener(deviceListener);
         scheduledExecutorService.scheduleAtFixedRate(new IgmpProxyTimerTask(), 0, 1000, TimeUnit.MILLISECONDS);
@@ -718,6 +719,7 @@
                         McastConfig config = networkConfig.getConfig(coreAppId, MCAST_CONFIG_CLASS);
                         if (config != null && mvlan != config.egressVlan().toShort()) {
                             mvlan = config.egressVlan().toShort();
+                            IgmpSender.getInstance().setMvlan(mvlan);
                             groupMemberMap.values().forEach(m -> leaveAction(m));
                         }
                     }