commit ca7b25d05e37b9a61f65ab16c135561c5b2270c1
author Deepa Vaddireddy <dvaddire@partner.ciena.com> Thu Sep 28 13:47:18 2017 +0000
committer Deepa Vaddireddy <dvaddire@partner.ciena.com> Fri Sep 29 08:43:32 2017 +0000
tree fdd879278a1451f5218fc9a0602d53538679ab54
parent bcd5235ed8f7870d958e1cfb192a60e1dfb87f78

VOL-473 Non-OLT connect point flow provisioning

Change-Id: I4cc4ddbbfa78181ab050dcf815e4ecf0b2e04d65

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 75e1d7b..f880646 100644
--- a/src/main/java/org/opencord/igmpproxy/IgmpSender.java
+++ b/src/main/java/org/opencord/igmpproxy/IgmpSender.java
@@ -30,6 +30,8 @@
 import org.onosproject.net.packet.DefaultOutboundPacket;
 import org.onosproject.net.packet.OutboundPacket;
 import org.onosproject.net.packet.PacketService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.nio.ByteBuffer;
 
@@ -52,6 +54,7 @@
     private short mvlan = DEFAULT_MVLAN;
     private byte igmpCos = DEFAULT_COS;
     private int maxResp = DEFAULT_MEX_RESP;
+    private Logger log = LoggerFactory.getLogger(getClass());
 
     private IgmpSender(PacketService packetService, MastershipService mastershipService) {
         this.packetService = packetService;
@@ -199,6 +202,10 @@
 
 
         if (IgmpManager.connectPointMode) {
+            if (IgmpManager.connectPoint == null) {
+                log.warn("cannot find a connectPoint to send the packet uplink");
+                return;
+            }
             sendIgmpPacket(ethPkt, IgmpManager.connectPoint.deviceId(), IgmpManager.connectPoint.port());
         } else {
             PortNumber upLink = IgmpManager.getDeviceUplink(deviceId);