Class ExternalSeedReaderImpl

java.lang.Object

com.biglybt.plugin.extseed.impl.ExternalSeedReaderImpl

All Implemented Interfaces:

PeerManagerListener2, ExternalSeedReader

Direct Known Subclasses:

ExternalSeedReaderGetRight, ExternalSeedReaderWebSeed

public abstract class ExternalSeedReaderImpl
extends Object
implements ExternalSeedReader, PeerManagerListener2

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	ExternalSeedReaderImpl.MutableInteger

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	active
private ExternalSeedReaderRequest	active_read_request
private CopyOnWriteSet<ExternalSeedReaderImpl.MutableInteger>	bad_pieces
private int	consec_failures
private PeerManager	current_manager
private ExternalSeedReaderRequest	current_request
private List<PeerReadRequest>	dangling_requests
private final String	host
private final String	host_net
static final int	INITIAL_DELAY
private String	ip_use_accessor
private long	last_failed_read
private List	listeners
private static int	min_download_speed_default
private long	peer_manager_change_time
private boolean	permanent_fail
private ExternalSeedPlugin	plugin
private int[]	priority_offsets
private long	rate_bytes_permitted
private int	rate_bytes_read
private AESemaphore	rate_sem
static final int	RECONNECT_DEFAULT
private int	reconnect_delay
private Semaphore	request_sem
private Thread	request_thread
private List<PeerReadRequest>	requests
private Monitor	requests_mon
static final int	STALLED_DOWNLOAD_SPEED
static final int	STALLED_PEER_SPEED
private String	status
static final int	TOP_PIECE_PRIORITY
private Torrent	torrent
private boolean	transient_seed
private static boolean	use_avail_to_activate
private String	user_agent
private boolean	ws_fast_activate
private int	ws_max_peer_speed
private int	ws_min_availability
private int	ws_min_download_speed
private long	ws_valid_until

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ExternalSeedReaderImpl(ExternalSeedPlugin _plugin, Torrent _torrent, String _host, Map _params)

Method Summary

Modifier and Type	Method	Description
void	addListener(ExternalSeedReaderListener l)
void	addRequests(List<PeerReadRequest> new_requests)
void	calculatePriorityOffsets(PeerManager peer_manager, int[] base_priorities)
void	cancelAllRequests()
void	cancelRequest(PeerReadRequest request)
boolean	checkActivation(PeerManager peer_manager, Peer peer)
void	deactivate(String reason)
void	eventOccurred(PeerManagerEvent event)
protected boolean	getBooleanParam(Map map, String name, boolean def)
int[]	getCurrentIncomingRequestProgress()
List<PeerReadRequest>	getExpiredRequests()
protected int	getFailureCount()
protected int	getIntParam(Map map, String name, int def)
String	getIP()
protected long	getLastFailTime()
int	getMaximumNumberOfRequests()
int	getOutgoingRequestCount()
int[]	getOutgoingRequestedPieceNumbers()
long	getPermittedBytes()
protected abstract int	getPieceGroupSize()
int[]	getPriorityOffsets()
protected abstract boolean	getRequestCanSpanPieces()
int	getRequestCount()
List<PeerReadRequest>	getRequests()
String	getStatus()
protected long	getSystemTime()
Torrent	getTorrent()
protected String	getUserAgent()
protected void	informCancelled(PeerReadRequest request)
protected void	informComplete(PeerReadRequest request, byte[] buffer)
protected void	informFailed(PeerReadRequest request)
boolean	isActive()
boolean	isPermanentlyUnavailable()
boolean	isTransient()
protected void	log(String str)
protected void	processRequests()
protected void	processRequests(List<PeerReadRequest> requests)
byte[]	read(int piece_number, int piece_offset, int length, int timeout)
long	readBytes(long max)	Rate handling
protected abstract void	readData(int piece_number, int piece_offset, int length, ExternalSeedHTTPDownloaderListener listener)
protected void	readData(ExternalSeedReaderRequest request)
protected boolean	readyToActivate(PeerManager peer_manager, Peer peer, long time_since_start)
protected boolean	readyToDeactivate(PeerManager peer_manager, Peer peer)
void	removeListener(ExternalSeedReaderListener l)
void	reportBytesRead(int num)
protected int	selectRequests(List<PeerReadRequest> requests)
protected void	setActive(PeerManager _peer_manager, boolean _active)
protected void	setActiveSupport(PeerManager _peer_manager, boolean _active)
protected void	setReconnectDelay(int delay, boolean reset_failures)

