Class AllTrackersManagerImpl

java.lang.Object

com.biglybt.core.tracker.alltrackers.AllTrackersManagerImpl

All Implemented Interfaces:

TOTorrentListener, AllTrackersManager.AllTrackers

public class AllTrackersManagerImpl
extends Object
implements AllTrackersManager.AllTrackers, TOTorrentListener

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	AllTrackersManagerImpl.AllTrackersEventImpl
private class	AllTrackersManagerImpl.AllTrackersTrackerImpl

Field Summary

Fields

Modifier and Type	Field	Description
private static final List<String>	active
private Map<TRTrackerAnnouncerRequest, String>	active_requests
private AllTrackersManager.AnnounceStatsProvider	announce_provider
private final Average	announce_rate
private AllTrackersManager.AnnounceStats	announce_stats
(package private) AsyncDispatcher	asyncDisp
private static final String	CONFIG_FILE
private static final String	CONFIG_PRIVATE_ACTIVE_AT_CLOSE
private final Core	core
private Map<HashWrapper, String>	dm_name_cache
private boolean	got_running
private Map<String, AllTrackersManagerImpl.AllTrackersTrackerImpl>	host_map
private MovingImmediateAverage	lag_average
(package private) static final int	LAG_CHECK_PERIOD
(package private) static final int	LAG_CHECK_TICKS
private boolean	lag_logged
private CopyOnWriteList<AllTrackersManager.AllTrackersListener>	listeners
private Map<String, LoggerChannel>	logging_keys
(package private) static final int	MAX_TRACKERS
private AtomicLong	options_mutation_count
private List<TOTorrent>	pending_torrents
private final Object	process_lock
(package private) static final int	SAVE_PERIOD
(package private) static final int	SAVE_TICKS
private AllTrackersManager.ScrapeStatsProvider	scrape_provider
private final Average	scrape_rate
private AllTrackersManager.ScrapeStats	scrape_stats
private static final AllTrackersManagerImpl	singleton
private final long	start_time
private boolean	started
private boolean	stopping
(package private) static final int	TICK_PERIOD
private final FrequencyLimitedDispatcher	totalDisp
private ConcurrentLinkedDeque<Object[]>	update_queue

Fields inherited from interface TOTorrentListener

CT_ANNOUNCE_URLS

Constructor Summary

Constructors

Modifier	Constructor	Description
private	AllTrackersManagerImpl()

Method Summary

Modifier and Type	Method	Description
void	addActiveRequest(TRTrackerAnnouncerRequest request)
void	addListener(AllTrackersManager.AllTrackersListener listener, boolean fire_for_existing)
void	addScrapeRequest()
private void	checkLag()
int	getActiveRequestCount()
float	getAnnouncesPerSecond()
AllTrackersManager.AnnounceStats	getAnnounceStats()
File	getLogFile(String short_key)
private LoggerChannel	getLogger(String short_key)
boolean	getLoggingEnabled(String short_key)
long	getOptionsMutationCount()
float	getScrapesPerSecond()
AllTrackersManager.ScrapeStats	getScrapeStats()
static AllTrackersManager.AllTrackers	getSingleton()
AllTrackersManager.AllTrackersTracker	getTracker(String name)
AllTrackersManager.AllTrackersTracker	getTracker(URL url)
int	getTrackerCount()
String	ingestURL(URL url)
boolean	isStopping()
private void	loadConfig()
private void	processUpdates(boolean for_close)
(package private) void	queueCommand(AllTrackersManagerImpl.AllTrackersTrackerImpl tracker, String cmd)
private void	recalcTotals()
private AllTrackersManagerImpl.AllTrackersTrackerImpl	register(TOTorrent torrent_maybe_null, String name)
private AllTrackersManagerImpl.AllTrackersTrackerImpl	register(TOTorrent torrent_maybe_null, URL url)
void	registerAnnounceStatsProvider(AllTrackersManager.AnnounceStatsProvider provider)
void	registerScrapeStatsProvider(AllTrackersManager.ScrapeStatsProvider provider)
void	registerTorrent(TOTorrent torrent)
private void	registerTorrentSupport(TOTorrent torrent)
void	registerTracker(TOTorrent torrent, URL url)
void	registerTrackers(TOTorrent torrent, List<List<URL>> trackers)
void	removeActiveRequest(TRTrackerAnnouncerRequest request)
void	removeListener(AllTrackersManager.AllTrackersListener listener)
void	removeScrapeRequest()
private void	saveConfig(boolean closing)
void	setLoggingEnabled(String short_key, boolean enabled)
void	torrentChanged(TOTorrent torrent, int change_type, Object data)
void	unregisterTorrent(TOTorrent torrent)
private void	unregisterTracker(String name)
private void	updateLogging()
void	updateTracker(String key, TRTrackerAnnouncerRequest request)
void	updateTracker(URL url, TRTrackerAnnouncerResponse response)
void	updateTracker(URL url, TRTrackerScraperResponse response)

