Package org.apache.hadoop.hbase.ipc

Class IntegrationTestRpcClient

java.lang.Object

org.apache.hadoop.hbase.ipc.IntegrationTestRpcClient

@Tag("org.apache.hadoop.hbase.testclassification.IntegrationTests")
public class IntegrationTestRpcClient
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	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	Description
(package private) static String	BIG_PAYLOAD
private final org.apache.hadoop.conf.Configuration	conf
private static final org.slf4j.Logger	LOG
private int	numIterations

Constructor Summary

Constructors

Constructor	Description
IntegrationTestRpcClient()

Method Summary

Modifier and Type	Method	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 Details

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 Details

IntegrationTestRpcClient

public IntegrationTestRpcClient()

Method Details

createRpcClient

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

testRpcWithWriteThread

@Test
public void testRpcWithWriteThread()
                            throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testRpcWithChaosMonkeyWithSyncClient

@Test
public void testRpcWithChaosMonkeyWithSyncClient()
                                          throws Throwable

Throws:

Throwable

testRpcWithChaosMonkeyWithAsyncClient

@Test
@Disabled
public void testRpcWithChaosMonkeyWithAsyncClient()
                                           throws Throwable

Throws:

Throwable

testRpcWithChaosMonkey

public void testRpcWithChaosMonkey(boolean isSyncClient)
                            throws Throwable

Throws:

Throwable