freenet.io.comm

Class UdpSocketHandler

java.lang.Object

freenet.io.comm.UdpSocketHandler

All Implemented Interfaces:

PacketSocketHandler, PortForwardSensitiveSocketHandler, SocketHandler, PrioRunnable, java.lang.Runnable

public class UdpSocketHandler
extends java.lang.Object
implements PrioRunnable, PacketSocketHandler, PortForwardSensitiveSocketHandler

Field Summary

Fields

Modifier and Type	Field and Description
static int	MIN_MTU
static int	UDP_HEADERS_LENGTH

Constructor Summary

Constructors

Constructor and Description
UdpSocketHandler(int listenPort, java.net.InetAddress bindto, Node node, long startupTime, java.lang.String title, IOStatisticCollector collector)

Method Summary

Modifier and Type	Method and Description
int	calculateMaxPacketSize()
void	close()
AddressTracker	getAddressTracker()
java.net.InetAddress	getBindTo()
AddressTracker.Status	getDetectedConnectivityStatus() Does this port appear to be port forwarded? @see AddressTracker
int	getDropProbability()
int	getHeadersLength() Get the size of the transport layer headers, for byte accounting purposes.
int	getHeadersLength(Peer peer) Get the size of the transport layer headers, for byte accounting purposes.
int	getMaxPacketSize() The maximum size of a packet, not including transport layer headers
int	getPacketSendThreshold() How big must the pending data be before we send a packet? *Includes* transport layer headers.
int	getPortNumber()
int	getPriority()
long	getStartTime()
java.lang.String	getTitle()
void	rescanPortForward() Something has changed at a higher level suggesting the port forwarding status may be bogus, so we need to rescan.
void	run()
void	sendPacket(byte[] blockToSend, Peer destination, boolean allowLocalAddresses) Send a block of encoded bytes to a peer.
void	setDropProbability(int dropProbability)
void	setLowLevelFilter(IncomingPacketFilter f) Must be called, or we will NPE in run()
void	start()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

UDP_HEADERS_LENGTH

public static final int UDP_HEADERS_LENGTH

See Also:

Constant Field Values

MIN_MTU

public static final int MIN_MTU

See Also:

Constant Field Values

Constructor Detail

UdpSocketHandler

public UdpSocketHandler(int listenPort,
                        java.net.InetAddress bindto,
                        Node node,
                        long startupTime,
                        java.lang.String title,
                        IOStatisticCollector collector)
                 throws java.net.SocketException

Throws:

java.net.SocketException

Method Detail

setLowLevelFilter

public void setLowLevelFilter(IncomingPacketFilter f)

Must be called, or we will NPE in run()

Specified by:

setLowLevelFilter in interface PacketSocketHandler

getBindTo

public java.net.InetAddress getBindTo()

getTitle

public java.lang.String getTitle()

run

public void run()

Specified by:

run in interface java.lang.Runnable

sendPacket

public void sendPacket(byte[] blockToSend,
                       Peer destination,
                       boolean allowLocalAddresses)
                throws Peer.LocalAddressException

Send a block of encoded bytes to a peer. This is called by send, and by IncomingPacketFilter.processOutgoing(..).

Specified by:

sendPacket in interface PacketSocketHandler

Parameters:

blockToSend - The data block to send.

destination - The peer to send it to.

Throws:

Peer.LocalAddressException

getMaxPacketSize

public int getMaxPacketSize()

Description copied from interface: PacketSocketHandler

The maximum size of a packet, not including transport layer headers

Specified by:

getMaxPacketSize in interface PacketSocketHandler

Returns:

The maximum packet size supported by this SocketManager, not including transport (UDP/IP) headers.

calculateMaxPacketSize

public int calculateMaxPacketSize()

getPacketSendThreshold

public int getPacketSendThreshold()

Description copied from interface: PacketSocketHandler

How big must the pending data be before we send a packet? *Includes* transport layer headers.

Specified by:

getPacketSendThreshold in interface PacketSocketHandler

start

public void start()

close

public void close()

getDropProbability

public int getDropProbability()

setDropProbability

public void setDropProbability(int dropProbability)

getPortNumber

public int getPortNumber()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getHeadersLength

public int getHeadersLength()

Description copied from interface: PacketSocketHandler

Get the size of the transport layer headers, for byte accounting purposes.

Specified by:

getHeadersLength in interface PacketSocketHandler

getHeadersLength

public int getHeadersLength(Peer peer)

Description copied from interface: PacketSocketHandler

Get the size of the transport layer headers, for byte accounting purposes.

Specified by:

getHeadersLength in interface PacketSocketHandler

Parameters:

peer - used to detect address family.

getAddressTracker

public AddressTracker getAddressTracker()

rescanPortForward

public void rescanPortForward()

Description copied from interface: PortForwardSensitiveSocketHandler

Something has changed at a higher level suggesting the port forwarding status may be bogus, so we need to rescan.

Specified by:

rescanPortForward in interface PortForwardSensitiveSocketHandler

getDetectedConnectivityStatus

public AddressTracker.Status getDetectedConnectivityStatus()

Description copied from interface: PacketSocketHandler

Does this port appear to be port forwarded? @see AddressTracker

Specified by:

getDetectedConnectivityStatus in interface PacketSocketHandler

getPriority

public int getPriority()

Specified by:

getPriority in interface PrioRunnable

getStartTime

public long getStartTime()