Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-3510. Add thread name for IPC reader threads 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1068162 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Todd Lipcon 2011-02-07 22:02:16 +00:00
parent 69eec35098
commit 81022285b9
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -102,6 +102,7 @@ Release 0.90.1 - Unreleased
HBASE-3470 Check that hbase-default.xml is loaded from within jar HBASE-3470 Check that hbase-default.xml is loaded from within jar
HBASE-3508 LruBlockCache statistics thread should have a name HBASE-3508 LruBlockCache statistics thread should have a name
HBASE-3511 Allow rolling restart to apply to only RS or only masters 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 Release 0.90.0 - January 19th, 2011
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

5
src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java
View File

@ -62,6 +62,7 @@ import org.apache.hadoop.util.ReflectionUtils;
import org.apache.hadoop.util.StringUtils; import org.apache.hadoop.util.StringUtils;
import com.google.common.base.Function; 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 /** 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 * parameter, and return a {@link Writable} as their value. A service runs on
@ -284,7 +285,9 @@ public abstract class HBaseServer implements RpcServer {
selector= Selector.open(); selector= Selector.open();
readers = new Reader[readThreads]; 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) { for (int i = 0; i < readThreads; ++i) {
Selector readSelector = Selector.open(); Selector readSelector = Selector.open();
Reader reader = new Reader(readSelector); Reader reader = new Reader(readSelector);