commit | 060da9a13a6e79fc1a5722a702d5fc29990effe4 | [log] [tgz] |
---|---|---|
author | HIGUCHI Yuta <y-higuchi@ak.jp.nec.com> | Fri Mar 11 19:16:35 2016 -0800 |
committer | Gerrit Code Review <gerrit@onlab.us> | Wed Mar 23 17:57:16 2016 +0000 |
tree | cf4a437370cfc53adb0bdd248ceb966a3bb2ad37 | |
parent | 4a24a3e06ffbfbeb37a11d482269f9dd5996c913 [diff] [blame] |
Improve Executors related logging behavior - Specify Logger for the Executor - Use Executor#execute instead of ExecutorService#submit for fire and forget type of usage. Note: submit() will swallow thrown Exception Change-Id: I507b841dc3feedf4ad20a746c304518d68fb846a
diff --git a/core/store/dist/src/main/java/org/onosproject/store/flow/impl/NewDistributedFlowRuleStore.java b/core/store/dist/src/main/java/org/onosproject/store/flow/impl/NewDistributedFlowRuleStore.java index a2b9995..7b94670 100644 --- a/core/store/dist/src/main/java/org/onosproject/store/flow/impl/NewDistributedFlowRuleStore.java +++ b/core/store/dist/src/main/java/org/onosproject/store/flow/impl/NewDistributedFlowRuleStore.java
@@ -305,7 +305,7 @@ msgHandlerPoolSize = newPoolSize; ExecutorService oldMsgHandler = messageHandlingExecutor; messageHandlingExecutor = Executors.newFixedThreadPool( - msgHandlerPoolSize, groupedThreads("onos/store/flow", "message-handlers")); + msgHandlerPoolSize, groupedThreads("onos/store/flow", "message-handlers", log)); // replace previously registered handlers. registerMessageHandlers(messageHandlingExecutor);