Package org.apache.hadoop.hbase.client

Class RpcRetryingCallerImpl<T>

java.lang.Object

org.apache.hadoop.hbase.client.RpcRetryingCallerImpl<T>

All Implemented Interfaces:

RpcRetryingCaller<T>

@Private
public class RpcRetryingCallerImpl<T>
extends Object
implements RpcRetryingCaller<T>

Runs an rpc'ing RetryingCallable. Sets into rpc client threadlocal outstanding timeouts as so we don't persist too much. Dynamic rather than static so can set the generic appropriately. This object has a state. It should not be used by in parallel by different threads. Reusing it is possible however, even between multiple threads. However, the user will have to manage the synchronization on its side: there is no synchronization inside the class.

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicBoolean	cancelled
private final RetryingCallerInterceptorContext	context
private final RetryingCallerInterceptor	interceptor
static final org.slf4j.Logger	LOG
private final int	maxAttempts
private final MetricsConnection	metrics
private final long	pause
private final long	pauseForServerOverloaded
private final int	rpcTimeout
private final int	startLogErrorsCnt	How many retries are allowed before we start to log
private final RetryingTimeTracker	tracker

Constructor Summary

Constructors

Constructor	Description
RpcRetryingCallerImpl(long pause, long pauseForServerOverloaded, int retries, RetryingCallerInterceptor interceptor, int startLogErrorsCnt, int rpcTimeout, MetricsConnection metricsConnection)

Method Summary

Modifier and Type	Method	Description
T	callWithoutRetries(RetryingCallable<T> callable, int callTimeout)	Call the server once only.
T	callWithRetries(RetryingCallable<T> callable, int callTimeout)	Retries if invocation fails.
void	cancel()
private int	getTimeout(int callTimeout)
private long	singleCallDuration(long expectedSleep)	Returns Calculate how long a single call took
String	toString()
(package private) static Throwable	translateException(Throwable t)	Get the good or the remote exception if any, throws the DoNotRetryIOException.

Methods inherited from class java.lang.Object

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

Field Details

LOG

public static final org.slf4j.Logger LOG

startLogErrorsCnt

private final int startLogErrorsCnt

How many retries are allowed before we start to log

pause

private final long pause

pauseForServerOverloaded

private final long pauseForServerOverloaded

maxAttempts

private final int maxAttempts

rpcTimeout

private final int rpcTimeout

cancelled

private final AtomicBoolean cancelled

interceptor

private final RetryingCallerInterceptor interceptor

context

private final RetryingCallerInterceptorContext context

tracker

private final RetryingTimeTracker tracker

metrics

private final MetricsConnection metrics

Constructor Details

RpcRetryingCallerImpl

public RpcRetryingCallerImpl(long pause,
 long pauseForServerOverloaded,
 int retries,
 RetryingCallerInterceptor interceptor,
 int startLogErrorsCnt,
 int rpcTimeout,
 MetricsConnection metricsConnection)

Method Details

cancel

public void cancel()

Specified by:

cancel in interface RpcRetryingCaller<T>

callWithRetries

public T callWithRetries(RetryingCallable<T> callable,
 int callTimeout)
                  throws IOException,
RuntimeException

Description copied from interface: RpcRetryingCaller

Retries if invocation fails.

Specified by:

callWithRetries in interface RpcRetryingCaller<T>

Parameters:

callable - The RetryingCallable to run.

callTimeout - Timeout for this call

Returns:

an object of type T

Throws:

IOException - if a remote or network exception occurs

RuntimeException - other unspecified error

singleCallDuration

private long singleCallDuration(long expectedSleep)

Returns Calculate how long a single call took

callWithoutRetries

public T callWithoutRetries(RetryingCallable<T> callable,
 int callTimeout)
                     throws IOException,
RuntimeException

Description copied from interface: RpcRetryingCaller

Call the server once only. RetryingCallable has a strange shape so we can do retries. Use this invocation if you want to do a single call only (A call to RetryingCallable.call(int) will not likely succeed).

Specified by:

callWithoutRetries in interface RpcRetryingCaller<T>

Returns:

an object of type T

Throws:

IOException - if a remote or network exception occurs

RuntimeException - other unspecified error

translateException

static Throwable translateException(Throwable t)
                             throws DoNotRetryIOException

Get the good or the remote exception if any, throws the DoNotRetryIOException.

Parameters:

t - the throwable to analyze

Returns:

the translated exception, if it's not a DoNotRetryIOException

Throws:

DoNotRetryIOException - - if we find it, we throw it instead of translating.

getTimeout

private int getTimeout(int callTimeout)

toString

public String toString()

Overrides:

toString in class Object