Class DiskManagerChannelImpl

java.lang.Object

com.biglybt.pifimpl.local.disk.DiskManagerChannelImpl

All Implemented Interfaces:

DiskManagerFileInfoListener, DownloadManagerPeerListener, PieceRTAProvider, DiskManagerChannel

public class DiskManagerChannelImpl
extends Object
implements DiskManagerChannel, DiskManagerFileInfoListener, DownloadManagerPeerListener, PieceRTAProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	DiskManagerChannelImpl.channelCreateListener
protected static class	DiskManagerChannelImpl.dataEntry
protected class	DiskManagerChannelImpl.request

Field Summary

Fields

Modifier and Type	Field	Description
private long	buffer_delay_millis
private long	buffer_millis_override
private Average	byte_rate
private int	channel_id
private static int	channel_id_next
private static final String	channel_key
private int	compact_delay
private static final int	COMPACT_DELAY
private static final Comparator<DiskManagerChannelImpl.dataEntry>	comparator
private DiskManagerFileInfo	core_file
private long	current_position
private DiskManagerChannelImpl.request	current_request
private Set<DiskManagerChannelImpl.dataEntry>	data_written
private static int	DEFAULT_BUFFER_MILLIS
private static int	DEFAULT_MIN_PIECES_TO_BUFFER
private boolean	destroyed
private DownloadImpl	download
private long	file_offset_in_torrent
private static CopyOnWriteList<DiskManagerChannelImpl.channelCreateListener>	listeners
private static final int	MAX_READ_CHUNK_DEFAULT
private PEPeerManager	peer_manager
private long	piece_size
private DiskManagerFileInfoImpl	plugin_file
private long[]	rtas
private long	start_position
private long	start_time
private static final boolean	TRACE
private List<AESemaphore>	waiters

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DiskManagerChannelImpl(DownloadImpl _download, DiskManagerFileInfoImpl _plugin_file)

Method Summary

Modifier and Type	Method	Description
static void	addListener(DiskManagerChannelImpl.channelCreateListener l)
DiskManagerRequest	createRequest()
void	dataChecked(long offset, long length)
void	dataWritten(long offset, long length, Object originator)
void	destroy()
long	getBlockingPosition()
long	getCurrentPosition()
DiskManagerFileInfo	getFile()
long	getPosition()
long	getStartPosition()
long	getStartTime()
String	getUserAgent()	Returns the user-agent associated with this RTA activity, if known
boolean	isDestroyed()
void	peerAdded(PEPeer peer)
void	peerManagerAdded(PEPeerManager manager)
void	peerManagerRemoved(PEPeerManager manager)
void	peerManagerWillBeAdded(PEPeerManager manager)	Called when a peer manager is created but not yet started
void	peerRemoved(PEPeer peer)
static void	removeListener(DiskManagerChannelImpl.channelCreateListener l)
protected static void	reportCreated(DiskManagerChannel channel)
void	setBufferMillis(long millis, long delay_millis)	Sets an external view of how much buffer is being maintained by an external source.
long[]	updateRTAs(PiecePicker picker)

Methods inherited from class Object

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

Field Details

DEFAULT_BUFFER_MILLIS

private static int DEFAULT_BUFFER_MILLIS

DEFAULT_MIN_PIECES_TO_BUFFER

private static int DEFAULT_MIN_PIECES_TO_BUFFER

TRACE

private static final boolean TRACE

See Also:

• Constant Field Values

COMPACT_DELAY

private static final int COMPACT_DELAY

See Also:

• Constant Field Values

MAX_READ_CHUNK_DEFAULT

private static final int MAX_READ_CHUNK_DEFAULT

See Also:

• Constant Field Values

comparator

private static final Comparator<DiskManagerChannelImpl.dataEntry> comparator

channel_key

private static final String channel_key

See Also:

• Constant Field Values

channel_id_next

private static int channel_id_next

listeners

private static CopyOnWriteList<DiskManagerChannelImpl.channelCreateListener> listeners

download

private DownloadImpl download

