org.apache.hadoop.hbase.client

Class TestFastFailWithoutTestUtil

java.lang.Object

org.apache.hadoop.hbase.client.TestFastFailWithoutTestUtil

public class TestFastFailWithoutTestUtil
extends java.lang.Object

Field Summary

Fields

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

Methods inherited from class java.lang.Object

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

Field Detail

isPriviThreadLocal

public final java.lang.ThreadLocal<java.util.concurrent.atomic.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 java.io.IOException

Throws:

java.io.IOException

testInterceptorIntercept50Times

public void testInterceptorIntercept50Times()
                                     throws java.io.IOException,
                                            java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

testInterceptorIntercept

public void testInterceptorIntercept()
                              throws java.io.IOException,
                                     java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

testExceptionsIdentifiedByInterceptor

public void testExceptionsIdentifiedByInterceptor()
                                           throws java.io.IOException

Throws:

java.io.IOException

createPreemptiveInterceptor

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

testPreemptiveFastFailException50Times

public void testPreemptiveFastFailException50Times()
                                            throws java.lang.InterruptedException,
                                                   java.util.concurrent.ExecutionException

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

getInterceptor

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

getRpcRetryingCaller

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

getSomeServerName

protected static ServerName getSomeServerName()