Class DiskManagerImpl

java.lang.Object

com.biglybt.core.logging.LogRelation

com.biglybt.core.disk.impl.DiskManagerImpl

All Implemented Interfaces:

DiskManager, DiskManagerHelper, DiskManagerUtil.MoveTaskAapter

public class DiskManagerImpl
extends LogRelation
implements DiskManagerHelper, DiskManagerUtil.MoveTaskAapter

The disk Wrapper.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	DiskManagerImpl.DownloadEndedProgressImpl

Nested classes/interfaces inherited from interface DiskManager

DiskManager.DownloadEndedProgress

Field Summary

Fields

Modifier and Type	Field	Description
private long	allocate_not_required
private long	allocated
private static final DiskManagerAllocationScheduler	allocation_scheduler
private String	allocation_task
private boolean	alreadyMoved
private final BitFlags	availability
private DMChecker	checker
private boolean	checking_enabled
private static final DiskAccessController	disk_access_controller
private static final int	DM_FREE_PIECELIST_TIMEOUT
protected final DownloadManager	download_manager
(package private) static boolean	enable_sparse_files
private String	errorMessage_set_via_method
private int	errorType
private final Object	file_piece_lock
private DiskManagerFileInfoImpl[]	files
private DiskManagerFileInfoSet	fileset
long	garbage
private int	lastPieceLength
private static final int	LDT_FILE_COMPLETED
private static final int	LDT_PIECE_DONE_CHANGED
private static final int	LDT_PRIO_CHANGED
private static final int	LDT_STATE_CHANGED
private final ListenerManager<DiskManagerListener>	listeners
protected static final ListenerManager<DiskManagerListener>	listeners_aggregator
private static final LogIDs	LOGID
(package private) static boolean	missing_file_dl_restart_enabled
private boolean	move_in_progress
private long[]	move_progress
private int	move_state
private File	move_subtask
private int	nbPieces
private int	percentDone
private DMPieceMap	piece_map_use_accessor
private long	piece_map_use_accessor_time
private DMPieceMapper	piece_mapper
private int	pieceLength
private DiskManagerPieceImpl[]	pieces
private final AtomicLong	priority_change_marker
private DMReader	reader
private static final DiskManagerRecheckScheduler	recheck_scheduler
private long	remaining
private long	remaining_excluding_dnd
(package private) static boolean	reorder_storage_mode
(package private) static int	reorder_storage_mode_min_mb
private RDResumeHandler	resume_handler
(package private) static boolean	skip_comp_dl_file_checks
(package private) static boolean	skip_incomp_dl_file_checks
private long	skipped_but_downloaded
private boolean	skipped_file_set_changed
private long	skipped_file_set_size
(package private) static boolean	sparse_files_dont_preallocate
private static final ThreadPool<AERunnable>	start_pool
(package private) final AEMonitor	start_stop_mon
private boolean	started
(package private) final AESemaphore	started_sem
private boolean	starting
private int	state_set_via_method
private boolean	stopping
(package private) static boolean	switch_to_upload_only_enable
private boolean	switched_to_upload_only
private final TOTorrent	torrent
private long	totalLength
private boolean	used
private DMWriter	writer

Fields inherited from interface DiskManager

ALLOCATING, BLOCK_SIZE, BLOCK_SIZE_KB, CHECKING, ET_FILE_MISSING, ET_INSUFFICIENT_SPACE, ET_NONE, ET_OTHER, ET_READ_ERROR, ET_STOP_DURING_INIT, ET_WRITE_ERROR, FAULTY, INITIALIZING, READY, SNAPSHOT

Constructor Summary

Constructors

Constructor	Description
DiskManagerImpl(TOTorrent _torrent, DownloadManager _dmanager)

Method Summary

