BasicConnectionTable

java.lang.Object
- com.fr.third.jgroups.blocks.BasicConnectionTable

直接已知子类:

ConnectionTableNIO
```
public abstract class BasicConnectionTable
extends java.lang.Object
```
Shared class for TCP connection tables.

作者:

Scott Marlow

嵌套类概要

嵌套类
限定符和类型	类和说明
`static interface`	`BasicConnectionTable.ConnectionListener` Used to be notified about connection establishment and teardown.
`static interface`	`BasicConnectionTable.Receiver` Used for message reception.

字段概要

字段
限定符和类型字段和说明

protected Log log

protected SocketFactory socket_factory

字段
限定符和类型	字段和说明
`protected Log`	`log`
`protected SocketFactory`	`socket_factory`

构造器概要

构造器
限定符构造器和说明

protected BasicConnectionTable()

构造器
限定符	构造器和说明
`protected`	`BasicConnectionTable()`

方法概要

方法
限定符和类型	方法和说明
`void`	`addConnectionListener(BasicConnectionTable.ConnectionListener l)`
`int`	`getLinger()`
`Address`	`getLocalAddress()`
`static int`	`getNumberOfConnectionCreations()`
`int`	`getNumConnections()`
`int`	`getPeerAddressReadTimeout()`
`int`	`getReceiveBufferSize()`
`int`	`getSendBufferSize()`
`int`	`getSendQueueSize()`
`int`	`getSocketConnectionTimeout()`
`SocketFactory`	`getSocketFactory()`
`boolean`	`getTcpNodelay()`
`ThreadFactory`	`getThreadFactory()`
`boolean`	`getUseSendQueues()`
`void`	`receive(Address sender, byte[] data, int offset, int length)` Calls the receiver callback.
`void`	`removeConnection(Address addr)` Remove `addr`from connection table.
`void`	`removeConnectionListener(BasicConnectionTable.ConnectionListener l)`
`void`	`retainAll(java.util.Collection<Address> current_mbrs)` Removes all connections from ConnectionTable which are not in current_mbrs
`void`	`send(Address dest, byte[] data, int offset, int length)`
`void`	`setLinger(int linger)`
`void`	`setPeerAddressReadTimeout(int peer_addr_read_timeout)`
`void`	`setReceiveBufferSize(int recv_buf_size)`
`void`	`setReceiver(BasicConnectionTable.Receiver r)`
`void`	`setSendBufferSize(int send_buf_size)`
`void`	`setSendQueueSize(int send_queue_size)`
`void`	`setSocketConnectionTimeout(int sock_conn_timeout)`
`void`	`setSocketFactory(SocketFactory socket_factory)`
`void`	`setTcpNodelay(boolean tcp_nodelay)`
`void`	`setThreadFactory(ThreadFactory factory)`
`void`	`setUseSendQueues(boolean flag)`
`void`	`start()`
`void`	`stop()`
`java.lang.String`	`toString()`

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

字段详细资料

log
```
protected final Log log
```

socket_factory
```
protected SocketFactory socket_factory
```

构造器详细资料
- BasicConnectionTable
```
protected 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)

getPeerAddressReadTimeout

public int getPeerAddressReadTimeout()

setPeerAddressReadTimeout

public void setPeerAddressReadTimeout(int peer_addr_read_timeout)

getNumConnections
```
public int getNumConnections()
```

getNumberOfConnectionCreations

public static int getNumberOfConnectionCreations()

getTcpNodelay
```
public boolean getTcpNodelay()
```

setTcpNodelay

public void setTcpNodelay(boolean tcp_nodelay)

getLinger
```
public int getLinger()
```

setLinger
```
public void setLinger(int linger)
```

setThreadFactory

public void setThreadFactory(ThreadFactory factory)

getThreadFactory

public ThreadFactory getThreadFactory()

getSocketFactory

public SocketFactory getSocketFactory()

setSocketFactory

public void setSocketFactory(SocketFactory socket_factory)

getUseSendQueues
```
public boolean getUseSendQueues()
```

setUseSendQueues

public void setUseSendQueues(boolean flag)

getSendQueueSize
```
public int getSendQueueSize()
```

setSendQueueSize

public void setSendQueueSize(int send_queue_size)

start

public void start()
           throws java.lang.Exception

抛出:: java.lang.Exception

stop
```
public void stop()
```

removeConnection
```
public void removeConnection(Address addr)
```
Remove addrfrom 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 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.

toString
```
public java.lang.String toString()
```
覆盖:

toString 在类中 java.lang.Object

send

public void send(Address dest,
        byte[] data,
        int offset,
        int length)
          throws java.lang.Exception

抛出:: java.lang.Exception

retainAll
```
public void retainAll(java.util.Collection<Address> current_mbrs)
```
Removes all connections from ConnectionTable which are not in current_mbrs

参数:
current_mbrs -

类 BasicConnectionTable

嵌套类概要

字段概要

构造器概要

方法概要

从类继承的方法 java.lang.Object

字段详细资料

log

socket_factory

构造器详细资料

BasicConnectionTable

方法详细资料

setReceiver

addConnectionListener

removeConnectionListener

getLocalAddress

getSendBufferSize

setSendBufferSize

getReceiveBufferSize

setReceiveBufferSize

getSocketConnectionTimeout

setSocketConnectionTimeout

getPeerAddressReadTimeout

setPeerAddressReadTimeout

getNumConnections

getNumberOfConnectionCreations

getTcpNodelay

setTcpNodelay

getLinger

setLinger

setThreadFactory

getThreadFactory

getSocketFactory

setSocketFactory

getUseSendQueues

setUseSendQueues

getSendQueueSize

setSendQueueSize

start

stop

removeConnection

receive

toString

send

retainAll