freenet.support

Class SectoredRandomGrabArray<T,C extends RemoveRandomWithObject<T>>

java.lang.Object

freenet.support.SectoredRandomGrabArray<T,C>

All Implemented Interfaces:

RequestSelectionTreeNode, RemoveRandom, RemoveRandomParent

Direct Known Subclasses:

SectoredRandomGrabArrayWithInt, SectoredRandomGrabArrayWithObject

public class SectoredRandomGrabArray<T,C extends RemoveRandomWithObject<T>>
extends java.lang.Object
implements RemoveRandom, RemoveRandomParent, RequestSelectionTreeNode

Like RandomGrabArray, but there is an equal chance of any given client's requests being returned. Again, not persistent; this is reconstructed on restart. LOCKING: There is a single lock for the entire tree, the ClientRequestSelector. This must be taken before calling any methods on RGA or SRGA. See the javadocs there for deeper explanation. A lot of this is over-complicated and over-expensive because of db4o. A lot of it is O(n). This is all kept in RAM now so we can change it at will, plus there is only one object queued per splitfile now, so memory pressure is much less of an issue. FIXME Simplify and improve performance!

Nested Class Summary

Nested classes/interfaces inherited from interface freenet.support.RemoveRandom

RemoveRandom.RemoveRandomReturn

Field Summary

Fields

Modifier and Type	Field and Description
protected ClientRequestSelector	root

Constructor Summary

Constructors

Constructor and Description
SectoredRandomGrabArray(RemoveRandomParent parent, ClientRequestSelector root)

Method Summary

Modifier and Type	Method and Description
protected void	addElement(T client, C rga)
void	addGrabber(T client, C requestGrabber, ClientContext context) Put a grabber.
void	clearWakeupTime(ClientContext context) When a request becomes fetchable, set all the wakeup times above it to 0.
T	getClient(int x)
C	getGrabber(T client) Get a grabber.
RequestSelectionTreeNode	getParentGrabArray() Return the parent RequestSelectionTreeNode or null if it's not in the tree or is the root (e.g.
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 int	haveClient(T client)
boolean	isEmpty()
void	maybeRemove(RemoveRandom r, ClientContext context) Remove the specified RemoveRandom, and propagate upwards if the parent is now empty.
boolean	reduceWakeupTime(long wakeupTime, ClientContext context) If the current cooldown time is larger than the parameter, reduce it and recurse up the tree.
RemoveRandom.RemoveRandomReturn	removeRandom(RandomGrabArrayItemExclusionList excluding, ClientContext context, long now) Return a random RandomGrabArrayItem, or a time at which there will be one, or null if the RGA is empty and should be removed by the parent.
void	setParent(RemoveRandomParent newParent)
int	size()

Methods inherited from class java.lang.Object

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

Field Detail

root

protected final ClientRequestSelector root

Constructor Detail

SectoredRandomGrabArray

public SectoredRandomGrabArray(RemoveRandomParent parent,
                               ClientRequestSelector root)

Method Detail

addElement

protected void addElement(T client,
                          C rga)

haveClient

protected int haveClient(T client)

getGrabber

public C getGrabber(T client)

Get a grabber.

getClient

public T getClient(int x)

addGrabber

public void addGrabber(T client,
                       C requestGrabber,
                       ClientContext context)

Put a grabber.

removeRandom

public RemoveRandom.RemoveRandomReturn removeRandom(RandomGrabArrayItemExclusionList excluding,
                                                    ClientContext context,
                                                    long now)

Description copied from interface: RemoveRandom

Return a random RandomGrabArrayItem, or a time at which there will be one, or null if the RGA is empty and should be removed by the parent.

Specified by:

removeRandom in interface RemoveRandom

isEmpty

public boolean isEmpty()

size

public int size()

maybeRemove

public void maybeRemove(RemoveRandom r,
                        ClientContext context)

Description copied from interface: RemoveRandomParent

Remove the specified RemoveRandom, and propagate upwards if the parent is now empty.

Specified by:

maybeRemove in interface RemoveRandomParent

setParent

public void setParent(RemoveRandomParent newParent)

Specified by:

setParent in interface RemoveRandom

getParentGrabArray

public RequestSelectionTreeNode getParentGrabArray()

Description copied from interface: RequestSelectionTreeNode

Return the parent RequestSelectionTreeNode or null if it's not in the tree or is the root (e.g. priority classes are kept in an array on ClientRequestSelector).

Specified by:

getParentGrabArray in interface RequestSelectionTreeNode

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.

Specified by:

getWakeupTime in interface RequestSelectionTreeNode

reduceWakeupTime

public boolean reduceWakeupTime(long wakeupTime,
                                ClientContext context)

Description copied from interface: RequestSelectionTreeNode

If the current cooldown time is larger than the parameter, reduce it and recurse up the tree. If we reach the root and wake it up, then wake up the scheduler. Returns true if anything changed.

Specified by:

reduceWakeupTime in interface RequestSelectionTreeNode

clearWakeupTime

public void clearWakeupTime(ClientContext context)

Description copied from interface: RequestSelectionTreeNode

When a request becomes fetchable, set all the wakeup times above it to 0. Will recurse up the tree.

Specified by:

clearWakeupTime in interface RequestSelectionTreeNode