freenet.node

Class RequestHandler

java.lang.Object

freenet.node.RequestHandler

All Implemented Interfaces:

ByteCounter, PrioRunnable, RequestSenderListener, java.lang.Runnable

public class RequestHandler
extends java.lang.Object
implements PrioRunnable, ByteCounter, RequestSenderListener

Handle an incoming request. Does not do the actual fetching; that is separated off into RequestSender so we get transfer coalescing and both ends for free.

Constructor Summary

Constructors

Constructor and Description
RequestHandler(PeerNode source, long id, Node n, short htl, Key key, RequestTag tag, KeyBlock passedInKeyBlock, boolean realTimeFlag, boolean needsPubKey)

Method Summary

Modifier and Type	Method and Description
int	getPriority()
void	onAbortDownstreamTransfers(int reason, java.lang.String desc) Abort downstream transfers (not necessarily upstream ones, so not via the PRB).
void	onCHKTransferBegins() Should return quickly, allocate a thread if it needs to block etc
void	onDataFoundLocally() Not called by RequestSender, but called if the data was in the store.
void	onNotStarted(boolean internalError) Not called by RequestSender, but called if localOnly is true and the data is not in the store.
void	onReceivedRejectOverload() Should return quickly, allocate a thread if it needs to block etc
void	onRequestSenderFinished(int status, boolean fromOfferedKey, RequestSender rs) Should return quickly, allocate a thread if it needs to block etc
void	receivedBytes(int x)
void	run()
void	sentBytes(int x) Sent some bytes.
void	sentPayload(int x) Sent payload - only include the number of bytes of actual payload i.e.
java.lang.String	toString()
protected void	transferFinished(boolean success) Once the transfer has finished and we have the final status code, either path fold or just unregister.

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestHandler

public RequestHandler(PeerNode source,
                      long id,
                      Node n,
                      short htl,
                      Key key,
                      RequestTag tag,
                      KeyBlock passedInKeyBlock,
                      boolean realTimeFlag,
                      boolean needsPubKey)

Parameters:

source -

id -

n -

htl -

key -

tag -

passedInKeyBlock - We ALWAYS look up in the datastore before starting a request. SECURITY: Do not pass messages into handler constructors. See note at top of NodeDispatcher.

realTimeFlag -

needsPubKey -

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

run

public void run()

Specified by:

run in interface java.lang.Runnable

onReceivedRejectOverload

public void onReceivedRejectOverload()

Description copied from interface: RequestSenderListener

Should return quickly, allocate a thread if it needs to block etc

Specified by:

onReceivedRejectOverload in interface RequestSenderListener

onCHKTransferBegins

public void onCHKTransferBegins()

Description copied from interface: RequestSenderListener

Should return quickly, allocate a thread if it needs to block etc

Specified by:

onCHKTransferBegins in interface RequestSenderListener

transferFinished

protected void transferFinished(boolean success)

Once the transfer has finished and we have the final status code, either path fold or just unregister.

Parameters:

success - Whether the block transfer succeeded.

onAbortDownstreamTransfers

public void onAbortDownstreamTransfers(int reason,
                                       java.lang.String desc)

Description copied from interface: RequestSenderListener

Abort downstream transfers (not necessarily upstream ones, so not via the PRB). Should return quickly, allocate a thread if it needs to block etc.

Specified by:

onAbortDownstreamTransfers in interface RequestSenderListener

onRequestSenderFinished

public void onRequestSenderFinished(int status,
                                    boolean fromOfferedKey,
                                    RequestSender rs)

Description copied from interface: RequestSenderListener

Should return quickly, allocate a thread if it needs to block etc

Specified by:

onRequestSenderFinished in interface RequestSenderListener

sentBytes

public void sentBytes(int x)

Description copied from interface: ByteCounter

Sent some bytes. *Includes* any bytes flagged as already-reported-to-throttle.

Specified by:

sentBytes in interface ByteCounter

receivedBytes

public void receivedBytes(int x)

Specified by:

receivedBytes in interface ByteCounter

sentPayload

public void sentPayload(int x)

Description copied from interface: ByteCounter

Sent payload - only include the number of bytes of actual payload i.e. data from the user's point of view, as opposed to overhead. IMPORTANT: This will also be reported to sentBytes()! DO NOT ADD the total from sentBytes() to the total from sentPayloadBytes(), or you will double-count.

Specified by:

sentPayload in interface ByteCounter

Parameters:

x - Number of bytes sent

getPriority

public int getPriority()

Specified by:

getPriority in interface PrioRunnable

onNotStarted

public void onNotStarted(boolean internalError)

Description copied from interface: RequestSenderListener

Not called by RequestSender, but called if localOnly is true and the data is not in the store.

Specified by:

onNotStarted in interface RequestSenderListener

Parameters:

internalError - If true, something broke severely.

onDataFoundLocally

public void onDataFoundLocally()

Description copied from interface: RequestSenderListener

Not called by RequestSender, but called if the data was in the store. tripPendingKey should already have been called.

Specified by:

onDataFoundLocally in interface RequestSenderListener