TransmitPacketInputBuilder tpib = new TransmitPacketInputBuilder();
tpib.setEgress(new NodeConnectorRef(nodeConnectorInstanceId));
tpib.setNode(new NodeRef(nodeInstanceId));
- tpib.setPayload(lldpDataFrom(nodeInstanceId, nodeConnectorInstanceId, flowConnector.getHardwareAddress(),
- md.getSessionContext().getPrimaryConductor().getVersion()));
- nodeConnectorMap.put(nodeConnectorInstanceId, tpib.build());
-
- md.transmitPacket(nodeConnectorMap.get(nodeConnectorInstanceId));
+ if(nodeInstanceId == null) {
+ LOG.warn("addNodeConnector(): nodeInstanceId should not be null nodeConnectorInstanceId {} nodeConnector {}",nodeConnectorInstanceId,nodeConnector);
+ } else if (nodeConnectorInstanceId == null) {
+ LOG.warn("addNodeConnector(): nodeConnectorInstanceId should not be null nodeConnectorInstanceId {} nodeConnector {}",nodeConnectorInstanceId,nodeConnector);
+ } else if (flowConnector == null) {
+ LOG.warn("addNodeConnector(): flowConnector should not be null nodeConnectorInstanceId {} nodeConnector {}",nodeConnectorInstanceId,nodeConnector);
+ } else if (md == null) {
+ LOG.warn("addNodeConnector(): md should not be null nodeConnectorInstanceId {} nodeConnector {}",nodeConnectorInstanceId,nodeConnector);
+ } else if(md.getSessionContext() == null) {
+ LOG.warn("addNodeConnector(): md.getSessionContext() should not be null nodeConnectorInstanceId {} nodeConnector {}",nodeConnectorInstanceId,nodeConnector);
+ } else if (md.getSessionContext().getPrimaryConductor() == null) {
+ LOG.warn("addNodeConnector(): md.getSessionContext().getPrimaryConductor() should not be null nodeConnectorInstanceId {} nodeConnector {}",nodeConnectorInstanceId,nodeConnector);
+ } else {
+ tpib.setPayload(lldpDataFrom(nodeInstanceId,nodeConnectorInstanceId,flowConnector.getHardwareAddress(),
+ md.getSessionContext().getPrimaryConductor().getVersion()));
+ nodeConnectorMap.put(nodeConnectorInstanceId, tpib.build());
+
+ md.transmitPacket(nodeConnectorMap.get(nodeConnectorInstanceId));
+ }
}
public void removeNodeConnector(