Class LightWeightSeed

java.lang.Object

com.biglybt.core.logging.LogRelation

com.biglybt.core.lws.LightWeightSeed

All Implemented Interfaces:

PeerManagerRegistrationAdapter

public class LightWeightSeed
extends LogRelation
implements PeerManagerRegistrationAdapter

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte	ACT_HAS_PEERS
private static final byte	ACT_HAS_POTENTIAL_PEERS
private static final byte	ACT_INCOMING
private static final byte	ACT_NO_PM
private static final byte	ACT_NONE
private static final byte	ACT_TIMING_OUT
private static final byte	ACT_TRACKER_ANNOUNCE
private static final byte	ACT_TRACKER_SCRAPE
private int	activation_state
private TOTorrent	actual_torrent
private final LightWeightSeedAdapter	adapter
private final URL	announce_url
private TRTrackerAnnouncer	announcer
private final File	data_location
private static final int	DEACTIVATION_TIMEOUT
private static final int	DEACTIVATION_WITH_POTENTIAL_TIMEOUT
private LWSDiskManager	disk_manager
private final HashWrapper	hash
private boolean	is_running
private long	last_activity_time
private final LightWeightSeedManager	manager
private final String	name
private final String	network
private PEPeerManager	peer_manager
private PeerManagerRegistration	peer_manager_registration
private LWSDownload	pseudo_download
private LWSTorrent	torrent_facade

Fields inherited from interface PeerManagerRegistrationAdapter

AT_ACCEPTED, AT_ACCEPTED_PROBE, AT_DECLINED

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	LightWeightSeed(LightWeightSeedManager _manager, String _name, HashWrapper _hash, URL _announce_url, File _data_location, String _network, LightWeightSeedAdapter _adapter)

Method Summary

Modifier and Type	Method	Description
protected void	activate(String reason_str, byte activation_reason)
int	activateRequest(InetSocketAddress remote_address)
protected void	checkDeactivation()
protected TRTrackerAnnouncer	createAnnouncer()
protected void	deactivate()
void	deactivateRequest(InetSocketAddress remote_address)
void	enqueueReadRequest(PEPeer peer, DiskManagerReadRequest request, DiskManagerReadRequestListener listener)
protected void	ensureActive(String reason, byte a_reason)
URL	getAnnounceURL()
File	getDataLocation()
String	getDescription()
int	getExtendedMessagingMode()
HashWrapper	getHash()
byte[]	getHashOverride()
int	getHashOverrideLocalPort(boolean only_if_allocated)
protected String	getName()
int	getNbPieces()
String	getNetwork()
protected int	getPeerCount()
byte[]	getPeerID()
Object[]	getQueryableInterfaces()	Query this class for a reference to another class that it may hold
LogRelation	getRelation()
String	getRelationText()	A short description of what your class holds that can be printed by the logger
byte[][]	getSecrets()
protected long	getSize()
protected String	getString()
protected Torrent	getTorrent()
protected TOTorrent	getTOTorrent(boolean actual)
boolean	isPeerSourceEnabled(String peer_source)
protected void	log(String str)
protected void	log(String str, Throwable e)
boolean	manualRoute(NetworkConnection connection)
void	remove()
protected void	start()
protected void	stop()

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

ACT_NONE

private static final byte ACT_NONE

See Also:

• Constant Field Values

ACT_HAS_PEERS

private static final byte ACT_HAS_PEERS

See Also:

• Constant Field Values

ACT_HAS_POTENTIAL_PEERS

private static final byte ACT_HAS_POTENTIAL_PEERS

See Also:

• Constant Field Values

ACT_INCOMING

private static final byte ACT_INCOMING

See Also:

• Constant Field Values

ACT_NO_PM

private static final byte ACT_NO_PM

See Also:

• Constant Field Values

ACT_TIMING_OUT

private static final byte ACT_TIMING_OUT

See Also:

• Constant Field Values

ACT_TRACKER_ANNOUNCE

private static final byte ACT_TRACKER_ANNOUNCE

See Also:

• Constant Field Values

ACT_TRACKER_SCRAPE

private static final byte ACT_TRACKER_SCRAPE

See Also:

• Constant Field Values