Modifier and Type	Method	Description
void	addListener(DiskManagerListener l)
private boolean	allocateFile(DiskManagerAllocationScheduler.AllocationInstance allocation_instance, DiskManagerFileInfoImpl fileInfo, File data_file, long existing_length, long target_length, boolean[] stop_after_start, long alloc_strategy)
private int[]	allocateFiles(Map<DiskManagerFileInfo, Long> file_sizes, boolean[] stop_after_start)
private boolean	canFailureBeIgnored(Throwable cause)
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
void	checkFreePieceList(boolean force_discard)
private static int	countDataFiles(DownloadManager dm, TOTorrent torrent, String torrent_save_dir, String torrent_save_file)
private static int	countFiles(File f, int stopAfterCount)
DiskManagerCheckRequest	createCheckRequest(int pieceNumber, Object user_data)	Create a request to check a particular piece
private DiskManagerFileInfoImpl	createFileInfo(DownloadManagerState state, DMPieceMapperFile pm_info, int file_index, File root_dir, StringInterner.FileKey relative_file, int storage_type)
DiskManagerReadRequest	createReadRequest(int pieceNumber, int offset, int length)
DiskManagerWriteRequest	createWriteRequest(int pieceNumber, int offset, DirectByteBuffer data, Object user_data)
private static void	deleteDataFileContents(DownloadManager dm, TOTorrent torrent, String torrent_save_dir, String torrent_save_file, boolean force_no_recycle)
static void	deleteDataFiles(DownloadManager dm, TOTorrent torrent, String torrent_save_dir, String torrent_save_file, boolean force_no_recycle)	Deletes all data files associated with torrent.
DiskManager.DownloadEndedProgress	downloadEnded(boolean start_of_day)
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
private void	fileAllocFailed(File file, long length, boolean is_new, Throwable e)
boolean	filesExist()
protected boolean	filesExist(File root_dir, boolean exact)
private void	fixupSkippedCalculation()
void	generateEvidence(IndentWriter writer)
String	getAllocationTask()
BitFlags	getAvailability()
int	getCacheMode()
int	getCompleteRecheckStatus()	returns -1 if no recheck in progress, percentage complete in 1000 notation otherwise
static DiskAccessController	getDefaultDiskAccessController()
DiskAccessController	getDiskAccessController()
String	getDisplayName()
DownloadManager	getDownload()
DownloadManager	getDownloadManager()
DownloadManagerState	getDownloadState()
String	getErrorMessage()
int	getErrorType()
DiskManagerFileInfo[]	getFiles()
DiskManagerFileInfoSet	getFileSet()
String	getInternalName()
int	getLastPieceLength()
long[]	getLatency()
long[]	getMoveProgress()	When a download's data is moving (for completion or removal events) this gives the [progress in 1000 notation,total_size] null if nothing's going on
String	getMoveSubTask()
int	getNbPieces()
int	getPercentAllocated()
int	getPercentDone()	Get the percentage done during checking, allocation or initializing
int	getPercentDoneExcludingDND()
DiskManagerPiece	getPiece(int PieceNumber)
byte[]	getPieceHash(int piece_number)
int	getPieceLength()
int	getPieceLength(int piece_number)
DMPieceList	getPieceList(int piece_number)
DMPieceMap	getPieceMap()	DON'T CACHE the DMPieceMap - as it is designed to be discarded when not in use
DiskManagerPiece[]	getPieces()
long	getPriorityChangeMarker()
Object[]	getQueryableInterfaces()	Query this class for a reference to another class that it may hold
long[]	getReadStats()
boolean	getRecheckCancelled()
DiskManagerRecheckScheduler	getRecheckScheduler()
String	getRelationText()	A short description of what your class holds that can be printed by the logger
long	getRemaining()	Get remaining bytes to completion *including* DND files
long	getRemainingExcludingDND()
File	getSaveLocation()
long	getSizeExcludingDND()
int	getState()
String	getStorageType(int fileIndex)	Returns the storage type for file at fileIndex.
static String	getStorageType(DownloadManager download_manager, int fileIndex)	Returns the storage type for a DownloadManager's file at fileIndex.
String[]	getStorageTypes()	Returns the storage type for all files.
static String[]	getStorageTypes(DownloadManager download_manager)	Returns the storage type for each file in DownloadManager.
TOTorrent	getTorrent()
long	getTotalLength()
long[]	getWriteStats()
boolean	hasListener(DiskManagerListener l)
boolean	hasOutstandingCheckRequestForPiece(int piece_number)
boolean	hasOutstandingReadRequestForPiece(int piece_number)
boolean	hasOutstandingWriteRequestForPiece(int piece_number)
boolean	isDone(int pieceNumber)
private boolean	isFileDestinationIsItself(SaveLocationChange loc_change)
boolean	isInteresting(int pieceNumber)
boolean	isStopped()
boolean	isUploadOnly()
private void	logMoveFileError(File destination_path, String message)
void	moveDataFiles(File new_parent_dir, String new_name)
private boolean	moveDataFiles0(SaveLocationChange loc_change, boolean change_to_read_only)
private void	moveDownloadFilesWhenEndedOrRemoved(boolean removing, boolean torrent_file_exists, DiskManagerImpl.DownloadEndedProgressImpl progress, boolean start_of_day)
private void	moveDownloadFilesWhenEndedOrRemoved0(SaveLocationChange loc_change, DiskManagerImpl.DownloadEndedProgressImpl progress)
protected void	moveFiles(SaveLocationChange loc_change, boolean change_to_read_only)
private void	moveTorrentFile(SaveLocationChange loc_change)
void	priorityChanged(DiskManagerFileInfo file)
void	rateLimitChanged()
DirectByteBuffer	readBlock(int pieceNumber, int offset, int length)
void	removeListener(DiskManagerListener l)
void	saveResumeData(boolean interim_save)
void	saveState(boolean interim)	Save the individual file priorities map to DownloadManager.getData( "file_priorities" ).
protected void	saveStateSupport(boolean persist, boolean interim)
private void	setErrorMessage(long file_length, Throwable e, String str)
private void	setErrorMessage(String str)
private void	setErrorMessage(Throwable e, String str)
private void	setErrorState()
private void	setErrorState(int type)
private void	setErrorState(int type, String msg)
private void	setErrorState(int type, String msg, Throwable cause)
private void	setErrorState(String msg)
void	setFailed(int type, String reason, Throwable cause, boolean can_continue)	Stops the disk manager and informs the download manager that things have gone wrong.
void	setFailedAndRecheck(DiskManagerFileInfo file, String reason)
void	setMoveState(int state)
void	setPieceCheckingEnabled(boolean enabled)
void	setPieceDone(DiskManagerPieceImpl dmPiece, boolean done)	Called when status has CHANGED and should only be called by DiskManagerPieceImpl
private void	setState(int _state)
void	skippedFileSetChanged(DiskManagerFileInfo file)
void	start()	Start checking/allocating
(package private) void	startSupport()
boolean	stop(boolean closing)	Stop can go async if the download is in a 'starting' state - if so this method returns true
void	storageTypeChanged(DiskManagerFileInfo file)
protected static void	storeFileDownloaded(DownloadManager download_manager, DiskManagerFileInfo[] files, boolean persist, boolean interim)
protected void	storeFilePriorities()
protected static void	storeFilePriorities(DownloadManager download_manager, DiskManagerFileInfo[] files)