Methods inherited from class Object

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

Methods inherited from interface ExternalSeedReader

getName, getPort, getType, getURL, sameAs

Field Details

RECONNECT_DEFAULT

public static final int RECONNECT_DEFAULT

See Also:

• Constant Field Values

INITIAL_DELAY

public static final int INITIAL_DELAY

See Also:

• Constant Field Values

STALLED_DOWNLOAD_SPEED

public static final int STALLED_DOWNLOAD_SPEED

See Also:

• Constant Field Values

STALLED_PEER_SPEED

public static final int STALLED_PEER_SPEED

See Also:

• Constant Field Values

TOP_PIECE_PRIORITY

public static final int TOP_PIECE_PRIORITY

See Also:

• Constant Field Values

use_avail_to_activate

private static boolean use_avail_to_activate

min_download_speed_default

private static int min_download_speed_default

plugin

private ExternalSeedPlugin plugin

torrent

private Torrent torrent

host

private final String host

host_net

private final String host_net

ip_use_accessor

private String ip_use_accessor

status

private String status

active

private boolean active

permanent_fail

private boolean permanent_fail

last_failed_read

private long last_failed_read

consec_failures

private int consec_failures

user_agent

private String user_agent

peer_manager_change_time

private long peer_manager_change_time

current_manager

private volatile PeerManager current_manager

requests

private List<PeerReadRequest> requests

dangling_requests

private List<PeerReadRequest> dangling_requests

request_thread

private Thread request_thread

request_sem

private Semaphore request_sem

requests_mon

private Monitor requests_mon

active_read_request

private ExternalSeedReaderRequest active_read_request

priority_offsets

private int[] priority_offsets

ws_fast_activate

private boolean ws_fast_activate

ws_min_availability

private int ws_min_availability

ws_min_download_speed

private int ws_min_download_speed

ws_max_peer_speed

private int ws_max_peer_speed

ws_valid_until

private long ws_valid_until

transient_seed

private boolean transient_seed

reconnect_delay

private int reconnect_delay

current_request

private volatile ExternalSeedReaderRequest current_request

listeners

private List listeners

rate_sem

private AESemaphore rate_sem

rate_bytes_read

private int rate_bytes_read

rate_bytes_permitted

private long rate_bytes_permitted

bad_pieces

private volatile CopyOnWriteSet<ExternalSeedReaderImpl.MutableInteger> bad_pieces

Constructor Details

ExternalSeedReaderImpl

protected ExternalSeedReaderImpl(ExternalSeedPlugin _plugin,
 Torrent _torrent,
 String _host,
 Map _params)

Method Details

getIP

public String getIP()

Specified by:

getIP in interface ExternalSeedReader

getTorrent

public Torrent getTorrent()

Specified by:

getTorrent in interface ExternalSeedReader

getStatus

public String getStatus()

Specified by:

getStatus in interface ExternalSeedReader

isTransient

public boolean isTransient()

Specified by:

isTransient in interface ExternalSeedReader

log

protected void log(String str)

getUserAgent

protected String getUserAgent()

getSystemTime

protected long getSystemTime()

getFailureCount

protected int getFailureCount()

getLastFailTime

protected long getLastFailTime()

isPermanentlyUnavailable

public boolean isPermanentlyUnavailable()

Specified by:

isPermanentlyUnavailable in interface ExternalSeedReader

setReconnectDelay

protected void setReconnectDelay(int delay,
 boolean reset_failures)

eventOccurred

public void eventOccurred(PeerManagerEvent event)

Specified by:

eventOccurred in interface PeerManagerListener2

readyToActivate

protected boolean readyToActivate(PeerManager peer_manager,
 Peer peer,
 long time_since_start)

readyToDeactivate

