Class PeerControlSchedulerBasic

java.lang.Object

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

com.biglybt.core.peermanager.control.impl.PeerControlSchedulerBasic

All Implemented Interfaces:

ParameterListener, PeerControlScheduler, CoreStatsProvider

public class PeerControlSchedulerBasic
extends PeerControlSchedulerImpl
implements CoreStatsProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	PeerControlSchedulerBasic.instanceWrapper

Field Summary

Fields

Modifier and Type	Field	Description
private final Object	instance_lock
private Map<PeerControlInstance, PeerControlSchedulerBasic.instanceWrapper>	instance_map
private long	last_lag_log
private int[]	last_peer_count
private int[]	last_piece_count
private long	latest_time
private long	next_peer_count_time
private long	next_piece_count_time
private long	peer_count_active_time
private final List<PeerControlSchedulerBasic.instanceWrapper>	pending_registrations
private long	piece_count_active_time
private final Random	random
private boolean	registrations_changed
private final SpeedTokenDispenserBasic	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
PeerControlSchedulerBasic()

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

random

private final Random random

instance_map

private Map<PeerControlInstance, PeerControlSchedulerBasic.instanceWrapper> instance_map

pending_registrations

private final List<PeerControlSchedulerBasic.instanceWrapper> pending_registrations

registrations_changed

private volatile boolean registrations_changed

instance_lock

private final Object instance_lock

tokenDispenser

private final SpeedTokenDispenserBasic tokenDispenser

latest_time

private long latest_time

last_lag_log

private long last_lag_log

next_peer_count_time

private long next_peer_count_time

next_piece_count_time

private long next_piece_count_time

peer_count_active_time

private volatile long peer_count_active_time

piece_count_active_time

private volatile long piece_count_active_time

last_peer_count

private volatile int[] last_peer_count

last_piece_count

private volatile int[] last_piece_count

Constructor Details

PeerControlSchedulerBasic

public PeerControlSchedulerBasic()

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