Methods inherited from class LogRelation

propogatedRelationText, queryForClass

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DM_FREE_PIECELIST_TIMEOUT

private static final int DM_FREE_PIECELIST_TIMEOUT

See Also:

• Constant Field Values

LOGID

private static final LogIDs LOGID

disk_access_controller

private static final DiskAccessController disk_access_controller

reorder_storage_mode

static boolean reorder_storage_mode

reorder_storage_mode_min_mb

static int reorder_storage_mode_min_mb

missing_file_dl_restart_enabled

static volatile boolean missing_file_dl_restart_enabled

skip_incomp_dl_file_checks

static boolean skip_incomp_dl_file_checks

skip_comp_dl_file_checks

static boolean skip_comp_dl_file_checks

switch_to_upload_only_enable

static boolean switch_to_upload_only_enable

enable_sparse_files

static boolean enable_sparse_files

sparse_files_dont_preallocate

static boolean sparse_files_dont_preallocate

recheck_scheduler

private static final DiskManagerRecheckScheduler recheck_scheduler

allocation_scheduler

private static final DiskManagerAllocationScheduler allocation_scheduler

start_pool

private static final ThreadPool<AERunnable> start_pool

used

private boolean used

started

private boolean started

started_sem

final AESemaphore started_sem

starting

private boolean starting

stopping

private volatile boolean stopping

state_set_via_method

private volatile int state_set_via_method

errorMessage_set_via_method

private volatile String errorMessage_set_via_method

errorType

private volatile int errorType

pieceLength

private int pieceLength

lastPieceLength

private int lastPieceLength

nbPieces

private int nbPieces

totalLength

private long totalLength

percentDone

private int percentDone

allocated

private long allocated

allocate_not_required

private long allocate_not_required

remaining

private long remaining

allocation_task

private volatile String allocation_task

remaining_excluding_dnd

private volatile long remaining_excluding_dnd

torrent

private final TOTorrent torrent

reader

