VOL-2620 Optimize igmpProxy app by directly using SADIS
Change-Id: I2c67f6162d446de1fb773fe311a93972f3aa582a
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);
}
}