Class DiskAccessControllerInstance

java.lang.Object

com.biglybt.core.diskmanager.access.impl.DiskAccessControllerInstance

public class DiskAccessControllerInstance
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	DiskAccessControllerInstance.groupSemaphore
protected class	DiskAccessControllerInstance.requestDispatcher

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final int	aggregation_byte_limit
(package private) final int	aggregation_request_limit
private final DiskAccessControllerInstance.requestDispatcher[]	dispatchers
(package private) final boolean	enable_aggregation
(package private) final boolean	invert_threads
(package private) long	io_count
(package private) long	io_time
private long	last_check
private int	max_kb_queued
private final DiskAccessControllerInstance.groupSemaphore	max_kb_sem
(package private) final int	max_threads
private final String	name
private long	next_request_byte_log
private int	next_request_num_log
private static final int	REQUEST_BYTE_LOG_CHUNK
private long	request_bytes_queued
private static final int	REQUEST_NUM_LOG_CHUNK
private long	requests_queued
(package private) static final ThreadLocal	tls
private final Map	torrent_dispatcher_map
(package private) long	total_aggregated_bytes
(package private) long	total_aggregated_requests_made
(package private) long	total_bytes
(package private) long	total_requests
(package private) long	total_single_bytes
(package private) long	total_single_requests_made

Constructor Summary

Constructors

Constructor	Description
DiskAccessControllerInstance(String _name, boolean _enable_aggregation, int _aggregation_request_limit, int _aggregation_byte_limit, int _max_threads, int _max_mb)

Method Summary

Modifier and Type	Method	Description
protected long	getBlockCount()
long	getIOCount()
long	getIOTime()
protected String	getName()
protected long	getQueuedBytes()
protected long	getQueueSize()
protected void	getSpaceAllowance(DiskAccessRequestImpl request)
protected String	getString()
long	getTotalAggregatedBytes()
protected long	getTotalAggregatedRequests()
long	getTotalBytes()
protected long	getTotalRequests()
long	getTotalSingleBytes()
protected long	getTotalSingleRequests()
protected void	queueRequest(DiskAccessRequestImpl request)
protected void	releaseSpaceAllowance(DiskAccessRequestImpl request)

Methods inherited from class Object

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

Field Details

aggregation_request_limit

final int aggregation_request_limit

aggregation_byte_limit

final int aggregation_byte_limit

name

private final String name

enable_aggregation

final boolean enable_aggregation

invert_threads

final boolean invert_threads

max_threads

final int max_threads

max_kb_queued

private int max_kb_queued

max_kb_sem

private final DiskAccessControllerInstance.groupSemaphore max_kb_sem

request_bytes_queued

private long request_bytes_queued

requests_queued

private long requests_queued

total_requests

long total_requests

total_single_requests_made

long total_single_requests_made

total_aggregated_requests_made

long total_aggregated_requests_made

total_bytes

long total_bytes

total_single_bytes

long total_single_bytes

total_aggregated_bytes

long total_aggregated_bytes

io_time

long io_time

io_count

long io_count

dispatchers

private final DiskAccessControllerInstance.requestDispatcher[] dispatchers

last_check

private long last_check

torrent_dispatcher_map

private final Map torrent_dispatcher_map

REQUEST_NUM_LOG_CHUNK

private static final int REQUEST_NUM_LOG_CHUNK

See Also:

• Constant Field Values

REQUEST_BYTE_LOG_CHUNK

private static final int REQUEST_BYTE_LOG_CHUNK

See Also:

• Constant Field Values

next_request_num_log

private int next_request_num_log

next_request_byte_log

private long next_request_byte_log

tls

static final ThreadLocal tls

Constructor Details

DiskAccessControllerInstance

public DiskAccessControllerInstance(String _name,
 boolean _enable_aggregation,
 int _aggregation_request_limit,
 int _aggregation_byte_limit,
 int _max_threads,
 int _max_mb)

Method Details

getName

protected String getName()

getBlockCount

protected long getBlockCount()

getQueueSize

protected long getQueueSize()

getQueuedBytes

protected long getQueuedBytes()

getTotalRequests

protected long getTotalRequests()

getTotalSingleRequests

protected long getTotalSingleRequests()

getTotalAggregatedRequests

protected long getTotalAggregatedRequests()

getTotalBytes

public long getTotalBytes()

getTotalSingleBytes

public long getTotalSingleBytes()

getTotalAggregatedBytes

public long getTotalAggregatedBytes()

getIOTime

public long getIOTime()

getIOCount

public long getIOCount()

queueRequest

protected void queueRequest(DiskAccessRequestImpl request)

getSpaceAllowance

protected void getSpaceAllowance(DiskAccessRequestImpl request)

releaseSpaceAllowance

protected void releaseSpaceAllowance(DiskAccessRequestImpl request)

getString

protected String getString()