private DMReader reader

checker

private DMChecker checker

writer

private DMWriter writer

resume_handler

private RDResumeHandler resume_handler

piece_mapper

private DMPieceMapper piece_mapper

pieces

private DiskManagerPieceImpl[] pieces

piece_map_use_accessor

private DMPieceMap piece_map_use_accessor

piece_map_use_accessor_time

private long piece_map_use_accessor_time

files

private DiskManagerFileInfoImpl[] files

fileset

private DiskManagerFileInfoSet fileset

download_manager

protected final DownloadManager download_manager

alreadyMoved

private boolean alreadyMoved

skipped_file_set_changed

private boolean skipped_file_set_changed

skipped_file_set_size

private long skipped_file_set_size

skipped_but_downloaded

private long skipped_but_downloaded

priority_change_marker

private final AtomicLong priority_change_marker

checking_enabled

private boolean checking_enabled

move_in_progress

private volatile boolean move_in_progress

move_progress

private volatile long[] move_progress

move_subtask

private volatile File move_subtask

move_state

private volatile int move_state

LDT_STATE_CHANGED

private static final int LDT_STATE_CHANGED

See Also:

• Constant Field Values

LDT_PRIO_CHANGED

private static final int LDT_PRIO_CHANGED

See Also:

• Constant Field Values

LDT_PIECE_DONE_CHANGED

private static final int LDT_PIECE_DONE_CHANGED

See Also:

• Constant Field Values

LDT_FILE_COMPLETED

private static final int LDT_FILE_COMPLETED

See Also:

• Constant Field Values

listeners_aggregator

protected static final ListenerManager<DiskManagerListener> listeners_aggregator

listeners

private final ListenerManager<DiskManagerListener> listeners

start_stop_mon

final AEMonitor start_stop_mon

file_piece_lock

private final Object file_piece_lock

availability

private final BitFlags availability

switched_to_upload_only

private volatile boolean switched_to_upload_only

garbage

public long garbage

Constructor Details

DiskManagerImpl

public DiskManagerImpl(TOTorrent _torrent,
 DownloadManager _dmanager)

Method Details

getDefaultDiskAccessController

public static DiskAccessController getDefaultDiskAccessController()

getDisplayName

public String getDisplayName()

Specified by:

getDisplayName in interface DiskManagerHelper

getDownload

public DownloadManager getDownload()

Specified by:

getDownload in interface DiskManager

Returns:

MAY BE NULL

start

public void start()

Description copied from interface: DiskManager

Start checking/allocating

Specified by:

start in interface DiskManager

startSupport

void startSupport()

stop

public boolean stop(boolean closing)

Description copied from interface: DiskManager

Stop can go async if the download is in a 'starting' state - if so this method returns true

Specified by:

stop in interface DiskManager

Parameters:

closing -

Returns:

isStopped

public boolean isStopped()

Specified by:

isStopped in interface DiskManager

filesExist

public boolean filesExist()

Specified by:

filesExist in interface DiskManager

Returns:

whether all files exist and sizes match

filesExist

protected boolean filesExist(File root_dir,
 boolean exact)

createFileInfo

private DiskManagerFileInfoImpl createFileInfo(DownloadManagerState state,
 DMPieceMapperFile pm_info,
 int file_index,
 File root_dir,
 StringInterner.FileKey relative_file,
 int storage_type)
                                        throws CacheFileManagerException

Throws:

CacheFileManagerException

allocateFiles

private int[] allocateFiles(Map<DiskManagerFileInfo, Long> file_sizes,
 boolean[] stop_after_start)

allocateFile

private boolean allocateFile(DiskManagerAllocationScheduler.AllocationInstance allocation_instance,
 DiskManagerFileInfoImpl fileInfo,
 File data_file,
 long existing_length,
 long target_length,
 boolean[] stop_after_start,
 long alloc_strategy)
                      throws Throwable

Throws:

Throwable

fileAllocFailed

private void fileAllocFailed(File file,
 long length,
 boolean is_new,
 Throwable e)

getDiskAccessController

public DiskAccessController getDiskAccessController()

Specified by:

getDiskAccessController in interface DiskManagerHelper

enqueueReadRequest

public void enqueueReadRequest(DiskManagerReadRequest request,
 DiskManagerReadRequestListener listener)

Description copied from interface: DiskManager

Enqueue an async disk read request.

Specified by:

