freenet.node

Class SSKInsertSender

java.lang.Object

freenet.node.BaseSender

freenet.node.SSKInsertSender

All Implemented Interfaces:

ByteCounter, AnyInsertSender, PrioRunnable, java.lang.Runnable

public class SSKInsertSender
extends BaseSender
implements PrioRunnable, AnyInsertSender, ByteCounter

SSKs require separate logic for inserts and requests, for various reasons: - SSKs can collide. - SSKs have only 1kB of data, so we can pack it into the DataReply, and we don't need to wait for a long data-transfer timeout. - SSKs have pubkeys, which don't always need to be sent.

Field Summary

Fields inherited from class freenet.node.BaseSender

dontDecrementHTLThisTime, gotMessages, hasForwarded, htl, lastMessage, lastNode, nodesRoutedTo, origHTL, rejectOverloads, routeAttempts

Method Summary

Modifier and Type	Method and Description
protected Message	createDataRequest()
protected void	forwardRejectedOverload() Forward RejectedOverload to the request originator.
protected long	getAcceptedTimeout()
SSKBlock	getBlock()
byte[]	getData()
byte[]	getHeaders()
short	getHTL()
int	getPriority()
byte[]	getPubkeyHash()
PeerNode[]	getRoutedTo()
int	getStatus()
java.lang.String	getStatusString()
static java.lang.String	getStatusString(int status)
int	getTotalReceivedBytes()
int	getTotalSentBytes()
long	getUID()
protected void	handleAcceptedRejectedTimeout(PeerNode next, UIDTag tag)
boolean	hasCollided()
boolean	hasRecentlyCollided()
protected long	ignoreLowBackoff()
protected boolean	isAccepted(Message msg)
protected boolean	isInsert()
protected MessageFilter	makeAcceptedRejectedFilter(PeerNode next, long acceptedTimeout, UIDTag tag) Construct a filter to wait the specified time for accepted or rejected.
protected void	onAccepted(PeerNode next)
void	receivedBytes(int x)
protected void	routeRequests() The main route requests loop.
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.
boolean	sentRequest()
protected PeerNode	sourceForRouting()
protected void	timedOutWhileWaiting(double load) We timed out while waiting for a slot from any node.
java.lang.String	toString()

Methods inherited from class freenet.node.BaseSender

calculateTimeout, calculateTimeout, getLongSlotWaiterTimeout, getShortSlotWaiterTimeout, hopsForFatalTimeoutWaitingForPeer, innerRouteRequests, innerRouteRequestsNew, innerRouteRequestsOld, routedLast, timeSinceSent

Methods inherited from class java.lang.Object

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

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

routeRequests

protected void routeRequests()

Description copied from class: BaseSender

The main route requests loop. This must be filled in by the implementation. It will deal with decrementing the HTL, completing on running out of HTL, RecentlyFailed for requests, fork on cacheable for inserts, and so on. It will choose a peer and then chain to innerRouteRequests(), which in turn can call back to routeRequests() if it needs a new peer.

Specified by:

routeRequests in class BaseSender

handleAcceptedRejectedTimeout

protected void handleAcceptedRejectedTimeout(PeerNode next,
                                             UIDTag tag)

Specified by:

handleAcceptedRejectedTimeout in class BaseSender

makeAcceptedRejectedFilter

protected MessageFilter makeAcceptedRejectedFilter(PeerNode next,
                                                   long acceptedTimeout,
                                                   UIDTag tag)

Description copied from class: BaseSender

Construct a filter to wait the specified time for accepted or rejected. The actual messages may vary.

Specified by:

makeAcceptedRejectedFilter in class BaseSender

Parameters:

next - The peer we are waiting for a response from.

acceptedTimeout - The time to wait.

tag - Use the UID from this tag. Some requests may change the tag after some hops, and if e.g. waiting for confirmation after a timeout, we need to use the old tag.

forwardRejectedOverload

protected void forwardRejectedOverload()

Forward RejectedOverload to the request originator. DO NOT CALL if have a *local* RejectedOverload.

Specified by:

forwardRejectedOverload in class BaseSender

getStatus

public int getStatus()

Specified by:

getStatus in interface AnyInsertSender

getHTL

public short getHTL()

Specified by:

getHTL in interface AnyInsertSender

getStatusString

public java.lang.String getStatusString()

Specified by:

getStatusString in interface AnyInsertSender

Returns:

The current status as a string

getStatusString

public static java.lang.String getStatusString(int status)

Returns:

The current status as a string

sentRequest

public boolean sentRequest()

Specified by:

sentRequest in interface AnyInsertSender

hasRecentlyCollided

public boolean hasRecentlyCollided()

hasCollided

public boolean hasCollided()

getPubkeyHash

public byte[] getPubkeyHash()

getHeaders

public byte[] getHeaders()

getData

public byte[] getData()

getBlock

public SSKBlock getBlock()

getUID

public long getUID()

Specified by:

getUID in interface AnyInsertSender

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

getTotalSentBytes

public int getTotalSentBytes()

receivedBytes

public void receivedBytes(int x)

Specified by:

receivedBytes in interface ByteCounter

getTotalReceivedBytes

public int getTotalReceivedBytes()

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

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getRoutedTo

public PeerNode[] getRoutedTo()

createDataRequest

protected Message createDataRequest()

Specified by:

createDataRequest in class BaseSender

getAcceptedTimeout

protected long getAcceptedTimeout()

Specified by:

getAcceptedTimeout in class BaseSender

timedOutWhileWaiting

protected void timedOutWhileWaiting(double load)

Description copied from class: BaseSender

We timed out while waiting for a slot from any node. Fail the request.

Specified by:

timedOutWhileWaiting in class BaseSender

Parameters:

load - The proportion of requests getting timed out, on average, across the nodes we are waiting for. This is used to decide how long the RecentlyFailed should be for.

isAccepted

protected boolean isAccepted(Message msg)

Overrides:

isAccepted in class BaseSender

onAccepted

protected void onAccepted(PeerNode next)

Specified by:

onAccepted in class BaseSender

isInsert

protected boolean isInsert()

Specified by:

isInsert in class BaseSender

sourceForRouting

protected PeerNode sourceForRouting()

Overrides:

sourceForRouting in class BaseSender

ignoreLowBackoff

protected long ignoreLowBackoff()

Overrides:

ignoreLowBackoff in class BaseSender