commit 2c70a573f9f1cf1af7d9dc221632ca40597e9025
author Andrea Campanella <andrea@opennetworking.org> Fri Jun 05 13:31:45 2020 +0200
committer Andrea Campanella <andrea@opennetworking.org> Wed Jun 17 10:30:30 2020 +0200
tree 3fb5cb02c7ad0b1b0a42db9ae6caa794f232fc7e
parent 0872abdaf1cf3c97537d3733a7eb1eec21daa2ea

Adding useful logs for igmp operations

Change-Id: If55ba0a7da86ade3c05b4f6bcbe36f7324abf83a

app/src/main/java/org/opencord/igmpproxy/impl/IgmpManager.java

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 e32bc4a..f70dde2 100644
--- a/app/src/main/java/org/opencord/igmpproxy/impl/IgmpManager.java
+++ b/app/src/main/java/org/opencord/igmpproxy/impl/IgmpManager.java
@@ -352,6 +352,9 @@
         DeviceId deviceId = cp.deviceId();
         PortNumber portNumber = cp.port();
 
+        log.debug("Processing IGMP report on membership {} for vlan {} on port {} with type {}",
+                  igmpGroup, vlan, cp, igmpType);
+
         Ip4Address groupIp = igmpGroup.getGaddr().getIp4Address();
         if (!groupIp.isMulticast()) {
             log.info(groupIp.toString() + " is not a valid group address");
@@ -405,7 +408,9 @@
         GroupMember groupMember = groupMemberStore.getGroupMember(groupMemberKey);
 
         if (join) {
+            log.debug("Received join on {} for vlan {}", cp, vlan);
             igmpStatisticsManager.increaseStat(IgmpStatisticType.IGMP_JOIN_REQ);
+
             if (groupMember == null) {
                 Optional<ConnectPoint> sourceConfigured = getSource();
                 if (!sourceConfigured.isPresent()) {
@@ -460,6 +465,7 @@
             //put updated member to the store
             groupMemberStore.putGroupMember(groupMember);
         } else {
+            log.debug("Received leave on {} for vlan {}", cp, vlan);
             igmpStatisticsManager.increaseStat(IgmpStatisticType.IGMP_LEAVE_REQ);
             if (groupMember == null) {
                 log.info("receive leave but no instance, group {} device: {} port:{}",
@@ -775,7 +781,7 @@
             return (connectPointMode && connectPoint.deviceId().equals(device)
                     && connectPoint.port().equals(port));
         } else {
-            log.info("connectPoint not configured for device {}", device);
+            log.debug("connectPoint not configured for device {}", device);
             return false;
         }
     }