Class MultiPeerDownloader2

java.lang.Object

com.biglybt.core.networkmanager.impl.RateControlledMultipleEntity

com.biglybt.core.networkmanager.impl.MultiPeerDownloader2

All Implemented Interfaces:

ControllerAllocationManagement, RateControlledEntity

public class MultiPeerDownloader2
extends RateControlledMultipleEntity

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	MultiPeerDownloader2.ConnectionEntry
protected static class	MultiPeerDownloader2.ConnectionList

Field Summary

Fields

Modifier and Type	Field	Description
private final MultiPeerDownloader2.ConnectionList	active_connections
private static final Object	ADD_ACTION
private ArrayList<NetworkConnectionBase>	connections_cow
private final AEMonitor	connections_mon
private final MultiPeerDownloader2.ConnectionList	idle_connections
private long	last_idle_check
private final RateHandler	main_handler
private static final int	MOVE_TO_IDLE_TIME
private final int	partition_id
private List<Object[]>	pending_actions
private static final Object	REMOVE_ACTION
private EventWaiter	waiter

Fields inherited from interface ControllerAllocationManagement

UNALLOCATED_PARTITION

Fields inherited from interface RateControlledEntity

PRIORITY_HIGH, PRIORITY_NORMAL

Constructor Summary

Constructors

Constructor	Description
MultiPeerDownloader2(RateHandler _main_handler)	Create new downloader using the given "global" rate handler to limit all peers managed by this downloader.

Method Summary

Modifier and Type	Method	Description
void	addPeerConnection(NetworkConnectionBase connection)	Add the given connection to the downloader.
boolean	canProcess(EventWaiter waiter)
long	doProcessing(EventWaiter waiter, int max_bytes)	Attempt to do a processing operation.
long	getBytesReadyToWrite()
int	getConnectionCount(EventWaiter _waiter)	If there are no connections then the waiter will be kicked when a connection arrives
int	getPartitionID()	Is ready for a processing op.
int	getPriority()	Get this entity's priority level.
boolean	getPriorityBoost()	stats functions
RateHandler	getRateHandler()
int	getReadyConnectionCount(EventWaiter waiter)	The waiter is kicked if the ready condition changes
String	getString()
boolean	removePeerConnection(NetworkConnectionBase connection)	Remove the given connection from the downloader.

Methods inherited from class RateControlledMultipleEntity

activeReadControllerRelease, activeWriteControllerRelease, isReadControllerActive, isWriteControllerActive, setReadControllerInactive, setTargetReadControllerPartition, setTargetWriteControllerPartition, setWriteControllerInactive

Methods inherited from class Object

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

Field Details

MOVE_TO_IDLE_TIME

private static final int MOVE_TO_IDLE_TIME

See Also:

• Constant Field Values

ADD_ACTION

private static final Object ADD_ACTION

REMOVE_ACTION

private static final Object REMOVE_ACTION

partition_id

private final int partition_id

See Also:

• Constant Field Values

connections_cow

private volatile ArrayList<NetworkConnectionBase> connections_cow

connections_mon

private final AEMonitor connections_mon

main_handler

private final RateHandler main_handler

pending_actions

private volatile List<Object[]> pending_actions

active_connections

private final MultiPeerDownloader2.ConnectionList active_connections

idle_connections

private final MultiPeerDownloader2.ConnectionList idle_connections

last_idle_check

private long last_idle_check

waiter

private volatile EventWaiter waiter

Constructor Details

MultiPeerDownloader2

public MultiPeerDownloader2(RateHandler _main_handler)

Create new downloader using the given "global" rate handler to limit all peers managed by this downloader.

Parameters:

main_handler -

Method Details

getRateHandler

public RateHandler getRateHandler()

getPartitionID

public int getPartitionID()

Description copied from interface: RateControlledEntity

Is ready for a processing op.

Returns:

true if it can process >0 bytes, false if not ready

addPeerConnection

public void addPeerConnection(NetworkConnectionBase connection)

Add the given connection to the downloader.

Parameters:

connection - to add

removePeerConnection

public boolean removePeerConnection(NetworkConnectionBase connection)

Remove the given connection from the downloader.

Parameters:

connection - to remove

Returns:

true if the connection was found and removed, false if not removed

canProcess

public boolean canProcess(EventWaiter waiter)

getBytesReadyToWrite

public long getBytesReadyToWrite()

getConnectionCount

public int getConnectionCount(EventWaiter _waiter)

Description copied from interface: RateControlledEntity

If there are no connections then the waiter will be kicked when a connection arrives

Parameters:

_waiter -

Returns:

getReadyConnectionCount

public int getReadyConnectionCount(EventWaiter waiter)

Description copied from interface: RateControlledEntity

The waiter is kicked if the ready condition changes

Parameters:

waiter -

Returns:

doProcessing

public long doProcessing(EventWaiter waiter,
 int max_bytes)

Description copied from interface: RateControlledEntity

Attempt to do a processing operation.

Returns:

true if >0 bytes were processed (success), false if 0 bytes were processed (failure)

getPriority

public int getPriority()

Description copied from interface: RateControlledEntity

Get this entity's priority level.

Returns:

priority

getPriorityBoost

public boolean getPriorityBoost()

Description copied from interface: RateControlledEntity

stats functions

Returns:

getString

public String getString()