Class DHTUDPPacketHandler
java.lang.Object
com.biglybt.core.dht.transport.udp.impl.packethandler.DHTUDPPacketHandler
- All Implemented Interfaces:
DHTUDPPacketHandlerStub
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final int
private static final int
private BloomFilter
private BloomFilter
private boolean
private final DHTUDPPacketHandlerFactory
private long
(package private) final int
private final PRUDPPacketHandler
private final DHTUDPRequestHandler
(package private) final DHTUDPPacketHandlerStats
private boolean
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
DHTUDPPacketHandler
(DHTUDPPacketHandlerFactory _factory, int _network, PRUDPPacketHandler _packet_handler, DHTUDPRequestHandler _request_handler) -
Method Summary
Modifier and TypeMethodDescriptionvoid
destroy()
protected int
getStats()
boolean
protected void
receive
(DHTUDPPacketRequest request) void
send
(DHTUDPPacketReply reply, InetSocketAddress destination_address) void
send
(DHTUDPPacketRequest request, InetSocketAddress destination_address) void
sendAndReceive
(DHTUDPPacketRequest request, 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, InetSocketAddress destination_address, DHTUDPPacketReceiver receiver) protected void
updateBloom
(InetSocketAddress destination_address)
-
Field Details
-
factory
-
network
final int network -
packet_handler
-
request_handler
-
stats
-
test_network_alive
private boolean test_network_alive -
BLOOM_FILTER_SIZE
private static final int BLOOM_FILTER_SIZE- See Also:
-
BLOOM_ROTATION_PERIOD
private static final int BLOOM_ROTATION_PERIOD- See Also:
-
bloom1
-
bloom2
-
last_bloom_rotation_time
private long last_bloom_rotation_time -
destroyed
private boolean destroyed
-
-
Constructor Details
-
DHTUDPPacketHandler
protected DHTUDPPacketHandler(DHTUDPPacketHandlerFactory _factory, int _network, PRUDPPacketHandler _packet_handler, DHTUDPRequestHandler _request_handler)
-
-
Method Details
-
isDestroyed
public boolean isDestroyed() -
testNetworkAlive
public void testNetworkAlive(boolean alive) -
getRequestHandler
-
getPacketHandler
-
getNetwork
protected int getNetwork() -
updateBloom
-
sendAndReceive
public void sendAndReceive(DHTUDPPacketRequest request, InetSocketAddress destination_address, DHTUDPPacketReceiver receiver, long timeout, int priority) throws DHTUDPPacketHandlerException - Throws:
DHTUDPPacketHandlerException
-
send
public void send(DHTUDPPacketRequest request, InetSocketAddress destination_address) throws DHTUDPPacketHandlerException - Throws:
DHTUDPPacketHandlerException
-
send
public void send(DHTUDPPacketReply reply, InetSocketAddress destination_address) throws DHTUDPPacketHandlerException - Specified by:
send
in interfaceDHTUDPPacketHandlerStub
- Throws:
DHTUDPPacketHandlerException
-
receive
-
setDelays
public void setDelays(int send_delay, int receive_delay, int queued_request_timeout) -
destroy
public void destroy() -
getStats
-
tunnelIPv6SeedRequest
private void tunnelIPv6SeedRequest(DHTUDPPacketRequest request, InetSocketAddress destination_address, DHTUDPPacketReceiver receiver) throws DHTUDPPacketHandlerException - Throws:
DHTUDPPacketHandlerException
-