Class PeerControlSchedulerPrioritised

java.lang.Object

com.biglybt.core.peermanager.control.impl.PeerControlSchedulerImpl

com.biglybt.core.peermanager.control.impl.PeerControlSchedulerPrioritised

All Implemented Interfaces:

ParameterListener, PeerControlScheduler, CoreStatsProvider

public class PeerControlSchedulerPrioritised
extends PeerControlSchedulerImpl
implements CoreStatsProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	PeerControlSchedulerPrioritised.instanceWrapper

Field Summary

Fields

Modifier and Type	Field	Description
private final Object	instance_lock
private Map<PeerControlInstance, PeerControlSchedulerPrioritised.instanceWrapper>	instance_map
private int[]	last_peer_count
private int[]	last_piece_count
private long	latest_time_mono
private long	next_peer_count_time_mono
private long	next_piece_count_time_mono
private long	peer_count_active_time_mono
(package private) final List<PeerControlSchedulerPrioritised.instanceWrapper>	pending_registrations
private long	piece_count_active_time_mono
private boolean	registrations_changed
private final SpeedTokenDispenserPrioritised	tokenDispenser

Fields inherited from class PeerControlSchedulerImpl

schedule_count, total_wait_time, useWeights, wait_count, yield_count

Fields inherited from interface PeerControlScheduler

SCHEDULE_PERIOD_MAX_CATCHUP, SCHEDULE_PERIOD_MILLIS

Constructor Summary

Constructors

Constructor	Description
PeerControlSchedulerPrioritised()

Method Summary

Modifier and Type	Method	Description
int[]	getPeerCount()
int[]	getPieceCount()
SpeedTokenDispenser	getSpeedTokenDispenser()
void	register(PeerControlInstance instance)
protected void	schedule()
void	unregister(PeerControlInstance instance)
void	updateScheduleOrdering()

Methods inherited from class PeerControlSchedulerImpl

getSingleton, overrideAllWeightedPriorities, overrideWeightedPriorities, parameterChanged, start, updateAllScheduleOrdering, updateStats

Methods inherited from class Object

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

Methods inherited from interface CoreStatsProvider

updateStats

Field Details

instance_map

private Map<PeerControlInstance, PeerControlSchedulerPrioritised.instanceWrapper> instance_map

pending_registrations

final List<PeerControlSchedulerPrioritised.instanceWrapper> pending_registrations

registrations_changed

private volatile boolean registrations_changed

latest_time_mono

private volatile long latest_time_mono

instance_lock

private final Object instance_lock

tokenDispenser

private final SpeedTokenDispenserPrioritised tokenDispenser

next_peer_count_time_mono

private long next_peer_count_time_mono

next_piece_count_time_mono

private long next_piece_count_time_mono

peer_count_active_time_mono

private volatile long peer_count_active_time_mono

piece_count_active_time_mono

private volatile long piece_count_active_time_mono

last_peer_count

private volatile int[] last_peer_count

last_piece_count

private volatile int[] last_piece_count

Constructor Details

PeerControlSchedulerPrioritised

public PeerControlSchedulerPrioritised()

Method Details

schedule

protected void schedule()

Specified by:

schedule in class PeerControlSchedulerImpl

register

public void register(PeerControlInstance instance)

Specified by:

register in interface PeerControlScheduler

unregister

public void unregister(PeerControlInstance instance)

Specified by:

unregister in interface PeerControlScheduler

getSpeedTokenDispenser

public SpeedTokenDispenser getSpeedTokenDispenser()

Specified by:

getSpeedTokenDispenser in interface PeerControlScheduler

updateScheduleOrdering

public void updateScheduleOrdering()

Specified by:

updateScheduleOrdering in interface PeerControlScheduler

getPeerCount

public int[] getPeerCount()

Specified by:

getPeerCount in interface PeerControlScheduler

getPieceCount

public int[] getPieceCount()

Specified by:

getPieceCount in interface PeerControlScheduler