org.jgroups.protocols
Class UDP_NIO.ConnectorTable
java.lang.Object
org.jgroups.protocols.UDP_NIO.ConnectorTable
- UDP_NIO
- MembershipListener, MessageListener, Receiver, Runnable
public static class UDP_NIO.ConnectorTable
extends java.lang.Object
Manages a bunch of Connectors
ConnectorTable(InetSocketAddress mcast_addr, int receive_buffer_size, int receive_sock_buf_size, boolean ip_mcast, Receiver receiver)
|
List | getConnectorAddresses() - Returns a list of local addresses (one for each Connector)
|
Receiver | getReceiver()
|
void | listenOn(String bind_interface, int local_port, int port_range, int receive_buffer_size, int receiver_sock_buf_size, int send_sock_buf_size, int ip_ttl, Receiver receiver) - Adds the given interface address to the list of interfaces on which the receiver mcast
socket has to listen.
|
void | receive(DatagramPacket packet)
|
static void | receivePacket(DatagramPacket packet, DatagramSocket sock, Receiver receiver)
|
void | run()
|
void | send(DatagramPacket msg) - Sends a packet.
|
void | setReceiver(Receiver receiver)
|
void | start() - Get all interfaces, create one Connector per interface and call start() on it
|
void | stop()
|
String | toString()
|
ConnectorTable
public ConnectorTable(InetSocketAddress mcast_addr,
int receive_buffer_size,
int receive_sock_buf_size,
boolean ip_mcast,
Receiver receiver)
throws IOException
getConnectorAddresses
public List getConnectorAddresses()
Returns a list of local addresses (one for each Connector)
getReceiver
public Receiver getReceiver()
listenOn
public void listenOn(String bind_interface,
int local_port,
int port_range,
int receive_buffer_size,
int receiver_sock_buf_size,
int send_sock_buf_size,
int ip_ttl,
Receiver receiver)
throws IOException
Adds the given interface address to the list of interfaces on which the receiver mcast
socket has to listen.
Also creates a new Connector. Calling this method twice on the same interface will throw an exception
bind_interface
- local_port
- port_range
- receive_buffer_size
-
receive
public void receive(DatagramPacket packet)
receivePacket
public static void receivePacket(DatagramPacket packet,
DatagramSocket sock,
Receiver receiver)
throws IOException
send
public void send(DatagramPacket msg)
throws Exception
Sends a packet. If the destination is a multicast address, call send() on all connectors.
If destination is not null, send the message using any Connector: if we send a unicast
message, it doesn't matter to which interface we are bound; the kernel will choose the correct
interface based on the destination and the routing table. Note that the receiver will have the
interface which was chosen by the kernel to send the message as the receiver's address, so the
correct Connector will receive a possible response.
setReceiver
public void setReceiver(Receiver receiver)
start
public void start()
throws Exception
Get all interfaces, create one Connector per interface and call start() on it
toString
public String toString()
Copyright B) 1998-2005 Bela Ban. All Rights Reserved.