freenet.client.async

Class ChosenBlock

java.lang.Object

freenet.client.async.ChosenBlock

Direct Known Subclasses:

ChosenBlockImpl

public abstract class ChosenBlock
extends java.lang.Object

A single selected request, including everything needed to execute it. Most important functions are the callbacks, which run off-thread, call the upstream callbacks on the SendableGet etc, and remove the fetching keys from the KeysFetchingLocally.

Field Summary

Fields

Modifier and Type	Field and Description
boolean	canWriteClientCache
ClientKey	ckey The client-layer key to be fetched, null if not a SendableGet
boolean	forkOnCacheable
boolean	ignoreStore
Key	key The key to be fetched, null if not a BaseSendableGet
boolean	localRequestOnly
boolean	realTimeFlag
SendableRequestItem	token The token indicating the key within the request to be fetched/inserted.

Constructor Summary

Constructors

Constructor and Description
ChosenBlock(SendableRequestItem token, Key key, ClientKey ckey, boolean localRequestOnly, boolean ignoreStore, boolean canWriteClientCache, boolean forkOnCacheable, boolean realTimeFlag, RequestScheduler sched)

Method Summary

Modifier and Type	Method and Description
abstract short	getPriority()
abstract SendableRequestSender	getSender(ClientContext context)
abstract boolean	isCancelled()
abstract boolean	isPersistent()
void	onDumped()
abstract void	onFailure(LowLevelGetException e, ClientContext context)
abstract void	onFailure(LowLevelPutException e, ClientContext context)
abstract void	onFetchSuccess(ClientContext context) The actual data delivery goes through CRS.tripPendingKey().
abstract void	onInsertSuccess(ClientKey key, ClientContext context)
boolean	send(NodeClientCore core, RequestScheduler sched)
boolean	sendIsBlocking() Call this after send()

Methods inherited from class java.lang.Object

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

Field Detail

token

public final transient SendableRequestItem token

The token indicating the key within the request to be fetched/inserted. Meaning is entirely defined by the request.

key

public final transient Key key

The key to be fetched, null if not a BaseSendableGet

ckey

public final transient ClientKey ckey

The client-layer key to be fetched, null if not a SendableGet

localRequestOnly

public final transient boolean localRequestOnly

ignoreStore

public final transient boolean ignoreStore

canWriteClientCache

public final transient boolean canWriteClientCache

forkOnCacheable

public final transient boolean forkOnCacheable

realTimeFlag

public final transient boolean realTimeFlag

Constructor Detail

ChosenBlock

public ChosenBlock(SendableRequestItem token,
                   Key key,
                   ClientKey ckey,
                   boolean localRequestOnly,
                   boolean ignoreStore,
                   boolean canWriteClientCache,
                   boolean forkOnCacheable,
                   boolean realTimeFlag,
                   RequestScheduler sched)

Method Detail

isPersistent

public abstract boolean isPersistent()

isCancelled

public abstract boolean isCancelled()

onFailure

public abstract void onFailure(LowLevelPutException e,
                               ClientContext context)

onInsertSuccess

public abstract void onInsertSuccess(ClientKey key,
                                     ClientContext context)

onFailure

public abstract void onFailure(LowLevelGetException e,
                               ClientContext context)

onFetchSuccess

public abstract void onFetchSuccess(ClientContext context)

The actual data delivery goes through CRS.tripPendingKey(). This is just a notification for book-keeping purposes. We call the scheduler to tell it that the request succeeded, so that it can be rescheduled soon for more requests.

Parameters:

context - Might be useful.

getPriority

public abstract short getPriority()

send

public boolean send(NodeClientCore core,
                    RequestScheduler sched)

getSender

public abstract SendableRequestSender getSender(ClientContext context)

onDumped

public void onDumped()

sendIsBlocking

public boolean sendIsBlocking()

Call this after send()