Package org.apache.hadoop.hbase.ipc

Class TestNettyIPC

java.lang.Object

org.apache.hadoop.hbase.ipc.AbstractTestIPC

org.apache.hadoop.hbase.ipc.TestNettyIPC

@Tag("org.apache.hadoop.hbase.testclassification.RPCTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestNettyIPC
extends AbstractTestIPC

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hbase.thirdparty.io.netty.channel.epoll.EpollEventLoopGroup	EPOLL
private String	eventLoopType
private static org.apache.hbase.thirdparty.io.netty.channel.nio.NioEventLoopGroup	NIO

Fields inherited from class org.apache.hadoop.hbase.ipc.AbstractTestIPC

CONF

Constructor Summary

Constructors

Constructor	Description
TestNettyIPC(Class<? extends org.apache.hadoop.hbase.ipc.RpcServer> rpcServerImpl, String eventLoopType)

Method Summary

Modifier and Type	Method	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 Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
private void	setConf(org.apache.hadoop.conf.Configuration conf)
static void	setUpBeforeClass()
static void	tearDownAfterClass()

Methods inherited from class org.apache.hadoop.hbase.ipc.AbstractTestIPC

createRpcServer, createTestFailingRpcServer, setUpBeforeTest, testAsyncEcho, testAsyncRemoteError, testAsyncTimeout, testBadPreambleHeader, testCompressCellBlock, testConnectionCloseWithOutstandingRPCs, testGetConnectionRegistry, testGetConnectionRegistryError, testNoCodec, testRemoteError, testRpcMaxRequestSize, testRpcScheduler, testRpcServerForNotNullRemoteAddressInCallObject, testRTEDuringConnectionSetup, testTimeout, testTracingErrorIpc, testTracingSuccessIpc

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

eventLoopType

private String eventLoopType

NIO

private static org.apache.hbase.thirdparty.io.netty.channel.nio.NioEventLoopGroup NIO

EPOLL

private static org.apache.hbase.thirdparty.io.netty.channel.epoll.EpollEventLoopGroup EPOLL

Constructor Details

TestNettyIPC

public TestNettyIPC(Class<? extends org.apache.hadoop.hbase.ipc.RpcServer> rpcServerImpl,
 String eventLoopType)

Method Details

getEventLoopTypes

private static List<String> getEventLoopTypes()

parameters

public static Stream<org.junit.jupiter.params.provider.Arguments> parameters()

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()

setConf

private void setConf(org.apache.hadoop.conf.Configuration conf)

createRpcClientNoCodec

protected org.apache.hadoop.hbase.ipc.NettyRpcClient createRpcClientNoCodec(org.apache.hadoop.conf.Configuration conf)

Specified by:

createRpcClientNoCodec in class AbstractTestIPC

createRpcClient

protected org.apache.hadoop.hbase.ipc.NettyRpcClient createRpcClient(org.apache.hadoop.conf.Configuration conf)

Specified by:

createRpcClient in class AbstractTestIPC

createRpcClientRTEDuringConnectionSetup

protected org.apache.hadoop.hbase.ipc.NettyRpcClient createRpcClientRTEDuringConnectionSetup(org.apache.hadoop.conf.Configuration conf)

Specified by:

createRpcClientRTEDuringConnectionSetup in class AbstractTestIPC

createBadAuthRpcClient

protected org.apache.hadoop.hbase.ipc.AbstractRpcClient<?> createBadAuthRpcClient(org.apache.hadoop.conf.Configuration conf)

Specified by:

createBadAuthRpcClient in class AbstractTestIPC