org.mjsip.net

Class UdpMultiRelay

java.lang.Object

java.lang.Thread

org.mjsip.net.UdpMultiRelay

All Implemented Interfaces:

java.lang.Runnable

public class UdpMultiRelay
extends java.lang.Thread

UdpMultiRelay implements an UDP multiple relay agent. It receives UDP packets at a local socket and relays them toward a list of remote destination.

It can operate according to two relay rules:

• one-to-one: packets directed to the same destination are sent using the same source socket, that is the socket where the remote node sends its packet to (per-destinaiotn outgoing socket)
• many-to-one: packets directed to the same destination are sent using different source sockets; that coincide with the sockets where they have been received (per-source outgoing socket)

Moreover, it can operate according to two filtering rules:

• unfiltered: all packets are relayed to all remote nodes regardless the origin
• filtered: packets are not sent to the same node they come from

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
UdpMultiRelay(UdpConnectedSocket socket, java.util.Vector dest_sockets, boolean one2one, boolean filtered, UdpMultiRelayListener listener) Creates a new UDP relay and starts it.

Method Summary

Modifier and Type	Method and Description
java.util.Vector	getDestSockets() Gets the destination sockets where packets have to be sent to.
UdpConnectedSocket	getSocket() Gets the recv socket
int	getSoTimeout() Gets the maximum time that the UDP relay can remain active after been halted
void	halt() Stops the UDP relay
boolean	isFiltered() Whether source filtering is used
boolean	isOneToOne() Whether one-to-one rule is used
void	run() Redirect packets from source addr/port to destination addr/port
void	setFiltered(boolean filtered) Sets source filtering
void	setOneToOne(boolean one2one) Sets one-to-one rule
void	setSoTimeout(int so_to) Sets the maximum time that the UDP relay can remain active after been halted

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

UdpMultiRelay

public UdpMultiRelay(UdpConnectedSocket socket,
                     java.util.Vector dest_sockets,
                     boolean one2one,
                     boolean filtered,
                     UdpMultiRelayListener listener)

Creates a new UDP relay and starts it.

Parameters:

socket - local socket where packet arrives (and where are sent from, in case of per-destination outgoing socket)

dest_sockets - destination addresses (Vector of UdpConnectedSocket), where packets have to be sent to

one2one - whether sending all packets to a remote node using the same socket where the remote node sends its packet to (per-destinaiotn outgoing socket)

filtered - whether filtering packet directed to local socket's remote address

listener - listener of UdpMultiRelay events

Method Detail

getSocket

public UdpConnectedSocket getSocket()

Gets the recv socket

getDestSockets

public java.util.Vector getDestSockets()

Gets the destination sockets where packets have to be sent to.

Returns:

a Vector of UdpConnectedSocket containing all destination sockets

isOneToOne

public boolean isOneToOne()

Whether one-to-one rule is used

setOneToOne

public void setOneToOne(boolean one2one)

Sets one-to-one rule

isFiltered

public boolean isFiltered()

Whether source filtering is used

setFiltered

public void setFiltered(boolean filtered)

Sets source filtering

halt

public void halt()

Stops the UDP relay

setSoTimeout

public void setSoTimeout(int so_to)

Sets the maximum time that the UDP relay can remain active after been halted

getSoTimeout

public int getSoTimeout()

Gets the maximum time that the UDP relay can remain active after been halted

run

public void run()

Redirect packets from source addr/port to destination addr/port

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread