Package org.jgroups.blocks.cs
Class TcpBaseServer
- java.lang.Object
-
- org.jgroups.blocks.cs.BaseServer
-
- org.jgroups.blocks.cs.TcpBaseServer
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,ConnectionListener
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 itint
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
-
-
-
-
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 classBaseServer
- Throws:
java.lang.Exception
-
peerAddressReadTimeout
public int peerAddressReadTimeout()
-
peerAddressReadTimeout
public TcpBaseServer peerAddressReadTimeout(int timeout)
-
-