Class DMCheckerImpl
java.lang.Object
com.biglybt.core.disk.impl.access.impl.DMCheckerImpl
- All Implemented Interfaces:
DMChecker
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) static final List
(package private) static final AESemaphore
protected final AESemaphore
protected int
protected final AESemaphore
protected int
(package private) boolean
private boolean
(package private) static boolean
(package private) static final AEMonitor
(package private) boolean
(package private) int
protected final DiskManagerHelper
(package private) static boolean
private static final boolean
protected static final LogIDs
private boolean
protected boolean
protected final AEMonitor
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptioncreateCheckRequest
(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
boolean
boolean
hasOutstandingCheckRequestForPiece
(int piece_number) void
setCheckingEnabled
(boolean enabled) void
start()
void
stop()
-
Field Details
-
LOGID
-
flush_pieces
static boolean flush_pieces -
checking_read_priority
static boolean checking_read_priority -
class_mon
-
async_check_queue
-
async_check_queue_sem
-
fully_async
private static final boolean fully_async -
disk_manager
-
async_checks
protected int async_checks -
async_check_sem
-
async_reads
protected int async_reads -
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
-
-
Constructor Details
-
DMCheckerImpl
-
-
Method Details
-
start
public void start() -
stop
public void stop() -
getCompleteRecheckStatus
public int getCompleteRecheckStatus()- Specified by:
getCompleteRecheckStatus
in interfaceDMChecker
-
getRecheckCancelled
public boolean getRecheckCancelled()- Specified by:
getRecheckCancelled
in interfaceDMChecker
-
setCheckingEnabled
public void setCheckingEnabled(boolean enabled) - Specified by:
setCheckingEnabled
in interfaceDMChecker
-
createCheckRequest
- Specified by:
createCheckRequest
in interfaceDMChecker
-
enqueueCompleteRecheckRequest
public void enqueueCompleteRecheckRequest(DiskManagerCheckRequest request, DiskManagerCheckRequestListener listener) - Specified by:
enqueueCompleteRecheckRequest
in interfaceDMChecker
-
enqueueCheckRequest
public void enqueueCheckRequest(DiskManagerCheckRequest request, DiskManagerCheckRequestListener listener) - Specified by:
enqueueCheckRequest
in interfaceDMChecker
-
hasOutstandingCheckRequestForPiece
public boolean hasOutstandingCheckRequestForPiece(int piece_number) - Specified by:
hasOutstandingCheckRequestForPiece
in interfaceDMChecker
-
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)
-