org.apache.hadoop.hbase.client

Class TestFastFail.MyPreemptiveFastFailInterceptor

java.lang.Object

org.apache.hadoop.hbase.client.TestFastFail.MyPreemptiveFastFailInterceptor

Enclosing class:

TestFastFail

public static class TestFastFail.MyPreemptiveFastFailInterceptor
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected long	failureMapCleanupIntervalMilliSec
protected long	fastFailThresholdMilliSec
protected long	lastFailureMapCleanupTimeMilliSec
static AtomicInteger	numBraveSouls
protected ConcurrentMap<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.client.FailureInfo>	repeatedFailuresMap

Constructor Summary

Constructors

Constructor and Description
MyPreemptiveFastFailInterceptor(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hbase.client.RetryingCallerInterceptorContext	createEmptyContext()
void	handleFailure(org.apache.hadoop.hbase.client.FastFailInterceptorContext arg0, Throwable arg1)
void	handleFailure(org.apache.hadoop.hbase.client.RetryingCallerInterceptorContext arg0, Throwable arg1)
protected void	handleFailureToServer(org.apache.hadoop.hbase.ServerName arg0, Throwable arg1)
void	handleThrowable(Throwable arg0, org.apache.hadoop.hbase.ServerName arg1, org.apache.commons.lang3.mutable.MutableBoolean arg2, org.apache.commons.lang3.mutable.MutableBoolean arg3)
void	intercept(org.apache.hadoop.hbase.client.FastFailInterceptorContext arg0)
void	intercept(org.apache.hadoop.hbase.client.RetryingCallerInterceptorContext arg0)
protected boolean	isServerInFailureMap(org.apache.hadoop.hbase.ServerName arg0)
protected void	occasionallyCleanupFailureInformation()
protected boolean	shouldRetryInspiteOfFastFail(org.apache.hadoop.hbase.client.FailureInfo fInfo)
String	toString()
void	updateFailureInfo(org.apache.hadoop.hbase.client.FastFailInterceptorContext arg0)
void	updateFailureInfo(org.apache.hadoop.hbase.client.RetryingCallerInterceptorContext arg0)

Methods inherited from class java.lang.Object

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

Field Detail

numBraveSouls

public static AtomicInteger numBraveSouls

fastFailThresholdMilliSec

protected final long fastFailThresholdMilliSec

repeatedFailuresMap

protected final ConcurrentMap<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.client.FailureInfo> repeatedFailuresMap

failureMapCleanupIntervalMilliSec

protected final long failureMapCleanupIntervalMilliSec

lastFailureMapCleanupTimeMilliSec

protected volatile long lastFailureMapCleanupTimeMilliSec

Constructor Detail

MyPreemptiveFastFailInterceptor

public MyPreemptiveFastFailInterceptor(org.apache.hadoop.conf.Configuration conf)

Method Detail

shouldRetryInspiteOfFastFail

protected boolean shouldRetryInspiteOfFastFail(org.apache.hadoop.hbase.client.FailureInfo fInfo)

intercept

public void intercept(org.apache.hadoop.hbase.client.FastFailInterceptorContext arg0)
               throws org.apache.hadoop.hbase.exceptions.PreemptiveFastFailException

Throws:

org.apache.hadoop.hbase.exceptions.PreemptiveFastFailException

handleFailure

public void handleFailure(org.apache.hadoop.hbase.client.FastFailInterceptorContext arg0,
                          Throwable arg1)
                   throws IOException

Throws:

IOException

updateFailureInfo

public void updateFailureInfo(org.apache.hadoop.hbase.client.FastFailInterceptorContext arg0)

handleFailureToServer

protected void handleFailureToServer(org.apache.hadoop.hbase.ServerName arg0,
                                     Throwable arg1)

handleThrowable

public void handleThrowable(Throwable arg0,
                            org.apache.hadoop.hbase.ServerName arg1,
                            org.apache.commons.lang3.mutable.MutableBoolean arg2,
                            org.apache.commons.lang3.mutable.MutableBoolean arg3)
                     throws IOException

Throws:

IOException

occasionallyCleanupFailureInformation

protected void occasionallyCleanupFailureInformation()

intercept

public void intercept(org.apache.hadoop.hbase.client.RetryingCallerInterceptorContext arg0)
               throws org.apache.hadoop.hbase.exceptions.PreemptiveFastFailException

Throws:

org.apache.hadoop.hbase.exceptions.PreemptiveFastFailException

handleFailure

public void handleFailure(org.apache.hadoop.hbase.client.RetryingCallerInterceptorContext arg0,
                          Throwable arg1)
                   throws IOException

Throws:

IOException

updateFailureInfo

public void updateFailureInfo(org.apache.hadoop.hbase.client.RetryingCallerInterceptorContext arg0)

createEmptyContext

public org.apache.hadoop.hbase.client.RetryingCallerInterceptorContext createEmptyContext()

isServerInFailureMap

protected boolean isServerInFailureMap(org.apache.hadoop.hbase.ServerName arg0)

toString

public String toString()