Code Review
/
openflowplugin.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
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.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> {
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,
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 -> {
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(
final NodeConnectorId id = InventoryDataServiceUtil
.nodeConnectorIdfromDatapathPortNo(
- features.getDatapathId(),
- OpenflowPortsUtil.getProtocolPortNumber(
- OpenflowVersion.get(features.getVersion()),
- stat.getPortNumber()),
+ features.getDatapathId(), portNumber,
OpenflowVersion.get(features.getVersion()));
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()
writeToTransaction(
getInstanceIdentifier()