Class GlobalManagerStatsImpl

java.lang.Object

com.biglybt.core.global.impl.GlobalManagerStatsImpl

All Implemented Interfaces:

GlobalManagerStats, SimpleTimer.TimerTickReceiver

public class GlobalManagerStatsImpl
extends Object
implements GlobalManagerStats, SimpleTimer.TimerTickReceiver

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	GlobalManagerStatsImpl.AggregateStatsDownloadWrapper
private static class	GlobalManagerStatsImpl.AggregateStatsImpl
private class	GlobalManagerStatsImpl.AggregateStatsWrapper
private static class	GlobalManagerStatsImpl.CountryDetailsImpl
private static class	GlobalManagerStatsImpl.HistoryEntry
private static class	GlobalManagerStatsImpl.PeerDetails

Nested classes/interfaces inherited from interface GlobalManagerStats

GlobalManagerStats.AggregateStats, GlobalManagerStats.CountryDetails, GlobalManagerStats.RemoteCountryStats, GlobalManagerStats.RemoteStats

Field Summary

Fields

Modifier and Type	Field	Description
private Map<String, Map<String,long[]>>	aggregate_stats
private GlobalManagerStatsImpl.AggregateStatsWrapper	as_local_wrapper
private GlobalManagerStatsImpl.AggregateStatsImpl	as_remote_latest
private GlobalManagerStatsImpl.AggregateStatsWrapper	as_remote_wrapper
private Map<String, GlobalManagerStats.CountryDetails>	country_details
private AtomicInteger	country_details_seq
private String	country_my_cc
private GlobalManagerStatsImpl.CountryDetailsImpl	country_total
private int	current_smoothing_interval
private int	current_smoothing_window
private final Average	data_receive_speed
private final Average	data_receive_speed_no_lan
private final Average	data_send_speed
private long	data_send_speed_at_close
private final Average	data_send_speed_no_lan
private DHT	dht_biglybt
private static final Object	DOWNLOAD_DATA_KEY
private final GlobalManagerImpl	manager
private static final long	MAX_ALLOWED_BYTES_PER_MIN
private static final Object	PEER_DATA_FINAL_KEY
private static final Object	PEER_DATA_INIT_KEY
private static final Object	PEER_DATA_KEY
private ConcurrentHashMap<InetAddress, GlobalManagerStats.RemoteStats>	pending_stats
private final Average	protocol_receive_speed
private final Average	protocol_receive_speed_no_lan
private final Average	protocol_send_speed
private final Average	protocol_send_speed_no_lan
private Map<DownloadManager, List<PEPeer>>	removed_peers
private int	sequence
private long	smooth_last_received
private long	smooth_last_sent
private GeneralUtils.SmoothAverage	smoothed_receive_rate
private GeneralUtils.SmoothAverage	smoothed_send_rate
private AsyncDispatcher	stats_dispatcher
private LinkedList<GlobalManagerStatsImpl.HistoryEntry>	stats_history
private Set<InetAddress>	stats_history_addresses
private static final long	STATS_HISTORY_MAX_AGE
private static final long	STATS_HISTORY_MAX_SAMPLES
private long	total_data_bytes_received
private long	total_data_bytes_sent
private long	total_protocol_bytes_received
private long	total_protocol_bytes_sent
private long	total_received_overall
private long	total_sent_overall
private long	totalDiscarded

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	GlobalManagerStatsImpl()
protected	GlobalManagerStatsImpl(GlobalManagerImpl _manager)

Method Summary

Modifier and Type	Method	Description
private void	addRemoteStats(GlobalManagerStats.RemoteStats stats)
void	dataBytesReceived(long length, boolean LAN)
void	dataBytesSent(long length, boolean LAN)
void	discarded(int length)
GlobalManagerStats.AggregateStats	getAggregateLocalStats()
GlobalManagerStats.AggregateStats	getAggregateLocalStats(DownloadManager dm)
GlobalManagerStats.AggregateStats	getAggregateRemoteStats()
Iterator<GlobalManagerStats.CountryDetails>	getCountryDetails()
int	getDataAndProtocolReceiveRate()
int	getDataAndProtocolSendRate()
long	getDataReceiveRate()	Data Receive Rate over the last 10s
long	getDataReceiveRateNoLAN()
long	getDataReceiveRateNoLAN(int average_period)
long	getDataSendRate()	Data Send Rate over the last 10s
long	getDataSendRateAtClose()
long	getDataSendRateNoLAN()
long	getDataSendRateNoLAN(int average_period)
int	getProtocolReceiveRate()
int	getProtocolReceiveRateNoLAN()
int	getProtocolReceiveRateNoLAN(int average_period)
int	getProtocolSendRate()
int	getProtocolSendRateNoLAN()
int	getProtocolSendRateNoLAN(int average_period)
long	getSmoothedReceiveRate()	Smoothed Receive Rate, including data and protocol, based on "Stats Smoothing Secs" see @link GeneralUtils for defaults and limits
long	getSmoothedSendRate()	Smoothed Send Rate, including data and protocol, based on "Stats Smoothing Secs", see @link GeneralUtils for defaults and limits
long	getTotalDataBytesReceived()
long	getTotalDataBytesSent()
long	getTotalDiscardedRaw()
long	getTotalProtocolBytesReceived()
long	getTotalProtocolBytesSent()
long	getTotalSwarmsPeerRate(boolean downloading, boolean seeding)
protected void	load()
void	protocolBytesReceived(long length, boolean LAN)
void	protocolBytesSent(long length, boolean LAN)
void	receiveRemoteStats(GlobalManagerStats.RemoteStats stats)
protected void	save()
void	tick(long mono_now, int tick_count)

