globalmanagerstatsimpl.java

java 文件下载器。可自定义

// Decompiled by Jad v1.5.8e2. Copyright 2001 Pavel Kouznetsov.
// Jad home page: http://kpdus.tripod.com/jad.html
// Decompiler options: packimports(3) fieldsfirst ansi space 
// Source File Name:   GlobalManagerStatsImpl.java

package org.gudy.azureus2.core3.global.impl;

import org.gudy.azureus2.core3.config.COConfigurationManager;
import org.gudy.azureus2.core3.global.GlobalManagerStats;
import org.gudy.azureus2.core3.util.Average;

// Referenced classes of package org.gudy.azureus2.core3.global.impl:
//			GlobalManagerImpl

public class GlobalManagerStatsImpl
	implements GlobalManagerStats
{

	private GlobalManagerImpl manager;
	private long total_data_bytes_received;
	private long total_protocol_bytes_received;
	private long totalDiscarded;
	private long total_data_bytes_sent;
	private long total_protocol_bytes_sent;
	private int data_send_speed_at_close;
	private Average data_receive_speed;
	private Average protocol_receive_speed;
	private Average data_receive_speed_no_lan;
	private Average protocol_receive_speed_no_lan;
	private Average data_send_speed;
	private Average protocol_send_speed;
	private Average data_send_speed_no_lan;
	private Average protocol_send_speed_no_lan;

	protected GlobalManagerStatsImpl(GlobalManagerImpl _manager)
	{
		data_receive_speed = Average.getInstance(1000, 10);
		protocol_receive_speed = Average.getInstance(1000, 10);
		data_receive_speed_no_lan = Average.getInstance(1000, 10);
		protocol_receive_speed_no_lan = Average.getInstance(1000, 10);
		data_send_speed = Average.getInstance(1000, 10);
		protocol_send_speed = Average.getInstance(1000, 10);
		data_send_speed_no_lan = Average.getInstance(1000, 10);
		protocol_send_speed_no_lan = Average.getInstance(1000, 10);
		manager = _manager;
		load();
	}

	protected void load()
	{
		data_send_speed_at_close = COConfigurationManager.getIntParameter("globalmanager.stats.send.speed.at.close", 0);
	}

	protected void save()
	{
		COConfigurationManager.setParameter("globalmanager.stats.send.speed.at.close", getDataSendRate());
	}

	public int getDataSendRateAtClose()
	{
		return data_send_speed_at_close;
	}

	public void discarded(int length)
	{
		totalDiscarded += length;
	}

	public void dataBytesReceived(int length, boolean LAN)
	{
		total_data_bytes_received += length;
		if (!LAN)
			data_receive_speed_no_lan.addValue(length);
		data_receive_speed.addValue(length);
	}

	public void protocolBytesReceived(int length, boolean LAN)
	{
		total_protocol_bytes_received += length;
		if (!LAN)
			protocol_receive_speed_no_lan.addValue(length);
		protocol_receive_speed.addValue(length);
	}

	public void dataBytesSent(int length, boolean LAN)
	{
		total_data_bytes_sent += length;
		if (!LAN)
			data_send_speed_no_lan.addValue(length);
		data_send_speed.addValue(length);
	}

	public void protocolBytesSent(int length, boolean LAN)
	{
		total_protocol_bytes_sent += length;
		if (!LAN)
			protocol_send_speed_no_lan.addValue(length);
		protocol_send_speed.addValue(length);
	}

	public int getDataReceiveRate()
	{
		return (int)data_receive_speed.getAverage();
	}

	public int getDataReceiveRateNoLAN()
	{
		return (int)data_receive_speed_no_lan.getAverage();
	}

	public int getDataReceiveRateNoLAN(int average_period)
	{
		return (int)(average_period > 0 ? data_receive_speed_no_lan.getAverage(average_period) : data_receive_speed_no_lan.getAverage());
	}

	public int getProtocolReceiveRate()
	{
		return (int)protocol_receive_speed.getAverage();
	}

	public int getProtocolReceiveRateNoLAN()
	{
		return (int)protocol_receive_speed_no_lan.getAverage();
	}

	public int getProtocolReceiveRateNoLAN(int average_period)
	{
		return (int)(average_period > 0 ? protocol_receive_speed_no_lan.getAverage(average_period) : protocol_receive_speed_no_lan.getAverage());
	}

	public int getDataAndProtocolReceiveRate()
	{
		return (int)(protocol_receive_speed.getAverage() + data_receive_speed.getAverage());
	}

	public int getDataSendRate()
	{
		return (int)data_send_speed.getAverage();
	}

	public int getDataSendRateNoLAN()
	{
		return (int)data_send_speed_no_lan.getAverage();
	}

	public int getDataSendRateNoLAN(int average_period)
	{
		return (int)(average_period > 0 ? data_send_speed_no_lan.getAverage(average_period) : data_send_speed_no_lan.getAverage());
	}

	public int getProtocolSendRate()
	{
		return (int)protocol_send_speed.getAverage();
	}

	public int getProtocolSendRateNoLAN()
	{
		return (int)protocol_send_speed_no_lan.getAverage();
	}

	public int getProtocolSendRateNoLAN(int average_period)
	{
		return (int)(average_period > 0 ? protocol_send_speed_no_lan.getAverage(average_period) : protocol_send_speed_no_lan.getAverage());
	}

	public int getDataAndProtocolSendRate()
	{
		return (int)(protocol_send_speed.getAverage() + data_send_speed.getAverage());
	}

	public long getTotalDataBytesSent()
	{
		return total_data_bytes_sent;
	}

	public long getTotalProtocolBytesSent()
	{
		return total_protocol_bytes_sent;
	}

	public long getTotalDataBytesReceived()
	{
		return total_data_bytes_received;
	}

	public long getTotalProtocolBytesReceived()
	{
		return total_protocol_bytes_received;
	}

	public long getTotalDiscardedRaw()
	{
		return totalDiscarded;
	}

	public long getTotalSwarmsPeerRate(boolean downloading, boolean seeding)
	{
		return manager.getTotalSwarmsPeerRate(downloading, seeding);
	}
}