enqueueReadRequest in interface DiskManager

Parameters:

request -

listener -

hasOutstandingReadRequestForPiece

public boolean hasOutstandingReadRequestForPiece(int piece_number)

Specified by:

hasOutstandingReadRequestForPiece in interface DiskManager

getNbPieces

public int getNbPieces()

Specified by:

getNbPieces in interface DiskManager

getPercentDone

public int getPercentDone()

Description copied from interface: DiskManager

Get the percentage done during checking, allocation or initializing

Specified by:

getPercentDone in interface DiskManager

Returns:

percent done * 1000 (1000 = 100%)

getPercentAllocated

public int getPercentAllocated()

Specified by:

getPercentAllocated in interface DiskManager

getLatency

public long[] getLatency()

Specified by:

getLatency in interface DiskManager

getAllocationTask

public String getAllocationTask()

Specified by:

getAllocationTask in interface DiskManager

getRemaining

public long getRemaining()

Description copied from interface: DiskManager

Get remaining bytes to completion *including* DND files

Specified by:

getRemaining in interface DiskManager

fixupSkippedCalculation

private void fixupSkippedCalculation()

getRemainingExcludingDND

public long getRemainingExcludingDND()

Specified by:

getRemainingExcludingDND in interface DiskManager

getSizeExcludingDND

public long getSizeExcludingDND()

Specified by:

getSizeExcludingDND in interface DiskManager

getPercentDoneExcludingDND

public int getPercentDoneExcludingDND()

Specified by:

getPercentDoneExcludingDND in interface DiskManager

setPieceDone

public void setPieceDone(DiskManagerPieceImpl dmPiece,
 boolean done)

Called when status has CHANGED and should only be called by DiskManagerPieceImpl

Specified by:

setPieceDone in interface DiskManagerHelper

getAvailability

public BitFlags getAvailability()

Specified by:

getAvailability in interface DiskManager

getPieces

public DiskManagerPiece[] getPieces()

Specified by:

getPieces in interface DiskManager

getPiece

public DiskManagerPiece getPiece(int PieceNumber)

Specified by:

getPiece in interface DiskManager

getPieceLength

public int getPieceLength()

Specified by:

getPieceLength in interface DiskManager

getPieceLength

public int getPieceLength(int piece_number)

Specified by:

getPieceLength in interface DiskManager

getTotalLength

public long getTotalLength()

Specified by:

getTotalLength in interface DiskManager

getLastPieceLength

public int getLastPieceLength()

getState

public int getState()

Specified by:

getState in interface DiskManager

setErrorMessage

private void setErrorMessage(String str)

setErrorMessage

private void setErrorMessage(Throwable e,
 String str)

setErrorMessage

private void setErrorMessage(long file_length,
 Throwable e,
 String str)

setErrorState

private void setErrorState()

setErrorState

private void setErrorState(String msg)

setErrorState

private void setErrorState(int type,
 String msg)

setErrorState

private void setErrorState(int type,
 String msg,
 Throwable cause)

setErrorState

private void setErrorState(int type)

setState

private void setState(int _state)

getFiles

public DiskManagerFileInfo[] getFiles()

Specified by:

getFiles in interface DiskManager

getFileSet

public DiskManagerFileInfoSet getFileSet()

Specified by:

getFileSet in interface DiskManager

getErrorMessage

public String getErrorMessage()

Specified by:

getErrorMessage in interface DiskManager

getErrorType

public int getErrorType()

Specified by:

getErrorType in interface DiskManager

canFailureBeIgnored

private boolean canFailureBeIgnored(Throwable cause)

isUploadOnly

public boolean isUploadOnly()

Specified by:

isUploadOnly in interface DiskManagerHelper

rateLimitChanged

public void rateLimitChanged()

Specified by:

rateLimitChanged in interface DiskManager

setFailed

public void setFailed(int type,
 String reason,
 Throwable cause,
 boolean can_continue)

Description copied from interface: DiskManagerHelper

Stops the disk manager and informs the download manager that things have gone wrong.

Specified by:

setFailed in interface DiskManagerHelper

Parameters:

reason -

setFailedAndRecheck

public void setFailedAndRecheck(DiskManagerFileInfo file,
 String reason)

Specified by:

setFailedAndRecheck in interface DiskManagerHelper

getCacheMode

public int getCacheMode()

Specified by:

getCacheMode in interface DiskManager

getReadStats

