Class TRTrackerServerProcessorUDP

java.lang.Object

com.biglybt.core.util.AERunnable

com.biglybt.core.util.ThreadPoolTask

com.biglybt.core.tracker.server.impl.TRTrackerServerProcessor

com.biglybt.core.tracker.server.impl.udp.TRTrackerServerProcessorUDP

All Implemented Interfaces:

Runnable

public class TRTrackerServerProcessorUDP
extends TRTrackerServerProcessor

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	TRTrackerServerProcessorUDP.connectionData

Nested classes/interfaces inherited from class TRTrackerServerProcessor

TRTrackerServerProcessor.lightweightPeer

Nested classes/interfaces inherited from class ThreadPoolTask

ThreadPoolTask.Worker

Nested classes/interfaces inherited from class AERunnable

AERunnable.AERunnableNamed

Field Summary

Fields

Modifier and Type	Field	Description
static final long	CONNECTION_ID_LIFETIME
private static final Map<Long, TRTrackerServerProcessorUDP.connectionData>	connection_id_map
private static final Map<String, List<TRTrackerServerProcessorUDP.connectionData>>	connection_ip_map
private static long	last_timeout_check
private static final LogIDs	LOGID
private static final SecureRandom	random
private static final AEMonitor	random_mon
private final DatagramPacket	request_dg
private final TRTrackerServerUDP	server
private final DatagramSocket	socket

Fields inherited from class ThreadPoolTask

worker

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TRTrackerServerProcessorUDP(TRTrackerServerUDP _server, DatagramSocket _socket, DatagramPacket _packet)

Method Summary

Modifier and Type	Method	Description
protected long	allocateConnectionId(String client_address)
protected boolean	checkConnectionId(String client_address, long id)
protected Object[]	handleAnnounceAndScrape(InetAddress client_address, String client_ip_address, PRUDPPacketRequest request, int request_type)
protected PRUDPPacket	handleConnect(String client_ip_address, PRUDPPacketRequest request)
void	interruptTask()
void	runSupport()

Methods inherited from class TRTrackerServerProcessor

addScrapeInterval, addScrapeInterval, processTrackerRequest, taskCompleted

Methods inherited from class ThreadPoolTask

getTaskState, releaseToPool, setTaskState, taskStarted

Methods inherited from class AERunnable

create, getName, run

Methods inherited from class Object

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

Field Details

LOGID

private static final LogIDs LOGID

CONNECTION_ID_LIFETIME

public static final long CONNECTION_ID_LIFETIME

See Also:

• Constant Field Values

server

private final TRTrackerServerUDP server

socket

private final DatagramSocket socket

request_dg

private final DatagramPacket request_dg

connection_id_map

private static final Map<Long, TRTrackerServerProcessorUDP.connectionData> connection_id_map

connection_ip_map

private static final Map<String, List<TRTrackerServerProcessorUDP.connectionData>> connection_ip_map

last_timeout_check

private static long last_timeout_check

random

private static final SecureRandom random

random_mon

private static final AEMonitor random_mon

Constructor Details

TRTrackerServerProcessorUDP

protected TRTrackerServerProcessorUDP(TRTrackerServerUDP _server,
 DatagramSocket _socket,
 DatagramPacket _packet)

Method Details

runSupport

public void runSupport()

Specified by:

runSupport in class AERunnable

interruptTask

public void interruptTask()

Specified by:

interruptTask in class ThreadPoolTask

allocateConnectionId

protected long allocateConnectionId(String client_address)

checkConnectionId

protected boolean checkConnectionId(String client_address,
 long id)

handleConnect

protected PRUDPPacket handleConnect(String client_ip_address,
 PRUDPPacketRequest request)

handleAnnounceAndScrape

protected Object[] handleAnnounceAndScrape(InetAddress client_address,
 String client_ip_address,
 PRUDPPacketRequest request,
 int request_type)
                                    throws Exception

Throws:

Exception