Class DMCheckerImpl

java.lang.Object

com.biglybt.core.disk.impl.access.impl.DMCheckerImpl

All Implemented Interfaces:

DMChecker

public class DMCheckerImpl
extends Object
implements DMChecker

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final List	async_check_queue
(package private) static final AESemaphore	async_check_queue_sem
protected final AESemaphore	async_check_sem
protected int	async_checks
protected final AESemaphore	async_read_sem
protected int	async_reads
(package private) boolean	check_cancelled
private boolean	checking_enabled
(package private) static boolean	checking_read_priority
(package private) static final AEMonitor	class_mon
(package private) boolean	complete_recheck_in_progress
(package private) int	complete_recheck_progress
protected final DiskManagerHelper	disk_manager
(package private) static boolean	flush_pieces
private static final boolean	fully_async
protected static final LogIDs	LOGID
private boolean	started
protected boolean	stopped
protected final AEMonitor	this_mon

Constructor Summary

Constructors

Constructor	Description
DMCheckerImpl(DiskManagerHelper _disk_manager)

Method Summary

Modifier and Type	Method	Description
DiskManagerCheckRequest	createCheckRequest(int pieceNumber, Object user_data)
void	enqueueCheckRequest(DiskManagerCheckRequest request, DiskManagerCheckRequestListener listener)
protected void	enqueueCheckRequest(DiskManagerCheckRequest request, DiskManagerCheckRequestListener listener, boolean read_flush)
protected void	enqueueCheckRequestSupport(DiskManagerCheckRequest request, DiskManagerCheckRequestListener listener, boolean read_flush, boolean hash_requested)
void	enqueueCompleteRecheckRequest(DiskManagerCheckRequest request, DiskManagerCheckRequestListener listener)
int	getCompleteRecheckStatus()
boolean	getRecheckCancelled()
boolean	hasOutstandingCheckRequestForPiece(int piece_number)
void	setCheckingEnabled(boolean enabled)
void	start()
void	stop()

Methods inherited from class Object

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

Field Details

LOGID

protected static final LogIDs LOGID

flush_pieces

static boolean flush_pieces

checking_read_priority

static boolean checking_read_priority

class_mon

static final AEMonitor class_mon

async_check_queue

static final List async_check_queue

async_check_queue_sem

static final AESemaphore async_check_queue_sem

fully_async

private static final boolean fully_async

disk_manager

protected final DiskManagerHelper disk_manager

async_checks

protected int async_checks

async_check_sem

protected final AESemaphore async_check_sem

async_reads

protected int async_reads

async_read_sem

protected final AESemaphore async_read_sem

started

private boolean started

stopped

protected volatile boolean stopped

complete_recheck_in_progress

volatile boolean complete_recheck_in_progress

complete_recheck_progress

volatile int complete_recheck_progress

check_cancelled

volatile boolean check_cancelled

checking_enabled

private boolean checking_enabled

this_mon

protected final AEMonitor this_mon

Constructor Details

DMCheckerImpl

public DMCheckerImpl(DiskManagerHelper _disk_manager)

Method Details

start

public void start()

Specified by:

start in interface DMChecker

stop

public void stop()

Specified by:

stop in interface DMChecker

getCompleteRecheckStatus

public int getCompleteRecheckStatus()

Specified by:

getCompleteRecheckStatus in interface DMChecker

getRecheckCancelled

public boolean getRecheckCancelled()

Specified by:

getRecheckCancelled in interface DMChecker

setCheckingEnabled

public void setCheckingEnabled(boolean enabled)

Specified by:

setCheckingEnabled in interface DMChecker

createCheckRequest

public DiskManagerCheckRequest createCheckRequest(int pieceNumber,
 Object user_data)

Specified by:

createCheckRequest in interface DMChecker

enqueueCompleteRecheckRequest

public void enqueueCompleteRecheckRequest(DiskManagerCheckRequest request,
 DiskManagerCheckRequestListener listener)

Specified by:

enqueueCompleteRecheckRequest in interface DMChecker

enqueueCheckRequest

public void enqueueCheckRequest(DiskManagerCheckRequest request,
 DiskManagerCheckRequestListener listener)

Specified by:

enqueueCheckRequest in interface DMChecker

hasOutstandingCheckRequestForPiece

public boolean hasOutstandingCheckRequestForPiece(int piece_number)

Specified by:

hasOutstandingCheckRequestForPiece in interface DMChecker

enqueueCheckRequest

protected void enqueueCheckRequest(DiskManagerCheckRequest request,
 DiskManagerCheckRequestListener listener,
 boolean read_flush)

enqueueCheckRequestSupport

protected void enqueueCheckRequestSupport(DiskManagerCheckRequest request,
 DiskManagerCheckRequestListener listener,
 boolean read_flush,
 boolean hash_requested)