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

java.lang.Object
  org.gudy.azureus2.core3.disk.impl.access.impl.DMCheckerImpl

All Implemented Interfaces:

DMChecker

public class DMCheckerImpl
extends java.lang.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, 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)
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,
                                                  java.lang.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)