org.apache.hadoop.hbase.ipc

Class TestAsyncIPC

java.lang.Object

org.apache.hadoop.hbase.ipc.AbstractTestIPC

org.apache.hadoop.hbase.ipc.TestAsyncIPC

public class TestAsyncIPC
extends AbstractTestIPC

Constructor Summary

Constructors

Constructor and Description
TestAsyncIPC(boolean useNativeTransport, boolean useGlobalEventLoopGroup)

Method Summary

Modifier and Type	Method and Description
protected AsyncRpcClient	createRpcClient(Configuration conf)
protected AsyncRpcClient	createRpcClientNoCodec(Configuration conf)
protected AsyncRpcClient	createRpcClientRTEDuringConnectionSetup(Configuration conf)
static void	main(String[] args)
static Collection<Object[]>	parameters()
void	testAsyncConnectionSetup()
void	testRTEDuringAsyncConnectionSetup()

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

testCompressCellBlock, testNoCodec, testRpcScheduler, testRTEDuringConnectionSetup

Methods inherited from class java.lang.Object

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

Constructor Detail

TestAsyncIPC

public TestAsyncIPC(boolean useNativeTransport,
                    boolean useGlobalEventLoopGroup)

Method Detail

parameters

public static Collection<Object[]> parameters()

createRpcClientNoCodec

protected AsyncRpcClient createRpcClientNoCodec(Configuration conf)

Specified by:

createRpcClientNoCodec in class AbstractTestIPC

createRpcClient

protected AsyncRpcClient createRpcClient(Configuration conf)

Specified by:

createRpcClient in class AbstractTestIPC

createRpcClientRTEDuringConnectionSetup

protected AsyncRpcClient createRpcClientRTEDuringConnectionSetup(Configuration conf)

Specified by:

createRpcClientRTEDuringConnectionSetup in class AbstractTestIPC

testAsyncConnectionSetup

public void testAsyncConnectionSetup()
                              throws Exception

Throws:

Exception

testRTEDuringAsyncConnectionSetup

public void testRTEDuringAsyncConnectionSetup()
                                       throws Exception

Throws:

Exception

main

public static void main(String[] args)
                 throws IOException,
                        SecurityException,
                        NoSuchMethodException,
                        InterruptedException

Throws:

IOException

SecurityException

NoSuchMethodException

InterruptedException