Class NetworkConnectionHelper

java.lang.Object

com.biglybt.core.networkmanager.NetworkConnectionHelper

All Implemented Interfaces:

ControllerAllocationManagement, NetworkConnectionBase

Direct Known Subclasses:

NetworkConnectionImpl, PeerForeignNetworkConnection

public abstract class NetworkConnectionHelper
extends Object
implements NetworkConnectionBase, ControllerAllocationManagement

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicInteger	active_read_partition
private final AtomicInteger	active_write_partition
(package private) int	download_limit
private final LimitedRateGroup	download_limiter
private LimitedRateGroup[]	download_limiters
private long	last_read_stall
private long	last_write_stall
private static final AtomicInteger	next_partition_id
private final int	partition_id
private final AtomicInteger	read_release_count
private int	target_read_partition
private int	target_write_partition
(package private) int	upload_limit
private final LimitedRateGroup	upload_limiter
private LimitedRateGroup[]	upload_limiters
private final AtomicInteger	write_release_count

Fields inherited from interface ControllerAllocationManagement

UNALLOCATED_PARTITION

Constructor Summary

Constructors

Constructor	Description
NetworkConnectionHelper()

Method Summary

Modifier and Type	Method	Description
void	activeReadControllerRelease(boolean added)
void	activeWriteControllerRelease(boolean added)
void	addRateLimiter(LimitedRateGroup limiter, boolean upload)
abstract void	close(String reason)
int	getDownloadLimit()
int	getPartitionID()
LimitedRateGroup[]	getRateLimiters(boolean upload)
int	getUploadLimit()
boolean	isReadControllerActive(int partition)
boolean	isWriteControllerActive(int partition)
void	removeRateLimiter(LimitedRateGroup limiter, boolean upload)
void	setDownloadLimit(int limit)
void	setReadControllerInactive()
void	setTargetReadControllerPartition(int partition)
void	setTargetWriteControllerPartition(int partition)
void	setUploadLimit(int limit)
void	setWriteControllerInactive()

Methods inherited from class Object

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

Methods inherited from interface NetworkConnectionBase

getEndpoint, getIncomingMessageQueue, getMssSize, getOutgoingMessageQueue, getString, getTransportBase, isClosed, isIncoming, isLANLocal, notifyOfException, resetLANLocalStatus

Field Details

next_partition_id

private static final AtomicInteger next_partition_id

partition_id

private final int partition_id

upload_limit

int upload_limit

upload_limiter

private final LimitedRateGroup upload_limiter

download_limit

int download_limit

download_limiter

private final LimitedRateGroup download_limiter

upload_limiters

private volatile LimitedRateGroup[] upload_limiters

download_limiters

private volatile LimitedRateGroup[] download_limiters

read_release_count

private final AtomicInteger read_release_count

target_read_partition

private volatile int target_read_partition

active_read_partition

private final AtomicInteger active_read_partition

last_read_stall

private long last_read_stall

write_release_count

private final AtomicInteger write_release_count

target_write_partition

private volatile int target_write_partition

active_write_partition

private final AtomicInteger active_write_partition

last_write_stall

private long last_write_stall

Constructor Details

NetworkConnectionHelper

public NetworkConnectionHelper()

Method Details

getPartitionID

public int getPartitionID()

Specified by:

getPartitionID in interface NetworkConnectionBase

close

public abstract void close(String reason)

getUploadLimit

public int getUploadLimit()

Specified by:

getUploadLimit in interface NetworkConnectionBase

getDownloadLimit

public int getDownloadLimit()

Specified by:

getDownloadLimit in interface NetworkConnectionBase

setUploadLimit

public void setUploadLimit(int limit)

Specified by:

setUploadLimit in interface NetworkConnectionBase

setDownloadLimit

public void setDownloadLimit(int limit)

Specified by:

setDownloadLimit in interface NetworkConnectionBase

addRateLimiter

public void addRateLimiter(LimitedRateGroup limiter,
 boolean upload)

Specified by:

addRateLimiter in interface NetworkConnectionBase

removeRateLimiter

public void removeRateLimiter(LimitedRateGroup limiter,
 boolean upload)

Specified by:

removeRateLimiter in interface NetworkConnectionBase

getRateLimiters

public LimitedRateGroup[] getRateLimiters(boolean upload)

Specified by:

getRateLimiters in interface NetworkConnectionBase

setTargetReadControllerPartition

public void setTargetReadControllerPartition(int partition)

Specified by:

setTargetReadControllerPartition in interface ControllerAllocationManagement

setReadControllerInactive

public void setReadControllerInactive()

Specified by:

setReadControllerInactive in interface ControllerAllocationManagement

activeReadControllerRelease

public void activeReadControllerRelease(boolean added)

Specified by:

activeReadControllerRelease in interface ControllerAllocationManagement

isReadControllerActive

public boolean isReadControllerActive(int partition)

Specified by:

isReadControllerActive in interface ControllerAllocationManagement

setTargetWriteControllerPartition

public void setTargetWriteControllerPartition(int partition)

Specified by:

setTargetWriteControllerPartition in interface ControllerAllocationManagement

setWriteControllerInactive

public void setWriteControllerInactive()

Specified by:

setWriteControllerInactive in interface ControllerAllocationManagement

activeWriteControllerRelease

public void activeWriteControllerRelease(boolean added)

Specified by:

activeWriteControllerRelease in interface ControllerAllocationManagement

isWriteControllerActive

public boolean isWriteControllerActive(int partition)

Specified by:

isWriteControllerActive in interface ControllerAllocationManagement