TcpBaseServer

java.lang.Object
- org.jgroups.blocks.cs.BaseServer
- - org.jgroups.blocks.cs.TcpBaseServer

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, ConnectionListener

Direct Known Subclasses:

TcpClient, TcpServer
```
public abstract class TcpBaseServer
extends BaseServer
```
Common base class for TCP based clients and servers

Since:

3.6.5

Author:

Bela Ban

Nested Class Summary
- Nested classes/interfaces inherited from class org.jgroups.blocks.cs.BaseServer
  BaseServer.Reaper

Field Summary

Fields
Modifier and Type Field Description

protected int peer_addr_read_timeout
- Fields inherited from class org.jgroups.blocks.cs.BaseServer
  client_bind_addr, client_bind_port, conn_expire_time, conn_listeners, conns, defer_client_binding, factory, linger, local_addr, log, max_length, reaper, reaperInterval, receiver, recv_buf_size, running, send_buf_size, sock_conn_timeout, sock_creation_lock, socket_factory, tcp_nodelay, time_service, use_peer_connections

Constructor Summary

Constructors
Modifier Constructor Description

protected TcpBaseServer(ThreadFactory f, SocketFactory sf)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected TcpConnection`	`createConnection(Address dest)`	Creates a new connection object to target dest, but doesn't yet connect it
`int`	`peerAddressReadTimeout()`
`TcpBaseServer`	`peerAddressReadTimeout(int timeout)`

Methods inherited from class org.jgroups.blocks.cs.BaseServer
addConnection, addConnectionListener, clearConnections, clientBindAddress, clientBindAddress, clientBindPort, clientBindPort, close, closeConnection, connectionClosed, connectionEstablished, connectionEstablishedTo, connExpireTime, connExpireTimeout, deferClientBinding, deferClientBinding, explanation, getConnection, getMaxLength, getNumConnections, getNumOpenConnections, hasConnection, linger, linger, localAddress, localAddress, log, log, notifyConnectionClosed, notifyConnectionEstablished, printConnections, reaperInterval, reaperInterval, receive, receive, receive, receiveBufferSize, receiveBufferSize, receiver, receiver, removeConnectionIfPresent, removeConnectionListener, replaceConnection, retainAll, running, send, send, sendBufferSize, sendBufferSize, sendToAll, sendToAll, setMaxLength, socketConnectionTimeout, socketConnectionTimeout, socketFactory, socketFactory, start, stop, tcpNodelay, tcpNodelay, timeService, timeService, toString, usePeerConnections, usePeerConnections, validateArgs

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail
- peer_addr_read_timeout
```
protected int peer_addr_read_timeout
```

Constructor Detail

TcpBaseServer

protected TcpBaseServer(ThreadFactory f,
                        SocketFactory sf)

Method Detail
- createConnection
```
protected TcpConnection createConnection(Address dest)
                                  throws java.lang.Exception
```
  Description copied from class: BaseServer
  
  Creates a new connection object to target dest, but doesn't yet connect it
  
  Specified by:
  
  createConnection in class BaseServer
  
  Throws:
  
  java.lang.Exception
- peerAddressReadTimeout
```
public int peerAddressReadTimeout()
```
- peerAddressReadTimeout
```
public TcpBaseServer peerAddressReadTimeout(int timeout)
```