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/IgmpSender.java

diff --git a/src/main/java/org/opencord/igmpproxy/IgmpSender.java b/src/main/java/org/opencord/igmpproxy/IgmpSender.java
index f880646..b455cb4 100644
--- a/src/main/java/org/opencord/igmpproxy/IgmpSender.java
+++ b/src/main/java/org/opencord/igmpproxy/IgmpSender.java
@@ -195,12 +195,11 @@
         return mac;
     }
 
-    public void sendIgmpPacketUplink(Ethernet ethPkt, DeviceId deviceId) {
+    public void sendIgmpPacketUplink(Ethernet ethPkt, DeviceId deviceId, PortNumber upLinkPort) {
         if (!mastershipService.isLocalMaster(deviceId)) {
             return;
         }
 
-
         if (IgmpManager.connectPointMode) {
             if (IgmpManager.connectPoint == null) {
                 log.warn("cannot find a connectPoint to send the packet uplink");
@@ -208,8 +207,7 @@
             }
             sendIgmpPacket(ethPkt, IgmpManager.connectPoint.deviceId(), IgmpManager.connectPoint.port());
         } else {
-            PortNumber upLink = IgmpManager.getDeviceUplink(deviceId);
-            sendIgmpPacket(ethPkt, deviceId, upLink);
+            sendIgmpPacket(ethPkt, deviceId, upLinkPort);
         }
     }