DEACTIVATION_TIMEOUT

private static final int DEACTIVATION_TIMEOUT

See Also:

• Constant Field Values

DEACTIVATION_WITH_POTENTIAL_TIMEOUT

private static final int DEACTIVATION_WITH_POTENTIAL_TIMEOUT

See Also:

• Constant Field Values

manager

private final LightWeightSeedManager manager

adapter

private final LightWeightSeedAdapter adapter

name

private final String name

hash

private final HashWrapper hash

announce_url

private final URL announce_url

data_location

private final File data_location

network

private final String network

peer_manager_registration

private PeerManagerRegistration peer_manager_registration

peer_manager

private volatile PEPeerManager peer_manager

disk_manager

private volatile LWSDiskManager disk_manager

pseudo_download

private LWSDownload pseudo_download

torrent_facade

private volatile LWSTorrent torrent_facade

announcer

private TRTrackerAnnouncer announcer

actual_torrent

private TOTorrent actual_torrent

is_running

private boolean is_running

last_activity_time

private long last_activity_time

activation_state

private int activation_state

Constructor Details

LightWeightSeed

protected LightWeightSeed(LightWeightSeedManager _manager,
 String _name,
 HashWrapper _hash,
 URL _announce_url,
 File _data_location,
 String _network,
 LightWeightSeedAdapter _adapter)

Method Details

getName

protected String getName()

getTorrent

protected Torrent getTorrent()

getTOTorrent

protected TOTorrent getTOTorrent(boolean actual)

getHash

public HashWrapper getHash()

getHashOverride

public byte[] getHashOverride()

Specified by:

getHashOverride in interface PeerManagerRegistrationAdapter

getPeerID

public byte[] getPeerID()

Specified by:

getPeerID in interface PeerManagerRegistrationAdapter

getNbPieces

public int getNbPieces()

Specified by:

getNbPieces in interface PeerManagerRegistrationAdapter

getExtendedMessagingMode

public int getExtendedMessagingMode()

Specified by:

getExtendedMessagingMode in interface PeerManagerRegistrationAdapter

getHashOverrideLocalPort

public int getHashOverrideLocalPort(boolean only_if_allocated)

Specified by:

getHashOverrideLocalPort in interface PeerManagerRegistrationAdapter

getAnnounceURL

public URL getAnnounceURL()

getDataLocation

public File getDataLocation()

getNetwork

public String getNetwork()

getSize

protected long getSize()

isPeerSourceEnabled

public boolean isPeerSourceEnabled(String peer_source)

Specified by:

isPeerSourceEnabled in interface PeerManagerRegistrationAdapter

manualRoute

public boolean manualRoute(NetworkConnection connection)

Specified by:

manualRoute in interface PeerManagerRegistrationAdapter

getSecrets

public byte[][] getSecrets()

Specified by:

getSecrets in interface PeerManagerRegistrationAdapter

activateRequest

public int activateRequest(InetSocketAddress remote_address)

Specified by:

activateRequest in interface PeerManagerRegistrationAdapter

Parameters:

remote_address -

Returns:

one of the AT_ constants

deactivateRequest

public void deactivateRequest(InetSocketAddress remote_address)

Specified by:

deactivateRequest in interface PeerManagerRegistrationAdapter

getDescription

public String getDescription()

Specified by:

getDescription in interface PeerManagerRegistrationAdapter

start

protected void start()

getPeerCount

protected int getPeerCount()

stop

protected void stop()

activate

protected void activate(String reason_str,
 byte activation_reason)

deactivate

protected void deactivate()

createAnnouncer

protected TRTrackerAnnouncer createAnnouncer()
                                      throws TRTrackerAnnouncerException

Throws:

TRTrackerAnnouncerException

ensureActive

protected void ensureActive(String reason,
 byte a_reason)

checkDeactivation

protected void checkDeactivation()

enqueueReadRequest

public void enqueueReadRequest(PEPeer peer,
 DiskManagerReadRequest request,
 DiskManagerReadRequestListener listener)

remove

public void remove()

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.

getRelation

public LogRelation getRelation()

getString

protected String getString()

log

protected void log(String str)

log

protected void log(String str,
 Throwable e)