[VOL-3912] Use correct connect point for hasing and thus thread selection
Change-Id: Ib0d398237c405b9fe010a515a7745c4d82832721
diff --git a/app/src/main/java/org/opencord/igmpproxy/impl/IgmpManager.java b/app/src/main/java/org/opencord/igmpproxy/impl/IgmpManager.java
index fbe96c6..9521d5b 100644
--- a/app/src/main/java/org/opencord/igmpproxy/impl/IgmpManager.java
+++ b/app/src/main/java/org/opencord/igmpproxy/impl/IgmpManager.java
@@ -136,6 +136,7 @@
private static byte igmpCos = 7;
private static byte igmpUniCos = 7;
public static boolean connectPointMode = true;
+ //This is the uplink connect point
public static ConnectPoint connectPoint = null;
private static ConnectPoint sourceDeviceAndPort = null;
private static boolean enableIgmpProvisioning = false;
@@ -394,7 +395,7 @@
}
private void queueIgmpReport(IGMPMembership igmpGroup, VlanId vlan, ConnectPoint cp, byte igmpType) {
- int packetHashCode = Objects.hash(igmpGroup.getGaddr(), connectPoint);
+ int packetHashCode = Objects.hash(igmpGroup.getGaddr(), cp);
int threadId = Math.abs(packetHashCode % numberOfIgmpReportProcessorThreads);
log.debug("IGMP report for ConnectPoint {} and group IP {} shall be processed in thread #{}",
cp, igmpGroup.getGaddr(), threadId);