freenet.node

Class PeerNode.SlotWaiter

java.lang.Object

freenet.node.PeerNode.SlotWaiter

Enclosing class:

PeerNode

public static class PeerNode.SlotWaiter
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
boolean	addWaitingFor(PeerNode peer) Add another node to wait for.
freenet.node.PeerNode.RequestLikelyAcceptedState	getAcceptedState()
java.lang.String	toString()
PeerNode	waitForAny(long maxWait, boolean timeOutIsFatal) Wait for any of the PeerNode's we have queued on to accept (locally i.e.
int	waitingForCount()
java.util.HashSet<PeerNode>	waitingForList()

Methods inherited from class java.lang.Object

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

Method Detail

addWaitingFor

public boolean addWaitingFor(PeerNode peer)

Add another node to wait for.

Returns:

True unless queueing the slot was impossible due to a problem with the PeerNode. So we return true when there is a successful queueing, and we also return true when there is a race condition and the waiter has already completed.

waitingForList

public java.util.HashSet<PeerNode> waitingForList()

waitForAny

public PeerNode waitForAny(long maxWait,
                           boolean timeOutIsFatal)
                    throws freenet.node.PeerNode.SlotWaiterFailedException

Wait for any of the PeerNode's we have queued on to accept (locally i.e. to allocate a local slot to) this request.

Parameters:

maxWait - The time to wait for. Can be 0, but if it is 0, this is a "peek", i.e. if we return null, the queued slots remain live. Whereas if maxWait is not 0, we will unregister when we timeout.

timeOutIsFatal - If true, if we timeout, count it for each node involved as a fatal timeout.

Returns:

A matched node, or null.

Throws:

SlotWaiterFailedException - If a peer actually failed.

freenet.node.PeerNode.SlotWaiterFailedException

getAcceptedState

public freenet.node.PeerNode.RequestLikelyAcceptedState getAcceptedState()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

waitingForCount

public int waitingForCount()