Class DiskManagerFileInfoImpl

java.lang.Object

com.biglybt.core.disk.impl.DiskManagerFileInfoImpl

All Implemented Interfaces:

DiskManagerFileInfo, CacheFileOwner

public class DiskManagerFileInfoImpl
extends Object
implements DiskManagerFileInfo, CacheFileOwner

Field Summary

Fields

Modifier and Type	Field	Description
(package private) CacheFile	cache_file
(package private) final DiskManagerHelper	diskManager
private long	downloaded
private static final AverageFactory.LazyMovingImmediateAverageAdapter<DiskManagerFileInfoImpl>	eta_adapter
(package private) AverageFactory.LazyMovingImmediateAverageState	eta_average_state
private String	extension
(package private) final int	file_index
private String	last_error
private CopyOnWriteList<DiskManagerFileInfoListener>	listeners
private int	priority
private static final AverageFactory.LazyMovingImmediateAverageAdapter<DiskManagerFileInfoImpl>	read_adapter
(package private) AverageFactory.LazyMovingImmediateAverageState	read_average_state
private final StringInterner.FileKey	relative_file
private File	root_dir
protected boolean	skipped_internal
private Boolean	skipping
(package private) final TOTorrentFile	torrent_file
private static final AverageFactory.LazyMovingImmediateAverageAdapter<DiskManagerFileInfoImpl>	write_adapter
(package private) AverageFactory.LazyMovingImmediateAverageState	write_average_state

Fields inherited from interface CacheFileOwner

CACHE_MODE_EXPERIMENTAL, CACHE_MODE_NO_CACHE, CACHE_MODE_NORMAL

Fields inherited from interface DiskManagerFileInfo

READ, ST_COMPACT, ST_LINEAR, ST_REORDER, ST_REORDER_COMPACT, WRITE

Constructor Summary

Constructors

Constructor	Description
DiskManagerFileInfoImpl(DiskManagerHelper _disk_manager, File _root_dir, StringInterner.FileKey _relative_file, int _file_index, TOTorrentFile _torrent_file, int _storage_type)

Method Summary

Modifier and Type	Method	Description
void	addListener(DiskManagerFileInfoListener listener)
void	close()
void	dataChecked(long offset, long size)
void	dataWritten(long offset, long size, Object originator)
boolean	exists()	Checks that the linked file exists (always returns true for pad files)
void	flushCache()
int	getAccessMode()
CacheFile	getCacheFile()
File	getCacheFileControlFileDir()
StringInterner.FileKey	getCacheFileLink(StringInterner.FileKey file)
String	getCacheFileOwnerName()
TOTorrentFile	getCacheFileTorrentFile()
int	getCacheMode()
DiskManager	getDiskManager()
long	getDownloaded()
DownloadManager	getDownloadManager()
long	getETA()
String	getExtension()
File	getFile(boolean follow_link)
long	getFileAllocationStrategy()
int	getFirstPieceNumber()
int	getIndex()
String	getLastError()
long	getLastModified()
int	getLastPieceNumber()
long	getLength()
File	getLink()
int	getNbPieces()
int	getPriority()	File Download Priority
int	getReadBytesPerSecond()
int	getStorageType()	Returns the storage type for this file
TOTorrentFile	getTorrentFile()
int	getWriteBytesPerSecond()
boolean	isSkipped()	Skipped files don't get downloaded.
Boolean	isSkipping()
protected void	load(int _priority, boolean _skipped)
void	moveFile(File new_root_dir, File new_absolute_file, boolean link_only, FileUtil.ProgressListener pl)
DirectByteBuffer	read(long offset, int length)
void	recheck()
void	removeListener(DiskManagerFileInfoListener listener)
void	renameFile(String new_name)
void	setAccessMode(int mode)
void	setDownloaded(long l)
void	setExtension(String string)
boolean	setLink(File link_destination, boolean no_delete)	Relink the file to the destination given - this method deals with if the file is part of a simple torrent or not (so it may set the download name to keep it in sync).
boolean	setLinkAtomic(File link_destination, boolean no_delete)
boolean	setLinkAtomic(File link_destination, boolean no_delete, FileUtil.ProgressListener pl)
void	setPriority(int b)
void	setSkipped(boolean skipped)
protected void	setSkippedInternal(boolean _skipped)
boolean	setStorageType(int type, boolean force)

Methods inherited from class Object

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

Methods inherited from interface DiskManagerFileInfo

isLinked, isMetadataDownload, setStorageType

Field Details

