Class PRUDPPacketHandlerSupport

java.lang.Object

com.biglybt.net.udp.uc.impl.PRUDPPacketHandlerSupport

All Implemented Interfaces:

PRUDPPacketHandler

public class PRUDPPacketHandlerSupport
extends Object
implements PRUDPPacketHandler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	PRUDPPacketHandlerSupport.MyByteArrayOutputStream

Field Summary

Fields

Modifier and Type	Field	Description
private PRUDPPacketHandlerImpl	altProtocolDelegate
private AEMonitor	bind_address_mon
private InetAddress	current_bind_ip
private InetAddress	default_bind_ip
private AESemaphore	destroy_sem
private boolean	destroyed
private InetAddress	explicit_bind_ip
private boolean	explicit_bind_ip_ad
private boolean	failed
private Throwable	init_error
private long	last_error_report
private static final LogIDs	LOGID
private static int	MAX_PACKET_SIZE
private static final long	MAX_RECV_QUEUE_DATA_SIZE
private static final long	MAX_SEND_QUEUE_DATA_SIZE
private final PRUDPPacketHandlerImpl.PacketTransformer	packet_transformer
private final int	port
private final CopyOnWriteList<PRUDPPrimordialHandler>	primordial_handlers
private int	queued_request_timeout
private int	receive_delay
private List<Object[]>	recv_queue
private long	recv_queue_data_size
private AEMonitor	recv_queue_mon
private AESemaphore	recv_queue_sem
private AEThread2	recv_thread
private PRUDPRequestHandler	request_handler
private Map<Integer, PRUDPPacketHandlerRequestImpl>	requests
private int	send_delay
private long	send_queue_data_size
private AEMonitor	send_queue_mon
private AESemaphore	send_queue_sem
private final List[]	send_queues
private AEThread2	send_thread
private DatagramSocket	socket
private final PRUDPPacketHandlerStatsImpl	stats
private InetAddress	target_bind_ip
private static long	total_bytes_received
private static long	total_bytes_sent
private static long	total_packets_received
private static long	total_packets_sent
private long	total_replies
private long	total_requests_processed
private long	total_requests_received
private boolean	TRACE_REQUESTS
private static boolean	use_socks

Fields inherited from interface PRUDPPacketHandler

PRIORITY_HIGH, PRIORITY_IMMEDIATE, PRIORITY_LOW, PRIORITY_MEDIUM

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PRUDPPacketHandlerSupport(int port, InetAddress bind_ip, PRUDPPacketHandlerImpl.PacketTransformer packet_transformer)
protected	PRUDPPacketHandlerSupport(int _port, InetAddress _bind_ip, PRUDPPacketHandlerImpl.PacketTransformer _packet_transformer, PRUDPPacketHandlerStatsImpl _stats, CopyOnWriteList<PRUDPPrimordialHandler> _primordial_handlers, PRUDPRequestHandler _request_handler)

Method Summary

Modifier and Type	Method	Description
void	addPrimordialHandler(PRUDPPrimordialHandler handler)
protected void	calcBind()
protected void	checkTargetAddress(InetSocketAddress address)
protected boolean	checkTimeouts()
void	closeSession()
void	destroy()
InetAddress	getCurrentBindAddress()
InetAddress	getExplicitBindAddress()
int	getPort()
long	getReceiveQueueLength()
PRUDPRequestHandler	getRequestHandler()
long	getSendQueueLength()
private DatagramSocket	getSocket(int port)
private DatagramSocket	getSocket(InetSocketAddress address)
PRUDPPacketHandlerStats	getStats()
boolean	hasPrimordialHandler()
PRUDPPacketHandler	openSession(InetSocketAddress target, String[] networks, String reason)
void	primordialSend(byte[] buffer, InetSocketAddress target)
protected void	process(DatagramPacket dg_packet, long receive_time)
private void	receiveFromSocket(DatagramPacket p)
protected void	receiveLoop(AESemaphore init_sem)
void	removePrimordialHandler(PRUDPPrimordialHandler handler)
void	send(PRUDPPacket request_packet, InetSocketAddress destination_address)	Send only
PRUDPPacket	sendAndReceive(PRUDPPacket request_packet, InetSocketAddress destination_address)
void	sendAndReceive(PRUDPPacket request_packet, InetSocketAddress destination_address, PRUDPPacketReceiver receiver, long timeout, int priority)	Asynchronous send and receive
PRUDPPacket	sendAndReceive(PasswordAuthentication auth, PRUDPPacket request_packet, InetSocketAddress destination_address)	Synchronous send and receive
PRUDPPacket	sendAndReceive(PasswordAuthentication auth, PRUDPPacket request_packet, InetSocketAddress destination_address, long timeout)
PRUDPPacket	sendAndReceive(PasswordAuthentication auth, PRUDPPacket request_packet, InetSocketAddress destination_address, long timeout, int priority)
PRUDPPacketHandlerRequestImpl	sendAndReceive(PasswordAuthentication auth, PRUDPPacket request_packet, InetSocketAddress destination_address, PRUDPPacketReceiver receiver, long timeout, int priority)
private void	sendToSocket(DatagramPacket p)
protected void	setDefaultBindAddress(InetAddress address)
void	setDelays(int _send_delay, int _receive_delay, int _queued_request_timeout)
void	setExplicitBindAddress(InetAddress address, boolean autoDelegate)
void	setRequestHandler(PRUDPRequestHandler _request_handler)

