freenet.node

Class SendableInsert

java.lang.Object

freenet.node.SendableRequest

freenet.node.SendableInsert

All Implemented Interfaces:

RequestSelectionTreeNode, RandomGrabArrayItem, java.io.Serializable

Direct Known Subclasses:

SimpleSendableInsert, SingleBlockInserter, SplitFileInserterSender

public abstract class SendableInsert
extends SendableRequest

Callback interface for a low level insert, which is immediately sendable. These should be registered on the ClientRequestScheduler when we want to send them. It will then, when it is time to send, create a thread, send the request, and call the callback below.

See Also:

Serialized Form

Field Summary

Fields inherited from class freenet.node.SendableRequest

parentGrabArray, persistent, realTimeFlag

Constructor Summary

Constructors

Constructor and Description
SendableInsert(boolean persistent, boolean realTimeFlag)

Method Summary

Modifier and Type	Method and Description
abstract boolean	canWriteClientCache()
abstract boolean	forkOnCacheable()
ClientRequestScheduler	getScheduler(ClientContext context)
long	getWakeupTime(ClientContext context, long now) Unless this is a RandomGrabArrayItem, this will return the wakeup time for the subtree rooted at this node.
protected abstract void	innerOnResume(ClientContext context)
void	internalError(java.lang.Throwable t, RequestScheduler sched, ClientContext context, boolean persistent) Requeue after an internal error
abstract boolean	isEmpty()
boolean	isInsert() Is this an insert? For purposes of determining which scheduler to use.
abstract boolean	localRequestOnly()
abstract void	onEncode(SendableRequestItem token, ClientKey key, ClientContext context) Encoded a key
abstract void	onFailure(LowLevelPutException e, SendableRequestItem keyNum, ClientContext context) Called when we don't!
void	onResume(ClientContext context)
abstract void	onSuccess(SendableRequestItem keyNum, ClientKey key, ClientContext context) Called when we successfully insert the data

Methods inherited from class freenet.node.SendableRequest

chooseKey, clearWakeupTime, countAllKeys, countSendableKeys, getClient, getClientRequest, getParentGrabArray, getPriorityClass, getSchedulerGroup, getSender, hashCode, isCancelled, isSSK, knowsParentGrabArray, objectToString, persistent, realTimeFlag, reduceWakeupTime, setParentGrabArray, unregister

Methods inherited from class java.lang.Object

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

Constructor Detail

SendableInsert

public SendableInsert(boolean persistent,
                      boolean realTimeFlag)

Method Detail

onSuccess

public abstract void onSuccess(SendableRequestItem keyNum,
                               ClientKey key,
                               ClientContext context)

Called when we successfully insert the data

onFailure

public abstract void onFailure(LowLevelPutException e,
                               SendableRequestItem keyNum,
                               ClientContext context)

Called when we don't!

internalError

public void internalError(java.lang.Throwable t,
                          RequestScheduler sched,
                          ClientContext context,
                          boolean persistent)

Description copied from class: SendableRequest

Requeue after an internal error

Specified by:

internalError in class SendableRequest

isInsert

public final boolean isInsert()

Description copied from class: SendableRequest

Is this an insert? For purposes of determining which scheduler to use.

Specified by:

isInsert in class SendableRequest

getScheduler

public ClientRequestScheduler getScheduler(ClientContext context)

Specified by:

getScheduler in class SendableRequest

canWriteClientCache

public abstract boolean canWriteClientCache()

localRequestOnly

public abstract boolean localRequestOnly()

forkOnCacheable

public abstract boolean forkOnCacheable()

onEncode

public abstract void onEncode(SendableRequestItem token,
                              ClientKey key,
                              ClientContext context)

Encoded a key

isEmpty

public abstract boolean isEmpty()

getWakeupTime

public long getWakeupTime(ClientContext context,
                          long now)

Description copied from interface: RequestSelectionTreeNode

Unless this is a RandomGrabArrayItem, this will return the wakeup time for the subtree rooted at this node. For a RandomGrabArrayItem it returns the wakeup time for just that single request.

onResume

public final void onResume(ClientContext context)
                    throws InsertException,
                           ResumeFailedException

Throws:

InsertException

ResumeFailedException

innerOnResume

protected abstract void innerOnResume(ClientContext context)
                               throws InsertException,
                                      ResumeFailedException

Throws:

InsertException

ResumeFailedException