org.jgroups.blocks
Class BasicConnectionTable
java.lang.Object
org.jgroups.blocks.BasicConnectionTable
- Direct Known Subclasses:
- ConnectionTable, ConnectionTableNIO
public abstract class BasicConnectionTable
- extends java.lang.Object
Shared class for TCP connection tables.
- Author:
- Scott Marlow
Field Summary |
protected org.apache.commons.logging.Log |
log
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
log
protected final org.apache.commons.logging.Log log
BasicConnectionTable
public BasicConnectionTable()
setReceiver
public final void setReceiver(BasicConnectionTable.Receiver r)
addConnectionListener
public void addConnectionListener(BasicConnectionTable.ConnectionListener l)
removeConnectionListener
public void removeConnectionListener(BasicConnectionTable.ConnectionListener l)
getLocalAddress
public Address getLocalAddress()
getSendBufferSize
public int getSendBufferSize()
setSendBufferSize
public void setSendBufferSize(int send_buf_size)
getReceiveBufferSize
public int getReceiveBufferSize()
setReceiveBufferSize
public void setReceiveBufferSize(int recv_buf_size)
getSocketConnectionTimeout
public int getSocketConnectionTimeout()
setSocketConnectionTimeout
public void setSocketConnectionTimeout(int sock_conn_timeout)
getNumConnections
public int getNumConnections()
getTcpNodelay
public boolean getTcpNodelay()
setTcpNodelay
public void setTcpNodelay(boolean tcp_nodelay)
getLinger
public int getLinger()
setLinger
public void setLinger(int linger)
getUseSendQueues
public boolean getUseSendQueues()
setUseSendQueues
public void setUseSendQueues(boolean flag)
start
public void start()
throws java.lang.Exception
- Throws:
java.lang.Exception
stop
public void stop()
remove
public void remove(Address addr)
- Remove
addr
from connection table. This is typically triggered when a member is suspected.
receive
public void receive(Address sender,
byte[] data,
int offset,
int length)
- Calls the receiver callback. We serialize access to this method because it may be called concurrently
by several Connection handler threads. Therefore the receiver doesn't need to synchronize.
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
send
public void send(Address dest,
byte[] data,
int offset,
int length)
throws java.lang.Exception
- Throws:
java.lang.Exception
retainAll
public void retainAll(java.util.Collection current_mbrs)
- Removes all connections from ConnectionTable which are not in current_mbrs
- Parameters:
current_mbrs
-
Copyright ? 1998-2006 Bela Ban. All Rights Reserved.