public long[] getReadStats()

Specified by:

getReadStats in interface DiskManager

getWriteStats

public long[] getWriteStats()

Specified by:

getWriteStats in interface DiskManager

getPieceMap

public DMPieceMap getPieceMap()

Description copied from interface: DiskManager

DON'T CACHE the DMPieceMap - as it is designed to be discarded when not in use

Specified by:

getPieceMap in interface DiskManager

Returns:

getPieceList

public DMPieceList getPieceList(int piece_number)

Specified by:

getPieceList in interface DiskManager

Specified by:

getPieceList in interface DiskManagerHelper

checkFreePieceList

public void checkFreePieceList(boolean force_discard)

getPieceHash

public byte[] getPieceHash(int piece_number)
                    throws TOTorrentException

Specified by:

getPieceHash in interface DiskManagerHelper

Throws:

TOTorrentException

createReadRequest

public DiskManagerReadRequest createReadRequest(int pieceNumber,
 int offset,
 int length)

Specified by:

createReadRequest in interface DiskManager

createCheckRequest

public DiskManagerCheckRequest createCheckRequest(int pieceNumber,
 Object user_data)

Description copied from interface: DiskManager

Create a request to check a particular piece

Specified by:

createCheckRequest in interface DiskManager

Parameters:

pieceNumber - -1 for a complete recheck request

user_data -

Returns:

hasOutstandingCheckRequestForPiece

public boolean hasOutstandingCheckRequestForPiece(int piece_number)

Specified by:

hasOutstandingCheckRequestForPiece in interface DiskManager

enqueueCompleteRecheckRequest

public void enqueueCompleteRecheckRequest(DiskManagerCheckRequest request,
 DiskManagerCheckRequestListener listener)

Description copied from interface: DiskManager

recheck the entire torrent asynchronously, reporting each piece to the listener

Specified by:

enqueueCompleteRecheckRequest in interface DiskManager

Parameters:

listener -

enqueueCheckRequest

public void enqueueCheckRequest(DiskManagerCheckRequest request,
 DiskManagerCheckRequestListener listener)

Description copied from interface: DiskManager

enqueue an asynchronous single piece check

Specified by:

enqueueCheckRequest in interface DiskManager

Parameters:

listener -

getCompleteRecheckStatus

public int getCompleteRecheckStatus()

Description copied from interface: DiskManager

returns -1 if no recheck in progress, percentage complete in 1000 notation otherwise

Specified by:

getCompleteRecheckStatus in interface DiskManager

Returns:

getRecheckCancelled

public boolean getRecheckCancelled()

Specified by:

getRecheckCancelled in interface DiskManager

getMoveProgress

public long[] getMoveProgress()

Description copied from interface: DiskManager

When a download's data is moving (for completion or removal events) this gives the [progress in 1000 notation,total_size] null if nothing's going on

Specified by:

getMoveProgress in interface DiskManager

Specified by:

getMoveProgress in interface DiskManagerUtil.MoveTaskAapter

Returns:

getMoveSubTask

public String getMoveSubTask()

Specified by:

getMoveSubTask in interface DiskManager

Specified by:

getMoveSubTask in interface DiskManagerUtil.MoveTaskAapter

setMoveState

public void setMoveState(int state)

Specified by:

setMoveState in interface DiskManager

Specified by:

setMoveState in interface DiskManagerUtil.MoveTaskAapter

setPieceCheckingEnabled

public void setPieceCheckingEnabled(boolean enabled)

Specified by:

setPieceCheckingEnabled in interface DiskManager

readBlock

public DirectByteBuffer readBlock(int pieceNumber,
 int offset,
 int length)

Specified by:

readBlock in interface DiskManager

createWriteRequest

public DiskManagerWriteRequest createWriteRequest(int pieceNumber,
 int offset,
 DirectByteBuffer data,
 Object user_data)

Specified by:

createWriteRequest in interface DiskManager

enqueueWriteRequest

public void enqueueWriteRequest(DiskManagerWriteRequest request,
 DiskManagerWriteRequestListener listener)

Description copied from interface: DiskManager

enqueue an async write request

Specified by:

enqueueWriteRequest in interface DiskManager

Parameters:

listener -

hasOutstandingWriteRequestForPiece

public boolean hasOutstandingWriteRequestForPiece(int piece_number)

Specified by:

hasOutstandingWriteRequestForPiece in interface DiskManager

