public class TestFastFailWithoutTestUtil
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
java.lang.ThreadLocal<java.util.concurrent.atomic.AtomicBoolean> |
isPriviThreadLocal
The variable which is used as an identifier within the 2 threads.
|
Constructor and Description |
---|
TestFastFailWithoutTestUtil() |
Modifier and Type | Method and Description |
---|---|
protected static org.apache.hadoop.hbase.client.PreemptiveFastFailInterceptor |
createPreemptiveInterceptor(Configuration conf) |
org.apache.hadoop.hbase.client.PreemptiveFastFailInterceptor |
getInterceptor() |
RpcRetryingCaller<java.lang.Void> |
getRpcRetryingCaller(int pauseTime,
int retries,
org.apache.hadoop.hbase.client.RetryingCallerInterceptor interceptor) |
protected static ServerName |
getSomeServerName() |
void |
testExceptionsIdentifiedByInterceptor() |
void |
testInterceptorContextClear() |
void |
testInterceptorContextPrepare() |
void |
testInterceptorFactoryMethods() |
void |
testInterceptorIntercept() |
void |
testInterceptorIntercept50Times() |
void |
testPreemptiveFastFailException50Times() |
public final java.lang.ThreadLocal<java.util.concurrent.atomic.AtomicBoolean> isPriviThreadLocal
public void testInterceptorFactoryMethods()
public void testInterceptorContextClear()
public void testInterceptorContextPrepare() throws java.io.IOException
java.io.IOException
public void testInterceptorIntercept50Times() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void testInterceptorIntercept() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void testExceptionsIdentifiedByInterceptor() throws java.io.IOException
java.io.IOException
protected static org.apache.hadoop.hbase.client.PreemptiveFastFailInterceptor createPreemptiveInterceptor(Configuration conf)
public void testPreemptiveFastFailException50Times() throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
java.lang.InterruptedException
java.util.concurrent.ExecutionException
public org.apache.hadoop.hbase.client.PreemptiveFastFailInterceptor getInterceptor()
public RpcRetryingCaller<java.lang.Void> getRpcRetryingCaller(int pauseTime, int retries, org.apache.hadoop.hbase.client.RetryingCallerInterceptor interceptor)
protected static ServerName getSomeServerName()