Methods inherited from class Object

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

Methods inherited from interface GlobalManagerStats

getTotalDataProtocolBytesReceived, getTotalDataProtocolBytesSent

Field Details

manager

private final GlobalManagerImpl manager

smooth_last_sent

private long smooth_last_sent

smooth_last_received

private long smooth_last_received

current_smoothing_window

private int current_smoothing_window

current_smoothing_interval

private int current_smoothing_interval

smoothed_receive_rate

private GeneralUtils.SmoothAverage smoothed_receive_rate

smoothed_send_rate

private GeneralUtils.SmoothAverage smoothed_send_rate

total_data_bytes_received

private long total_data_bytes_received

total_protocol_bytes_received

private long total_protocol_bytes_received

totalDiscarded

private long totalDiscarded

total_data_bytes_sent

private long total_data_bytes_sent

total_protocol_bytes_sent

private long total_protocol_bytes_sent

data_send_speed_at_close

private long data_send_speed_at_close

data_receive_speed

private final Average data_receive_speed

protocol_receive_speed

private final Average protocol_receive_speed

data_receive_speed_no_lan

private final Average data_receive_speed_no_lan

protocol_receive_speed_no_lan

private final Average protocol_receive_speed_no_lan

data_send_speed

private final Average data_send_speed

protocol_send_speed

private final Average protocol_send_speed

data_send_speed_no_lan

private final Average data_send_speed_no_lan

protocol_send_speed_no_lan

private final Average protocol_send_speed_no_lan

PEER_DATA_INIT_KEY

private static final Object PEER_DATA_INIT_KEY

PEER_DATA_KEY

private static final Object PEER_DATA_KEY

PEER_DATA_FINAL_KEY

private static final Object PEER_DATA_FINAL_KEY

DOWNLOAD_DATA_KEY

private static final Object DOWNLOAD_DATA_KEY

removed_peers

private Map<DownloadManager, List<PEPeer>> removed_peers

country_details

private Map<String, GlobalManagerStats.CountryDetails> country_details

country_total

private GlobalManagerStatsImpl.CountryDetailsImpl country_total

country_details_seq

private AtomicInteger country_details_seq

country_my_cc

private String country_my_cc

stats_dispatcher

private AsyncDispatcher stats_dispatcher

pending_stats

private ConcurrentHashMap<InetAddress, GlobalManagerStats.RemoteStats> pending_stats

STATS_HISTORY_MAX_AGE

private static final long STATS_HISTORY_MAX_AGE

See Also:

• Constant Field Values

STATS_HISTORY_MAX_SAMPLES

private static final long STATS_HISTORY_MAX_SAMPLES

See Also:

• Constant Field Values

MAX_ALLOWED_BYTES_PER_MIN

private static final long MAX_ALLOWED_BYTES_PER_MIN

See Also:

• Constant Field Values

aggregate_stats

private Map<String, Map<String,long[]>> aggregate_stats

sequence

private int sequence

total_received_overall

private long total_received_overall

total_sent_overall

private long total_sent_overall

as_remote_latest

private volatile GlobalManagerStatsImpl.AggregateStatsImpl as_remote_latest

dht_biglybt

private DHT dht_biglybt

stats_history

private LinkedList<GlobalManagerStatsImpl.HistoryEntry> stats_history

stats_history_addresses

private Set<InetAddress> stats_history_addresses

as_remote_wrapper

private GlobalManagerStatsImpl.AggregateStatsWrapper as_remote_wrapper

as_local_wrapper

private GlobalManagerStatsImpl.AggregateStatsWrapper as_local_wrapper

Constructor Details

GlobalManagerStatsImpl

protected GlobalManagerStatsImpl()

GlobalManagerStatsImpl

protected GlobalManagerStatsImpl(GlobalManagerImpl _manager)

Method Details

load

protected void load()

save

protected void save()

getDataSendRateAtClose

public long getDataSendRateAtClose()

Specified by:

getDataSendRateAtClose in interface GlobalManagerStats

discarded

public void discarded(int length)

Specified by:

discarded in interface GlobalManagerStats

dataBytesReceived

public void dataBytesReceived(long length,
 boolean LAN)

Specified by:

dataBytesReceived in interface GlobalManagerStats

protocolBytesReceived

public void protocolBytesReceived(long length,
 boolean LAN)

Specified by:

protocolBytesReceived in interface GlobalManagerStats

dataBytesSent

public void dataBytesSent(long length,
 boolean LAN)

Specified by:

dataBytesSent in interface GlobalManagerStats

protocolBytesSent

public void protocolBytesSent(long length,
 boolean LAN)

