freenet.node

Class RequestStarter

java.lang.Object

freenet.node.RequestStarter

All Implemented Interfaces:

RandomGrabArrayItemExclusionList, java.lang.Runnable

public class RequestStarter
extends java.lang.Object
implements java.lang.Runnable, RandomGrabArrayItemExclusionList

Starts requests. Nobody starts a request directly, you have to go through RequestStarter. And you have to provide a RequestStarterClient. We do round robin between clients on the same priority level.

Field Summary

Fields

Modifier and Type	Field and Description
static short	BULK_SPLITFILE_PRIORITY_CLASS Bulk splitfile fetches
static short	IMMEDIATE_SPLITFILE_PRIORITY_CLASS FProxy splitfile fetches
static short	INTERACTIVE_PRIORITY_CLASS FProxy etc
static short	MAXIMUM_PRIORITY_CLASS Anything more important than FProxy
static short	MINIMUM_FETCHABLE_PRIORITY_CLASS
static short	NUMBER_OF_PRIORITY_CLASSES
static short	PAUSED_PRIORITY_CLASS Anything less important than prefetch (redundant??)
static short	PREFETCH_PRIORITY_CLASS Prefetch
static short	UPDATE_PRIORITY_CLASS USK updates etc

Constructor Summary

Constructors

Constructor and Description
RequestStarter(NodeClientCore node, BaseRequestThrottle throttle, java.lang.String name, RunningAverage averageOutputBytesPerRequest, RunningAverage averageInputBytesPerRequest, boolean isInsert, boolean isSSK, boolean realTime)

Method Summary

Modifier and Type	Method and Description
long	exclude(RandomGrabArrayItem item, ClientContext context, long now) Can this item be excluded, based on e.g.
static boolean	isValidPriorityClass(int prio)
void	run()
java.lang.String	toString()
void	wakeUp() LOCKING: Caller must avoid locking while calling this function.

Methods inherited from class java.lang.Object

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

Field Detail

MAXIMUM_PRIORITY_CLASS

public static final short MAXIMUM_PRIORITY_CLASS

Anything more important than FProxy

See Also:

Constant Field Values

INTERACTIVE_PRIORITY_CLASS

public static final short INTERACTIVE_PRIORITY_CLASS

FProxy etc

See Also:

Constant Field Values

IMMEDIATE_SPLITFILE_PRIORITY_CLASS

public static final short IMMEDIATE_SPLITFILE_PRIORITY_CLASS

FProxy splitfile fetches

See Also:

Constant Field Values

UPDATE_PRIORITY_CLASS

public static final short UPDATE_PRIORITY_CLASS

USK updates etc

See Also:

Constant Field Values

BULK_SPLITFILE_PRIORITY_CLASS

public static final short BULK_SPLITFILE_PRIORITY_CLASS

Bulk splitfile fetches

See Also:

Constant Field Values

PREFETCH_PRIORITY_CLASS

public static final short PREFETCH_PRIORITY_CLASS

Prefetch

See Also:

Constant Field Values

PAUSED_PRIORITY_CLASS

public static final short PAUSED_PRIORITY_CLASS

Anything less important than prefetch (redundant??)

See Also:

Constant Field Values

NUMBER_OF_PRIORITY_CLASSES

public static final short NUMBER_OF_PRIORITY_CLASSES

See Also:

Constant Field Values

MINIMUM_FETCHABLE_PRIORITY_CLASS

public static final short MINIMUM_FETCHABLE_PRIORITY_CLASS

See Also:

Constant Field Values

Constructor Detail

RequestStarter

public RequestStarter(NodeClientCore node,
                      BaseRequestThrottle throttle,
                      java.lang.String name,
                      RunningAverage averageOutputBytesPerRequest,
                      RunningAverage averageInputBytesPerRequest,
                      boolean isInsert,
                      boolean isSSK,
                      boolean realTime)

Method Detail

isValidPriorityClass

public static boolean isValidPriorityClass(int prio)

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

wakeUp

public void wakeUp()

LOCKING: Caller must avoid locking while calling this function. In particular, if the RequestStarter lock is held we will get a deadlock.

exclude

public long exclude(RandomGrabArrayItem item,
                    ClientContext context,
                    long now)

Can this item be excluded, based on e.g. already running requests?

Specified by:

exclude in interface RandomGrabArrayItemExclusionList