You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2016/09/12 14:05:51 UTC
hbase git commit: HBASE-16614 Use daemon thread for netty event loop
Repository: hbase
Updated Branches:
refs/heads/master 105bfc7d7 -> 0860bdb67
HBASE-16614 Use daemon thread for netty event loop
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/0860bdb6
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/0860bdb6
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/0860bdb6
Branch: refs/heads/master
Commit: 0860bdb675180a7ed9a1bbafe542b9e730d39e31
Parents: 105bfc7
Author: zhangduo <zh...@apache.org>
Authored: Mon Sep 12 16:32:03 2016 +0800
Committer: zhangduo <zh...@apache.org>
Committed: Mon Sep 12 22:05:03 2016 +0800
----------------------------------------------------------------------
.../apache/hadoop/hbase/ipc/DefaultNettyEventLoopConfig.java | 5 ++++-
.../main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java | 4 +++-
2 files changed, 7 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/0860bdb6/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/DefaultNettyEventLoopConfig.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/DefaultNettyEventLoopConfig.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/DefaultNettyEventLoopConfig.java
index c7c0f32..f710d54 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/DefaultNettyEventLoopConfig.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/DefaultNettyEventLoopConfig.java
@@ -21,6 +21,7 @@ import io.netty.channel.Channel;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.util.concurrent.DefaultThreadFactory;
import org.apache.hadoop.hbase.classification.InterfaceAudience;
import org.apache.hadoop.hbase.util.Pair;
@@ -32,6 +33,8 @@ import org.apache.hadoop.hbase.util.Pair;
class DefaultNettyEventLoopConfig {
public static final Pair<EventLoopGroup, Class<? extends Channel>> GROUP_AND_CHANNEL_CLASS = Pair
- .<EventLoopGroup, Class<? extends Channel>> newPair(new NioEventLoopGroup(),
+ .<EventLoopGroup, Class<? extends Channel>> newPair(
+ new NioEventLoopGroup(0,
+ new DefaultThreadFactory("Default-IPC-NioEventLoopGroup", true, Thread.MAX_PRIORITY)),
NioSocketChannel.class);
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/0860bdb6/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java
index 8c568af..cde453f 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java
@@ -21,6 +21,7 @@ import io.netty.channel.Channel;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.util.concurrent.DefaultThreadFactory;
import java.io.IOException;
import java.net.SocketAddress;
@@ -51,7 +52,8 @@ public class NettyRpcClient extends AbstractRpcClient<NettyRpcConnection> {
.getEventLoopConfig(conf);
if (groupAndChannelClass == null) {
// Use our own EventLoopGroup.
- this.group = new NioEventLoopGroup();
+ this.group = new NioEventLoopGroup(0,
+ new DefaultThreadFactory("IPC-NioEventLoopGroup", true, Thread.MAX_PRIORITY));
this.channelClass = NioSocketChannel.class;
this.shutdownGroupWhenClose = true;
} else {