commit 0510462b9057b0d870392cd40a3b608b7e8b867b Author: Todd Lipcon Date: Sun Jan 16 18:00:23 2011 -0800 HBASE-3510. Name IPC Reader threads diff --git src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java index 19ad295..c461bbc 100644 --- src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java +++ src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java @@ -65,6 +65,7 @@ import org.apache.hadoop.util.ReflectionUtils; import org.apache.hadoop.util.StringUtils; import com.google.common.base.Function; +import com.google.common.util.concurrent.ThreadFactoryBuilder; /** An abstract IPC service. IPC calls take a single {@link Writable} as a * parameter, and return a {@link Writable} as their value. A service runs on @@ -272,7 +273,9 @@ public abstract class HBaseServer { selector= Selector.open(); readers = new Reader[readThreads]; - readPool = Executors.newFixedThreadPool(readThreads); + readPool = Executors.newFixedThreadPool(readThreads, + new ThreadFactoryBuilder().setNameFormat( + "IPC Reader %d on port " + port).build()); for (int i = 0; i < readThreads; ++i) { Selector readSelector = Selector.open(); Reader reader = new Reader(readSelector);