Methods inherited from class Object

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

Methods inherited from interface PRUDPPacketHandler

getBindIP

Field Details

LOGID

private static final LogIDs LOGID

TRACE_REQUESTS

private boolean TRACE_REQUESTS

MAX_PACKET_SIZE

private static int MAX_PACKET_SIZE

total_packets_sent

private static volatile long total_packets_sent

total_packets_received

private static volatile long total_packets_received

total_bytes_sent

private static volatile long total_bytes_sent

total_bytes_received

private static volatile long total_bytes_received

MAX_SEND_QUEUE_DATA_SIZE

private static final long MAX_SEND_QUEUE_DATA_SIZE

See Also:

• Constant Field Values

MAX_RECV_QUEUE_DATA_SIZE

private static final long MAX_RECV_QUEUE_DATA_SIZE

See Also:

• Constant Field Values

use_socks

private static boolean use_socks

port

private final int port

socket

private DatagramSocket socket

primordial_handlers

private final CopyOnWriteList<PRUDPPrimordialHandler> primordial_handlers

stats

private final PRUDPPacketHandlerStatsImpl stats

request_handler

private PRUDPRequestHandler request_handler

requests

private Map<Integer, PRUDPPacketHandlerRequestImpl> requests

send_queue_mon

private AEMonitor send_queue_mon

send_queue_data_size

private long send_queue_data_size

send_queues

private final List[] send_queues

send_queue_sem

private AESemaphore send_queue_sem

send_thread

private AEThread2 send_thread

recv_queue_mon

private AEMonitor recv_queue_mon

recv_queue_data_size

private long recv_queue_data_size

recv_queue

private List<Object[]> recv_queue

recv_queue_sem

private AESemaphore recv_queue_sem

recv_thread

private AEThread2 recv_thread

send_delay

private int send_delay

receive_delay

private int receive_delay

queued_request_timeout

private int queued_request_timeout

total_requests_received

private long total_requests_received

total_requests_processed

private long total_requests_processed

total_replies

private long total_replies

last_error_report

private long last_error_report

bind_address_mon

private AEMonitor bind_address_mon

default_bind_ip

private InetAddress default_bind_ip

explicit_bind_ip

private InetAddress explicit_bind_ip

explicit_bind_ip_ad

private boolean explicit_bind_ip_ad

current_bind_ip

private volatile InetAddress current_bind_ip

target_bind_ip

private volatile InetAddress target_bind_ip

failed

private volatile boolean failed

destroyed

private volatile boolean destroyed

destroy_sem

private AESemaphore destroy_sem

init_error

private Throwable init_error

altProtocolDelegate

private PRUDPPacketHandlerImpl altProtocolDelegate

packet_transformer

private final PRUDPPacketHandlerImpl.PacketTransformer packet_transformer

Constructor Details

PRUDPPacketHandlerSupport

protected PRUDPPacketHandlerSupport(int port,
 InetAddress bind_ip,
 PRUDPPacketHandlerImpl.PacketTransformer packet_transformer)

PRUDPPacketHandlerSupport

protected PRUDPPacketHandlerSupport(int _port,
 InetAddress _bind_ip,
 PRUDPPacketHandlerImpl.PacketTransformer _packet_transformer,
 PRUDPPacketHandlerStatsImpl _stats,
 CopyOnWriteList<PRUDPPrimordialHandler> _primordial_handlers,
 PRUDPRequestHandler _request_handler)

Method Details

hasPrimordialHandler

public boolean hasPrimordialHandler()

Specified by:

hasPrimordialHandler in interface PRUDPPacketHandler

addPrimordialHandler

public void addPrimordialHandler(PRUDPPrimordialHandler handler)

Specified by:

addPrimordialHandler in interface PRUDPPacketHandler

removePrimordialHandler

public void removePrimordialHandler(PRUDPPrimordialHandler handler)

Specified by:

removePrimordialHandler in interface PRUDPPacketHandler

setRequestHandler

public void setRequestHandler(PRUDPRequestHandler _request_handler)

Specified by:

setRequestHandler in interface PRUDPPacketHandler

getRequestHandler

public PRUDPRequestHandler getRequestHandler()

Specified by:

getRequestHandler in interface PRUDPPacketHandler

getPort

public int getPort()

Specified by:

getPort in interface PRUDPPacketHandler

getCurrentBindAddress

public InetAddress getCurrentBindAddress()

Specified by:

getCurrentBindAddress in interface PRUDPPacketHandler

setDefaultBindAddress

protected void setDefaultBindAddress(InetAddress address)

getExplicitBindAddress

