Class TRTrackerAnnouncerImpl

java.lang.Object

com.biglybt.core.tracker.client.impl.TRTrackerAnnouncerImpl

All Implemented Interfaces:

TRTrackerAnnouncer

Direct Known Subclasses:

TRTrackerAnnouncerMuxer

public abstract class TRTrackerAnnouncerImpl
extends Object
implements TRTrackerAnnouncer

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	TRTrackerAnnouncerImpl.Helper

Field Summary

Fields

Modifier and Type	Field	Description
private int	cache_peers_used
private static final String	chars
private static final int	key_id_length
private static final int	LDT_TRACKER_RESPONSE
private static final int	LDT_URL_CHANGED
private static final int	LDT_URL_REFRESH
protected final ListenerManager<TRTrackerAnnouncerListener>	listeners
static final LogIDs	LOGID
private final byte[]	peer_id
private final long	session_id
private static AtomicLong	session_id_next
private final TOTorrent	torrent
private final String	tracker_key
(package private) final Map<String, TRTrackerAnnouncerResponsePeer>	tracker_peer_cache
private final AEMonitor	tracker_peer_cache_mon
private final int	udp_key

Fields inherited from interface TRTrackerAnnouncer

AZ_TRACKER_VERSION_1, AZ_TRACKER_VERSION_2, AZ_TRACKER_VERSION_3, AZ_TRACKER_VERSION_CURRENT, DEFAULT_PEERS_TO_CACHE, REFRESH_MINIMUM_SECS, TS_COMPLETED, TS_DOWNLOADING, TS_INITIALISED, TS_STOPPED

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TRTrackerAnnouncerImpl(TOTorrent _torrent)

Method Summary

Modifier and Type	Method	Description
void	addListener(TRTrackerAnnouncerListener l)
protected void	addToTrackerCache(TRTrackerAnnouncerResponsePeerImpl[] peers)
void	clearTrackerResponseCache()
private static String	createKeyID()
protected Map	exportTrackerCache()
TrackerPeerSource	getCacheTrackerPeerSource()
TRTrackerAnnouncerImpl.Helper	getHelper()
protected abstract int	getPeerCacheLimit()
byte[]	getPeerId()
protected TRTrackerAnnouncerResponsePeer[]	getPeersFromCache(int num_want)
TOTorrent	getTorrent()
Map	getTrackerResponseCache()	returns a Map containing "bencoded" entries representing a cache of tracker responses.
protected int	importTrackerCache(Map map)
protected void	informResponse(TRTrackerAnnouncerHelper helper, TRTrackerAnnouncerRequest request, TRTrackerAnnouncerResponse response)
protected void	informURLRefresh()
static Map	mergeResponseCache(Map map1, Map map2)
void	removeFromTrackerResponseCache(String ip, int tcp_port)	remove a specific entry from the cache if present
void	removeListener(TRTrackerAnnouncerListener l)
void	setTrackerResponseCache(Map map)	sets the response cache.

Methods inherited from class Object

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

Methods inherited from interface TRTrackerAnnouncer

clearIPOverride, complete, destroy, generateEvidence, getBestAnnouncer, getLastResponse, getLastUpdateTime, getStatus, getStatusString, getTimeUntilNextUpdate, getTrackerPeerSource, getTrackerURL, isManual, refreshListeners, resetTrackerUrl, setAnnounceDataProvider, setAnnounceResult, setIPOverride, setRefreshDelayOverrides, setTrackerURL, stop, update

Field Details

LOGID

public static final LogIDs LOGID

LDT_TRACKER_RESPONSE

private static final int LDT_TRACKER_RESPONSE

See Also:

• Constant Field Values

LDT_URL_CHANGED

private static final int LDT_URL_CHANGED

See Also:

• Constant Field Values

LDT_URL_REFRESH

private static final int LDT_URL_REFRESH

See Also:

• Constant Field Values

chars

private static final String chars

See Also:

• Constant Field Values

key_id_length

private static final int key_id_length

See Also:

• Constant Field Values

session_id_next

private static AtomicLong session_id_next

listeners

protected final ListenerManager<TRTrackerAnnouncerListener> listeners

tracker_peer_cache

final Map<String, TRTrackerAnnouncerResponsePeer> tracker_peer_cache

tracker_peer_cache_mon

private final AEMonitor tracker_peer_cache_mon

cache_peers_used

private int cache_peers_used

torrent

private final TOTorrent torrent

peer_id

private final byte[] peer_id

session_id

private final long session_id

tracker_key

private final String tracker_key

udp_key

private final int udp_key

Constructor Details

TRTrackerAnnouncerImpl

protected TRTrackerAnnouncerImpl(TOTorrent _torrent)
                          throws TRTrackerAnnouncerException

Throws:

TRTrackerAnnouncerException

Method Details

createKeyID

private static String createKeyID()

getTorrent

public TOTorrent getTorrent()

Specified by:

getTorrent in interface TRTrackerAnnouncer

getHelper

public TRTrackerAnnouncerImpl.Helper getHelper()

getPeerId

public byte[] getPeerId()

Specified by:

getPeerId in interface TRTrackerAnnouncer

getTrackerResponseCache

public Map getTrackerResponseCache()

Description copied from interface: TRTrackerAnnouncer

returns a Map containing "bencoded" entries representing a cache of tracker responses.

Specified by:

getTrackerResponseCache in interface TRTrackerAnnouncer

Returns:

clearTrackerResponseCache

public void clearTrackerResponseCache()

Specified by:

clearTrackerResponseCache in interface TRTrackerAnnouncer

setTrackerResponseCache

public void setTrackerResponseCache(Map map)

Description copied from interface: TRTrackerAnnouncer

sets the response cache. This may be used by the tracker client to return peer details when the tracker is offline

Specified by:

setTrackerResponseCache in interface TRTrackerAnnouncer

Parameters:

map -

exportTrackerCache

protected Map exportTrackerCache()

importTrackerCache

protected int importTrackerCache(Map map)

addToTrackerCache

protected void addToTrackerCache(TRTrackerAnnouncerResponsePeerImpl[] peers)

removeFromTrackerResponseCache

public void removeFromTrackerResponseCache(String ip,
 int tcp_port)

Description copied from interface: TRTrackerAnnouncer

remove a specific entry from the cache if present

Specified by:

removeFromTrackerResponseCache in interface TRTrackerAnnouncer

Parameters:

ip -

tcp_port -

mergeResponseCache

public static Map mergeResponseCache(Map map1,
 Map map2)

getPeerCacheLimit

protected abstract int getPeerCacheLimit()

getPeersFromCache

protected TRTrackerAnnouncerResponsePeer[] getPeersFromCache(int num_want)

getCacheTrackerPeerSource

public TrackerPeerSource getCacheTrackerPeerSource()

Specified by:

getCacheTrackerPeerSource in interface TRTrackerAnnouncer

informResponse

protected void informResponse(TRTrackerAnnouncerHelper helper,
 TRTrackerAnnouncerRequest request,
 TRTrackerAnnouncerResponse response)

informURLRefresh

protected void informURLRefresh()

addListener

public void addListener(TRTrackerAnnouncerListener l)

Specified by:

addListener in interface TRTrackerAnnouncer

removeListener

public void removeListener(TRTrackerAnnouncerListener l)

Specified by:

removeListener in interface TRTrackerAnnouncer