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(java.lang.String[] args)
static java.util.Collection<java.lang.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 java.util.Collection<java.lang.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 java.lang.Exception

Throws:

java.lang.Exception

testRTEDuringAsyncConnectionSetup

public void testRTEDuringAsyncConnectionSetup()
                                       throws java.lang.Exception

Throws:

java.lang.Exception

main

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

Throws:

java.io.IOException

java.lang.SecurityException

java.lang.NoSuchMethodException

java.lang.InterruptedException