org.gudy.azureus2.core3.disk.impl.access.impl
Class DMCheckerImpl

java.lang.Object
  extended by org.gudy.azureus2.core3.disk.impl.access.impl.DMCheckerImpl
All Implemented Interfaces:
DMChecker

public class DMCheckerImpl
extends Object
implements DMChecker

Author:
parg

Field Summary
protected  AESemaphore async_check_sem
           
protected  int async_checks
           
protected  AESemaphore async_read_sem
           
protected  int async_reads
           
protected  DiskManagerHelper disk_manager
           
protected static LogIDs LOGID
           
protected  boolean stopped
           
protected  AEMonitor this_mon
           
 
Constructor Summary
DMCheckerImpl(DiskManagerHelper _disk_manager)
           
 
Method Summary
 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)
           
 void enqueueCompleteRecheckRequest(DiskManagerCheckRequest request, DiskManagerCheckRequestListener listener)
           
 int getCompleteRecheckStatus()
           
 boolean hasOutstandingCheckRequestForPiece(int piece_number)
           
 void setCheckingEnabled(boolean enabled)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

LOGID

protected static final LogIDs LOGID

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

stopped

protected volatile boolean stopped

this_mon

protected final AEMonitor this_mon
Constructor Detail

DMCheckerImpl

public DMCheckerImpl(DiskManagerHelper _disk_manager)
Method Detail

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

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)