mirrors/onos
1
0
Fork 0
mirror of https://github.com/opennetworkinglab/onos.git synced 2026-05-05 12:16:13 +02:00
Code Issues Projects Releases Wiki Activity

Trace messages via openflow

Browse Source 
Change-Id: If823a75a35501914dc7da265b177cac81d8238ac
This commit is contained in:
Laszlo Papp 2017-11-24 17:06:59 +00:00 committed by Yuta HIGUCHI
parent a06a61694c
commit b68fe7e441
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
protocols/openflow/ctl/src/main/java/org/onosproject/openflow/controller/impl/OFChannelHandler.java
View File

@ -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 {

3
protocols/openflow/ctl/src/main/java/org/onosproject/openflow/controller/impl/OpenFlowControllerImpl.java
View File

@ -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);