From b68fe7e44127eed5a71bb956a45f8fc1ca3b77e7 Mon Sep 17 00:00:00 2001
From: Laszlo Papp <laszlo.papp@hubersuhner.com>
Date: Fri, 24 Nov 2017 17:06:59 +0000
Subject: [PATCH] Trace messages via openflow

Change-Id: If823a75a35501914dc7da265b177cac81d8238ac
---
 .../onosproject/openflow/controller/impl/OFChannelHandler.java | 3 +++
 .../openflow/controller/impl/OpenFlowControllerImpl.java       | 3 +++
 2 files changed, 6 insertions(+)

diff --git a/protocols/openflow/ctl/src/main/java/org/onosproject/openflow/controller/impl/OFChannelHandler.java b/protocols/openflow/ctl/src/main/java/org/onosproject/openflow/controller/impl/OFChannelHandler.java
index 9be0b53166..79e391b346 100644
--- a/protocols/openflow/ctl/src/main/java/org/onosproject/openflow/controller/impl/OFChannelHandler.java
+++ b/protocols/openflow/ctl/src/main/java/org/onosproject/openflow/controller/impl/OFChannelHandler.java
@@ -1644,6 +1644,9 @@ class OFChannelHandler extends ChannelInboundHandlerAdapter
     @Override
     public boolean sendMsg(Iterable<OFMessage> msgs) {
         if (channel.isActive()) {
+            if (log.isTraceEnabled()) {
+                log.trace("Sending messages for switch {} via openflow channel: {}", getSwitchInfoString(), msgs);
+            }
             channel.writeAndFlush(msgs, channel.voidPromise());
             return true;
         } else {
diff --git a/protocols/openflow/ctl/src/main/java/org/onosproject/openflow/controller/impl/OpenFlowControllerImpl.java b/protocols/openflow/ctl/src/main/java/org/onosproject/openflow/controller/impl/OpenFlowControllerImpl.java
index 974a71ce94..b704e516aa 100644
--- a/protocols/openflow/ctl/src/main/java/org/onosproject/openflow/controller/impl/OpenFlowControllerImpl.java
+++ b/protocols/openflow/ctl/src/main/java/org/onosproject/openflow/controller/impl/OpenFlowControllerImpl.java
@@ -313,6 +313,9 @@ public class OpenFlowControllerImpl implements OpenFlowController {
     @Override
     public void processPacket(Dpid dpid, OFMessage msg) {
         OpenFlowSwitch sw = this.getSwitch(dpid);
+        if (log.isTraceEnabled()) {
+            log.trace("Processing message from switch {} via openflow: {}", dpid, msg);
+        }
 
         // Check if someone is waiting for this message
         ConcurrentMap<Long, CompletableFuture<OFMessage>> xids = responses.get(dpid);