Unit tests for open flow controller message handling.
Change-Id: I9cffe4f4585eaf0df48d9fcb6a9f62ddcc0f9403
diff --git a/openflow/ctl/src/main/java/org/onosproject/openflow/controller/impl/OpenFlowControllerImpl.java b/openflow/ctl/src/main/java/org/onosproject/openflow/controller/impl/OpenFlowControllerImpl.java
index fdcd2f0..b97c336 100644
--- a/openflow/ctl/src/main/java/org/onosproject/openflow/controller/impl/OpenFlowControllerImpl.java
+++ b/openflow/ctl/src/main/java/org/onosproject/openflow/controller/impl/OpenFlowControllerImpl.java
@@ -107,7 +107,7 @@
label = "Number of controller worker threads; default is 16")
private int workerThreads = DEFAULT_WORKER_THREADS;
- private final ExecutorService executorMsgs =
+ protected ExecutorService executorMsgs =
Executors.newFixedThreadPool(32, groupedThreads("onos/of", "event-stats-%d"));
private final ExecutorService executorBarrier =
@@ -611,10 +611,10 @@
}
}
- private final class OFMessageHandler implements Runnable {
+ protected final class OFMessageHandler implements Runnable {
- private final OFMessage msg;
- private final Dpid dpid;
+ protected final OFMessage msg;
+ protected final Dpid dpid;
public OFMessageHandler(Dpid dpid, OFMessage msg) {
this.msg = msg;