Package org.jgroups.util

Class DefaultSocketFactory

java.lang.Object

org.jgroups.util.DefaultSocketFactory

All Implemented Interfaces:

SocketFactory

public class DefaultSocketFactory
extends Object
implements SocketFactory

Default implementation, ignores service names

Author:

Bela Ban

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<Object,String>	sockets

Constructor Summary

Constructors

Constructor	Description
DefaultSocketFactory()

Method Summary

Modifier and Type	Method	Description
protected <T> T	add(T sock, String service_name)
void	close(DatagramSocket sock)
void	close(ServerSocket sock)
void	close(Socket sock)
DatagramSocket	createDatagramSocket(String service_name)
DatagramSocket	createDatagramSocket(String service_name, int port)
DatagramSocket	createDatagramSocket(String service_name, int port, InetAddress laddr)
DatagramSocket	createDatagramSocket(String service_name, SocketAddress bindaddr)
MulticastSocket	createMulticastSocket(String service_name)
MulticastSocket	createMulticastSocket(String service_name, int port)
MulticastSocket	createMulticastSocket(String service_name, SocketAddress bindaddr)
ServerSocket	createServerSocket(String service_name)
ServerSocket	createServerSocket(String service_name, int port)
ServerSocket	createServerSocket(String service_name, int port, int backlog)
ServerSocket	createServerSocket(String service_name, int port, int backlog, InetAddress bindAddr)
Socket	createSocket(String service_name)
Socket	createSocket(String service_name, String host, int port)
Socket	createSocket(String service_name, String host, int port, InetAddress localAddr, int localPort)
Socket	createSocket(String service_name, InetAddress address, int port)
Socket	createSocket(String service_name, InetAddress address, int port, InetAddress localAddr, int localPort)
Map<Object,String>	getSockets()	Returns all open sockets.
protected <T> void	remove(T sock)

Methods inherited from class java.lang.Object

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

Field Details

sockets

protected final Map<Object,String> sockets

Constructor Details

DefaultSocketFactory

public DefaultSocketFactory()

Method Details

createSocket

public Socket createSocket(String service_name)
                    throws IOException

Specified by:

createSocket in interface SocketFactory

Throws:

IOException

createSocket

public Socket createSocket(String service_name,
 String host,
 int port)
                    throws IOException

Specified by:

createSocket in interface SocketFactory

Throws:

IOException

createSocket

public Socket createSocket(String service_name,
 InetAddress address,
 int port)
                    throws IOException

Specified by:

createSocket in interface SocketFactory

Throws:

IOException

createSocket

public Socket createSocket(String service_name,
 String host,
 int port,
 InetAddress localAddr,
 int localPort)
                    throws IOException

Specified by:

createSocket in interface SocketFactory

Throws:

IOException

createSocket

public Socket createSocket(String service_name,
 InetAddress address,
 int port,
 InetAddress localAddr,
 int localPort)
                    throws IOException

Specified by:

createSocket in interface SocketFactory

Throws:

IOException

createServerSocket

public ServerSocket createServerSocket(String service_name)
                                throws IOException

Specified by:

createServerSocket in interface SocketFactory

Throws:

IOException

createServerSocket

public ServerSocket createServerSocket(String service_name,
 int port)
                                throws IOException

Specified by:

createServerSocket in interface SocketFactory

Throws:

IOException

createServerSocket

public ServerSocket createServerSocket(String service_name,
 int port,
 int backlog)
                                throws IOException

Specified by:

createServerSocket in interface SocketFactory

Throws:

IOException

createServerSocket

public ServerSocket createServerSocket(String service_name,
 int port,
 int backlog,
 InetAddress bindAddr)
                                throws IOException

Specified by:

createServerSocket in interface SocketFactory

Throws:

IOException

createDatagramSocket

public DatagramSocket createDatagramSocket(String service_name)
                                    throws SocketException

Specified by:

createDatagramSocket in interface SocketFactory

Throws:

SocketException

createDatagramSocket

public DatagramSocket createDatagramSocket(String service_name,
 SocketAddress bindaddr)
                                    throws SocketException

Specified by:

createDatagramSocket in interface SocketFactory

Throws:

SocketException

createDatagramSocket

public DatagramSocket createDatagramSocket(String service_name,
 int port)
                                    throws SocketException

Specified by:

createDatagramSocket in interface SocketFactory

Throws:

SocketException

createDatagramSocket

public DatagramSocket createDatagramSocket(String service_name,
 int port,
 InetAddress laddr)
                                    throws SocketException

Specified by:

createDatagramSocket in interface SocketFactory

Throws:

SocketException

createMulticastSocket

public MulticastSocket createMulticastSocket(String service_name)
                                      throws IOException

Specified by:

createMulticastSocket in interface SocketFactory

Throws:

IOException

createMulticastSocket

public MulticastSocket createMulticastSocket(String service_name,
 int port)
                                      throws IOException

Specified by:

createMulticastSocket in interface SocketFactory

Throws:

IOException

createMulticastSocket

public MulticastSocket createMulticastSocket(String service_name,
 SocketAddress bindaddr)
                                      throws IOException

Specified by:

createMulticastSocket in interface SocketFactory

Throws:

IOException

close

public void close(Socket sock)
           throws IOException

Specified by:

close in interface SocketFactory

Throws:

IOException

close

public void close(ServerSocket sock)
           throws IOException

Specified by:

close in interface SocketFactory

Throws:

IOException

close

public void close(DatagramSocket sock)

Specified by:

close in interface SocketFactory

getSockets

public Map<Object,String> getSockets()

Description copied from interface: SocketFactory

Returns all open sockets. This method can be used to list or close all open sockets.

Specified by:

getSockets in interface SocketFactory

Returns:

A map of open sockets; keys are Sockets, ServerSockets, DatagramSockets or MulticastSockets, values are the service names.

add

protected <T> T add(T sock,
 String service_name)

remove

protected <T> void remove(T sock)