Package org.jgroups.tests.rt.transports

Class UdpTransport

java.lang.Object

org.jgroups.tests.rt.transports.UdpTransport

All Implemented Interfaces:

RtTransport

public class UdpTransport
extends Object
implements RtTransport

Transport based on UDP datagrams. Note that this transport is not reliable: if a packet is dropped, the sender will wait for the response forever and this block.

Since:

4.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	UdpTransport.Receiver

Field Summary

Fields

Modifier and Type	Field	Description
protected InetAddress	host
protected final Log	log
protected List<SocketAddress>	members
protected int	port
protected RtReceiver	receiver
protected UdpTransport.Receiver	receiver_thread
protected boolean	server
protected DatagramSocket	sock

Constructor Summary

Constructors

Constructor	Description
UdpTransport()

Method Summary

Modifier and Type	Method	Description
List<? extends Object>	clusterMembers()	Returns the addresses of all cluster members.
Object	localAddress()	Returns the local addres of this member.
String[]	options()	Prints the accepted options, e.g.
void	options(String... options)	Sets options on this transport.
void	receiver(RtReceiver receiver)	Sets the receiver whose RtReceiver.receive(Object,byte[],int,int) callback will be invoked whenever a message is received
void	send(Object dest, byte[] buf, int offset, int length)	Sends a message
void	start(String... options)	Starts the transport, e.g.
void	stop()	Stops the transport, e.g.

Methods inherited from class java.lang.Object

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

Field Details

sock

protected DatagramSocket sock

receiver_thread

protected UdpTransport.Receiver receiver_thread

receiver

protected RtReceiver receiver

host

protected InetAddress host

port

protected int port

server

protected boolean server

log

protected final Log log

members

protected List<SocketAddress> members

Constructor Details

UdpTransport

public UdpTransport()

Method Details

options

public String[] options()

Description copied from interface: RtTransport

Prints the accepted options, e.g. [-host host] [-port port] [-server host]

Specified by:

options in interface RtTransport

Returns:

options

public void options(String... options)
             throws Exception

Description copied from interface: RtTransport

Sets options on this transport. Usually done after creation and before RtTransport.start(String...) is called, but may also be called at runtime.

Specified by:

options in interface RtTransport

Parameters:

options - The options

Throws:

Exception

receiver

public void receiver(RtReceiver receiver)

Description copied from interface: RtTransport

Sets the receiver whose RtReceiver.receive(Object,byte[],int,int) callback will be invoked whenever a message is received

Specified by:

receiver in interface RtTransport

Parameters:

receiver -

localAddress

public Object localAddress()

Description copied from interface: RtTransport

Returns the local addres of this member.

Specified by:

localAddress in interface RtTransport

Returns:

The local address. Implementations without cluster membership may return null

clusterMembers

public List<? extends Object> clusterMembers()

Description copied from interface: RtTransport

Returns the addresses of all cluster members. May return null if not implemented

Specified by:

clusterMembers in interface RtTransport

Returns:

The list of all members in the cluster

start

public void start(String... options)
           throws Exception

Description copied from interface: RtTransport

Starts the transport, e.g. connecting to a server socket

Specified by:

start in interface RtTransport

Parameters:

options - Options passed to the transport at startup time. May be null

Throws:

Exception

stop

public void stop()

Description copied from interface: RtTransport

Stops the transport, e.g. stopping the accept() loop in a TCP-based server

Specified by:

stop in interface RtTransport

send

public void send(Object dest,
 byte[] buf,
 int offset,
 int length)
          throws Exception

Description copied from interface: RtTransport

Sends a message

Specified by:

send in interface RtTransport

Parameters:

dest - The destination address

buf - The buffer

offset - The offset at which the data starts

length - The length (in bytes) of the data to send

Throws:

Exception