root_dir

private File root_dir

relative_file

private final StringInterner.FileKey relative_file

file_index

final int file_index

cache_file

CacheFile cache_file

extension

private String extension

downloaded

private long downloaded

diskManager

final DiskManagerHelper diskManager

torrent_file

final TOTorrentFile torrent_file

priority

private int priority

skipped_internal

protected boolean skipped_internal

skipping

private volatile Boolean skipping

last_error

private String last_error

listeners

private volatile CopyOnWriteList<DiskManagerFileInfoListener> listeners

read_average_state

volatile AverageFactory.LazyMovingImmediateAverageState read_average_state

write_average_state

volatile AverageFactory.LazyMovingImmediateAverageState write_average_state

eta_average_state

volatile AverageFactory.LazyMovingImmediateAverageState eta_average_state

read_adapter

private static final AverageFactory.LazyMovingImmediateAverageAdapter<DiskManagerFileInfoImpl> read_adapter

write_adapter

private static final AverageFactory.LazyMovingImmediateAverageAdapter<DiskManagerFileInfoImpl> write_adapter

eta_adapter

private static final AverageFactory.LazyMovingImmediateAverageAdapter<DiskManagerFileInfoImpl> eta_adapter

Constructor Details

DiskManagerFileInfoImpl

public DiskManagerFileInfoImpl(DiskManagerHelper _disk_manager,
 File _root_dir,
 StringInterner.FileKey _relative_file,
 int _file_index,
 TOTorrentFile _torrent_file,
 int _storage_type)
                        throws CacheFileManagerException

Throws:

CacheFileManagerException

Method Details

load

protected void load(int _priority,
 boolean _skipped)

getCacheFileOwnerName

public String getCacheFileOwnerName()

Specified by:

getCacheFileOwnerName in interface CacheFileOwner

getCacheFileTorrentFile

public TOTorrentFile getCacheFileTorrentFile()

Specified by:

getCacheFileTorrentFile in interface CacheFileOwner

getCacheFileControlFileDir

public File getCacheFileControlFileDir()

Specified by:

getCacheFileControlFileDir in interface CacheFileOwner

getCacheMode

public int getCacheMode()

Specified by:

getCacheMode in interface CacheFileOwner

getCacheFileLink

public StringInterner.FileKey getCacheFileLink(StringInterner.FileKey file)

Specified by:

getCacheFileLink in interface CacheFileOwner

getFileAllocationStrategy

public long getFileAllocationStrategy()

Specified by:

getFileAllocationStrategy in interface CacheFileOwner

flushCache

public void flushCache()
                throws Exception

Specified by:

flushCache in interface DiskManagerFileInfo

Throws:

Exception

exists

public boolean exists()

Description copied from interface: DiskManagerFileInfo

Checks that the linked file exists (always returns true for pad files)

Specified by:

exists in interface DiskManagerFileInfo

Returns:

moveFile

public void moveFile(File new_root_dir,
 File new_absolute_file,
 boolean link_only,
 FileUtil.ProgressListener pl)
              throws CacheFileManagerException

Throws:

CacheFileManagerException

renameFile

public void renameFile(String new_name)
                throws CacheFileManagerException

Throws:

CacheFileManagerException

getCacheFile

public CacheFile getCacheFile()

setAccessMode

public void setAccessMode(int mode)
                   throws CacheFileManagerException

Throws:

CacheFileManagerException

getAccessMode

public int getAccessMode()

Specified by:

getAccessMode in interface DiskManagerFileInfo

getDownloaded

public long getDownloaded()

Specified by:

getDownloaded in interface DiskManagerFileInfo

Returns:

getLastModified

public long getLastModified()

Specified by:

getLastModified in interface DiskManagerFileInfo

getExtension

public String getExtension()

Specified by:

getExtension in interface DiskManagerFileInfo

Returns:

getFile

public File getFile(boolean follow_link)

Specified by:

getFile in interface DiskManagerFileInfo

Returns:

getTorrentFile

public TOTorrentFile getTorrentFile()

Specified by:

getTorrentFile in interface DiskManagerFileInfo

setLink

public boolean setLink(File link_destination,
 boolean no_delete)

Description copied from interface: DiskManagerFileInfo

Relink the file to the destination given - this method deals with if the file is part of a simple torrent or not (so it may set the download name to keep it in sync). If you just want a simple relink, use setLinkAtomic.

Specified by:

setLink in interface DiskManagerFileInfo

Parameters:

link_destination -

Returns:

