Class TRTrackerBTAnnouncerImpl

java.lang.Object

com.biglybt.core.tracker.client.impl.bt.TRTrackerBTAnnouncerImpl

All Implemented Interfaces:

TRTrackerAnnouncerHelper, TRTrackerAnnouncer

public class TRTrackerBTAnnouncerImpl
extends Object
implements TRTrackerAnnouncerHelper

This class handles communication with the tracker

Field Summary

Fields

Modifier and Type	Field	Description
private static final AllTrackersManager.AllTrackers	all_trackers
private TRTrackerAnnouncerDataProvider	announce_data_provider
private final TOTorrentAnnounceURLSet[]	announce_urls
private int	announceCount
private int	announceFailCount
private byte	autoUDPprobeEvery
private int	autoUDPProbeSuccessCount
private boolean	az_tracker
private static final AEMonitor	class_mon
private boolean	complete_reported
private boolean	completed
private long	current_time_to_wait_secs
private TimerEvent	current_timer_event
private byte[]	data_peer_id
private boolean	destroyed
private boolean	dh_hack
private final int	dispersal_random
private boolean	enable_sni_hack
private int	failure_added_time
private long	failure_time_last_updated
private TRTrackerAnnouncerImpl.Helper	helper
private String	info_hash
private boolean	internal_error_hack
private String	ip_override
private TRTrackerAnnouncerResponseImpl	last_response
private String	last_tracker_message
private long	last_update_time_secs
private URL	lastAZTrackerCheckedURL
private URL	lastUsedUrl
static final LogIDs	LOGID
private final boolean	manual_control
private long	min_interval
private long	min_interval_override
private static final int	OVERRIDE_PERIOD
private final String[]	peer_networks
private long	rd_last_override
private int	rd_override_percentage
private boolean	stopped
private boolean	stopped_for_queue
private static boolean	tcpAnnounceEnabled
protected final AEMonitor	this_mon
private TimerEventPerformer	timer_event_action
private final TOTorrent	torrent
private final HashWrapper	torrent_hash_actual
private final HashWrapper	torrent_hash_target
private String	tracker_id
private long	tracker_interval
private long	tracker_min_interval
private byte[]	tracker_peer_id
private String	tracker_peer_id_str
private static final Map	tracker_report_map
protected int	tracker_state
private String	tracker_status_str
private final Timer	tracker_timer
private static final Timer	tracker_timer_private
private static final Timer	tracker_timer_public
private List<List<URL>>	trackerUrlLists
static final String	UDP_REALM
private static boolean	udpAnnounceEnabled
private static boolean	udpProbeEnabled
private boolean	update_in_progress
private static int	userMaxNumwant
private static int	userMinInterval
private InetSocketAddress	working_udp_ia

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

Constructor	Description
TRTrackerBTAnnouncerImpl(HashWrapper _torrent_hash_override, TOTorrent _torrent, TOTorrentAnnounceURLSet[] _announce_urls, String[] _peer_networks, boolean _manual, TRTrackerAnnouncerImpl.Helper _helper)

Method Summary