public InetAddress getExplicitBindAddress()

Specified by:

getExplicitBindAddress in interface PRUDPPacketHandler

setExplicitBindAddress

public void setExplicitBindAddress(InetAddress address,
 boolean autoDelegate)

Specified by:

setExplicitBindAddress in interface PRUDPPacketHandler

calcBind

protected void calcBind()

getSocket

private DatagramSocket getSocket(int port)
                          throws SocketException

Throws:

SocketException

getSocket

private DatagramSocket getSocket(InetSocketAddress address)
                          throws SocketException

Throws:

SocketException

receiveLoop

protected void receiveLoop(AESemaphore init_sem)

checkTimeouts

protected boolean checkTimeouts()

process

protected void process(DatagramPacket dg_packet,
 long receive_time)

sendAndReceive

public PRUDPPacket sendAndReceive(PRUDPPacket request_packet,
 InetSocketAddress destination_address)
                           throws PRUDPPacketHandlerException

Throws:

PRUDPPacketHandlerException

sendAndReceive

public PRUDPPacket sendAndReceive(PasswordAuthentication auth,
 PRUDPPacket request_packet,
 InetSocketAddress destination_address)
                           throws PRUDPPacketHandlerException

Description copied from interface: PRUDPPacketHandler

Synchronous send and receive

Specified by:

sendAndReceive in interface PRUDPPacketHandler

Parameters:

auth -

request_packet -

destination_address -

Returns:

Throws:

PRUDPPacketHandlerException

sendAndReceive

public PRUDPPacket sendAndReceive(PasswordAuthentication auth,
 PRUDPPacket request_packet,
 InetSocketAddress destination_address,
 long timeout)
                           throws PRUDPPacketHandlerException

Specified by:

sendAndReceive in interface PRUDPPacketHandler

Throws:

PRUDPPacketHandlerException

sendAndReceive

public PRUDPPacket sendAndReceive(PasswordAuthentication auth,
 PRUDPPacket request_packet,
 InetSocketAddress destination_address,
 long timeout,
 int priority)
                           throws PRUDPPacketHandlerException

Specified by:

sendAndReceive in interface PRUDPPacketHandler

Throws:

PRUDPPacketHandlerException

sendAndReceive

public void sendAndReceive(PRUDPPacket request_packet,
 InetSocketAddress destination_address,
 PRUDPPacketReceiver receiver,
 long timeout,
 int priority)
                    throws PRUDPPacketHandlerException

Description copied from interface: PRUDPPacketHandler

Asynchronous send and receive

Specified by:

sendAndReceive in interface PRUDPPacketHandler

Parameters:

request_packet -

destination_address -

receiver -

Throws:

PRUDPPacketHandlerException

sendAndReceive

public PRUDPPacketHandlerRequestImpl sendAndReceive(PasswordAuthentication auth,
 PRUDPPacket request_packet,
 InetSocketAddress destination_address,
 PRUDPPacketReceiver receiver,
 long timeout,
 int priority)
                                             throws PRUDPPacketHandlerException

Throws:

PRUDPPacketHandlerException

send

public void send(PRUDPPacket request_packet,
 InetSocketAddress destination_address)
          throws PRUDPPacketHandlerException

Description copied from interface: PRUDPPacketHandler

Send only

Specified by:

send in interface PRUDPPacketHandler

Parameters:

request_packet -

destination_address -

Throws:

PRUDPPacketHandlerException

checkTargetAddress

protected void checkTargetAddress(InetSocketAddress address)
                           throws PRUDPPacketHandlerException

Throws:

PRUDPPacketHandlerException

setDelays

public void setDelays(int _send_delay,
 int _receive_delay,
 int _queued_request_timeout)

Specified by:

setDelays in interface PRUDPPacketHandler

getSendQueueLength

public long getSendQueueLength()

getReceiveQueueLength

public long getReceiveQueueLength()

primordialSend

public void primordialSend(byte[] buffer,
 InetSocketAddress target)
                    throws PRUDPPacketHandlerException

Specified by:

primordialSend in interface PRUDPPacketHandler

Throws:

PRUDPPacketHandlerException

sendToSocket

private void sendToSocket(DatagramPacket p)
                   throws IOException

Throws:

IOException

receiveFromSocket

private void receiveFromSocket(DatagramPacket p)
                        throws IOException

Throws:

IOException

getStats

public PRUDPPacketHandlerStats getStats()

Specified by:

getStats in interface PRUDPPacketHandler

destroy

public void destroy()

Specified by:

destroy in interface PRUDPPacketHandler

openSession

public PRUDPPacketHandler openSession(InetSocketAddress target,
 String[] networks,
 String reason)
                               throws PRUDPPacketHandlerException

Specified by:

openSession in interface PRUDPPacketHandler

Throws:

PRUDPPacketHandlerException

closeSession

public void closeSession()
                  throws PRUDPPacketHandlerException

Specified by:

closeSession in interface PRUDPPacketHandler

Throws:

PRUDPPacketHandlerException