true - worked, false - failed, use getLastError to possibly get some extra info

getLastError

public String getLastError()

Specified by:

getLastError in interface DiskManagerFileInfo

setLinkAtomic

public boolean setLinkAtomic(File link_destination,
 boolean no_delete)

Specified by:

setLinkAtomic in interface DiskManagerFileInfo

setLinkAtomic

public boolean setLinkAtomic(File link_destination,
 boolean no_delete,
 FileUtil.ProgressListener pl)

Specified by:

setLinkAtomic in interface DiskManagerFileInfo

getLink

public File getLink()

Specified by:

getLink in interface DiskManagerFileInfo

setStorageType

public boolean setStorageType(int type,
 boolean force)

Specified by:

setStorageType in interface DiskManagerFileInfo

Parameters:

type -

force - discards any existing file content if it exists - use with care...

Returns:

getStorageType

public int getStorageType()

Description copied from interface: DiskManagerFileInfo

Returns the storage type for this file

Specified by:

getStorageType in interface DiskManagerFileInfo

Returns:

DiskManagerFileInfo.ST_LINEAR, DiskManagerFileInfo.ST_COMPACT, DiskManagerFileInfo.ST_REORDER, DiskManagerFileInfo.ST_REORDER_COMPACT

getFirstPieceNumber

public int getFirstPieceNumber()

Specified by:

getFirstPieceNumber in interface DiskManagerFileInfo

Returns:

getLastPieceNumber

public int getLastPieceNumber()

Specified by:

getLastPieceNumber in interface DiskManagerFileInfo

getLength

public long getLength()

Specified by:

getLength in interface DiskManagerFileInfo

Returns:

getIndex

public int getIndex()

Specified by:

getIndex in interface DiskManagerFileInfo

getNbPieces

public int getNbPieces()

Specified by:

getNbPieces in interface DiskManagerFileInfo

Returns:

setDownloaded

public void setDownloaded(long l)

Parameters:

l -

setExtension

public void setExtension(String string)

Parameters:

string -

getPriority

public int getPriority()

Description copied from interface: DiskManagerFileInfo

File Download Priority

Specified by:

getPriority in interface DiskManagerFileInfo

Returns:

setPriority

public void setPriority(int b)

Specified by:

setPriority in interface DiskManagerFileInfo

Parameters:

b -

isSkipped

public boolean isSkipped()

Description copied from interface: DiskManagerFileInfo

Skipped files don't get downloaded.

The state of the existing data is dependent upon DiskManagerFileInfo.getStorageType(). States DiskManagerFileInfo.ST_COMPACT and DiskManagerFileInfo.ST_REORDER_COMPACT will delete (or trim) the file. Other states will retain existing data (ie. Do Not Download).

Specified by:

isSkipped in interface DiskManagerFileInfo

Returns:

setSkipped

public void setSkipped(boolean skipped)

Specified by:

setSkipped in interface DiskManagerFileInfo

Parameters:

skipped -

isSkipping

public Boolean isSkipping()

Specified by:

isSkipping in interface DiskManagerFileInfo

setSkippedInternal

protected void setSkippedInternal(boolean _skipped)

getDiskManager

public DiskManager getDiskManager()

Specified by:

getDiskManager in interface DiskManagerFileInfo

getDownloadManager

public DownloadManager getDownloadManager()

Specified by:

getDownloadManager in interface DiskManagerFileInfo

dataWritten

public void dataWritten(long offset,
 long size,
 Object originator)

dataChecked

public void dataChecked(long offset,
 long size)

read

public DirectByteBuffer read(long offset,
 int length)
                      throws IOException

Specified by:

read in interface DiskManagerFileInfo

Throws:

IOException

getReadBytesPerSecond

public int getReadBytesPerSecond()

Specified by:

getReadBytesPerSecond in interface DiskManagerFileInfo

getWriteBytesPerSecond

public int getWriteBytesPerSecond()

Specified by:

getWriteBytesPerSecond in interface DiskManagerFileInfo

getETA

public long getETA()

Specified by:

getETA in interface DiskManagerFileInfo

recheck

public void recheck()

Specified by:

recheck in interface DiskManagerFileInfo

close

public void close()

Specified by:

close in interface DiskManagerFileInfo

addListener

public void addListener(DiskManagerFileInfoListener listener)

Specified by:

addListener in interface DiskManagerFileInfo

removeListener

public void removeListener(DiskManagerFileInfoListener listener)

Specified by:

removeListener in interface DiskManagerFileInfo