Class DHTUDPPacketHandler

java.lang.Object

com.biglybt.core.dht.transport.udp.impl.packethandler.DHTUDPPacketHandler

All Implemented Interfaces:

DHTUDPPacketHandlerStub

public class DHTUDPPacketHandler
extends Object
implements DHTUDPPacketHandlerStub

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	BLOOM_FILTER_SIZE
private static final int	BLOOM_ROTATION_PERIOD
private BloomFilter	bloom1
private BloomFilter	bloom2
private boolean	destroyed
private final DHTUDPPacketHandlerFactory	factory
private long	last_bloom_rotation_time
(package private) final int	network
private final PRUDPPacketHandler	packet_handler
private final DHTUDPRequestHandler	request_handler
(package private) final 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

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, 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)

Methods inherited from class Object

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

Field Details

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 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

public DHTUDPRequestHandler getRequestHandler()

getPacketHandler

public PRUDPPacketHandler getPacketHandler()

getNetwork

protected int getNetwork()

updateBloom

protected void updateBloom(InetSocketAddress destination_address)

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 interface DHTUDPPacketHandlerStub

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,
 InetSocketAddress destination_address,
 DHTUDPPacketReceiver receiver)
                            throws DHTUDPPacketHandlerException

Throws:

DHTUDPPacketHandlerException