Class FMFileAccessPieceReorderer

java.lang.Object

com.biglybt.core.diskmanager.file.impl.FMFileAccessPieceReorderer

All Implemented Interfaces:

FMFileAccess

public class FMFileAccessPieceReorderer
extends Object
implements FMFileAccess

Nested Class Summary

Nested classes/interfaces inherited from interface FMFileAccess

FMFileAccess.FileAccessor

Field Summary

Fields

Modifier and Type	Field	Description
private final File	control_dir
private final String	control_file
private long	current_length
private final FMFileAccess	delegate
private static final int	DIRT_CLEAN
private static final int	DIRT_DIRTY
private static final long	DIRT_FLUSH_MILLIS
private static final int	DIRT_NEVER_WRITTEN
private int	dirt_state
private long	dirt_time
private int	first_piece_length
private int	first_piece_number
private int	last_piece_length
private static final int	MIN_PIECES_REORDERABLE
private int	next_piece_index
private int	num_pieces
private int[]	piece_map
private int[]	piece_reverse_map
private int	piece_size
private int	previous_storage_type
private static final byte	SS_FILE
private final int	storage_type
private static final boolean	TRACE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FMFileAccessPieceReorderer(TOTorrentFile _torrent_file, File _control_dir, String _control_file, int _storage_type, FMFileAccess _delegate)

Method Summary

Modifier and Type	Method	Description
void	aboutToOpen()
private void	configBorked(String error)
private static Map	encodeConfig(int storage_type, long current_length, long next_piece_index, int[] piece_map)
void	flush()
FMFileImpl	getFile()
long	getLength(FMFileAccess.FileAccessor fa)
protected int	getPieceIndex(FMFileAccess.FileAccessor fa, int piece_number, boolean allocate_if_needed)
protected long	getPieceOffset(FMFileAccess.FileAccessor fa, int piece_number, boolean allocate_if_needed)
String	getString()
boolean	isPieceCompleteProcessingNeeded(int piece_number)
void	read(FMFileAccess.FileAccessor fa, DirectByteBuffer[] buffers, long position)
private void	readConfig()
protected void	readWrite(FMFileAccess.FileAccessor fa, DirectByteBuffer[] buffers, long position, boolean is_read)
protected int	readWritePiece(FMFileAccess.FileAccessor fa, DirectByteBuffer[] buffers, int piece_number, int piece_offset, boolean is_read)
protected static void	recoverConfig(TOTorrentFile torrent_file, File data_file, File config_file, int storage_type)
protected void	setDirty()
void	setLength(FMFileAccess.FileAccessor fa, long length)
void	setPieceComplete(FMFileAccess.FileAccessor fa, int piece_number, DirectByteBuffer piece_data)
void	write(FMFileAccess.FileAccessor fa, DirectByteBuffer[] buffers, long position)
private void	writeConfig()

Methods inherited from class Object

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

Field Details

TRACE

private static final boolean TRACE

See Also:

• Constant Field Values

MIN_PIECES_REORDERABLE

private static final int MIN_PIECES_REORDERABLE

See Also:

• Constant Field Values

SS_FILE

private static final byte SS_FILE

See Also:

• Constant Field Values

DIRT_CLEAN

private static final int DIRT_CLEAN

See Also:

• Constant Field Values

DIRT_DIRTY

private static final int DIRT_DIRTY

See Also:

• Constant Field Values

DIRT_NEVER_WRITTEN

private static final int DIRT_NEVER_WRITTEN

See Also:

• Constant Field Values

DIRT_FLUSH_MILLIS

private static final long DIRT_FLUSH_MILLIS

See Also:

• Constant Field Values

delegate

private final FMFileAccess delegate

control_dir

private final File control_dir

control_file

private final String control_file

storage_type

private final int storage_type

piece_size

private int piece_size

first_piece_length

private int first_piece_length

first_piece_number

private int first_piece_number

last_piece_length

private int last_piece_length

num_pieces

private int num_pieces

previous_storage_type

private int previous_storage_type

