Class DMReaderImpl

java.lang.Object

com.biglybt.core.disk.impl.access.impl.DMReaderImpl

All Implemented Interfaces:

DMReader

public class DMReaderImpl
extends Object
implements DMReader

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	DMReaderImpl.requestDispatcher

Field Summary

Fields

Modifier and Type	Field	Description
private final ConcurrentHashMap<DiskAccessRequest, String>	active_requests
private final AESemaphore	async_read_sem
private int	async_reads
private final DiskAccessController	disk_access
private final DiskManagerHelper	disk_manager
private long	latency
private static final LogIDs	LOGID
private final Set<Object[]>	read_requests
private boolean	started
private boolean	stopped
private int	suspended
private final List<Object[]>	suspended_requests
private final AEMonitor	this_mon
private long	total_read_bytes
private long	total_read_ops

Constructor Summary

Constructors

Constructor	Description
DMReaderImpl(DiskManagerHelper _disk_manager)

Method Summary

Modifier and Type	Method	Description
DiskManagerReadRequest	createReadRequest(int pieceNumber, int offset, int length)
long	getLatency()
long[]	getStats()	2 entries, first = read-ops, second = read-bytes
boolean	hasOutstandingReadRequestForPiece(int piece_number)
DirectByteBuffer	readBlock(int pieceNumber, int offset, int length)
void	readBlock(DiskManagerReadRequest request, DiskManagerReadRequestListener _listener)
void	setSuspended(boolean b)
void	start()
void	stop()

Methods inherited from class Object

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

Field Details

LOGID

private static final LogIDs LOGID

disk_manager

private final DiskManagerHelper disk_manager

disk_access

private final DiskAccessController disk_access

active_requests

private final ConcurrentHashMap<DiskAccessRequest, String> active_requests

async_reads

private int async_reads

read_requests

private final Set<Object[]> read_requests

async_read_sem

private final AESemaphore async_read_sem

suspended_requests

private final List<Object[]> 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

private final AEMonitor this_mon

Constructor Details

DMReaderImpl

public DMReaderImpl(DiskManagerHelper _disk_manager)

Method Details

start

public void start()

Specified by:

start in interface DMReader

stop

public void stop()

Specified by:

stop in interface DMReader

setSuspended

public void setSuspended(boolean b)

Specified by:

setSuspended in interface DMReader

createReadRequest

public DiskManagerReadRequest createReadRequest(int pieceNumber,
 int offset,
 int length)

Specified by:

createReadRequest in interface DMReader

hasOutstandingReadRequestForPiece

public boolean hasOutstandingReadRequestForPiece(int piece_number)

Specified by:

hasOutstandingReadRequestForPiece in interface DMReader

getStats

public long[] getStats()

Description copied from interface: DMReader

2 entries, first = read-ops, second = read-bytes

Specified by:

getStats in interface DMReader

Returns:

getLatency

public long getLatency()

Specified by:

getLatency in interface DMReader

readBlock

public DirectByteBuffer readBlock(int pieceNumber,
 int offset,
 int length)

Specified by:

readBlock in interface DMReader

readBlock

public void readBlock(DiskManagerReadRequest request,
 DiskManagerReadRequestListener _listener)

Specified by:

readBlock in interface DMReader