Modifier and Type	Method	Description
void	addListener(TRTrackerAnnouncerListener l)
(package private) static void	analyseTimerEvents()
(package private) static void	analyseTimerEvents(Timer timer)
private String	announceHTTP(URL[] tracker_url, URL original_reqUrl, ByteArrayOutputStream message, boolean first_effort)
private String	announceHTTPSupport(URL[] tracker_url, URL original_reqUrl, Proxy proxy, boolean first_effort, ByteArrayOutputStream message)
protected String	announceUDP(URL original_reqUrl, ByteArrayOutputStream message, boolean is_probe)
protected int	calculateNumWant()
void	clearIPOverride()
void	clearTrackerResponseCache()
void	cloneFrom(TRTrackerBTAnnouncerImpl other)
void	complete(boolean already_reported)
protected TRTrackerAnnouncerResponseImpl	completeSupport(TimerEvent timer_event)
private TRTrackerAnnouncerRequestImpl	constructRequest(String evt, URL _url, TimerEvent timer_event)
private void	constructTrackerUrlLists(boolean shuffle)
protected TRTrackerAnnouncerResponseImpl	decodeTrackerResponse(URL url, byte[] data)
void	destroy()
protected String	exceptionToString(Throwable e)
protected String	exceptionToString(HttpURLConnection con, Throwable e)
void	generateEvidence(IndentWriter writer)
protected long	getAdjustedSecsToWait()
TOTorrentAnnounceURLSet[]	getAnnounceSets()
TRTrackerAnnouncer	getBestAnnouncer()
TrackerPeerSource	getCacheTrackerPeerSource()
protected int	getErrorRetryInterval()	Retrieve the retry interval to use on announce errors.
long	getInterval()
TRTrackerAnnouncerResponse	getLastResponse()
int	getLastUpdateTime()	Last Update Time in seconds
private Long	getLong(Map map, String key)
protected long	getLongURLParam(String url, String param)
long	getMinInterval()
byte[]	getPeerId()
int	getStatus()
String	getStatusString()
int	getTimeUntilNextUpdate()
TOTorrent	getTorrent()
TrackerPeerSource	getTrackerPeerSource(TOTorrentAnnounceURLSet set)	Gets a delegate tracker peer source for reporting against
Map	getTrackerResponseCache()	returns a Map containing "bencoded" entries representing a cache of tracker responses.
URL	getTrackerURL()
protected String	getURLParam(String url, String param)
protected void	informURLChange(URL old_url, URL new_url, boolean explicit)
protected void	informURLRefresh()
boolean	isManual()
boolean	isUpdating()
void	refreshListeners()	This method forces all listeners to get an explicit "urlChanged" event to get them to re-examine the tracker
void	removeFromTrackerResponseCache(String ip, int tcpPort)	remove a specific entry from the cache if present
void	removeListener(TRTrackerAnnouncerListener l)
protected void	requestUpdate()
protected long	requestUpdateSupport(TimerEvent timer_event)
void	resetTrackerUrl(boolean shuffle)
void	setAnnounceDataProvider(TRTrackerAnnouncerDataProvider _provider)
void	setAnnounceResult(DownloadAnnounceResult result)
void	setIPOverride(String override)
void	setRefreshDelayOverrides(int percentage)
void	setTrackerResponseCache(Map map)	sets the response cache.
void	setTrackerURL(URL new_url)
protected TRTrackerAnnouncerResponseImpl	startSupport(TimerEvent timer_event)
void	stop(boolean for_queue)
protected TRTrackerAnnouncerResponseImpl	stopSupport(TimerEvent timer_event)
protected String	trackerURLListToString()
void	update(boolean force)
private TRTrackerAnnouncerResponseImpl	update(String evt, TimerEvent timer_event)
private TRTrackerAnnouncerResponseImpl	update2(String evt, TimerEvent timer_event)
private TRTrackerAnnouncerResponseImpl	update2Support(String evt, TimerEvent event)
private byte[]	updateOld(URL[] tracker_url, URL reqUrl)
protected TRTrackerAnnouncerResponseImpl	updateSupport(TimerEvent timer_event)

Methods inherited from class Object

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

Field Details

LOGID

public static final LogIDs LOGID

OVERRIDE_PERIOD

private static final int OVERRIDE_PERIOD

See Also:

• Constant Field Values

tracker_timer_public

private static final Timer tracker_timer_public

tracker_timer_private

private static final Timer tracker_timer_private

all_trackers

private static final AllTrackersManager.AllTrackers all_trackers

UDP_REALM

public static final String UDP_REALM

See Also:

• Constant Field Values

userMinInterval

private static int userMinInterval

userMaxNumwant

private static int userMaxNumwant

tcpAnnounceEnabled

private static boolean tcpAnnounceEnabled

udpAnnounceEnabled

private static boolean udpAnnounceEnabled

udpProbeEnabled

private static boolean udpProbeEnabled

class_mon

private static final AEMonitor class_mon

tracker_report_map

private static final Map tracker_report_map

tracker_timer

private final Timer tracker_timer

torrent

private final TOTorrent torrent

announce_urls

private final TOTorrentAnnounceURLSet[] announce_urls

helper

private TRTrackerAnnouncerImpl.Helper helper

current_timer_event

private TimerEvent current_timer_event

timer_event_action

private TimerEventPerformer timer_event_action

tracker_state

protected int tracker_state

tracker_status_str

private String tracker_status_str

last_response

private TRTrackerAnnouncerResponseImpl last_response

last_update_time_secs

private long last_update_time_secs

current_time_to_wait_secs

private long current_time_to_wait_secs

manual_control

private final boolean manual_control

dispersal_random

private final int dispersal_random

tracker_interval

private long tracker_interval

tracker_min_interval

private long tracker_min_interval

min_interval

private long min_interval

failure_added_time

private int failure_added_time

failure_time_last_updated

private long failure_time_last_updated

stopped

private boolean stopped

stopped_for_queue

private boolean stopped_for_queue

completed

private boolean completed

complete_reported

private boolean complete_reported

update_in_progress

private boolean update_in_progress

rd_last_override

private long rd_last_override

rd_override_percentage

private int rd_override_percentage

min_interval_override

private long min_interval_override

trackerUrlLists

private List<List<URL>> trackerUrlLists

lastUsedUrl

private URL lastUsedUrl

lastAZTrackerCheckedURL

private URL lastAZTrackerCheckedURL

