public class TestAsyncClientPauseForRpcThrottling extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TestAsyncClientPauseForRpcThrottling.ThrottlingRegionServerForTest |
static class |
TestAsyncClientPauseForRpcThrottling.ThrottlingRSRpcServicesForTest |
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.apache.hadoop.hbase.client.AsyncConnection |
CONN |
private static byte[] |
FAMILY |
private static AtomicInteger |
FORCE_RETRIES |
private static int |
MAX_MULTIPLIER_EXPECTATION |
private static byte[] |
QUALIFIER |
private static int |
RETRY_COUNT |
private static org.apache.hadoop.hbase.TableName |
TABLE_NAME |
private static AtomicBoolean |
THROTTLE |
private static HBaseTestingUtil |
UTIL |
private static long |
WAIT_INTERVAL_NANOS |
Constructor and Description |
---|
TestAsyncClientPauseForRpcThrottling() |
Modifier and Type | Method and Description |
---|---|
private void |
assertTime(Callable<Void> callable,
long time,
boolean isGreater) |
private void |
assertTimeBetween(Callable<Void> callable,
long minNs,
long maxNs) |
private long |
getCostNs(Callable<Void> callable) |
void |
itDoesNotMultiplyThrottledBatchWait() |
void |
itDoesNotMultiplyThrottledGetWait() |
void |
itDoesNotMultiplyThrottledScanWait() |
void |
itDoesNotWaitForThrottledBatchExceedingTimeout() |
void |
itDoesNotWaitForThrottledGetExceedingTimeout() |
void |
itDoesNotWaitForThrottledScanExceedingTimeout() |
void |
itDoesNotWaitForUnthrottledBatch() |
void |
itDoesNotWaitForUnthrottledGet() |
void |
itDoesNotWaitForUnthrottledScan() |
void |
itWaitsForThrottledBatch() |
void |
itWaitsForThrottledGet() |
void |
itWaitsForThrottledScan() |
static void |
setUp() |
static void |
tearDown() |
public static final HBaseClassTestRule CLASS_RULE
private static final HBaseTestingUtil UTIL
private static org.apache.hadoop.hbase.TableName TABLE_NAME
private static byte[] FAMILY
private static byte[] QUALIFIER
private static org.apache.hadoop.hbase.client.AsyncConnection CONN
private static final AtomicBoolean THROTTLE
private static final AtomicInteger FORCE_RETRIES
private static final long WAIT_INTERVAL_NANOS
private static final int RETRY_COUNT
private static final int MAX_MULTIPLIER_EXPECTATION
public TestAsyncClientPauseForRpcThrottling()
private void assertTime(Callable<Void> callable, long time, boolean isGreater) throws Exception
Exception
private void assertTimeBetween(Callable<Void> callable, long minNs, long maxNs) throws Exception
Exception
public void itWaitsForThrottledGet() throws Exception
Exception
public void itDoesNotWaitForUnthrottledGet() throws Exception
Exception
public void itDoesNotWaitForThrottledGetExceedingTimeout() throws Exception
Exception
public void itDoesNotMultiplyThrottledGetWait() throws Exception
Exception
public void itWaitsForThrottledBatch() throws Exception
Exception
public void itDoesNotWaitForUnthrottledBatch() throws Exception
Exception
public void itDoesNotWaitForThrottledBatchExceedingTimeout() throws Exception
Exception
public void itDoesNotMultiplyThrottledBatchWait() throws Exception
Exception
public void itWaitsForThrottledScan() throws Exception
Exception
public void itDoesNotWaitForUnthrottledScan() throws Exception
Exception
public void itDoesNotWaitForThrottledScanExceedingTimeout() throws Exception
Exception
public void itDoesNotMultiplyThrottledScanWait() throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.