org.apache.hadoop.hbase.client

Class RpcRetryingCallerImpl<T>

java.lang.Object

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

All Implemented Interfaces:

RpcRetryingCaller<T>

@InterfaceAudience.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 and Description
private AtomicBoolean	cancelled
private RetryingCallerInterceptorContext	context
private RetryingCallerInterceptor	interceptor
static org.slf4j.Logger	LOG
private int	maxAttempts
private long	pause
private long	pauseForCQTBE
private int	rpcTimeout
private int	startLogErrorsCnt How many retries are allowed before we start to log
private RetryingTimeTracker	tracker

Constructor Summary

Constructors

Constructor and Description
RpcRetryingCallerImpl(long pause, long pauseForCQTBE, int retries, int startLogErrorsCnt)
RpcRetryingCallerImpl(long pause, long pauseForCQTBE, int retries, RetryingCallerInterceptor interceptor, int startLogErrorsCnt, int rpcTimeout)

Method Summary

Modifier and Type	Method and 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)
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 Detail

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

pauseForCQTBE

private final long pauseForCQTBE

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

Constructor Detail

RpcRetryingCallerImpl

public RpcRetryingCallerImpl(long pause,
                             long pauseForCQTBE,
                             int retries,
                             int startLogErrorsCnt)

RpcRetryingCallerImpl

public RpcRetryingCallerImpl(long pause,
                             long pauseForCQTBE,
                             int retries,
                             RetryingCallerInterceptor interceptor,
                             int startLogErrorsCnt,
                             int rpcTimeout)

Method Detail

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