org.jgroups.blocks
Class TCPConnectionMap
java.lang.Object
org.jgroups.blocks.TCPConnectionMap
public class TCPConnectionMap
- extends java.lang.Object
Constructor Summary |
TCPConnectionMap(java.lang.String service_name,
ThreadFactory f,
SocketFactory socket_factory,
TCPConnectionMap.Receiver r,
java.net.InetAddress bind_addr,
java.net.InetAddress external_addr,
int srv_port,
int max_port)
|
TCPConnectionMap(java.lang.String service_name,
ThreadFactory f,
SocketFactory socket_factory,
TCPConnectionMap.Receiver r,
java.net.InetAddress bind_addr,
java.net.InetAddress external_addr,
int srv_port,
int max_port,
long reaper_interval,
long conn_expire_time)
|
TCPConnectionMap(java.lang.String service_name,
ThreadFactory f,
TCPConnectionMap.Receiver r,
java.net.InetAddress bind_addr,
java.net.InetAddress external_addr,
int srv_port,
int max_port,
long reaper_interval,
long conn_expire_time)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
socket_factory
protected SocketFactory socket_factory
TCPConnectionMap
public TCPConnectionMap(java.lang.String service_name,
ThreadFactory f,
SocketFactory socket_factory,
TCPConnectionMap.Receiver r,
java.net.InetAddress bind_addr,
java.net.InetAddress external_addr,
int srv_port,
int max_port)
throws java.lang.Exception
- Throws:
java.lang.Exception
TCPConnectionMap
public TCPConnectionMap(java.lang.String service_name,
ThreadFactory f,
TCPConnectionMap.Receiver r,
java.net.InetAddress bind_addr,
java.net.InetAddress external_addr,
int srv_port,
int max_port,
long reaper_interval,
long conn_expire_time)
throws java.lang.Exception
- Throws:
java.lang.Exception
TCPConnectionMap
public TCPConnectionMap(java.lang.String service_name,
ThreadFactory f,
SocketFactory socket_factory,
TCPConnectionMap.Receiver r,
java.net.InetAddress bind_addr,
java.net.InetAddress external_addr,
int srv_port,
int max_port,
long reaper_interval,
long conn_expire_time)
throws java.lang.Exception
- Throws:
java.lang.Exception
getLocalAddress
public Address getLocalAddress()
getReceiver
public TCPConnectionMap.Receiver getReceiver()
setReceiver
public void setReceiver(TCPConnectionMap.Receiver receiver)
getSocketFactory
public SocketFactory getSocketFactory()
setSocketFactory
public void setSocketFactory(SocketFactory socket_factory)
addConnectionMapListener
public void addConnectionMapListener(AbstractConnectionMap.ConnectionMapListener<TCPConnectionMap.TCPConnection> l)
removeConnectionMapListener
public void removeConnectionMapListener(AbstractConnectionMap.ConnectionMapListener<TCPConnectionMap.TCPConnection> l)
receive
public void receive(Address sender,
byte[] data,
int offset,
int length)
- Calls the receiver callback. We do not serialize access to this method,
and it may be called concurrently by several Connection handler threads.
Therefore the receiver needs to be reentrant.
send
public void send(Address dest,
byte[] data,
int offset,
int length)
throws java.lang.Exception
- Throws:
java.lang.Exception
start
public void start()
throws java.lang.Exception
- Throws:
java.lang.Exception
stop
public void stop()
setReceiveBufferSize
public void setReceiveBufferSize(int recv_buf_size)
setSocketConnectionTimeout
public void setSocketConnectionTimeout(int sock_conn_timeout)
setSendBufferSize
public void setSendBufferSize(int send_buf_size)
setLinger
public void setLinger(int linger)
setTcpNodelay
public void setTcpNodelay(boolean tcp_nodelay)
setSendQueueSize
public void setSendQueueSize(int send_queue_size)
setUseSendQueues
public void setUseSendQueues(boolean use_send_queues)
getNumConnections
public int getNumConnections()
connectionEstablishedTo
public boolean connectionEstablishedTo(Address addr)
printConnections
public java.lang.String printConnections()
retainAll
public void retainAll(java.util.Collection<Address> members)
getConnectionExpiryTimeout
public long getConnectionExpiryTimeout()
getSenderQueueSize
public int getSenderQueueSize()
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
Copyright © 1998-2009 Bela Ban / Red Hat. All Rights Reserved.