Specified by:

protocolBytesSent in interface GlobalManagerStats

getDataReceiveRate

public long getDataReceiveRate()

Description copied from interface: GlobalManagerStats

Data Receive Rate over the last 10s

Specified by:

getDataReceiveRate in interface GlobalManagerStats

getDataReceiveRateNoLAN

public long getDataReceiveRateNoLAN()

Specified by:

getDataReceiveRateNoLAN in interface GlobalManagerStats

getDataReceiveRateNoLAN

public long getDataReceiveRateNoLAN(int average_period)

Specified by:

getDataReceiveRateNoLAN in interface GlobalManagerStats

getProtocolReceiveRate

public int getProtocolReceiveRate()

Specified by:

getProtocolReceiveRate in interface GlobalManagerStats

getProtocolReceiveRateNoLAN

public int getProtocolReceiveRateNoLAN()

Specified by:

getProtocolReceiveRateNoLAN in interface GlobalManagerStats

getProtocolReceiveRateNoLAN

public int getProtocolReceiveRateNoLAN(int average_period)

Specified by:

getProtocolReceiveRateNoLAN in interface GlobalManagerStats

getDataAndProtocolReceiveRate

public int getDataAndProtocolReceiveRate()

Specified by:

getDataAndProtocolReceiveRate in interface GlobalManagerStats

getDataSendRate

public long getDataSendRate()

Description copied from interface: GlobalManagerStats

Data Send Rate over the last 10s

Specified by:

getDataSendRate in interface GlobalManagerStats

getDataSendRateNoLAN

public long getDataSendRateNoLAN()

Specified by:

getDataSendRateNoLAN in interface GlobalManagerStats

getDataSendRateNoLAN

public long getDataSendRateNoLAN(int average_period)

Specified by:

getDataSendRateNoLAN in interface GlobalManagerStats

getProtocolSendRate

public int getProtocolSendRate()

Specified by:

getProtocolSendRate in interface GlobalManagerStats

getProtocolSendRateNoLAN

public int getProtocolSendRateNoLAN()

Specified by:

getProtocolSendRateNoLAN in interface GlobalManagerStats

getProtocolSendRateNoLAN

public int getProtocolSendRateNoLAN(int average_period)

Specified by:

getProtocolSendRateNoLAN in interface GlobalManagerStats

getDataAndProtocolSendRate

public int getDataAndProtocolSendRate()

Specified by:

getDataAndProtocolSendRate in interface GlobalManagerStats

getTotalDataBytesSent

public long getTotalDataBytesSent()

Specified by:

getTotalDataBytesSent in interface GlobalManagerStats

getTotalProtocolBytesSent

public long getTotalProtocolBytesSent()

Specified by:

getTotalProtocolBytesSent in interface GlobalManagerStats

getTotalDataBytesReceived

public long getTotalDataBytesReceived()

Specified by:

getTotalDataBytesReceived in interface GlobalManagerStats

getTotalProtocolBytesReceived

public long getTotalProtocolBytesReceived()

Specified by:

getTotalProtocolBytesReceived in interface GlobalManagerStats

getTotalDiscardedRaw

public long getTotalDiscardedRaw()

getTotalSwarmsPeerRate

public long getTotalSwarmsPeerRate(boolean downloading,
 boolean seeding)

Specified by:

getTotalSwarmsPeerRate in interface GlobalManagerStats

getSmoothedSendRate

public long getSmoothedSendRate()

Description copied from interface: GlobalManagerStats

Smoothed Send Rate, including data and protocol, based on "Stats Smoothing Secs", see @link GeneralUtils for defaults and limits

Specified by:

getSmoothedSendRate in interface GlobalManagerStats

getSmoothedReceiveRate

public long getSmoothedReceiveRate()

Description copied from interface: GlobalManagerStats

Smoothed Receive Rate, including data and protocol, based on "Stats Smoothing Secs" see @link GeneralUtils for defaults and limits

Specified by:

getSmoothedReceiveRate in interface GlobalManagerStats

getCountryDetails

public Iterator<GlobalManagerStats.CountryDetails> getCountryDetails()

Specified by:

getCountryDetails in interface GlobalManagerStats

tick

public void tick(long mono_now,
 int tick_count)

Specified by:

tick in interface SimpleTimer.TimerTickReceiver

receiveRemoteStats

public void receiveRemoteStats(GlobalManagerStats.RemoteStats stats)

Specified by:

receiveRemoteStats in interface GlobalManagerStats

addRemoteStats

private void addRemoteStats(GlobalManagerStats.RemoteStats stats)

getAggregateRemoteStats

public GlobalManagerStats.AggregateStats getAggregateRemoteStats()

Specified by:

getAggregateRemoteStats in interface GlobalManagerStats

getAggregateLocalStats

public GlobalManagerStats.AggregateStats getAggregateLocalStats()

Specified by:

getAggregateLocalStats in interface GlobalManagerStats

getAggregateLocalStats

public GlobalManagerStats.AggregateStats getAggregateLocalStats(DownloadManager dm)

Specified by:

getAggregateLocalStats in interface GlobalManagerStats