org.apache.hadoop.hbase.client

Class TestFastFail.CallQueueTooBigPffeInterceptor

java.lang.Object

org.apache.hadoop.hbase.client.TestFastFail.CallQueueTooBigPffeInterceptor

Enclosing class:

TestFastFail

public static class TestFastFail.CallQueueTooBigPffeInterceptor
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
CallQueueTooBigPffeInterceptor(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 serverName, Throwable t)
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 arg0)
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

numCallQueueTooBig

public static AtomicInteger numCallQueueTooBig

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

CallQueueTooBigPffeInterceptor

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

Method Detail

handleFailureToServer

protected void handleFailureToServer(org.apache.hadoop.hbase.ServerName serverName,
                                     Throwable t)

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)

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

shouldRetryInspiteOfFastFail

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

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