current_length

private long current_length

piece_map

private int[] piece_map

piece_reverse_map

private int[] piece_reverse_map

next_piece_index

private int next_piece_index

dirt_state

private int dirt_state

dirt_time

private long dirt_time

Constructor Details

FMFileAccessPieceReorderer

protected FMFileAccessPieceReorderer(TOTorrentFile _torrent_file,
 File _control_dir,
 String _control_file,
 int _storage_type,
 FMFileAccess _delegate)
                              throws FMFileManagerException

Throws:

FMFileManagerException

Method Details

aboutToOpen

public void aboutToOpen()
                 throws FMFileManagerException

Specified by:

aboutToOpen in interface FMFileAccess

Throws:

FMFileManagerException

getLength

public long getLength(FMFileAccess.FileAccessor fa)
               throws FMFileManagerException

Specified by:

getLength in interface FMFileAccess

Throws:

FMFileManagerException

setLength

public void setLength(FMFileAccess.FileAccessor fa,
 long length)
               throws FMFileManagerException

Specified by:

setLength in interface FMFileAccess

Throws:

FMFileManagerException

getPieceOffset

protected long getPieceOffset(FMFileAccess.FileAccessor fa,
 int piece_number,
 boolean allocate_if_needed)
                       throws FMFileManagerException

Throws:

FMFileManagerException

readWritePiece

protected int readWritePiece(FMFileAccess.FileAccessor fa,
 DirectByteBuffer[] buffers,
 int piece_number,
 int piece_offset,
 boolean is_read)
                      throws FMFileManagerException

Throws:

FMFileManagerException

readWrite

protected void readWrite(FMFileAccess.FileAccessor fa,
 DirectByteBuffer[] buffers,
 long position,
 boolean is_read)
                  throws FMFileManagerException

Throws:

FMFileManagerException

read

public void read(FMFileAccess.FileAccessor fa,
 DirectByteBuffer[] buffers,
 long position)
          throws FMFileManagerException

Specified by:

read in interface FMFileAccess

Throws:

FMFileManagerException

write

public void write(FMFileAccess.FileAccessor fa,
 DirectByteBuffer[] buffers,
 long position)
           throws FMFileManagerException

Specified by:

write in interface FMFileAccess

Throws:

FMFileManagerException

flush

public void flush()
           throws FMFileManagerException

Specified by:

flush in interface FMFileAccess

Throws:

FMFileManagerException

isPieceCompleteProcessingNeeded

public boolean isPieceCompleteProcessingNeeded(int piece_number)

Specified by:

isPieceCompleteProcessingNeeded in interface FMFileAccess

setPieceComplete

public void setPieceComplete(FMFileAccess.FileAccessor fa,
 int piece_number,
 DirectByteBuffer piece_data)
                      throws FMFileManagerException

Specified by:

setPieceComplete in interface FMFileAccess

Throws:

FMFileManagerException

getPieceIndex

protected int getPieceIndex(FMFileAccess.FileAccessor fa,
 int piece_number,
 boolean allocate_if_needed)
                     throws FMFileManagerException

Throws:

FMFileManagerException

readConfig

private void readConfig()
                 throws FMFileManagerException

Throws:

FMFileManagerException

configBorked

private void configBorked(String error)
                   throws FMFileManagerException

Throws:

FMFileManagerException

setDirty

protected void setDirty()
                 throws FMFileManagerException

Throws:

FMFileManagerException

encodeConfig

private static Map encodeConfig(int storage_type,
 long current_length,
 long next_piece_index,
 int[] piece_map)

recoverConfig

protected static void recoverConfig(TOTorrentFile torrent_file,
 File data_file,
 File config_file,
 int storage_type)
                             throws FMFileManagerException

Throws:

FMFileManagerException

writeConfig

private void writeConfig()
                  throws FMFileManagerException

Throws:

FMFileManagerException

getFile

public FMFileImpl getFile()

Specified by:

getFile in interface FMFileAccess

getString

public String getString()

Specified by:

getString in interface FMFileAccess