Class TrackerStatus

java.lang.Object

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

public class TrackerStatus
extends Object

One TrackerStatus object handles scrape functionality for all torrents on one tracker.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	TrackerStatus.ScrapeTask

Field Summary

Fields

Modifier and Type	Field	Description
private static final AllTrackersManager.AllTrackers	all_trackers
private final AllTrackersManager.AllTrackersTracker	all_trackers_tracker
private byte	autoUDPscrapeEvery
private boolean	az_tracker
private boolean	bSingleHashScrapes
private final TrackerChecker	checker
private boolean	dh_hack
private boolean	enable_sni_hack
private static final int	FAULTY_SCRAPE_RETRY_INTERVAL
private static final int	GROUP_SCRAPES_LIMIT
private static final int	GROUP_SCRAPES_MS	When scraping a single hash, also scrape other hashes that are going to be scraped within this range.
private final HashMap<HashWrapper, TRTrackerScraperResponseImpl>	hashes	key = Torrent hash.
protected final AEMonitor	hashes_mon
private boolean	internal_error_hack
private static final List	logged_invalid_urls
private static final LogIDs	LOGID
private static final int	NOHASH_RETRY_INTERVAL
private final AtomicInteger	numActiveScrapes
private int	scrapeCount
private final TRTrackerScraperImpl	scraper	only needed to notify listeners
private String	scrapeURL
private static final String	SS
private static final String	SSErr
private static boolean	tcpScrapeEnabled
private static final ThreadPool	thread_pool
private final URL	tracker_url
private static boolean	udpProbeEnabled
private static boolean	udpScrapeEnabled

Constructor Summary

Constructors

Constructor	Description
TrackerStatus(TrackerChecker _checker, TRTrackerScraperImpl _scraper, URL _tracker_url)

Method Summary

Modifier and Type	Method	Description
protected TRTrackerScraperResponseImpl	addHash(HashWrapper hash)
private String	formatScrapeErrorMessage(URL reqURL, String msg)
protected TRTrackerScraperResponseImpl	getHashData(HashWrapper hash)
protected Map	getHashes()
protected AEMonitor	getHashesMonitor()
int	getNumActiveScrapes()
protected String	getString()
boolean	getSupportsMultipeHashScrapes()
protected URL	getTrackerURL()
protected String	getURLParam(String url, String param)
protected boolean	isTrackerScrapeUrlValid()
protected void	removeHash(HashWrapper hash)
protected void	runScrapes(ArrayList<TRTrackerScraperResponseImpl> responses, boolean force, boolean async)
protected void	runScrapesSupport(ArrayList<TRTrackerScraperResponseImpl> allResponses, boolean force)
private URL	scrapeHTTP(List<HashWrapper> hashesInQuery, URL[] _reqUrl, ByteArrayOutputStream message)
private URL	scrapeHTTPSupport(URL[] _reqUrl, byte[] example_hash, Proxy proxy, ByteArrayOutputStream message)
protected void	scrapeReceived(TRTrackerScraperResponse response)
protected boolean	scrapeUDP(URL reqUrl, ByteArrayOutputStream message, List<HashWrapper> hashesInQuery, boolean do_auth_test)
private void	setAllError(URL reqURL, List<TRTrackerScraperResponseImpl> responses, Exception e)
protected void	updateSingleHash(HashWrapper hash, boolean force)
protected void	updateSingleHash(HashWrapper hash, boolean force, boolean async)

Methods inherited from class Object

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

Field Details

LOGID

private static final LogIDs LOGID

SS

private static final String SS

See Also:

• Constant Field Values

SSErr

private static final String SSErr

See Also:

• Constant Field Values

FAULTY_SCRAPE_RETRY_INTERVAL

private static final int FAULTY_SCRAPE_RETRY_INTERVAL

See Also:

• Constant Field Values

NOHASH_RETRY_INTERVAL

private static final int NOHASH_RETRY_INTERVAL

