Package org.apache.hadoop.hbase.client

Class TestRpcBasedRegistryHedgedReads

java.lang.Object

org.apache.hadoop.hbase.client.TestRpcBasedRegistryHedgedReads

public class TestRpcBasedRegistryHedgedReads
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TestRpcBasedRegistryHedgedReads.RpcChannelImpl	A dummy RpcChannel implementation that intercepts the GetClusterId() RPC calls and injects errors.
static final class	TestRpcBasedRegistryHedgedReads.RpcClientImpl

Field Summary

Fields

Modifier and Type	Field	Description
private static int	BAD_RESP_INDEX
private static Set<org.apache.hadoop.hbase.ServerName>	BOOTSTRAP_NODES
private static AtomicInteger	CALLED
static final HBaseClassTestRule	CLASS_RULE
private static final ExecutorService	EXECUTOR
private static Set<Integer>	GOOD_RESP_INDEXS
private static final String	HEDGED_REQS_FANOUT_CONFIG_NAME
private static final String	INITIAL_DELAY_SECS_CONFIG_NAME
private static final org.slf4j.Logger	LOG
private static final String	MIN_REFRESH_INTERVAL_SECS_CONFIG_NAME
private static final String	REFRESH_INTERVAL_SECS_CONFIG_NAME
private static org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetClusterIdResponse	RESP
private static final HBaseCommonTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
TestRpcBasedRegistryHedgedReads()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.client.AbstractRpcBasedConnectionRegistry	createRegistry(int hedged)
private <T> T	logIfError(CompletableFuture<T> future)
void	setUp()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testAllFailHedged3()
void	testAllFailNoHedged()
void	testFirstSucceededNoHedge()
void	testSecondRoundSucceededHedge4()
void	testSucceededWithLargestHedged()

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

HEDGED_REQS_FANOUT_CONFIG_NAME

private static final String HEDGED_REQS_FANOUT_CONFIG_NAME

See Also:

• Constant Field Values

INITIAL_DELAY_SECS_CONFIG_NAME

private static final String INITIAL_DELAY_SECS_CONFIG_NAME

See Also:

• Constant Field Values

REFRESH_INTERVAL_SECS_CONFIG_NAME

private static final String REFRESH_INTERVAL_SECS_CONFIG_NAME

See Also:

• Constant Field Values

MIN_REFRESH_INTERVAL_SECS_CONFIG_NAME

private static final String MIN_REFRESH_INTERVAL_SECS_CONFIG_NAME

See Also:

• Constant Field Values

UTIL

private static final HBaseCommonTestingUtil UTIL

EXECUTOR

private static final ExecutorService EXECUTOR

BOOTSTRAP_NODES

private static Set<org.apache.hadoop.hbase.ServerName> BOOTSTRAP_NODES

CALLED

private static AtomicInteger CALLED

BAD_RESP_INDEX

private static volatile int BAD_RESP_INDEX

GOOD_RESP_INDEXS

private static volatile Set<Integer> GOOD_RESP_INDEXS

RESP

private static org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetClusterIdResponse RESP

Constructor Details

TestRpcBasedRegistryHedgedReads

public TestRpcBasedRegistryHedgedReads()

Method Details

createRegistry

private org.apache.hadoop.hbase.client.AbstractRpcBasedConnectionRegistry createRegistry(int hedged)
                                                                                  throws IOException

Throws:

IOException

setUpBeforeClass

public static void setUpBeforeClass()

tearDownAfterClass

public static void tearDownAfterClass()

setUp

public void setUp()

logIfError

private <T> T logIfError(CompletableFuture<T> future)
                  throws IOException

Throws:

IOException

testAllFailNoHedged

public void testAllFailNoHedged()
                         throws IOException

Throws:

IOException

testAllFailHedged3

public void testAllFailHedged3()
                        throws IOException

Throws:

IOException

testFirstSucceededNoHedge

public void testFirstSucceededNoHedge()
                               throws IOException

Throws:

IOException

testSecondRoundSucceededHedge4

public void testSecondRoundSucceededHedge4()
                                    throws IOException

Throws:

IOException

testSucceededWithLargestHedged

public void testSucceededWithLargestHedged()
                                    throws IOException,
InterruptedException

Throws:

IOException

InterruptedException