protected boolean readyToDeactivate(PeerManager peer_manager,
 Peer peer)

checkActivation

public boolean checkActivation(PeerManager peer_manager,
 Peer peer)

Specified by:

checkActivation in interface ExternalSeedReader

deactivate

public void deactivate(String reason)

Specified by:

deactivate in interface ExternalSeedReader

setActive

protected void setActive(PeerManager _peer_manager,
 boolean _active)

setActiveSupport

protected void setActiveSupport(PeerManager _peer_manager,
 boolean _active)

isActive

public boolean isActive()

Specified by:

isActive in interface ExternalSeedReader

processRequests

protected void processRequests()

readBytes

public long readBytes(long max)

Rate handling

Specified by:

readBytes in interface ExternalSeedReader

getPermittedBytes

public long getPermittedBytes()
                       throws ExternalSeedException

Throws:

ExternalSeedException

reportBytesRead

public void reportBytesRead(int num)

getCurrentIncomingRequestProgress

public int[] getCurrentIncomingRequestProgress()

Specified by:

getCurrentIncomingRequestProgress in interface ExternalSeedReader

getMaximumNumberOfRequests

public int getMaximumNumberOfRequests()

Specified by:

getMaximumNumberOfRequests in interface ExternalSeedReader

calculatePriorityOffsets

public void calculatePriorityOffsets(PeerManager peer_manager,
 int[] base_priorities)

Specified by:

calculatePriorityOffsets in interface ExternalSeedReader

getPieceGroupSize

protected abstract int getPieceGroupSize()

getRequestCanSpanPieces

protected abstract boolean getRequestCanSpanPieces()

getPriorityOffsets

public int[] getPriorityOffsets()

Specified by:

getPriorityOffsets in interface ExternalSeedReader

selectRequests

protected int selectRequests(List<PeerReadRequest> requests)

read

public byte[] read(int piece_number,
 int piece_offset,
 int length,
 int timeout)
            throws ExternalSeedException

Specified by:

read in interface ExternalSeedReader

Throws:

ExternalSeedException

readData

protected void readData(ExternalSeedReaderRequest request)
                 throws ExternalSeedException

Throws:

ExternalSeedException

readData

protected abstract void readData(int piece_number,
 int piece_offset,
 int length,
 ExternalSeedHTTPDownloaderListener listener)
                          throws ExternalSeedException

Throws:

ExternalSeedException

processRequests

protected void processRequests(List<PeerReadRequest> requests)

addRequests

public void addRequests(List<PeerReadRequest> new_requests)

Specified by:

addRequests in interface ExternalSeedReader

cancelRequest

public void cancelRequest(PeerReadRequest request)

Specified by:

cancelRequest in interface ExternalSeedReader

cancelAllRequests

public void cancelAllRequests()

Specified by:

cancelAllRequests in interface ExternalSeedReader

getRequestCount

public int getRequestCount()

Specified by:

getRequestCount in interface ExternalSeedReader

getExpiredRequests

public List<PeerReadRequest> getExpiredRequests()

Specified by:

getExpiredRequests in interface ExternalSeedReader

getRequests

public List<PeerReadRequest> getRequests()

Specified by:

getRequests in interface ExternalSeedReader

getOutgoingRequestedPieceNumbers

public int[] getOutgoingRequestedPieceNumbers()

Specified by:

getOutgoingRequestedPieceNumbers in interface ExternalSeedReader

getOutgoingRequestCount

public int getOutgoingRequestCount()

Specified by:

getOutgoingRequestCount in interface ExternalSeedReader

informComplete

protected void informComplete(PeerReadRequest request,
 byte[] buffer)

informCancelled

protected void informCancelled(PeerReadRequest request)

informFailed

protected void informFailed(PeerReadRequest request)

addListener

public void addListener(ExternalSeedReaderListener l)

Specified by:

addListener in interface ExternalSeedReader

removeListener

public void removeListener(ExternalSeedReaderListener l)

Specified by:

removeListener in interface ExternalSeedReader

getIntParam

protected int getIntParam(Map map,
 String name,
 int def)

getBooleanParam

protected boolean getBooleanParam(Map map,
 String name,
 boolean def)