freenet.node

Class RequestTag

java.lang.Object

freenet.node.UIDTag

freenet.node.RequestTag

public class RequestTag
extends UIDTag

Tag for a request.

Field Summary

Fields inherited from class freenet.node.UIDTag

accepted, noRecordUnlock, notRoutedOnwards, sourceRestarted, tracker, unlockedHandler

Constructor Summary

Constructors

Constructor and Description
RequestTag(boolean isSSK, freenet.node.RequestTag.START start, PeerNode source, boolean realTimeFlag, long uid, Node node)

Method Summary

Modifier and Type	Method and Description
void	completedDownstreamTransfers()
boolean	currentlyRoutingTo(PeerNode peer)
int	expectedTransfersIn(boolean ignoreLocalVsRemote, int outwardTransfersPerInsert, boolean forAccept) Add up the expected transfers in.
int	expectedTransfersOut(boolean ignoreLocalVsRemote, int outwardTransfersPerInsert, boolean forAccept) Add up the expected transfers out.
void	finishedWaitingForOpennet(PeerNode next)
void	handlerDisconnected()
void	handlerThrew(java.lang.Throwable t) The handler threw a Throwable, i.e.
void	handlerTransferBegins()
protected void	innerUnlock(boolean noRecordUnlock)
boolean	isInsert()
boolean	isOfferReply()
boolean	isSSK()
void	logStillPresent(java.lang.Long uid)
protected boolean	mustUnlock() Caller must call innerUnlock(noRecordUnlock) immediately if this returns true.
void	onAbortDownstreamTransfers(int reason, java.lang.String desc)
void	senderTransferBegins(NodeCHK k, RequestSender requestSender)
void	senderTransferEnds(NodeCHK key, RequestSender requestSender)
void	setRejected()
void	setRequestSenderFinished(int status)
void	setSender(RequestSender rs, boolean coalesced)
void	setServedFromDatastore()
void	waitingForOpennet(PeerNode next)

Methods inherited from class freenet.node.UIDTag

addRoutedTo, clearWaitingForSlot, countAsSourceRestarted, currentlyFetchingOfferedKeyFrom, getSource, handlingTimeout, hasRoutedTo, hasSourceReallyRestarted, isLocal, isSource, isWaitingForSlot, maybeLogStillPresent, onRestartOrDisconnectSource, postUnlock, reassignToSelf, removeFetchingOfferedKeyFrom, removeRoutingTo, setAccepted, setNotRoutedOnwards, setWaitingForSlot, shouldStop, timedOutToHandlerButContinued, toString, unlockHandler, unlockHandler, wasLocal

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestTag

public RequestTag(boolean isSSK,
                  freenet.node.RequestTag.START start,
                  PeerNode source,
                  boolean realTimeFlag,
                  long uid,
                  Node node)

Method Detail

setRequestSenderFinished

public void setRequestSenderFinished(int status)

setSender

public void setSender(RequestSender rs,
                      boolean coalesced)

mustUnlock

protected boolean mustUnlock()

Description copied from class: UIDTag

Caller must call innerUnlock(noRecordUnlock) immediately if this returns true. Hence derived versions should call mustUnlock() only after they have checked their own unlock blockers.

Overrides:

mustUnlock in class UIDTag

innerUnlock

protected final void innerUnlock(boolean noRecordUnlock)

Overrides:

innerUnlock in class UIDTag

handlerThrew

public void handlerThrew(java.lang.Throwable t)

The handler threw a Throwable, i.e. failed due to a serious bug. Unlock the handler, and record the throwable in case of future problems.

Parameters:

t - The Throwable thrown by the RequestHandler.

setServedFromDatastore

public void setServedFromDatastore()

setRejected

public void setRejected()

logStillPresent

public void logStillPresent(java.lang.Long uid)

Specified by:

logStillPresent in class UIDTag

onAbortDownstreamTransfers

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

handlerDisconnected

public void handlerDisconnected()

expectedTransfersIn

public int expectedTransfersIn(boolean ignoreLocalVsRemote,
                               int outwardTransfersPerInsert,
                               boolean forAccept)

Description copied from class: UIDTag

Add up the expected transfers in.

Specified by:

expectedTransfersIn in class UIDTag

Parameters:

ignoreLocalVsRemote - If true, pretend that the request is remote even if it's local.

outwardTransfersPerInsert - Expected number of outward transfers for an insert.

forAccept - If true, we are deciding whether to accept a request. If false, we are deciding whether to SEND a request. We need to be more careful for the latter than the former, to avoid unnecessary rejections and mandatory backoffs.

expectedTransfersOut

public int expectedTransfersOut(boolean ignoreLocalVsRemote,
                                int outwardTransfersPerInsert,
                                boolean forAccept)

Description copied from class: UIDTag

Add up the expected transfers out.

Specified by:

expectedTransfersOut in class UIDTag

Parameters:

ignoreLocalVsRemote - If true, pretend that the request is remote even if it's local.

outwardTransfersPerInsert - Expected number of outward transfers for an insert.

forAccept - If true, we are deciding whether to accept a request. If false, we are deciding whether to SEND a request. We need to be more careful for the latter than the former, to avoid unnecessary rejections and mandatory backoffs.

completedDownstreamTransfers

public void completedDownstreamTransfers()

isSSK

public boolean isSSK()

Specified by:

isSSK in class UIDTag

isInsert

public boolean isInsert()

Specified by:

isInsert in class UIDTag

isOfferReply

public boolean isOfferReply()

Specified by:

isOfferReply in class UIDTag

waitingForOpennet

public void waitingForOpennet(PeerNode next)

finishedWaitingForOpennet

public void finishedWaitingForOpennet(PeerNode next)

currentlyRoutingTo

public boolean currentlyRoutingTo(PeerNode peer)

Overrides:

currentlyRoutingTo in class UIDTag

handlerTransferBegins

public void handlerTransferBegins()

senderTransferBegins

public void senderTransferBegins(NodeCHK k,
                                 RequestSender requestSender)

senderTransferEnds

public void senderTransferEnds(NodeCHK key,
                               RequestSender requestSender)