HBASE-20777 RpcConnection could still remain opened after we shutdown the NettyRpcServer

This commit is contained in:
zhangduo 2018-06-25 08:54:56 +08:00
parent 3f319bef8d
commit 07afb7e32f
1 changed files with 2 additions and 1 deletions

View File

@ -69,7 +69,8 @@ public class NettyRpcServer extends RpcServer {
private final CountDownLatch closed = new CountDownLatch(1); private final CountDownLatch closed = new CountDownLatch(1);
private final Channel serverChannel; private final Channel serverChannel;
private final ChannelGroup allChannels = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE); private final ChannelGroup allChannels =
new DefaultChannelGroup(GlobalEventExecutor.INSTANCE, true);
public NettyRpcServer(Server server, String name, List<BlockingServiceAndInterface> services, public NettyRpcServer(Server server, String name, List<BlockingServiceAndInterface> services,
InetSocketAddress bindAddress, Configuration conf, RpcScheduler scheduler, InetSocketAddress bindAddress, Configuration conf, RpcScheduler scheduler,