plugin_file

private DiskManagerFileInfoImpl plugin_file

core_file

private DiskManagerFileInfo core_file

data_written

private Set<DiskManagerChannelImpl.dataEntry> data_written

compact_delay

private int compact_delay

waiters

private List<AESemaphore> waiters

file_offset_in_torrent

private long file_offset_in_torrent

piece_size

private long piece_size

byte_rate

private Average byte_rate

start_position

private long start_position

start_time

private long start_time

current_position

private volatile long current_position

current_request

private DiskManagerChannelImpl.request current_request

buffer_millis_override

private long buffer_millis_override

buffer_delay_millis

private long buffer_delay_millis

peer_manager

private PEPeerManager peer_manager

rtas

private long[] rtas

channel_id

private int channel_id

destroyed

private volatile boolean destroyed

Constructor Details

DiskManagerChannelImpl

protected DiskManagerChannelImpl(DownloadImpl _download,
 DiskManagerFileInfoImpl _plugin_file)
                          throws DownloadException

Throws:

DownloadException

Method Details

addListener

public static void addListener(DiskManagerChannelImpl.channelCreateListener l)

removeListener

public static void removeListener(DiskManagerChannelImpl.channelCreateListener l)

reportCreated

protected static void reportCreated(DiskManagerChannel channel)

getFile

public DiskManagerFileInfo getFile()

Specified by:

getFile in interface DiskManagerChannel

createRequest

public DiskManagerRequest createRequest()

Specified by:

createRequest in interface DiskManagerChannel

getPosition

public long getPosition()

Specified by:

getPosition in interface DiskManagerChannel

isDestroyed

public boolean isDestroyed()

Specified by:

isDestroyed in interface DiskManagerChannel

dataWritten

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

Specified by:

dataWritten in interface DiskManagerFileInfoListener

dataChecked

public void dataChecked(long offset,
 long length)

Specified by:

dataChecked in interface DiskManagerFileInfoListener

peerManagerWillBeAdded

public void peerManagerWillBeAdded(PEPeerManager manager)

Description copied from interface: DownloadManagerPeerListener

Called when a peer manager is created but not yet started

Specified by:

peerManagerWillBeAdded in interface DownloadManagerPeerListener

Parameters:

manager -

peerManagerAdded

public void peerManagerAdded(PEPeerManager manager)

Specified by:

peerManagerAdded in interface DownloadManagerPeerListener

peerManagerRemoved

public void peerManagerRemoved(PEPeerManager manager)

Specified by:

peerManagerRemoved in interface DownloadManagerPeerListener

peerAdded

public void peerAdded(PEPeer peer)

Specified by:

peerAdded in interface DownloadManagerPeerListener

peerRemoved

public void peerRemoved(PEPeer peer)

Specified by:

peerRemoved in interface DownloadManagerPeerListener

updateRTAs

public long[] updateRTAs(PiecePicker picker)

Specified by:

updateRTAs in interface PieceRTAProvider

getStartTime

public long getStartTime()

Specified by:

getStartTime in interface PieceRTAProvider

getStartPosition

public long getStartPosition()

Specified by:

getStartPosition in interface PieceRTAProvider

getCurrentPosition

public long getCurrentPosition()

Specified by:

getCurrentPosition in interface PieceRTAProvider

getBlockingPosition

public long getBlockingPosition()

Specified by:

getBlockingPosition in interface PieceRTAProvider

setBufferMillis

public void setBufferMillis(long millis,
 long delay_millis)

Description copied from interface: PieceRTAProvider

Sets an external view of how much buffer is being maintained by an external source. This reduces piece urgency and therefore reduces discard.

Specified by:

setBufferMillis in interface PieceRTAProvider

getUserAgent

public String getUserAgent()

Description copied from interface: PieceRTAProvider

Returns the user-agent associated with this RTA activity, if known

Specified by:

getUserAgent in interface PieceRTAProvider

Returns:

destroy

public void destroy()

Specified by:

destroy in interface DiskManagerChannel