Class DMWriterImpl

java.lang.Object

com.biglybt.core.disk.impl.access.impl.DMWriterImpl

All Implemented Interfaces:

DMWriter

public class DMWriterImpl
extends Object
implements DMWriter

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static interface	DMWriterImpl.DispatcherListener
protected class	DMWriterImpl.requestDispatcher

Nested classes/interfaces inherited from interface DMWriter

DMWriter.ProgressListener

Field Summary

Fields

Modifier and Type	Field	Description
private final ConcurrentHashMap<DiskAccessRequest, String>	active_requests
private final AESemaphore	async_write_sem
private int	async_writes
private long	async_writes_bytes
private boolean	complete_recheck_in_progress
private final DiskAccessController	disk_access
private final DiskManagerHelper	disk_manager
private long	latency
(package private) static final LogIDs	LOGID
private static final int	MIN_ZERO_BLOCK
private final int	pieceLength
private boolean	started
(package private) boolean	stopped
(package private) final AEMonitor	this_mon
private long	total_write_bytes
private long	total_write_ops
private final Set<DiskManagerWriteRequest>	write_requests

Constructor Summary

Constructors

Constructor	Description
DMWriterImpl(DiskManagerHelper _disk_manager)

Method Summary

Modifier and Type	Method	Description
DiskManagerWriteRequest	createWriteRequest(int pieceNumber, int offset, DirectByteBuffer buffer, Object user_data)
long	getLatency()
long[]	getStats()	4 entries, total write-ops, total write-bytes, outstanding write-ops, outstanding write-bytes
boolean	hasOutstandingWriteRequestForPiece(int piece_number)
boolean	isChecking()
void	start()
void	stop()
void	writeBlock(DiskManagerWriteRequest request, DiskManagerWriteRequestListener _listener)
boolean	zeroFile(DiskManagerAllocationScheduler.AllocationInstance allocation_instance, DiskManagerFileInfoImpl file, long start_from, long overall_length, DMWriter.ProgressListener listener)

Methods inherited from class Object

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

Field Details

LOGID

static final LogIDs LOGID

MIN_ZERO_BLOCK

private static final int MIN_ZERO_BLOCK

See Also:

• Constant Field Values

disk_manager

private final DiskManagerHelper disk_manager

disk_access

private final DiskAccessController disk_access

active_requests

private final ConcurrentHashMap<DiskAccessRequest, String> active_requests

async_writes

private int async_writes

async_writes_bytes

private long async_writes_bytes

write_requests

private final Set<DiskManagerWriteRequest> write_requests

async_write_sem

private final AESemaphore async_write_sem

started

private boolean started

stopped

volatile boolean stopped

pieceLength

private final int pieceLength

complete_recheck_in_progress

private boolean complete_recheck_in_progress

this_mon

final AEMonitor this_mon

total_write_ops

private long total_write_ops

total_write_bytes

private long total_write_bytes

latency

private volatile long latency

Constructor Details

DMWriterImpl

public DMWriterImpl(DiskManagerHelper _disk_manager)

Method Details

start

public void start()

Specified by:

start in interface DMWriter

stop

public void stop()

Specified by:

stop in interface DMWriter

isChecking

public boolean isChecking()

zeroFile

public boolean zeroFile(DiskManagerAllocationScheduler.AllocationInstance allocation_instance,
 DiskManagerFileInfoImpl file,
 long start_from,
 long overall_length,
 DMWriter.ProgressListener listener)
                 throws DiskManagerException

Specified by:

zeroFile in interface DMWriter

Throws:

DiskManagerException

createWriteRequest

public DiskManagerWriteRequest createWriteRequest(int pieceNumber,
 int offset,
 DirectByteBuffer buffer,
 Object user_data)

Specified by:

createWriteRequest in interface DMWriter

hasOutstandingWriteRequestForPiece

public boolean hasOutstandingWriteRequestForPiece(int piece_number)

Specified by:

hasOutstandingWriteRequestForPiece in interface DMWriter

writeBlock

public void writeBlock(DiskManagerWriteRequest request,
 DiskManagerWriteRequestListener _listener)

Specified by:

writeBlock in interface DMWriter

getStats

public long[] getStats()

Description copied from interface: DMWriter

4 entries, total write-ops, total write-bytes, outstanding write-ops, outstanding write-bytes

Specified by:

getStats in interface DMWriter

Returns:

getLatency

public long getLatency()

Specified by:

getLatency in interface DMWriter