org.apache.hadoop.hbase.client

Class TestMasterRegistryHedgedReads

java.lang.Object

org.apache.hadoop.hbase.client.TestMasterRegistryHedgedReads

public class TestMasterRegistryHedgedReads
extends Object

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
private static int	BAD_RESP_INDEX
private static AtomicInteger	CALLED
static HBaseClassTestRule	CLASS_RULE
private static ExecutorService	EXECUTOR
private static Set<Integer>	GOOD_RESP_INDEXS
private static org.slf4j.Logger	LOG
private static org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetClusterIdResponse	RESP
private static HBaseCommonTestingUtility	UTIL

Constructor Summary

Constructors

Constructor and Description
TestMasterRegistryHedgedReads()

Method Summary

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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

UTIL

private static final HBaseCommonTestingUtility UTIL

EXECUTOR

private static final ExecutorService EXECUTOR

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.MasterProtos.GetClusterIdResponse RESP

Constructor Detail

TestMasterRegistryHedgedReads

public TestMasterRegistryHedgedReads()

Method Detail

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