Class TRNonBlockingServer

java.lang.Object

com.biglybt.core.tracker.server.impl.TRTrackerServerImpl

com.biglybt.core.tracker.server.impl.tcp.TRTrackerServerTCP

com.biglybt.core.tracker.server.impl.tcp.nonblocking.TRNonBlockingServer

All Implemented Interfaces:

VirtualServerChannelSelector.SelectListener, TRTrackerServer

public class TRNonBlockingServer
extends TRTrackerServerTCP
implements VirtualServerChannelSelector.SelectListener

Nested Class Summary

Nested classes/interfaces inherited from class TRTrackerServerTCP

TRTrackerServerTCP.DOSEntry

Field Summary

Fields

Modifier and Type	Field	Description
private VirtualServerChannelSelector	accept_server
private static final int	CLOSE_DELAY
private boolean	closed
private List	connections_to_close
private InetAddress	current_bind_ip
private boolean	immediate_close
private static final LogIDs	LOGID
static final int	MAX_CONCURRENT_CONNECTIONS
private TRNonBlockingServerProcessorFactory	processor_factory
private List	processors
private final VirtualChannelSelector	read_selector
private static int	SELECT_LOOP_TIME
private final AEMonitor	this_mon
private static final int	TIMEOUT_CHECK_INTERVAL
private long	total_connections
private long	total_timeouts
private final VirtualChannelSelector	write_selector

Fields inherited from class TRTrackerServerTCP

class_mon, dos_log_file, PROCESSING_GET_LIMIT, PROCESSING_POST_MULTIPLIER

Fields inherited from class TRTrackerServerImpl

all_networks_permitted, announce_cache_period, announce_cache_threshold, banned_clients, CLIENT_TIMEOUT_MULTIPLIER, full_scrape_enable, listeners, listeners2, max_peers_to_send, max_seed_retention, permitted_networks, redirect_on_not_found, RETRY_MINIMUM_MILLIS, RETRY_MINIMUM_SECS, scrape_cache_period, seed_limit, send_peer_ids, support_experimental_extensions, TIMEOUT_CHECK

Fields inherited from interface TRTrackerServer

DEFAULT_ANNOUNCE_CACHE_PEER_THRESHOLD, DEFAULT_ANNOUNCE_CACHE_PERIOD, DEFAULT_INC_BY, DEFAULT_INC_PER, DEFAULT_MAX_RETRY_DELAY, DEFAULT_MIN_RETRY_DELAY, DEFAULT_NAME, DEFAULT_NAT_CHECK_SECS, DEFAULT_SCRAPE_CACHE_PERIOD, DEFAULT_SCRAPE_RETRY_PERCENTAGE, DEFAULT_TRACKER_PORT, DEFAULT_TRACKER_PORT_SSL

Constructor Summary

Constructors

Constructor	Description
TRNonBlockingServer(String _name, int _port, InetAddress _bind_ip, boolean _apply_ip_filter, boolean _start_up_ready, Map<String,Object> _properties, TRNonBlockingServerProcessorFactory _processor_factory)
TRNonBlockingServer(String _name, int _port, InetAddress _bind_ip, boolean _apply_ip_filter, TRNonBlockingServerProcessorFactory _processor_factory)
TRNonBlockingServer(String _name, int _port, InetAddress _bind_ip, boolean _apply_ip_filter, Map<String,Object> _properties, TRNonBlockingServerProcessorFactory _processor_factory)

Method Summary

Modifier and Type	Method	Description
void	checkTimeouts(long now)
void	closeLoop()
protected void	closeSupport()
InetAddress	getBindIP()
void	newConnectionAccepted(ServerSocketChannel server, SocketChannel channel)	The given connection has just been accepted.
protected void	readyToWrite(TRNonBlockingServerProcessor processor)
protected void	removeAndCloseConnection(TRNonBlockingServerProcessor processor)
protected void	selectLoop(VirtualChannelSelector selector)
void	setImmediateClose(boolean immediate)

Methods inherited from class TRTrackerServerTCP

checkDOS, checkDOSRemove, getHost, getPort, getRestrictNonBlocking, handleExternalRequest, isSSL, runProcessor, setPort, setRestrictNonBlocking

Methods inherited from class TRTrackerServerImpl

