org.apache.hadoop.hbase.ipc

Class IntegrationTestRpcClient

java.lang.Object

org.apache.hadoop.hbase.ipc.IntegrationTestRpcClient

public class IntegrationTestRpcClient
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	IntegrationTestRpcClient.Cluster
(package private) static class	IntegrationTestRpcClient.MiniChaosMonkey
(package private) static class	IntegrationTestRpcClient.SimpleClient
(package private) static class	IntegrationTestRpcClient.TimeoutThread

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static String	BIG_PAYLOAD
private org.apache.hadoop.conf.Configuration	conf
private static org.slf4j.Logger	LOG
private int	numIterations

Constructor Summary

Constructors

Constructor and Description
IntegrationTestRpcClient()

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.hbase.ipc.AbstractRpcClient<?>	createRpcClient(org.apache.hadoop.conf.Configuration conf, boolean isSyncClient)
void	testRpcWithChaosMonkey(boolean isSyncClient)
void	testRpcWithChaosMonkeyWithAsyncClient()
void	testRpcWithChaosMonkeyWithSyncClient()
void	testRpcWithWriteThread()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

conf

private final org.apache.hadoop.conf.Configuration conf

numIterations

private int numIterations

BIG_PAYLOAD

static String BIG_PAYLOAD

Constructor Detail

IntegrationTestRpcClient

public IntegrationTestRpcClient()

Method Detail

createRpcClient

protected org.apache.hadoop.hbase.ipc.AbstractRpcClient<?> createRpcClient(org.apache.hadoop.conf.Configuration conf,
                                                                           boolean isSyncClient)

testRpcWithWriteThread

public void testRpcWithWriteThread()
                            throws IOException,
                                   InterruptedException

Throws:

IOException

InterruptedException

testRpcWithChaosMonkeyWithSyncClient

public void testRpcWithChaosMonkeyWithSyncClient()
                                          throws Throwable

Throws:

Throwable

testRpcWithChaosMonkeyWithAsyncClient

public void testRpcWithChaosMonkeyWithAsyncClient()
                                           throws Throwable

Throws:

Throwable

testRpcWithChaosMonkey

public void testRpcWithChaosMonkey(boolean isSyncClient)
                            throws Throwable

Throws:

Throwable