torrent_hash_actual

private final HashWrapper torrent_hash_actual

torrent_hash_target

private final HashWrapper torrent_hash_target

last_tracker_message

private String last_tracker_message

info_hash

private String info_hash

tracker_peer_id

private byte[] tracker_peer_id

tracker_peer_id_str

private String tracker_peer_id_str

data_peer_id

private byte[] data_peer_id

announceCount

private int announceCount

announceFailCount

private int announceFailCount

autoUDPprobeEvery

private byte autoUDPprobeEvery

autoUDPProbeSuccessCount

private int autoUDPProbeSuccessCount

working_udp_ia

private InetSocketAddress working_udp_ia

tracker_id

private String tracker_id

ip_override

private String ip_override

peer_networks

private final String[] peer_networks

announce_data_provider

private TRTrackerAnnouncerDataProvider announce_data_provider

this_mon

protected final AEMonitor this_mon

az_tracker

private boolean az_tracker

enable_sni_hack

private boolean enable_sni_hack

internal_error_hack

private boolean internal_error_hack

dh_hack

private boolean dh_hack

destroyed

private boolean destroyed

Constructor Details

TRTrackerBTAnnouncerImpl

public TRTrackerBTAnnouncerImpl(HashWrapper _torrent_hash_override,
 TOTorrent _torrent,
 TOTorrentAnnounceURLSet[] _announce_urls,
 String[] _peer_networks,
 boolean _manual,
 TRTrackerAnnouncerImpl.Helper _helper)
                         throws TRTrackerAnnouncerException

Throws:

TRTrackerAnnouncerException

Method Details

analyseTimerEvents

static void analyseTimerEvents()

analyseTimerEvents

static void analyseTimerEvents(Timer timer)

cloneFrom

public void cloneFrom(TRTrackerBTAnnouncerImpl other)

getAdjustedSecsToWait

protected long getAdjustedSecsToWait()

getStatus

public int getStatus()

Specified by:

getStatus in interface TRTrackerAnnouncer

getStatusString

public String getStatusString()

Specified by:

getStatusString in interface TRTrackerAnnouncer

getBestAnnouncer

public TRTrackerAnnouncer getBestAnnouncer()

Specified by:

getBestAnnouncer in interface TRTrackerAnnouncer

setRefreshDelayOverrides

public void setRefreshDelayOverrides(int percentage)

Specified by:

setRefreshDelayOverrides in interface TRTrackerAnnouncer

isUpdating

public boolean isUpdating()

Specified by:

isUpdating in interface TRTrackerAnnouncerHelper

getInterval

public long getInterval()

Specified by:

getInterval in interface TRTrackerAnnouncerHelper

getMinInterval

public long getMinInterval()

Specified by:

getMinInterval in interface TRTrackerAnnouncerHelper

getTimeUntilNextUpdate

public int getTimeUntilNextUpdate()

Specified by:

getTimeUntilNextUpdate in interface TRTrackerAnnouncer

Specified by:

getTimeUntilNextUpdate in interface TRTrackerAnnouncerHelper

getLastUpdateTime

public int getLastUpdateTime()

Description copied from interface: TRTrackerAnnouncer

Last Update Time in seconds

Specified by:

getLastUpdateTime in interface TRTrackerAnnouncer

update

public void update(boolean force)

Specified by:

update in interface TRTrackerAnnouncer

complete

public void complete(boolean already_reported)

Specified by:

complete in interface TRTrackerAnnouncer

stop

public void stop(boolean for_queue)

Specified by:

stop in interface TRTrackerAnnouncer

requestUpdate

protected void requestUpdate()

requestUpdateSupport

protected long requestUpdateSupport(TimerEvent timer_event)

startSupport

protected TRTrackerAnnouncerResponseImpl startSupport(TimerEvent timer_event)

completeSupport

protected TRTrackerAnnouncerResponseImpl completeSupport(TimerEvent timer_event)

stopSupport

protected TRTrackerAnnouncerResponseImpl stopSupport(TimerEvent timer_event)

updateSupport

protected TRTrackerAnnouncerResponseImpl updateSupport(TimerEvent timer_event)

update

private TRTrackerAnnouncerResponseImpl update(String evt,
 TimerEvent timer_event)

update2

private TRTrackerAnnouncerResponseImpl update2(String evt,
 TimerEvent timer_event)

update2Support

private TRTrackerAnnouncerResponseImpl update2Support(String evt,
 TimerEvent event)

updateOld

private byte[] updateOld(URL[] tracker_url,
 URL reqUrl)
                  throws Exception

Throws:

Exception

announceHTTP

private String announceHTTP(URL[] tracker_url,
 URL original_reqUrl,
 ByteArrayOutputStream message,
 boolean first_effort)
                     throws Exception

Throws:

