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

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 and Description
protected int	peer_addr_read_timeout
protected int	send_queue_size
protected SocketFactory	socket_factory
protected boolean	use_send_queues

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, reaper, reaperInterval, receiver, recv_buf_size, running, send_buf_size, sock_conn_timeout, sock_creation_lock, tcp_nodelay, time_service, use_peer_connections

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TcpBaseServer(ThreadFactory f)

Method Summary

Modifier and Type	Method and 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)
int	sendQueueSize()
TcpBaseServer	sendQueueSize(int send_queue_size)
SocketFactory	socketFactory()
TcpBaseServer	socketFactory(SocketFactory factory)
boolean	useSendQueues()
TcpBaseServer	useSendQueues(boolean flag)

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, getNumConnections, getNumOpenConnections, hasConnection, linger, linger, localAddress, localAddress, log, log, notifyConnectionClosed, notifyConnectionEstablished, printConnections, reaperInterval, reaperInterval, receive, receive, receiveBufferSize, receiveBufferSize, receiver, receiver, removeConnectionIfPresent, removeConnectionListener, replaceConnection, retainAll, running, send, send, sendBufferSize, sendBufferSize, sendToAll, sendToAll, socketConnectionTimeout, socketConnectionTimeout, 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

socket_factory

protected SocketFactory socket_factory

use_send_queues

protected volatile boolean use_send_queues

send_queue_size

protected int send_queue_size

peer_addr_read_timeout

protected int peer_addr_read_timeout

Constructor Detail

TcpBaseServer

protected TcpBaseServer(ThreadFactory f)

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)

sendQueueSize

public int sendQueueSize()

sendQueueSize

public TcpBaseServer sendQueueSize(int send_queue_size)

useSendQueues

public boolean useSendQueues()

useSendQueues

public TcpBaseServer useSendQueues(boolean flag)

socketFactory

public SocketFactory socketFactory()

socketFactory

public TcpBaseServer socketFactory(SocketFactory factory)