svn commit: r1068161 - in /hbase/branches/0.90: CHANGES.txt src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java

[to...@apache.org]

Author: todd
Date: Mon Feb  7 22:01:05 2011
New Revision: 1068161

URL: http://svn.apache.org/viewvc?rev=1068161&view=rev
Log:
HBASE-3510. Add thread name for IPC reader threads

Modified:
    hbase/branches/0.90/CHANGES.txt
    hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java

Modified: hbase/branches/0.90/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/CHANGES.txt?rev=1068161&r1=1068160&r2=1068161&view=diff
==============================================================================
--- hbase/branches/0.90/CHANGES.txt (original)
+++ hbase/branches/0.90/CHANGES.txt Mon Feb  7 22:01:05 2011
@@ -35,6 +35,7 @@ Release 0.90.1 - Unreleased
    HBASE-3470  Check that hbase-default.xml is loaded from within jar
    HBASE-3508  LruBlockCache statistics thread should have a name
    HBASE-3511  Allow rolling restart to apply to only RS or only masters
+   HBASE-3510  Add thread name for IPC reader threads
 
 Release 0.90.0 - January 19th, 2011
   INCOMPATIBLE CHANGES

Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java?rev=1068161&r1=1068160&r2=1068161&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java Mon Feb  7 22:01:05 2011
@@ -65,6 +65,7 @@ import org.apache.hadoop.util.Reflection
 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);