Class DMCheckerImpl
- java.lang.Object
-
- com.biglybt.core.disk.impl.access.impl.DMCheckerImpl
-
-
Field Summary
Fields Modifier and Type Field Description (package private) static java.util.List
async_check_queue
(package private) static AESemaphore
async_check_queue_sem
protected AESemaphore
async_check_sem
protected int
async_checks
protected AESemaphore
async_read_sem
protected int
async_reads
private boolean
checking_enabled
(package private) static boolean
checking_read_priority
(package private) static AEMonitor
class_mon
(package private) boolean
complete_recheck_in_progress
(package private) int
complete_recheck_progress
protected DiskManagerHelper
disk_manager
(package private) static boolean
flush_pieces
private static boolean
fully_async
protected static LogIDs
LOGID
private boolean
started
protected boolean
stopped
protected AEMonitor
this_mon
-
Constructor Summary
Constructors Constructor Description DMCheckerImpl(DiskManagerHelper _disk_manager)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description DiskManagerCheckRequest
createCheckRequest(int pieceNumber, java.lang.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
hasOutstandingCheckRequestForPiece(int piece_number)
void
setCheckingEnabled(boolean enabled)
void
start()
void
stop()
-
-
-
Field Detail
-
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 java.util.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
-
checking_enabled
private boolean checking_enabled
-
this_mon
protected final AEMonitor this_mon
-
-
Constructor Detail
-
DMCheckerImpl
public DMCheckerImpl(DiskManagerHelper _disk_manager)
-
-
Method Detail
-
getCompleteRecheckStatus
public int getCompleteRecheckStatus()
- Specified by:
getCompleteRecheckStatus
in interfaceDMChecker
-
setCheckingEnabled
public void setCheckingEnabled(boolean enabled)
- Specified by:
setCheckingEnabled
in interfaceDMChecker
-
createCheckRequest
public DiskManagerCheckRequest createCheckRequest(int pieceNumber, java.lang.Object user_data)
- 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)
-
-