org.apache.hadoop.hbase.client

Class TestFastFailWithoutTestUtil

java.lang.Object

org.apache.hadoop.hbase.client.TestFastFailWithoutTestUtil

public class TestFastFailWithoutTestUtil
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
ThreadLocal<AtomicBoolean>	isPriviThreadLocal The variable which is used as an identifier within the 2 threads.

Constructor Summary

Constructors

Constructor and Description
TestFastFailWithoutTestUtil()

Method Summary

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<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()

Methods inherited from class java.lang.Object

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

Field Detail

isPriviThreadLocal

public final ThreadLocal<AtomicBoolean> isPriviThreadLocal

The variable which is used as an identifier within the 2 threads.

Constructor Detail

TestFastFailWithoutTestUtil

public TestFastFailWithoutTestUtil()

Method Detail

testInterceptorFactoryMethods

public void testInterceptorFactoryMethods()

testInterceptorContextClear

public void testInterceptorContextClear()

testInterceptorContextPrepare

public void testInterceptorContextPrepare()
                                   throws IOException

Throws:

IOException

testInterceptorIntercept50Times

public void testInterceptorIntercept50Times()
                                     throws IOException,
                                            InterruptedException

Throws:

IOException

InterruptedException

testInterceptorIntercept

public void testInterceptorIntercept()
                              throws IOException,
                                     InterruptedException

Throws:

IOException

InterruptedException

testExceptionsIdentifiedByInterceptor

public void testExceptionsIdentifiedByInterceptor()
                                           throws IOException

Throws:

IOException

createPreemptiveInterceptor

protected static org.apache.hadoop.hbase.client.PreemptiveFastFailInterceptor createPreemptiveInterceptor(Configuration conf)

testPreemptiveFastFailException50Times

public void testPreemptiveFastFailException50Times()
                                            throws InterruptedException,
                                                   ExecutionException

Throws:

InterruptedException

ExecutionException

getInterceptor

public org.apache.hadoop.hbase.client.PreemptiveFastFailInterceptor getInterceptor()

getRpcRetryingCaller

public RpcRetryingCaller<Void> getRpcRetryingCaller(int pauseTime,
                                                    int retries,
                                                    org.apache.hadoop.hbase.client.RetryingCallerInterceptor interceptor)

getSomeServerName

protected static ServerName getSomeServerName()