Class DiskAccessControllerInstance
- java.lang.Object
-
- com.biglybt.core.diskmanager.access.impl.DiskAccessControllerInstance
-
public class DiskAccessControllerInstance extends java.lang.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) int
aggregation_byte_limit
(package private) int
aggregation_request_limit
private DiskAccessControllerInstance.requestDispatcher[]
dispatchers
(package private) boolean
enable_aggregation
(package private) boolean
invert_threads
(package private) long
io_count
(package private) long
io_time
private long
last_check
private int
max_mb_queued
private DiskAccessControllerInstance.groupSemaphore
max_mb_sem
(package private) int
max_threads
private java.lang.String
name
private long
next_request_byte_log
private int
next_request_num_log
private static int
REQUEST_BYTE_LOG_CHUNK
private long
request_bytes_queued
private static int
REQUEST_NUM_LOG_CHUNK
private long
requests_queued
(package private) static java.lang.ThreadLocal
tls
private java.util.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(java.lang.String _name, boolean _enable_aggregation, int _aggregation_request_limit, int _aggregation_byte_limit, int _max_threads, int _max_mb)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected long
getBlockCount()
long
getIOCount()
long
getIOTime()
protected java.lang.String
getName()
protected long
getQueuedBytes()
protected long
getQueueSize()
protected void
getSpaceAllowance(DiskAccessRequestImpl request)
protected java.lang.String
getString()
long
getTotalAggregatedBytes()
protected long
getTotalAggregatedRequests()
long
getTotalBytes()
protected long
getTotalRequests()
long
getTotalSingleBytes()
protected long
getTotalSingleRequests()
static void
main(java.lang.String[] args)
protected void
queueRequest(DiskAccessRequestImpl request)
protected void
releaseSpaceAllowance(DiskAccessRequestImpl request)
-
-
-
Field Detail
-
aggregation_request_limit
final int aggregation_request_limit
-
aggregation_byte_limit
final int aggregation_byte_limit
-
name
private final java.lang.String name
-
enable_aggregation
final boolean enable_aggregation
-
invert_threads
final boolean invert_threads
-
max_threads
final int max_threads
-
max_mb_queued
private int max_mb_queued
-
max_mb_sem
private final DiskAccessControllerInstance.groupSemaphore max_mb_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 java.util.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 java.lang.ThreadLocal tls
-
-
Method Detail
-
getName
protected java.lang.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 java.lang.String getString()
-
main
public static void main(java.lang.String[] args)
-
-