org.apache.hadoop.hbase.client

Class AsyncRpcRetryingCaller<T>

java.lang.Object

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

Direct Known Subclasses:

AsyncAdminRequestRetryingCaller, AsyncMasterRequestRpcRetryingCaller, AsyncServerRequestRpcRetryingCaller, AsyncSingleRequestRpcRetryingCaller

@InterfaceAudience.Private
public abstract class AsyncRpcRetryingCaller<T>
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected AsyncConnectionImpl	conn
protected HBaseRpcController	controller
private List<RetriesExhaustedException.ThrowableWithExtraContext>	exceptions
protected CompletableFuture<T>	future
private static org.slf4j.Logger	LOG
private int	maxAttempts
protected long	operationTimeoutNs
private long	pauseNs
private long	pauseNsForServerOverloaded
private int	priority
private org.apache.hbase.thirdparty.io.netty.util.Timer	retryTimer
private long	rpcTimeoutNs
private int	startLogErrorsCnt
private long	startNs
private int	tries

Constructor Summary

Constructors

Constructor and Description
AsyncRpcRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer, AsyncConnectionImpl conn, int priority, long pauseNs, long pauseNsForServerOverloaded, int maxAttempts, long operationTimeoutNs, long rpcTimeoutNs, int startLogErrorsCnt)

Method Summary

Modifier and Type	Method and Description
(package private) CompletableFuture<T>	call()
protected void	completeExceptionally()
protected abstract void	doCall()
private long	elapsedMs()
protected Optional<TableName>	getTableName()
protected void	onError(Throwable t, Supplier<String> errMsg, Consumer<Throwable> updateCachedLocation)
protected long	remainingTimeNs()
protected void	resetCallTimeout()
private void	tryScheduleRetry(Throwable error)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

retryTimer

private final org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer

priority

private final int priority

startNs

private final long startNs

pauseNs

private final long pauseNs

pauseNsForServerOverloaded

private final long pauseNsForServerOverloaded

tries

private int tries

maxAttempts

private final int maxAttempts

startLogErrorsCnt

private final int startLogErrorsCnt

exceptions

private final List<RetriesExhaustedException.ThrowableWithExtraContext> exceptions

rpcTimeoutNs

private final long rpcTimeoutNs

operationTimeoutNs

protected final long operationTimeoutNs

conn

protected final AsyncConnectionImpl conn

future

protected final CompletableFuture<T> future

controller

protected final HBaseRpcController controller

Constructor Detail

AsyncRpcRetryingCaller

public AsyncRpcRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer,
                              AsyncConnectionImpl conn,
                              int priority,
                              long pauseNs,
                              long pauseNsForServerOverloaded,
                              int maxAttempts,
                              long operationTimeoutNs,
                              long rpcTimeoutNs,
                              int startLogErrorsCnt)

Method Detail

elapsedMs

private long elapsedMs()

remainingTimeNs

protected final long remainingTimeNs()

completeExceptionally

protected final void completeExceptionally()

resetCallTimeout

protected final void resetCallTimeout()

tryScheduleRetry

private void tryScheduleRetry(Throwable error)

getTableName

protected Optional<TableName> getTableName()

onError

protected final void onError(Throwable t,
                             Supplier<String> errMsg,
                             Consumer<Throwable> updateCachedLocation)

doCall

protected abstract void doCall()

call

CompletableFuture<T> call()