addAuthenticationListener, addLink, addListener, addListener2, addRequestListener, close, deny, destroySupport, getAllNetworksSupported, getAnnounceCachePeerThreshold, getAnnounceCachePeriod, getAnnounceRetryInterval, getBiasedPeers, getMaxPeersToSend, getMaxSeedRetention, getMinAnnounceRetryInterval, getMinScrapeRetryInterval, getName, getPassword, getPeers, getPermittedNetworks, getScrapeCachePeriod, getScrapeRetryInterval, getSeedAnnounceIntervalMultiplier, getSeedLimit, getSendPeerIds, getStats, getStats, getTorrent, getTorrent, getTorrentCount, getTorrents, getUsername, hasExternalAuthorisation, hasInternalAuthorisation, isCompactEnabled, isEnabled, isFullScrapeEnabled, isIPFiltered, isKeepAliveEnabled, isKeyEnabled, isKnownTorrent, isReady, isTrackerPasswordEnabled, isWebPasswordEnabled, isWebPasswordHTTPSOnly, performExternalAuthorisation, performExternalAuthorisation, permit, permit, postProcess, preProcess, readConfig, readConfigSettings, removeAuthenticationListener, removeLink, removeListener, removeListener2, removeRequestListener, setBiasedPeers, setEnabled, setEnableKeepAlive, setReady, supportsExtensions, timerLoop, updateStats, updateTime

Methods inherited from class Object

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

Field Details

LOGID

private static final LogIDs LOGID

TIMEOUT_CHECK_INTERVAL

private static final int TIMEOUT_CHECK_INTERVAL

See Also:

• Constant Field Values

CLOSE_DELAY

private static final int CLOSE_DELAY

See Also:

• Constant Field Values

SELECT_LOOP_TIME

private static int SELECT_LOOP_TIME

processor_factory

private TRNonBlockingServerProcessorFactory processor_factory

read_selector

private final VirtualChannelSelector read_selector

write_selector

private final VirtualChannelSelector write_selector

connections_to_close

private List connections_to_close

processors

private List processors

current_bind_ip

private InetAddress current_bind_ip

total_timeouts

private long total_timeouts

total_connections

private long total_connections

MAX_CONCURRENT_CONNECTIONS

public static final int MAX_CONCURRENT_CONNECTIONS

this_mon

private final AEMonitor this_mon

accept_server

private VirtualServerChannelSelector accept_server

immediate_close

private boolean immediate_close

closed

private volatile boolean closed

Constructor Details

TRNonBlockingServer

public TRNonBlockingServer(String _name,
 int _port,
 InetAddress _bind_ip,
 boolean _apply_ip_filter,
 TRNonBlockingServerProcessorFactory _processor_factory)
                    throws TRTrackerServerException

Throws:

TRTrackerServerException

TRNonBlockingServer

public TRNonBlockingServer(String _name,
 int _port,
 InetAddress _bind_ip,
 boolean _apply_ip_filter,
 Map<String,Object> _properties,
 TRNonBlockingServerProcessorFactory _processor_factory)
                    throws TRTrackerServerException

Throws:

TRTrackerServerException

TRNonBlockingServer

public TRNonBlockingServer(String _name,
 int _port,
 InetAddress _bind_ip,
 boolean _apply_ip_filter,
 boolean _start_up_ready,
 Map<String,Object> _properties,
 TRNonBlockingServerProcessorFactory _processor_factory)
                    throws TRTrackerServerException

Throws:

TRTrackerServerException

Method Details

getBindIP

public InetAddress getBindIP()

Specified by:

getBindIP in interface TRTrackerServer

setImmediateClose

public void setImmediateClose(boolean immediate)

selectLoop

protected void selectLoop(VirtualChannelSelector selector)

newConnectionAccepted

public void newConnectionAccepted(ServerSocketChannel server,
 SocketChannel channel)

Description copied from interface: VirtualServerChannelSelector.SelectListener

The given connection has just been accepted.

Specified by:

newConnectionAccepted in interface VirtualServerChannelSelector.SelectListener

Parameters:

channel - new connection

readyToWrite

protected void readyToWrite(TRNonBlockingServerProcessor processor)

removeAndCloseConnection

protected void removeAndCloseConnection(TRNonBlockingServerProcessor processor)

checkTimeouts

public void checkTimeouts(long now)

closeLoop

public void closeLoop()

closeSupport

protected void closeSupport()

Specified by:

closeSupport in class TRTrackerServerImpl