public class TestAsyncIPC extends AbstractTestIPC
Constructor and Description |
---|
TestAsyncIPC(boolean useNativeTransport,
boolean useGlobalEventLoopGroup) |
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() |
testCompressCellBlock, testNoCodec, testRpcScheduler, testRTEDuringConnectionSetup
public TestAsyncIPC(boolean useNativeTransport, boolean useGlobalEventLoopGroup)
public static java.util.Collection<java.lang.Object[]> parameters()
protected AsyncRpcClient createRpcClientNoCodec(Configuration conf)
createRpcClientNoCodec
in class AbstractTestIPC
protected AsyncRpcClient createRpcClient(Configuration conf)
createRpcClient
in class AbstractTestIPC
protected AsyncRpcClient createRpcClientRTEDuringConnectionSetup(Configuration conf)
createRpcClientRTEDuringConnectionSetup
in class AbstractTestIPC
public void testAsyncConnectionSetup() throws java.lang.Exception
java.lang.Exception
public void testRTEDuringAsyncConnectionSetup() throws java.lang.Exception
java.lang.Exception
public static void main(java.lang.String[] args) throws java.io.IOException, java.lang.SecurityException, java.lang.NoSuchMethodException, java.lang.InterruptedException
java.io.IOException
java.lang.SecurityException
java.lang.NoSuchMethodException
java.lang.InterruptedException