commit 305908cd3c134a9076f1dcfaf3b2d98ada86df9e
author Esin Karaman <esin.karaman@netsia.com> Mon Feb 24 14:42:52 2020 +0000
committer Esin Karaman <esin.karaman@netsia.com> Wed Feb 26 15:51:54 2020 +0300
tree d8520328c43d0baab8a79f988e5fc398580ddb6a
parent 4c55437963ef7ebcda19f805f6dc0e24ff25e5db

VOL-2620 Optimize igmpProxy-1.2 app by directly using SADIS

Change-Id: I2c0c7480866b65e6c2bd96ef636e16643aa0ec88

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

diff --git a/src/main/java/org/opencord/igmpproxy/StateMachine.java b/src/main/java/org/opencord/igmpproxy/StateMachine.java
index 391bdee..1097560 100644
--- a/src/main/java/org/opencord/igmpproxy/StateMachine.java
+++ b/src/main/java/org/opencord/igmpproxy/StateMachine.java
@@ -18,6 +18,8 @@
 import com.google.common.collect.Maps;
 import org.onlab.packet.Ip4Address;
 import org.onosproject.net.DeviceId;
+import org.onosproject.net.PortNumber;
+
 import java.util.Map;
 import java.util.Set;
 
@@ -52,11 +54,11 @@
         map.remove(getId(devId, groupIp));
     }
 
-    public static boolean join(DeviceId devId, Ip4Address groupIp, Ip4Address srcIP) {
+    public static boolean join(DeviceId devId, Ip4Address groupIp, Ip4Address srcIP, PortNumber upLinkPort) {
         SingleStateMachine machine = get(devId, groupIp);
 
         if (null == machine) {
-            machine = new SingleStateMachine(devId, groupIp, srcIP);
+            machine = new SingleStateMachine(devId, groupIp, srcIP, upLinkPort);
             map.put(getId(devId, groupIp), machine);
 
             boolean shouldSendJoin = true;