commit f845cc37408a8dcf63476ad0db30047400194010
author Yuta HIGUCHI <y-higuchi@onlab.us> Tue Nov 25 19:28:12 2014 -0800
committer Yuta HIGUCHI <y-higuchi@onlab.us> Tue Nov 25 20:44:10 2014 -0800
tree 67ff1561d2d8f07fca6e0ff4106491a530c4fb82
parent ae1d210a8fd4dd80a4ab7a36a181c094bddbfdee

Give a name to each ThreadPool

Change-Id: Iec2b044fca542672608fd67ff43680f0d34b9da2

apps/sdnip/src/main/java/org/onlab/onos/sdnip/bgp/BgpSessionManager.java

diff --git a/apps/sdnip/src/main/java/org/onlab/onos/sdnip/bgp/BgpSessionManager.java b/apps/sdnip/src/main/java/org/onlab/onos/sdnip/bgp/BgpSessionManager.java
index aaf26fa..1ef19c6 100644
--- a/apps/sdnip/src/main/java/org/onlab/onos/sdnip/bgp/BgpSessionManager.java
+++ b/apps/sdnip/src/main/java/org/onlab/onos/sdnip/bgp/BgpSessionManager.java
@@ -16,6 +16,7 @@
 package org.onlab.onos.sdnip.bgp;
 
 import static com.google.common.base.Preconditions.checkNotNull;
+import static org.onlab.util.Tools.namedThreads;
 
 import java.net.InetAddress;
 import java.net.InetSocketAddress;
@@ -186,8 +187,8 @@
         isShutdown = false;
 
         ChannelFactory channelFactory =
-            new NioServerSocketChannelFactory(Executors.newCachedThreadPool(),
-                                              Executors.newCachedThreadPool());
+            new NioServerSocketChannelFactory(Executors.newCachedThreadPool(namedThreads("BGP-SM-boss-%d")),
+                                              Executors.newCachedThreadPool(namedThreads("BGP-SM-worker-%d")));
         ChannelPipelineFactory pipelineFactory = new ChannelPipelineFactory() {
                 @Override
                 public ChannelPipeline getPipeline() throws Exception {