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:
java.lang.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 com.biglybt.core.tracker.server.impl.TRTrackerServerProcessor
TRTrackerServerProcessor.lightweightPeer
-
Nested classes/interfaces inherited from class com.biglybt.core.util.AERunnable
AERunnable.AERunnableNamed
-
-
Field Summary
Fields Modifier and Type Field Description static long
CONNECTION_ID_LIFETIME
private static java.util.Map<java.lang.Long,TRTrackerServerProcessorUDP.connectionData>
connection_id_map
private static java.util.Map<java.lang.String,java.util.List<TRTrackerServerProcessorUDP.connectionData>>
connection_ip_map
private static long
last_timeout_check
private static LogIDs
LOGID
private static java.security.SecureRandom
random
private static AEMonitor
random_mon
private java.net.DatagramPacket
request_dg
private TRTrackerServerUDP
server
private java.net.DatagramSocket
socket
-
Fields inherited from class com.biglybt.core.util.ThreadPoolTask
worker
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
TRTrackerServerProcessorUDP(TRTrackerServerUDP _server, java.net.DatagramSocket _socket, java.net.DatagramPacket _packet)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected long
allocateConnectionId(java.lang.String client_address)
protected boolean
checkConnectionId(java.lang.String client_address, long id)
protected java.lang.Object[]
handleAnnounceAndScrape(java.lang.String client_ip_address, PRUDPPacketRequest request, int request_type)
protected PRUDPPacket
handleConnect(java.lang.String client_ip_address, PRUDPPacketRequest request)
void
interruptTask()
void
runSupport()
-
Methods inherited from class com.biglybt.core.tracker.server.impl.TRTrackerServerProcessor
addScrapeInterval, addScrapeInterval, processTrackerRequest, taskCompleted
-
Methods inherited from class com.biglybt.core.util.ThreadPoolTask
getName, getTaskState, releaseToPool, setTaskState, taskStarted
-
Methods inherited from class com.biglybt.core.util.AERunnable
create, run
-
-
-
-
Field Detail
-
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 java.net.DatagramSocket socket
-
request_dg
private final java.net.DatagramPacket request_dg
-
connection_id_map
private static final java.util.Map<java.lang.Long,TRTrackerServerProcessorUDP.connectionData> connection_id_map
-
connection_ip_map
private static final java.util.Map<java.lang.String,java.util.List<TRTrackerServerProcessorUDP.connectionData>> connection_ip_map
-
last_timeout_check
private static long last_timeout_check
-
random
private static final java.security.SecureRandom random
-
random_mon
private static final AEMonitor random_mon
-
-
Constructor Detail
-
TRTrackerServerProcessorUDP
protected TRTrackerServerProcessorUDP(TRTrackerServerUDP _server, java.net.DatagramSocket _socket, java.net.DatagramPacket _packet)
-
-
Method Detail
-
runSupport
public void runSupport()
- Specified by:
runSupport
in classAERunnable
-
interruptTask
public void interruptTask()
- Specified by:
interruptTask
in classThreadPoolTask
-
allocateConnectionId
protected long allocateConnectionId(java.lang.String client_address)
-
checkConnectionId
protected boolean checkConnectionId(java.lang.String client_address, long id)
-
handleConnect
protected PRUDPPacket handleConnect(java.lang.String client_ip_address, PRUDPPacketRequest request)
-
handleAnnounceAndScrape
protected java.lang.Object[] handleAnnounceAndScrape(java.lang.String client_ip_address, PRUDPPacketRequest request, int request_type) throws java.lang.Exception
- Throws:
java.lang.Exception
-
-