Class PRUDPPacketHandlerImpl

java.lang.Object

com.biglybt.net.udp.uc.impl.PRUDPPacketHandlerImpl

All Implemented Interfaces:

PRUDPPacketHandler

public class PRUDPPacketHandlerImpl
extends Object
implements PRUDPPacketHandler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static interface	PRUDPPacketHandlerImpl.PacketTransformer

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	destroyed
private static List<PRUDPPacketHandlerImpl>	handlers
private final PRUDPPacketHandlerSupport	impl

Fields inherited from interface PRUDPPacketHandler

PRIORITY_HIGH, PRIORITY_IMMEDIATE, PRIORITY_LOW, PRIORITY_MEDIUM

Constructor Summary

Constructors

Modifier	Constructor	Description
private	PRUDPPacketHandlerImpl(int port, InetAddress bind_ip, PRUDPPacketHandlerImpl.PacketTransformer packet_transformer)
private	PRUDPPacketHandlerImpl(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)
void	closeSession()
protected static PRUDPPacketHandlerImpl	createPacketHandler(int port, InetAddress bind_ip, PRUDPPacketHandlerImpl.PacketTransformer packet_transformer)
protected static PRUDPPacketHandlerImpl	createPacketHandler(int port, InetAddress bind_ip, PRUDPPacketHandlerImpl.PacketTransformer packet_transformer, PRUDPPacketHandlerStatsImpl stats, CopyOnWriteList<PRUDPPrimordialHandler> primordial_handlers, PRUDPRequestHandler request_handler)
void	destroy()
InetAddress	getBindIP()
InetAddress	getCurrentBindAddress()
InetAddress	getExplicitBindAddress()
int	getPort()
protected long	getReceiveQueueLength()
PRUDPRequestHandler	getRequestHandler()
protected long	getSendQueueLength()
PRUDPPacketHandlerStats	getStats()
boolean	hasPrimordialHandler()
PRUDPPacketHandler	openSession(InetSocketAddress target, String[] networks, String reason)
void	primordialSend(byte[] data, InetSocketAddress target)
void	removePrimordialHandler(PRUDPPrimordialHandler handler)
void	send(PRUDPPacket request_packet, InetSocketAddress destination_address)	Send only
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_millis)
PRUDPPacket	sendAndReceive(PasswordAuthentication auth, PRUDPPacket request_packet, InetSocketAddress destination_address, long timeout_millis, int priority)
protected PRUDPPacketHandlerRequestImpl	sendAndReceive(PasswordAuthentication auth, PRUDPPacket request_packet, InetSocketAddress destination_address, PRUDPPacketReceiver receiver, long timeout, int priority)
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

Field Details

handlers

private static List<PRUDPPacketHandlerImpl> handlers

impl

private final PRUDPPacketHandlerSupport impl

destroyed

private boolean destroyed

Constructor Details

PRUDPPacketHandlerImpl

private PRUDPPacketHandlerImpl(int port,
 InetAddress bind_ip,
 PRUDPPacketHandlerImpl.PacketTransformer packet_transformer)

PRUDPPacketHandlerImpl

private PRUDPPacketHandlerImpl(int port,
 InetAddress bind_ip,
 PRUDPPacketHandlerImpl.PacketTransformer packet_transformer,
 PRUDPPacketHandlerStatsImpl stats,
 CopyOnWriteList<PRUDPPrimordialHandler> primordial_handlers,
 PRUDPRequestHandler request_handler)

Method Details

createPacketHandler

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

createPacketHandler

protected static PRUDPPacketHandlerImpl createPacketHandler(int port,
 InetAddress bind_ip,
 PRUDPPacketHandlerImpl.PacketTransformer packet_transformer,
 PRUDPPacketHandlerStatsImpl stats,
 CopyOnWriteList<PRUDPPrimordialHandler> primordial_handlers,
 PRUDPRequestHandler request_handler)

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 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_millis)
                           throws PRUDPPacketHandlerException

Specified by:

sendAndReceive in interface PRUDPPacketHandler

Throws:

PRUDPPacketHandlerException

sendAndReceive

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

Specified by:

sendAndReceive in interface PRUDPPacketHandler

Throws:

PRUDPPacketHandlerException

sendAndReceive

protected 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

getRequestHandler

public PRUDPRequestHandler getRequestHandler()

Specified by:

getRequestHandler in interface PRUDPPacketHandler

setRequestHandler

public void setRequestHandler(PRUDPRequestHandler request_handler)

Specified by:

setRequestHandler in interface PRUDPPacketHandler

primordialSend

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

Specified by:

primordialSend in interface PRUDPPacketHandler

Throws:

PRUDPPacketHandlerException

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

getPort

public int getPort()

Specified by:

getPort in interface PRUDPPacketHandler

getBindIP

public InetAddress getBindIP()

Specified by:

getBindIP in interface PRUDPPacketHandler

getCurrentBindAddress

public InetAddress getCurrentBindAddress()

Specified by:

getCurrentBindAddress in interface PRUDPPacketHandler

getExplicitBindAddress

public InetAddress getExplicitBindAddress()

Specified by:

getExplicitBindAddress in interface PRUDPPacketHandler

setExplicitBindAddress

public void setExplicitBindAddress(InetAddress address,
 boolean autoDelegate)

Specified by:

setExplicitBindAddress in interface PRUDPPacketHandler

setDelays

public void setDelays(int send_delay,
 int receive_delay,
 int queued_request_timeout)

Specified by:

setDelays in interface PRUDPPacketHandler

getSendQueueLength

protected long getSendQueueLength()

getReceiveQueueLength

protected long getReceiveQueueLength()

getStats

public PRUDPPacketHandlerStats getStats()

Specified by:

getStats 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

destroy

public void destroy()

Specified by:

destroy in interface PRUDPPacketHandler