public class SimpleSingleFileFetcher extends BaseSingleFileFetcher implements ClientGetState, java.io.Serializable
cancelled, cooldownWakeupTime, ctx, deleteFetchContext, finished, keyparentparentGrabArray, persistent, realTimeFlag| Modifier and Type | Method and Description |
|---|---|
void |
cancel(ClientContext context)
Cancel the request, and call onFailure() on the callback in order to tell
downstream (ultimately the client) that cancel has succeeded, and to allow
it to call removeFrom() to avoid a database leak.
|
protected Bucket |
extract(ClientKeyBlock block,
ClientContext context)
Convert a ClientKeyBlock to a Bucket.
|
protected ClientGetState |
getClientGetState() |
long |
getToken()
getToken() is not supported
|
protected void |
notFoundInStore(ClientContext context) |
protected void |
onBlockDecodeError(SendableRequestItem token,
ClientContext context) |
protected void |
onFailure(FetchException e,
boolean forceFatal,
ClientContext context) |
void |
onFailure(LowLevelGetException e,
SendableRequestItem reqTokenIgnored,
ClientContext context)
Called when/if the low-level request fails.
|
void |
onShutdown(ClientContext context)
Called just before the final write of client.dat before the node shuts down.
|
void |
onSuccess(ClientKeyBlock block,
boolean fromStore,
java.lang.Object reqTokenIgnored,
ClientContext context)
Called when/if the low-level request succeeds.
|
protected void |
onSuccess(FetchResult data,
ClientContext context)
Will be overridden by SingleFileFetcher
|
chooseKey, countAllKeys, countSendableKeys, getClient, getClientRequest, getContext, getCooldownWakeup, getKey, getPriorityClass, getRequest, getWakeupTime, isCancelled, isEmpty, isSSK, listKeys, makeKeyListener, onChangedFetchContext, onEnterFiniteCooldown, onGotKey, onResume, onSuccess, preRegister, reschedule, retry, schedule, unregister, unregisterAllclearWakeupTime, getNodeKey, getScheduler, getSender, internalError, isInsert, reduceWakeupTime, translateExceptiongetParentGrabArray, getSchedulerGroup, hashCode, knowsParentGrabArray, objectToString, persistent, realTimeFlag, setParentGrabArrayclone, equals, finalize, getClass, notify, notifyAll, toString, wait, wait, waitonResume, schedulepublic void onFailure(LowLevelGetException e, SendableRequestItem reqTokenIgnored, ClientContext context)
SendableGetonFailure in class SendableGetprotected void onFailure(FetchException e, boolean forceFatal, ClientContext context)
protected void onSuccess(FetchResult data, ClientContext context)
public void onSuccess(ClientKeyBlock block, boolean fromStore, java.lang.Object reqTokenIgnored, ClientContext context)
BaseSingleFileFetcheronSuccess in class BaseSingleFileFetcherprotected Bucket extract(ClientKeyBlock block, ClientContext context)
public long getToken()
getToken in interface ClientGetStatepublic void cancel(ClientContext context)
ClientGetStatecancel in interface ClientGetStatecancel in class BaseSingleFileFetcherprotected void notFoundInStore(ClientContext context)
notFoundInStore in class BaseSingleFileFetcherprotected void onBlockDecodeError(SendableRequestItem token, ClientContext context)
onBlockDecodeError in class BaseSingleFileFetcherpublic void onShutdown(ClientContext context)
ClientGetStateonShutdown in interface ClientGetStateprotected ClientGetState getClientGetState()
getClientGetState in class SendableGet