See Also:

• Constant Field Values

GROUP_SCRAPES_MS

private static final int GROUP_SCRAPES_MS

When scraping a single hash, also scrape other hashes that are going to be scraped within this range.

See Also:

• Constant Field Values

GROUP_SCRAPES_LIMIT

private static final int GROUP_SCRAPES_LIMIT

See Also:

• Constant Field Values

tcpScrapeEnabled

private static boolean tcpScrapeEnabled

udpScrapeEnabled

private static boolean udpScrapeEnabled

udpProbeEnabled

private static boolean udpProbeEnabled

all_trackers

private static final AllTrackersManager.AllTrackers all_trackers

autoUDPscrapeEvery

private byte autoUDPscrapeEvery

scrapeCount

private int scrapeCount

logged_invalid_urls

private static final List logged_invalid_urls

thread_pool

private static final ThreadPool thread_pool

tracker_url

private final URL tracker_url

all_trackers_tracker

private final AllTrackersManager.AllTrackersTracker all_trackers_tracker

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

scrapeURL

private String scrapeURL

hashes

private final HashMap<HashWrapper, TRTrackerScraperResponseImpl> hashes

key = Torrent hash. values = TRTrackerScraperResponseImpl

scraper

private final TRTrackerScraperImpl scraper

only needed to notify listeners

bSingleHashScrapes

private boolean bSingleHashScrapes

hashes_mon

protected final AEMonitor hashes_mon

checker

private final TrackerChecker checker

numActiveScrapes

private final AtomicInteger numActiveScrapes

Constructor Details

TrackerStatus

public TrackerStatus(TrackerChecker _checker,
 TRTrackerScraperImpl _scraper,
 URL _tracker_url)

Method Details

isTrackerScrapeUrlValid

protected boolean isTrackerScrapeUrlValid()

getHashData

protected TRTrackerScraperResponseImpl getHashData(HashWrapper hash)

updateSingleHash

protected void updateSingleHash(HashWrapper hash,
 boolean force)

updateSingleHash

protected void updateSingleHash(HashWrapper hash,
 boolean force,
 boolean async)

runScrapes

protected void runScrapes(ArrayList<TRTrackerScraperResponseImpl> responses,
 boolean force,
 boolean async)

runScrapesSupport

protected void runScrapesSupport(ArrayList<TRTrackerScraperResponseImpl> allResponses,
 boolean force)

formatScrapeErrorMessage

private String formatScrapeErrorMessage(URL reqURL,
 String msg)

setAllError

private void setAllError(URL reqURL,
 List<TRTrackerScraperResponseImpl> responses,
 Exception e)

scrapeHTTP

private URL scrapeHTTP(List<HashWrapper> hashesInQuery,
 URL[] _reqUrl,
 ByteArrayOutputStream message)
                throws Exception

Throws:

Exception

scrapeHTTPSupport

private URL scrapeHTTPSupport(URL[] _reqUrl,
 byte[] example_hash,
 Proxy proxy,
 ByteArrayOutputStream message)
                       throws IOException

Throws:

IOException

scrapeUDP

protected boolean scrapeUDP(URL reqUrl,
 ByteArrayOutputStream message,
 List<HashWrapper> hashesInQuery,
 boolean do_auth_test)
                     throws Throwable

Throws:

Throwable

getURLParam

protected String getURLParam(String url,
 String param)

addHash

protected TRTrackerScraperResponseImpl addHash(HashWrapper hash)

removeHash

protected void removeHash(HashWrapper hash)

getTrackerURL

protected URL getTrackerURL()

getHashes

protected Map getHashes()

getHashesMonitor

protected AEMonitor getHashesMonitor()

scrapeReceived

protected void scrapeReceived(TRTrackerScraperResponse response)

getSupportsMultipeHashScrapes

public boolean getSupportsMultipeHashScrapes()

getString

protected String getString()

getNumActiveScrapes

public int getNumActiveScrapes()