Methods inherited from class Object

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

Field Details

MAX_TRACKERS

static final int MAX_TRACKERS

See Also:

• Constant Field Values

TICK_PERIOD

static final int TICK_PERIOD

See Also:

• Constant Field Values

SAVE_PERIOD

static final int SAVE_PERIOD

See Also:

• Constant Field Values

SAVE_TICKS

static final int SAVE_TICKS

See Also:

• Constant Field Values

LAG_CHECK_PERIOD

static final int LAG_CHECK_PERIOD

See Also:

• Constant Field Values

LAG_CHECK_TICKS

static final int LAG_CHECK_TICKS

See Also:

• Constant Field Values

CONFIG_FILE

private static final String CONFIG_FILE

See Also:

• Constant Field Values

CONFIG_PRIVATE_ACTIVE_AT_CLOSE

private static final String CONFIG_PRIVATE_ACTIVE_AT_CLOSE

See Also:

• Constant Field Values

singleton

private static final AllTrackersManagerImpl singleton

start_time

private final long start_time

core

private final Core core

started

private volatile boolean started

stopping

private volatile boolean stopping

host_map

private Map<String, AllTrackersManagerImpl.AllTrackersTrackerImpl> host_map

update_queue

private ConcurrentLinkedDeque<Object[]> update_queue

listeners

private CopyOnWriteList<AllTrackersManager.AllTrackersListener> listeners

active_requests

private Map<TRTrackerAnnouncerRequest, String> active_requests

got_running

private boolean got_running

process_lock

private final Object process_lock

pending_torrents

private List<TOTorrent> pending_torrents

logging_keys

private Map<String, LoggerChannel> logging_keys

dm_name_cache

private Map<HashWrapper, String> dm_name_cache

options_mutation_count

private AtomicLong options_mutation_count

lag_average

private MovingImmediateAverage lag_average

lag_logged

private boolean lag_logged

active

private static final List<String> active

announce_rate

private final Average announce_rate

scrape_rate

private final Average scrape_rate

announce_stats

private AllTrackersManager.AnnounceStats announce_stats

scrape_stats

private volatile AllTrackersManager.ScrapeStats scrape_stats

announce_provider

private AllTrackersManager.AnnounceStatsProvider announce_provider

scrape_provider

private AllTrackersManager.ScrapeStatsProvider scrape_provider

totalDisp

private final FrequencyLimitedDispatcher totalDisp

asyncDisp

AsyncDispatcher asyncDisp

Constructor Details

AllTrackersManagerImpl

private AllTrackersManagerImpl()

Method Details

getSingleton

public static AllTrackersManager.AllTrackers getSingleton()

isStopping

public boolean isStopping()

Specified by:

isStopping in interface AllTrackersManager.AllTrackers

checkLag

private void checkLag()

processUpdates

private void processUpdates(boolean for_close)

loadConfig

private void loadConfig()

saveConfig

private void saveConfig(boolean closing)

updateLogging

private void updateLogging()

registerAnnounceStatsProvider

public void registerAnnounceStatsProvider(AllTrackersManager.AnnounceStatsProvider provider)

Specified by:

registerAnnounceStatsProvider in interface AllTrackersManager.AllTrackers

registerScrapeStatsProvider

public void registerScrapeStatsProvider(AllTrackersManager.ScrapeStatsProvider provider)

Specified by:

registerScrapeStatsProvider in interface AllTrackersManager.AllTrackers

addActiveRequest

public void addActiveRequest(TRTrackerAnnouncerRequest request)

Specified by:

addActiveRequest in interface AllTrackersManager.AllTrackers

removeActiveRequest

public void removeActiveRequest(TRTrackerAnnouncerRequest request)

Specified by:

removeActiveRequest in interface AllTrackersManager.AllTrackers

addScrapeRequest

public void addScrapeRequest()

Specified by:

addScrapeRequest in interface AllTrackersManager.AllTrackers

