Class DHTUDPPacketHandler
- java.lang.Object
-
- com.biglybt.core.dht.transport.udp.impl.packethandler.DHTUDPPacketHandler
-
- All Implemented Interfaces:
DHTUDPPacketHandlerStub
public class DHTUDPPacketHandler extends java.lang.Object implements DHTUDPPacketHandlerStub
-
-
Field Summary
Fields Modifier and Type Field Description private static int
BLOOM_FILTER_SIZE
private static int
BLOOM_ROTATION_PERIOD
private BloomFilter
bloom1
private BloomFilter
bloom2
private boolean
destroyed
private DHTUDPPacketHandlerFactory
factory
private long
last_bloom_rotation_time
(package private) int
network
private PRUDPPacketHandler
packet_handler
private DHTUDPRequestHandler
request_handler
(package private) DHTUDPPacketHandlerStats
stats
private boolean
test_network_alive
-
Constructor Summary
Constructors Modifier Constructor Description protected
DHTUDPPacketHandler(DHTUDPPacketHandlerFactory _factory, int _network, PRUDPPacketHandler _packet_handler, DHTUDPRequestHandler _request_handler)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
destroy()
protected int
getNetwork()
PRUDPPacketHandler
getPacketHandler()
DHTUDPRequestHandler
getRequestHandler()
DHTUDPPacketHandlerStats
getStats()
boolean
isDestroyed()
protected void
receive(DHTUDPPacketRequest request)
void
send(DHTUDPPacketReply reply, java.net.InetSocketAddress destination_address)
void
send(DHTUDPPacketRequest request, java.net.InetSocketAddress destination_address)
void
sendAndReceive(DHTUDPPacketRequest request, java.net.InetSocketAddress destination_address, DHTUDPPacketReceiver receiver, long timeout, int priority)
void
setDelays(int send_delay, int receive_delay, int queued_request_timeout)
void
testNetworkAlive(boolean alive)
private void
tunnelIPv6SeedRequest(DHTUDPPacketRequest request, java.net.InetSocketAddress destination_address, DHTUDPPacketReceiver receiver)
protected void
updateBloom(java.net.InetSocketAddress destination_address)
-
-
-
Field Detail
-
factory
private final DHTUDPPacketHandlerFactory factory
-
network
final int network
-
packet_handler
private final PRUDPPacketHandler packet_handler
-
request_handler
private final DHTUDPRequestHandler request_handler
-
stats
final DHTUDPPacketHandlerStats stats
-
test_network_alive
private boolean test_network_alive
-
BLOOM_FILTER_SIZE
private static final int BLOOM_FILTER_SIZE
- See Also:
- Constant Field Values
-
BLOOM_ROTATION_PERIOD
private static final int BLOOM_ROTATION_PERIOD
- See Also:
- Constant Field Values
-
bloom1
private BloomFilter bloom1
-
bloom2
private BloomFilter bloom2
-
last_bloom_rotation_time
private long last_bloom_rotation_time
-
destroyed
private boolean destroyed
-
-
Constructor Detail
-
DHTUDPPacketHandler
protected DHTUDPPacketHandler(DHTUDPPacketHandlerFactory _factory, int _network, PRUDPPacketHandler _packet_handler, DHTUDPRequestHandler _request_handler)
-
-
Method Detail
-
isDestroyed
public boolean isDestroyed()
-
testNetworkAlive
public void testNetworkAlive(boolean alive)
-
getRequestHandler
public DHTUDPRequestHandler getRequestHandler()
-
getPacketHandler
public PRUDPPacketHandler getPacketHandler()
-
getNetwork
protected int getNetwork()
-
updateBloom
protected void updateBloom(java.net.InetSocketAddress destination_address)
-
sendAndReceive
public void sendAndReceive(DHTUDPPacketRequest request, java.net.InetSocketAddress destination_address, DHTUDPPacketReceiver receiver, long timeout, int priority) throws DHTUDPPacketHandlerException
- Throws:
DHTUDPPacketHandlerException
-
send
public void send(DHTUDPPacketRequest request, java.net.InetSocketAddress destination_address) throws DHTUDPPacketHandlerException
- Throws:
DHTUDPPacketHandlerException
-
send
public void send(DHTUDPPacketReply reply, java.net.InetSocketAddress destination_address) throws DHTUDPPacketHandlerException
- Specified by:
send
in interfaceDHTUDPPacketHandlerStub
- Throws:
DHTUDPPacketHandlerException
-
receive
protected void receive(DHTUDPPacketRequest request)
-
setDelays
public void setDelays(int send_delay, int receive_delay, int queued_request_timeout)
-
destroy
public void destroy()
-
getStats
public DHTUDPPacketHandlerStats getStats()
-
tunnelIPv6SeedRequest
private void tunnelIPv6SeedRequest(DHTUDPPacketRequest request, java.net.InetSocketAddress destination_address, DHTUDPPacketReceiver receiver) throws DHTUDPPacketHandlerException
- Throws:
DHTUDPPacketHandlerException
-
-