Package org.apache.hadoop.hbase.ipc

Class TestNettyTlsIPC

java.lang.Object

org.apache.hadoop.hbase.ipc.AbstractTestIPC

org.apache.hadoop.hbase.ipc.TestNettyTlsIPC

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

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	acceptPlainText
private X509KeyType	caKeyType
private X509KeyType	certKeyType
private boolean	clientTlsEnabled
private static org.apache.hadoop.hbase.util.NettyEventLoopGroupConfig	EVENT_LOOP_GROUP_CONFIG
private char[]	keyPassword
private static X509TestContextProvider	PROVIDER
private static final HBaseCommonTestingUtil	UTIL
private X509TestContext	x509TestContext

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

CONF

Constructor Summary

Constructors

Constructor	Description
TestNettyTlsIPC(Class<? extends org.apache.hadoop.hbase.ipc.RpcServer> rpcServerImpl, X509KeyType caKeyType, X509KeyType certKeyType, char[] keyPassword, boolean acceptPlainText, boolean clientTlsEnabled)

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.AbstractRpcClient<?>	createRpcClient(org.apache.hadoop.conf.Configuration conf)
protected org.apache.hadoop.hbase.ipc.AbstractRpcClient<?>	createRpcClientNoCodec(org.apache.hadoop.conf.Configuration conf)
protected org.apache.hadoop.hbase.ipc.AbstractRpcClient<?>	createRpcClientRTEDuringConnectionSetup(org.apache.hadoop.conf.Configuration conf)
protected org.apache.hadoop.hbase.ipc.RpcServer	createRpcServer(org.apache.hadoop.hbase.Server server, String name, List<org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface> services, InetSocketAddress bindAddress, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.ipc.RpcScheduler scheduler)
protected org.apache.hadoop.hbase.ipc.RpcServer	createTestFailingRpcServer(String name, List<org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface> services, InetSocketAddress bindAddress, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.ipc.RpcScheduler scheduler)
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
void	setUp()
static void	setUpBeforeClass()
void	tearDown()
static void	tearDownAfterClass()

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

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

UTIL

private static final HBaseCommonTestingUtil UTIL

PROVIDER

private static X509TestContextProvider PROVIDER

EVENT_LOOP_GROUP_CONFIG

private static org.apache.hadoop.hbase.util.NettyEventLoopGroupConfig EVENT_LOOP_GROUP_CONFIG

caKeyType

private X509KeyType caKeyType

certKeyType

private X509KeyType certKeyType

keyPassword

private char[] keyPassword

acceptPlainText

private boolean acceptPlainText

clientTlsEnabled

private boolean clientTlsEnabled

x509TestContext

private X509TestContext x509TestContext

Constructor Details

TestNettyTlsIPC

public TestNettyTlsIPC(Class<? extends org.apache.hadoop.hbase.ipc.RpcServer> rpcServerImpl,
 X509KeyType caKeyType,
 X509KeyType certKeyType,
 char[] keyPassword,
 boolean acceptPlainText,
 boolean clientTlsEnabled)

Method Details

parameters

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

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws IOException

Throws:

IOException

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws InterruptedException

Throws:

InterruptedException

setUp

@BeforeEach
public void setUp()
           throws IOException

Throws:

IOException

tearDown

@AfterEach
public void tearDown()

createRpcServer

protected org.apache.hadoop.hbase.ipc.RpcServer createRpcServer(org.apache.hadoop.hbase.Server server,
 String name,
 List<org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface> services,
 InetSocketAddress bindAddress,
 org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.hbase.ipc.RpcScheduler scheduler)
                                                         throws IOException

Overrides:

createRpcServer in class AbstractTestIPC

Throws:

IOException

createRpcClientNoCodec

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

Specified by:

createRpcClientNoCodec in class AbstractTestIPC

createRpcClient

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

Specified by:

createRpcClient in class AbstractTestIPC

createRpcClientRTEDuringConnectionSetup

protected org.apache.hadoop.hbase.ipc.AbstractRpcClient<?> createRpcClientRTEDuringConnectionSetup(org.apache.hadoop.conf.Configuration conf)
                                                                                            throws IOException

Specified by:

createRpcClientRTEDuringConnectionSetup in class AbstractTestIPC

Throws:

IOException

createTestFailingRpcServer

protected org.apache.hadoop.hbase.ipc.RpcServer createTestFailingRpcServer(String name,
 List<org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface> services,
 InetSocketAddress bindAddress,
 org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.hbase.ipc.RpcScheduler scheduler)
                                                                    throws IOException

Overrides:

createTestFailingRpcServer in class AbstractTestIPC

Throws:

IOException

createBadAuthRpcClient

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

Specified by:

createBadAuthRpcClient in class AbstractTestIPC