|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface DiskManager
Nested Class Summary | |
---|---|
static interface |
DiskManager.GettingThere
|
static interface |
DiskManager.OperationStatus
|
Field Summary | |
---|---|
static int |
ALLOCATING
|
static int |
BLOCK_SIZE
|
static int |
BLOCK_SIZE_KB
|
static int |
CHECKING
|
static int |
ET_INSUFFICIENT_SPACE
|
static int |
ET_NONE
|
static int |
ET_OTHER
|
static int |
FAULTY
|
static int |
INITIALIZING
|
static int |
READY
|
Method Summary | |
---|---|
void |
addListener(DiskManagerListener l)
|
boolean |
checkBlockConsistencyForHint(String originator,
int pieceNumber,
int offset,
int length)
|
boolean |
checkBlockConsistencyForRead(String originator,
boolean peer_request,
int pieceNumber,
int offset,
int length)
method for checking that the block details are sensible |
boolean |
checkBlockConsistencyForWrite(String originator,
int pieceNumber,
int offset,
DirectByteBuffer data)
method for checking that the block details are sensible |
DiskManagerCheckRequest |
createCheckRequest(int pieceNumber,
Object user_data)
Create a request to check a particular piece |
DiskManagerReadRequest |
createReadRequest(int pieceNumber,
int offset,
int length)
|
DiskManagerWriteRequest |
createWriteRequest(int pieceNumber,
int offset,
DirectByteBuffer data,
Object user_data)
|
void |
downloadEnded(DiskManager.OperationStatus op_status)
|
void |
downloadRemoved()
|
void |
enqueueCheckRequest(DiskManagerCheckRequest request,
DiskManagerCheckRequestListener listener)
enqueue an asynchronous single piece check |
void |
enqueueCompleteRecheckRequest(DiskManagerCheckRequest request,
DiskManagerCheckRequestListener listener)
recheck the entire torrent asynchronously, reporting each piece to the listener |
void |
enqueueReadRequest(DiskManagerReadRequest request,
DiskManagerReadRequestListener listener)
Enqueue an async disk read request. |
void |
enqueueWriteRequest(DiskManagerWriteRequest request,
DiskManagerWriteRequestListener listener)
enqueue an async write request |
boolean |
filesExist()
|
void |
generateEvidence(IndentWriter writer)
|
int |
getCacheMode()
|
int |
getCompleteRecheckStatus()
returns -1 if no recheck in progress, percentage complete in 1000 notation otherwise |
String |
getErrorMessage()
|
int |
getErrorType()
|
DiskManagerFileInfo[] |
getFiles()
|
DiskManagerFileInfoSet |
getFileSet()
|
int |
getMoveProgress()
When a download's data is moving (for completion or removal events) this gives the progress in 1000 notation. |
int |
getNbPieces()
|
int |
getPercentDone()
Get the percentage done during checking, allocation or initializing |
int |
getPercentDoneExcludingDND()
|
DiskManagerPiece |
getPiece(int PieceNumber)
|
int |
getPieceLength()
|
int |
getPieceLength(int piece_number)
|
DMPieceList |
getPieceList(int pieceNumber)
|
DMPieceMap |
getPieceMap()
DON'T CACHE the DMPieceMap - as it is designed to be discarded when not in use |
DiskManagerPiece[] |
getPieces()
|
long |
getPriorityChangeMarker()
|
long[] |
getReadStats()
|
long |
getRemaining()
Get remaining bytes to completion *including* DND files |
long |
getRemainingExcludingDND()
|
File |
getSaveLocation()
|
long |
getSizeExcludingDND()
|
int |
getState()
|
TOTorrent |
getTorrent()
|
long |
getTotalLength()
|
boolean |
hasListener(DiskManagerListener l)
|
boolean |
hasOutstandingCheckRequestForPiece(int piece_number)
|
boolean |
hasOutstandingReadRequestForPiece(int piece_number)
|
boolean |
hasOutstandingWriteRequestForPiece(int piece_number)
|
boolean |
isDone(int pieceNumber)
|
boolean |
isInteresting(int pieceNumber)
|
boolean |
isStopped()
|
void |
moveDataFiles(File new_parent_dir,
String dl_name,
DiskManager.OperationStatus op_status)
|
DirectByteBuffer |
readBlock(int pieceNumber,
int offset,
int length)
|
void |
removeListener(DiskManagerListener l)
|
void |
saveResumeData(boolean interim_save)
|
void |
saveState()
Save the individual file priorities map to DownloadManager.getData( "file_priorities" ). |
void |
setPieceCheckingEnabled(boolean enabled)
|
void |
start()
Start checking/allocating |
boolean |
stop(boolean closing)
Stop can go async if the download is in a 'starting' state - if so this method returns true |
Field Detail |
---|
static final int INITIALIZING
static final int ALLOCATING
static final int CHECKING
static final int READY
static final int FAULTY
static final int ET_NONE
static final int ET_OTHER
static final int ET_INSUFFICIENT_SPACE
static final int BLOCK_SIZE_KB
static final int BLOCK_SIZE
Method Detail |
---|
void start()
boolean stop(boolean closing)
closing
-
boolean isStopped()
boolean filesExist()
DirectByteBuffer readBlock(int pieceNumber, int offset, int length)
DiskManagerWriteRequest createWriteRequest(int pieceNumber, int offset, DirectByteBuffer data, Object user_data)
void enqueueWriteRequest(DiskManagerWriteRequest request, DiskManagerWriteRequestListener listener)
pieceNumber
- offset
- data
- user_data
- this will be provided to the listener when called backlistener
- boolean hasOutstandingWriteRequestForPiece(int piece_number)
DiskManagerReadRequest createReadRequest(int pieceNumber, int offset, int length)
void enqueueReadRequest(DiskManagerReadRequest request, DiskManagerReadRequestListener listener)
request
- listener
- boolean hasOutstandingReadRequestForPiece(int piece_number)
DiskManagerCheckRequest createCheckRequest(int pieceNumber, Object user_data)
pieceNumber
- -1 for a complete recheck requestuser_data
-
void enqueueCheckRequest(DiskManagerCheckRequest request, DiskManagerCheckRequestListener listener)
pieceNumber
- listener
- user_data
- boolean hasOutstandingCheckRequestForPiece(int piece_number)
void enqueueCompleteRecheckRequest(DiskManagerCheckRequest request, DiskManagerCheckRequestListener listener)
listener
- user_data
- void setPieceCheckingEnabled(boolean enabled)
void saveResumeData(boolean interim_save) throws Exception
Exception
DiskManagerPiece[] getPieces()
int getNbPieces()
DiskManagerFileInfo[] getFiles()
DiskManagerFileInfoSet getFileSet()
DiskManagerPiece getPiece(int PieceNumber)
DMPieceMap getPieceMap()
DMPieceList getPieceList(int pieceNumber)
int getState()
long getTotalLength()
int getPieceLength()
int getPieceLength(int piece_number)
long getRemaining()
long getRemainingExcludingDND()
int getPercentDone()
String getErrorMessage()
int getErrorType()
void downloadEnded(DiskManager.OperationStatus op_status)
void downloadRemoved()
void moveDataFiles(File new_parent_dir, String dl_name, DiskManager.OperationStatus op_status)
int getCompleteRecheckStatus()
int getMoveProgress()
boolean checkBlockConsistencyForWrite(String originator, int pieceNumber, int offset, DirectByteBuffer data)
pieceNumber
- offset
- data
-
boolean checkBlockConsistencyForRead(String originator, boolean peer_request, int pieceNumber, int offset, int length)
pieceNumber
- offset
- length
-
boolean checkBlockConsistencyForHint(String originator, int pieceNumber, int offset, int length)
TOTorrent getTorrent()
File getSaveLocation()
void addListener(DiskManagerListener l)
void removeListener(DiskManagerListener l)
boolean hasListener(DiskManagerListener l)
void saveState()
boolean isInteresting(int pieceNumber)
pieceNumber
-
boolean isDone(int pieceNumber)
int getCacheMode()
long[] getReadStats()
void generateEvidence(IndentWriter writer)
long getSizeExcludingDND()
int getPercentDoneExcludingDND()
long getPriorityChangeMarker()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |