Class DMReaderImpl
java.lang.Object
com.biglybt.core.disk.impl.access.impl.DMReaderImpl
- All Implemented Interfaces:
DMReader
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final ConcurrentHashMap
<DiskAccessRequest, String> private final AESemaphore
private int
private final DiskAccessController
private final DiskManagerHelper
private long
private static final LogIDs
private boolean
private boolean
private int
private final AEMonitor
private long
private long
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptioncreateReadRequest
(int pieceNumber, int offset, int length) long
long[]
getStats()
2 entries, first = read-ops, second = read-bytesboolean
hasOutstandingReadRequestForPiece
(int piece_number) readBlock
(int pieceNumber, int offset, int length) void
readBlock
(DiskManagerReadRequest request, DiskManagerReadRequestListener _listener) void
setSuspended
(boolean b) void
start()
void
stop()
-
Field Details
-
LOGID
-
disk_manager
-
disk_access
-
active_requests
-
async_reads
private int async_reads -
read_requests
-
async_read_sem
-
suspended_requests
-
started
private boolean started -
stopped
private boolean stopped -
suspended
private int suspended -
total_read_ops
private long total_read_ops -
total_read_bytes
private long total_read_bytes -
latency
private volatile long latency -
this_mon
-
-
Constructor Details
-
DMReaderImpl
-
-
Method Details
-
start
public void start() -
stop
public void stop() -
setSuspended
public void setSuspended(boolean b) - Specified by:
setSuspended
in interfaceDMReader
-
createReadRequest
- Specified by:
createReadRequest
in interfaceDMReader
-
hasOutstandingReadRequestForPiece
public boolean hasOutstandingReadRequestForPiece(int piece_number) - Specified by:
hasOutstandingReadRequestForPiece
in interfaceDMReader
-
getStats
public long[] getStats()Description copied from interface:DMReader
2 entries, first = read-ops, second = read-bytes -
getLatency
public long getLatency()- Specified by:
getLatency
in interfaceDMReader
-
readBlock
-
readBlock
-