checkBlockConsistencyForWrite

public boolean checkBlockConsistencyForWrite(String originator,
 int pieceNumber,
 int offset,
 DirectByteBuffer data)

Description copied from interface: DiskManager

method for checking that the block details are sensible

Specified by:

checkBlockConsistencyForWrite in interface DiskManager

Parameters:

pieceNumber -

offset -

data -

Returns:

checkBlockConsistencyForRead

public boolean checkBlockConsistencyForRead(String originator,
 boolean peer_request,
 int pieceNumber,
 int offset,
 int length)

Description copied from interface: DiskManager

method for checking that the block details are sensible

Specified by:

checkBlockConsistencyForRead in interface DiskManager

Parameters:

pieceNumber -

offset -

length -

Returns:

checkBlockConsistencyForHint

public boolean checkBlockConsistencyForHint(String originator,
 int pieceNumber,
 int offset,
 int length)

Specified by:

checkBlockConsistencyForHint in interface DiskManager

saveResumeData

public void saveResumeData(boolean interim_save)
                    throws Exception

Specified by:

saveResumeData in interface DiskManager

Throws:

Exception

downloadEnded

public DiskManager.DownloadEndedProgress downloadEnded(boolean start_of_day)

Specified by:

downloadEnded in interface DiskManager

downloadRemoved

public void downloadRemoved()

Specified by:

downloadRemoved in interface DiskManager

moveDownloadFilesWhenEndedOrRemoved

private void moveDownloadFilesWhenEndedOrRemoved(boolean removing,
 boolean torrent_file_exists,
 DiskManagerImpl.DownloadEndedProgressImpl progress,
 boolean start_of_day)

moveDownloadFilesWhenEndedOrRemoved0

private void moveDownloadFilesWhenEndedOrRemoved0(SaveLocationChange loc_change,
 DiskManagerImpl.DownloadEndedProgressImpl progress)

moveDataFiles

public void moveDataFiles(File new_parent_dir,
 String new_name)

Specified by:

moveDataFiles in interface DiskManager

moveFiles

protected void moveFiles(SaveLocationChange loc_change,
 boolean change_to_read_only)

logMoveFileError

private void logMoveFileError(File destination_path,
 String message)

isFileDestinationIsItself

private boolean isFileDestinationIsItself(SaveLocationChange loc_change)

moveDataFiles0

private boolean moveDataFiles0(SaveLocationChange loc_change,
 boolean change_to_read_only)
                        throws Exception

Throws:

Exception

moveTorrentFile

private void moveTorrentFile(SaveLocationChange loc_change)

getTorrent

public TOTorrent getTorrent()

Specified by:

getTorrent in interface DiskManager

Specified by:

getTorrent in interface DiskManagerHelper

addListener

public void addListener(DiskManagerListener l)

Specified by:

addListener in interface DiskManager

removeListener

public void removeListener(DiskManagerListener l)

Specified by:

removeListener in interface DiskManager

hasListener

public boolean hasListener(DiskManagerListener l)

Specified by:

hasListener in interface DiskManager

deleteDataFiles

public static void deleteDataFiles(DownloadManager dm,
 TOTorrent torrent,
 String torrent_save_dir,
 String torrent_save_file,
 boolean force_no_recycle)

Deletes all data files associated with torrent. Currently, deletes all files, then tries to delete the path recursively if the paths are empty. An unexpected result may be that a empty directory that the user created will be removed. TODO: only remove empty directories that are created for the torrent

countFiles

private static int countFiles(File f,
 int stopAfterCount)

countDataFiles

private static int countDataFiles(DownloadManager dm,
 TOTorrent torrent,
 String torrent_save_dir,
 String torrent_save_file)

deleteDataFileContents

private static void deleteDataFileContents(DownloadManager dm,
 TOTorrent torrent,
 String torrent_save_dir,
 String torrent_save_file,
 boolean force_no_recycle)
                                    throws TOTorrentException,
UnsupportedEncodingException,
LocaleUtilEncodingException

Throws:

TOTorrentException

UnsupportedEncodingException

LocaleUtilEncodingException

skippedFileSetChanged

public void skippedFileSetChanged(DiskManagerFileInfo file)

Specified by:

skippedFileSetChanged in interface DiskManagerHelper

priorityChanged

public void priorityChanged(DiskManagerFileInfo file)

Specified by:

priorityChanged in interface DiskManagerHelper

