OPNFLWPLUG-644: Openflow Event logging using log4j

[openflowplugin.git] / openflowplugin-impl / src / main / java / org / opendaylight / openflowplugin / impl / datastore / multipart / PortDescMultipartWriter.java

diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/datastore/multipart/PortDescMultipartWriter.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/datastore/multipart/PortDescMultipartWriter.java
index 36dac14e79c02ad199f84037cc87ea30d091f01a..23103b4c3781c5c0bfe2970e49bcdcf80e0a2e27 100644 (file)
--- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/datastore/multipart/PortDescMultipartWriter.java
+++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/datastore/multipart/PortDescMultipartWriter.java
@@ -24,9 +24,12 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731
 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.FlowCapableNodeConnectorStatisticsData;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.FlowCapableNodeConnectorStatisticsDataBuilder;
 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class PortDescMultipartWriter extends AbstractMultipartWriter<MultipartReplyPortDesc> {
 
+    private static final Logger OF_EVENT_LOG = LoggerFactory.getLogger("OfEventLog");
     private final FeaturesReply features;
 
     public PortDescMultipartWriter(final TxFacade txFacade,
@@ -45,13 +48,16 @@ public class PortDescMultipartWriter extends AbstractMultipartWriter<MultipartRe
     public void storeStatistics(final MultipartReplyPortDesc statistics, final boolean withParents) {
         statistics.getPorts()
             .forEach(stat -> {
+                long portNumber = OpenflowPortsUtil.getProtocolPortNumber(
+                        OpenflowVersion.get(features.getVersion()),
+                        stat.getPortNumber());
                 final NodeConnectorId id = InventoryDataServiceUtil
                     .nodeConnectorIdfromDatapathPortNo(
-                        features.getDatapathId(),
-                        OpenflowPortsUtil.getProtocolPortNumber(
-                            OpenflowVersion.get(features.getVersion()),
-                            stat.getPortNumber()),
+                        features.getDatapathId(), portNumber,
                         OpenflowVersion.get(features.getVersion()));
+                OF_EVENT_LOG.debug("Node Connector Status, Node: {}, PortNumber: {}, PortName: {}, Status: {}",
+                        features.getDatapathId(), portNumber, stat.getName(),
+                        stat.getConfiguration().isPORTDOWN() ? "Down" : "Up");
 
                 writeToTransaction(
                     getInstanceIdentifier()