commit f4f801636899635252b85b826ea644d70a49573b
author David Bainbridge <dbainbri@ciena.com> Tue Aug 15 11:49:41 2017 -0700
committer Gerrit Code Review <gerrit@opencord.org> Tue Aug 15 11:49:41 2017 -0700
tree 502b5fe1aa9b2aedab7f6eba6f5e50656f8199af
parent fcb3ccf720a9af7c8f747d248f38e55fac5295a2
parent 88134a45592c8c857626dd027aecb5fffc3d0c9a

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

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 d57c42e..1b95105 100644
--- a/src/main/java/org/opencord/igmpproxy/IgmpManager.java
+++ b/src/main/java/org/opencord/igmpproxy/IgmpManager.java
@@ -206,6 +206,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);
@@ -739,6 +740,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));
                         }
                     }