Exception

announceHTTPSupport

private String announceHTTPSupport(URL[] tracker_url,
 URL original_reqUrl,
 Proxy proxy,
 boolean first_effort,
 ByteArrayOutputStream message)
                            throws IOException

Throws:

IOException

announceUDP

protected String announceUDP(URL original_reqUrl,
 ByteArrayOutputStream message,
 boolean is_probe)

getLongURLParam

protected long getLongURLParam(String url,
 String param)

getURLParam

protected String getURLParam(String url,
 String param)

exceptionToString

protected String exceptionToString(Throwable e)

exceptionToString

protected String exceptionToString(HttpURLConnection con,
 Throwable e)

constructRequest

private TRTrackerAnnouncerRequestImpl constructRequest(String evt,
 URL _url,
 TimerEvent timer_event)
                                                throws Exception

Throws:

Exception

calculateNumWant

protected int calculateNumWant()

getPeerId

public byte[] getPeerId()

Specified by:

getPeerId in interface TRTrackerAnnouncer

setAnnounceDataProvider

public void setAnnounceDataProvider(TRTrackerAnnouncerDataProvider _provider)

Specified by:

setAnnounceDataProvider in interface TRTrackerAnnouncer

getTorrent

public TOTorrent getTorrent()

Specified by:

getTorrent in interface TRTrackerAnnouncer

getTrackerURL

public URL getTrackerURL()

Specified by:

getTrackerURL in interface TRTrackerAnnouncer

setTrackerURL

public void setTrackerURL(URL new_url)

Specified by:

setTrackerURL in interface TRTrackerAnnouncer

getAnnounceSets

public TOTorrentAnnounceURLSet[] getAnnounceSets()

Specified by:

getAnnounceSets in interface TRTrackerAnnouncerHelper

resetTrackerUrl

public void resetTrackerUrl(boolean shuffle)

Specified by:

resetTrackerUrl in interface TRTrackerAnnouncer

refreshListeners

public void refreshListeners()

Description copied from interface: TRTrackerAnnouncer

This method forces all listeners to get an explicit "urlChanged" event to get them to re-examine the tracker

Specified by:

refreshListeners in interface TRTrackerAnnouncer

setIPOverride

public void setIPOverride(String override)

Specified by:

setIPOverride in interface TRTrackerAnnouncer

clearIPOverride

public void clearIPOverride()

Specified by:

clearIPOverride in interface TRTrackerAnnouncer

constructTrackerUrlLists

private void constructTrackerUrlLists(boolean shuffle)

trackerURLListToString

protected String trackerURLListToString()

decodeTrackerResponse

protected TRTrackerAnnouncerResponseImpl decodeTrackerResponse(URL url,
 byte[] data)

getLong

private Long getLong(Map map,
 String key)

informURLChange

protected void informURLChange(URL old_url,
 URL new_url,
 boolean explicit)

informURLRefresh

protected void informURLRefresh()

getLastResponse

public TRTrackerAnnouncerResponse getLastResponse()

Specified by:

getLastResponse in interface TRTrackerAnnouncer

isManual

public boolean isManual()

Specified by:

isManual in interface TRTrackerAnnouncer

destroy

public void destroy()

Specified by:

destroy in interface TRTrackerAnnouncer

getErrorRetryInterval

protected int getErrorRetryInterval()

Retrieve the retry interval to use on announce errors.

setAnnounceResult

public void setAnnounceResult(DownloadAnnounceResult result)

Specified by:

setAnnounceResult in interface TRTrackerAnnouncer

addListener

public void addListener(TRTrackerAnnouncerListener l)

Specified by:

addListener in interface TRTrackerAnnouncer

removeListener

public void removeListener(TRTrackerAnnouncerListener l)

Specified by:

removeListener 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 -

removeFromTrackerResponseCache

public void removeFromTrackerResponseCache(String ip,
 int tcpPort)

Description copied from interface: TRTrackerAnnouncer

remove a specific entry from the cache if present

Specified by:

removeFromTrackerResponseCache in interface TRTrackerAnnouncer

Parameters:

ip -

tcpPort -

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

getTrackerPeerSource

public TrackerPeerSource getTrackerPeerSource(TOTorrentAnnounceURLSet set)

Description copied from interface: TRTrackerAnnouncer

Gets a delegate tracker peer source for reporting against

Specified by:

getTrackerPeerSource in interface TRTrackerAnnouncer

Parameters:

set -

Returns:

getCacheTrackerPeerSource

public TrackerPeerSource getCacheTrackerPeerSource()

Specified by:

getCacheTrackerPeerSource in interface TRTrackerAnnouncer

generateEvidence

public void generateEvidence(IndentWriter writer)

Specified by:

generateEvidence in interface TRTrackerAnnouncer