Class PRUDPPacketHandlerPluginProxy

java.lang.Object

com.biglybt.net.udp.uc.impl.PRUDPPacketHandlerPluginProxy

All Implemented Interfaces:

PRUDPPacketHandler

public class PRUDPPacketHandlerPluginProxy
extends Object
implements PRUDPPacketHandler

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	DEFAULT_TIMEOUT
private final PRUDPPacketHandler	delegate
private final AEProxyFactory.PluginProxy	pp
private final Socket	socket
private final InetSocketAddress	target

Fields inherited from interface PRUDPPacketHandler

PRIORITY_HIGH, PRIORITY_IMMEDIATE, PRIORITY_LOW, PRIORITY_MEDIUM

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PRUDPPacketHandlerPluginProxy(PRUDPPacketHandler _delegate, InetSocketAddress _target, AEProxyFactory.PluginProxy _pp)

Method Summary

Modifier and Type	Method	Description
void	addPrimordialHandler(PRUDPPrimordialHandler handler)
void	closeSession()
void	destroy()
InetAddress	getCurrentBindAddress()
InetAddress	getExplicitBindAddress()
int	getPort()
PRUDPRequestHandler	getRequestHandler()
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)
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

DEFAULT_TIMEOUT

private static final int DEFAULT_TIMEOUT

See Also:

• Constant Field Values

pp

private final AEProxyFactory.PluginProxy pp

delegate

private final PRUDPPacketHandler delegate

target

private final InetSocketAddress target

socket

private final Socket socket

Constructor Details

PRUDPPacketHandlerPluginProxy

protected PRUDPPacketHandlerPluginProxy(PRUDPPacketHandler _delegate,
 InetSocketAddress _target,
 AEProxyFactory.PluginProxy _pp)
                                 throws Exception

Throws:

Exception

Method Details

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

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

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

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

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