Package org.apache.hadoop.hbase.ipc

Class TestBlockingIPC

java.lang.Object

org.apache.hadoop.hbase.ipc.AbstractTestIPC

org.apache.hadoop.hbase.ipc.TestBlockingIPC

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

Field Summary

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

CONF

Constructor Summary

Constructors

Constructor	Description
TestBlockingIPC(Class<? extends org.apache.hadoop.hbase.ipc.RpcServer> rpcServerImpl)

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.BlockingRpcClient	createRpcClient(org.apache.hadoop.conf.Configuration conf)
protected org.apache.hadoop.hbase.ipc.BlockingRpcClient	createRpcClientNoCodec(org.apache.hadoop.conf.Configuration conf)
protected org.apache.hadoop.hbase.ipc.BlockingRpcClient	createRpcClientRTEDuringConnectionSetup(org.apache.hadoop.conf.Configuration conf)
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()

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

Constructor Details

TestBlockingIPC

public TestBlockingIPC(Class<? extends org.apache.hadoop.hbase.ipc.RpcServer> rpcServerImpl)

Method Details

parameters

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

createRpcClientNoCodec

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

Specified by:

createRpcClientNoCodec in class AbstractTestIPC

createRpcClient

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

Specified by:

createRpcClient in class AbstractTestIPC

createRpcClientRTEDuringConnectionSetup

protected org.apache.hadoop.hbase.ipc.BlockingRpcClient createRpcClientRTEDuringConnectionSetup(org.apache.hadoop.conf.Configuration conf)
                                                                                         throws IOException

Specified by:

createRpcClientRTEDuringConnectionSetup 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