public class TestNettyIPC extends AbstractTestIPC
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.apache.hbase.thirdparty.io.netty.channel.epoll.EpollEventLoopGroup |
EPOLL |
String |
eventLoopType |
private static org.apache.hbase.thirdparty.io.netty.channel.nio.NioEventLoopGroup |
NIO |
CONF, rpcServerImpl, traceRule
Constructor and Description |
---|
TestNettyIPC() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.hbase.ipc.AbstractRpcClient<?> |
createBadAuthRpcClient(org.apache.hadoop.conf.Configuration conf) |
protected org.apache.hadoop.hbase.ipc.NettyRpcClient |
createRpcClient(org.apache.hadoop.conf.Configuration conf) |
protected org.apache.hadoop.hbase.ipc.NettyRpcClient |
createRpcClientNoCodec(org.apache.hadoop.conf.Configuration conf) |
protected org.apache.hadoop.hbase.ipc.NettyRpcClient |
createRpcClientRTEDuringConnectionSetup(org.apache.hadoop.conf.Configuration conf) |
private static List<String> |
getEventLoopTypes() |
static List<Object[]> |
parameters() |
private void |
setConf(org.apache.hadoop.conf.Configuration conf) |
static void |
setUpBeforeClass() |
static void |
tearDownAfterClass() |
createRpcServer, createTestFailingRpcServer, setUpBeforeTest, testAsyncEcho, testAsyncRemoteError, testAsyncTimeout, testBadPreambleHeader, testCompressCellBlock, testConnectionCloseWithOutstandingRPCs, testGetConnectionRegistry, testGetConnectionRegistryError, testNoCodec, testRemoteError, testRpcMaxRequestSize, testRpcScheduler, testRpcServerForNotNullRemoteAddressInCallObject, testRTEDuringConnectionSetup, testTimeout, testTracingErrorIpc, testTracingSuccessIpc
public static final HBaseClassTestRule CLASS_RULE
public String eventLoopType
private static org.apache.hbase.thirdparty.io.netty.channel.nio.NioEventLoopGroup NIO
private static org.apache.hbase.thirdparty.io.netty.channel.epoll.EpollEventLoopGroup EPOLL
public TestNettyIPC()
private static List<String> getEventLoopTypes()
public static List<Object[]> parameters()
public static void setUpBeforeClass()
public static void tearDownAfterClass()
private void setConf(org.apache.hadoop.conf.Configuration conf)
protected org.apache.hadoop.hbase.ipc.NettyRpcClient createRpcClientNoCodec(org.apache.hadoop.conf.Configuration conf)
createRpcClientNoCodec
in class AbstractTestIPC
protected org.apache.hadoop.hbase.ipc.NettyRpcClient createRpcClient(org.apache.hadoop.conf.Configuration conf)
createRpcClient
in class AbstractTestIPC
protected org.apache.hadoop.hbase.ipc.NettyRpcClient createRpcClientRTEDuringConnectionSetup(org.apache.hadoop.conf.Configuration conf)
createRpcClientRTEDuringConnectionSetup
in class AbstractTestIPC
protected org.apache.hadoop.hbase.ipc.AbstractRpcClient<?> createBadAuthRpcClient(org.apache.hadoop.conf.Configuration conf)
createBadAuthRpcClient
in class AbstractTestIPC
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.