org.apache.hadoop.hbase.ipc

Class TestBlockingIPC

java.lang.Object

org.apache.hadoop.hbase.ipc.AbstractTestIPC

org.apache.hadoop.hbase.ipc.TestBlockingIPC

public class TestBlockingIPC
extends AbstractTestIPC

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	TestBlockingIPC.TestFailingRpcServer

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE

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

CONF

Constructor Summary

Constructors

Constructor and Description
TestBlockingIPC()

Method Summary

Modifier and Type	Method and Description
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)
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(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)

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

testAsyncEcho, testAsyncRemoteError, testAsyncTimeout, testCompressCellBlock, testConnectionCloseWithOutstandingRPCs, testNoCodec, testRemoteError, testRpcMaxRequestSize, testRpcScheduler, testRpcServerForNotNullRemoteAddressInCallObject, testRTEDuringConnectionSetup, testTimeout

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

Constructor Detail

TestBlockingIPC

public TestBlockingIPC()

Method Detail

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

Specified by:

createRpcServer in class AbstractTestIPC

Throws:

IOException

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

createTestFailingRpcServer

protected org.apache.hadoop.hbase.ipc.RpcServer createTestFailingRpcServer(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

Specified by:

createTestFailingRpcServer in class AbstractTestIPC

Throws:

IOException