class ScannerCallableWithReplicas.RetryingRPC extends Object implements RetryingCallable<Pair<Result[],ScannerCallable>>, Cancellable
Modifier and Type | Field and Description |
---|---|
(package private) ScannerCallable |
callable |
(package private) RpcRetryingCaller<Result[]> |
caller |
private boolean |
cancelled |
Constructor and Description |
---|
RetryingRPC(ScannerCallable callable) |
Modifier and Type | Method and Description |
---|---|
Pair<Result[],ScannerCallable> |
call(int callTimeout)
Computes a result, or throws an exception if unable to do so.
|
void |
cancel() |
String |
getExceptionMessageAdditionalDetail()
Returns Some details from the implementation that we would like to add to a terminating
exception; i.e.
|
boolean |
isCancelled() |
void |
prepare(boolean reload)
Prepare by setting up any connections to servers, etc., ahead of call invocation.
|
long |
sleep(long pause,
int tries)
Sleep and retry.
|
void |
throwable(Throwable t,
boolean retrying)
Called when call throws an exception and we are going to retry; take action to make it so we
succeed on next call (clear caches, do relookup of locations, etc.).
|
final ScannerCallable callable
RpcRetryingCaller<Result[]> caller
private volatile boolean cancelled
RetryingRPC(ScannerCallable callable)
public Pair<Result[],ScannerCallable> call(int callTimeout) throws IOException
RetryingCallable
call
in interface RetryingCallable<Pair<Result[],ScannerCallable>>
callTimeout
- - the time available for this call. 0 for infinite.IOException
public void prepare(boolean reload) throws IOException
RetryingCallable
prepare
in interface RetryingCallable<Pair<Result[],ScannerCallable>>
reload
- Set this to true if need to requery locationsIOException
- epublic void throwable(Throwable t, boolean retrying)
RetryingCallable
throwable
in interface RetryingCallable<Pair<Result[],ScannerCallable>>
t
- throwable which was thrownretrying
- True if we are in retrying mode (we are not in retrying mode when max retries
== 1; we ARE in retrying mode if retries > 1 even when we are the last
attempt)public String getExceptionMessageAdditionalDetail()
RetryingCallable
getExceptionMessageAdditionalDetail
in interface RetryingCallable<Pair<Result[],ScannerCallable>>
public long sleep(long pause, int tries)
RetryingCallable
sleep
in interface RetryingCallable<Pair<Result[],ScannerCallable>>
pause
- time to pausetries
- amount of tries until till sleeppublic void cancel()
cancel
in interface Cancellable
public boolean isCancelled()
isCancelled
in interface Cancellable
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.