removeScrapeRequest

public void removeScrapeRequest()

Specified by:

removeScrapeRequest in interface AllTrackersManager.AllTrackers

getActiveRequestCount

public int getActiveRequestCount()

Specified by:

getActiveRequestCount in interface AllTrackersManager.AllTrackers

getAnnouncesPerSecond

public float getAnnouncesPerSecond()

Specified by:

getAnnouncesPerSecond in interface AllTrackersManager.AllTrackers

getScrapesPerSecond

public float getScrapesPerSecond()

Specified by:

getScrapesPerSecond in interface AllTrackersManager.AllTrackers

getAnnounceStats

public AllTrackersManager.AnnounceStats getAnnounceStats()

Specified by:

getAnnounceStats in interface AllTrackersManager.AllTrackers

getScrapeStats

public AllTrackersManager.ScrapeStats getScrapeStats()

Specified by:

getScrapeStats in interface AllTrackersManager.AllTrackers

getTrackerCount

public int getTrackerCount()

Specified by:

getTrackerCount in interface AllTrackersManager.AllTrackers

recalcTotals

private void recalcTotals()

registerTorrent

public void registerTorrent(TOTorrent torrent)

Specified by:

registerTorrent in interface AllTrackersManager.AllTrackers

unregisterTorrent

public void unregisterTorrent(TOTorrent torrent)

Specified by:

unregisterTorrent in interface AllTrackersManager.AllTrackers

registerTorrentSupport

private void registerTorrentSupport(TOTorrent torrent)

torrentChanged

public void torrentChanged(TOTorrent torrent,
 int change_type,
 Object data)

Specified by:

torrentChanged in interface TOTorrentListener

registerTracker

public void registerTracker(TOTorrent torrent,
 URL url)

Specified by:

registerTracker in interface AllTrackersManager.AllTrackers

registerTrackers

public void registerTrackers(TOTorrent torrent,
 List<List<URL>> trackers)

Specified by:

registerTrackers in interface AllTrackersManager.AllTrackers

getOptionsMutationCount

public long getOptionsMutationCount()

Specified by:

getOptionsMutationCount in interface AllTrackersManager.AllTrackers

ingestURL

public String ingestURL(URL url)

Specified by:

ingestURL in interface AllTrackersManager.AllTrackers

register

private AllTrackersManagerImpl.AllTrackersTrackerImpl register(TOTorrent torrent_maybe_null,
 URL url)

register

private AllTrackersManagerImpl.AllTrackersTrackerImpl register(TOTorrent torrent_maybe_null,
 String name)

unregisterTracker

private void unregisterTracker(String name)

updateTracker

public void updateTracker(URL url,
 TRTrackerAnnouncerResponse response)

Specified by:

updateTracker in interface AllTrackersManager.AllTrackers

updateTracker

public void updateTracker(String key,
 TRTrackerAnnouncerRequest request)

Specified by:

updateTracker in interface AllTrackersManager.AllTrackers

updateTracker

public void updateTracker(URL url,
 TRTrackerScraperResponse response)

Specified by:

updateTracker in interface AllTrackersManager.AllTrackers

queueCommand

void queueCommand(AllTrackersManagerImpl.AllTrackersTrackerImpl tracker,
 String cmd)

getTracker

public AllTrackersManager.AllTrackersTracker getTracker(String name)

Specified by:

getTracker in interface AllTrackersManager.AllTrackers

getTracker

public AllTrackersManager.AllTrackersTracker getTracker(URL url)

Specified by:

getTracker in interface AllTrackersManager.AllTrackers

getLoggingEnabled

public boolean getLoggingEnabled(String short_key)

Specified by:

getLoggingEnabled in interface AllTrackersManager.AllTrackers

setLoggingEnabled

public void setLoggingEnabled(String short_key,
 boolean enabled)

Specified by:

setLoggingEnabled in interface AllTrackersManager.AllTrackers

getLogger

private LoggerChannel getLogger(String short_key)

getLogFile

public File getLogFile(String short_key)

Specified by:

getLogFile in interface AllTrackersManager.AllTrackers

addListener

public void addListener(AllTrackersManager.AllTrackersListener listener,
 boolean fire_for_existing)

Specified by:

addListener in interface AllTrackersManager.AllTrackers

removeListener

public void removeListener(AllTrackersManager.AllTrackersListener listener)

Specified by:

removeListener in interface AllTrackersManager.AllTrackers