storageTypeChanged

public void storageTypeChanged(DiskManagerFileInfo file)

Specified by:

storageTypeChanged in interface DiskManagerHelper

storeFilePriorities

protected void storeFilePriorities()

storeFilePriorities

protected static void storeFilePriorities(DownloadManager download_manager,
 DiskManagerFileInfo[] files)

storeFileDownloaded

protected static void storeFileDownloaded(DownloadManager download_manager,
 DiskManagerFileInfo[] files,
 boolean persist,
 boolean interim)

saveState

public void saveState(boolean interim)

Description copied from interface: DiskManager

Save the individual file priorities map to DownloadManager.getData( "file_priorities" ).

Specified by:

saveState in interface DiskManager

saveStateSupport

protected void saveStateSupport(boolean persist,
 boolean interim)

getDownloadManager

public DownloadManager getDownloadManager()

getInternalName

public String getInternalName()

Specified by:

getInternalName in interface DiskManagerHelper

getDownloadState

public DownloadManagerState getDownloadState()

Specified by:

getDownloadState in interface DiskManagerHelper

getSaveLocation

public File getSaveLocation()

Specified by:

getSaveLocation in interface DiskManager

getStorageTypes

public String[] getStorageTypes()

Description copied from interface: DiskManagerHelper

Returns the storage type for all files.

According to DiskManagerUtil.convertDMStorageTypeFromString(String), values are:
"R" DiskManagerFileInfo.ST_REORDER
"L" DiskManagerFileInfo.ST_LINEAR
"C" DiskManagerFileInfo.ST_COMPACT
"X" DiskManagerFileInfo.ST_REORDER_COMPACT

Specified by:

getStorageTypes in interface DiskManagerHelper

getStorageType

public String getStorageType(int fileIndex)

Description copied from interface: DiskManagerHelper

Returns the storage type for file at fileIndex.

According to DiskManagerUtil.convertDMStorageTypeFromString(String), values are:
"R" DiskManagerFileInfo.ST_REORDER
"L" DiskManagerFileInfo.ST_LINEAR
"C" DiskManagerFileInfo.ST_COMPACT
"X" DiskManagerFileInfo.ST_REORDER_COMPACT

Specified by:

getStorageType in interface DiskManagerHelper

getStorageTypes

public static String[] getStorageTypes(DownloadManager download_manager)

Returns the storage type for each file in DownloadManager.

According to DiskManagerUtil.convertDMStorageTypeFromString(String), String values are:
"R" DiskManagerFileInfo.ST_REORDER
"L" DiskManagerFileInfo.ST_LINEAR
"C" DiskManagerFileInfo.ST_COMPACT
"X" DiskManagerFileInfo.ST_REORDER_COMPACT

getStorageType

public static String getStorageType(DownloadManager download_manager,
 int fileIndex)

Returns the storage type for a DownloadManager's file at fileIndex.

According to DiskManagerUtil.convertDMStorageTypeFromString(String), values are:
"R" DiskManagerFileInfo.ST_REORDER
"L" DiskManagerFileInfo.ST_LINEAR
"C" DiskManagerFileInfo.ST_COMPACT
"X" DiskManagerFileInfo.ST_REORDER_COMPACT

getRelationText

public String getRelationText()

Description copied from class: LogRelation

A short description of what your class holds that can be printed by the logger

Overrides:

getRelationText in class LogRelation

Returns:

getQueryableInterfaces

public Object[] getQueryableInterfaces()

Description copied from class: LogRelation

Query this class for a reference to another class that it may hold

Overrides:

getQueryableInterfaces in class LogRelation

Returns:

If found, the class desired. Otherwise, null.

getRecheckScheduler

public DiskManagerRecheckScheduler getRecheckScheduler()

Specified by:

getRecheckScheduler in interface DiskManagerHelper

isInteresting

public boolean isInteresting(int pieceNumber)

Specified by:

isInteresting in interface DiskManager

Parameters:

pieceNumber -

Returns:

true if the pieceNumber is Needed and not Done

isDone

public boolean isDone(int pieceNumber)

Specified by:

isDone in interface DiskManager

getPriorityChangeMarker

public long getPriorityChangeMarker()

Specified by:

getPriorityChangeMarker in interface DiskManager

generateEvidence

public void generateEvidence(IndentWriter writer)

Specified by:

generateEvidence in interface DiskManager