org.jgroups.blocks

Class TcpServer

java.lang.Object

org.jgroups.blocks.BaseServer<Address,TcpConnection>

org.jgroups.blocks.TcpServer

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Server<Address>

public class TcpServer
extends BaseServer<Address,TcpConnection>

Class that manages allows to send and receive messages via TCP sockets. Uses 1 thread/connection to read messages.

Author:

Vladimir Blagojevic, Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	TcpServer.Acceptor

Nested classes/interfaces inherited from class org.jgroups.blocks.BaseServer

BaseServer.ConnectionListener<A,V extends Connection>, BaseServer.Reaper

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.Thread	acceptor
protected int	peer_addr_read_timeout
protected int	send_queue_size
protected java.net.ServerSocket	srv_sock
protected boolean	use_send_queues

Fields inherited from class org.jgroups.blocks.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, socket_factory, tcp_nodelay, time_service

Constructor Summary

Constructors

Constructor and Description
TcpServer(java.net.InetAddress bind_addr, int port)
TcpServer(IpAddress local_addr)
TcpServer(java.lang.String service_name, ThreadFactory f, SocketFactory socket_factory, Receiver<Address> r, java.net.InetAddress bind_addr, java.net.InetAddress external_addr, int external_port, int srv_port, int max_port, long reaper_interval, long conn_expire_time)

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()
TcpServer	peerAddressReadTimeout(int timeout)
int	sendQueueSize()
TcpServer	sendQueueSize(int send_queue_size)
void	start() Starts the server.
void	stop() Stops the server, e.g.
boolean	useSendQueues()
TcpServer	useSendQueues(boolean flag)

Methods inherited from class org.jgroups.blocks.BaseServer

addConnection, addConnectionListener, clientBindAddress, clientBindAddress, clientBindPort, clientBindPort, close, connectionEstablishedTo, connExpireTime, connExpireTimeout, deferClientBinding, deferClientBinding, explanation, getConnection, getNumConnections, getNumOpenConnections, hasConnection, linger, linger, localAddress, log, log, notifyConnectionClosed, notifyConnectionOpened, printConnections, reaperInterval, reaperInterval, receive, receive, receiveBufferSize, receiveBufferSize, receiver, receiver, removeConnectionIfPresent, removeConnectionListener, replaceConnection, retainAll, send, send, sendBufferSize, sendBufferSize, socketConnectionTimeout, socketConnectionTimeout, socketFactory, socketFactory, tcpNodelay, tcpNodelay, timeService, timeService, toString, validateArgs

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

srv_sock

protected final java.net.ServerSocket srv_sock

acceptor

protected final java.lang.Thread acceptor

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

TcpServer

public TcpServer(IpAddress local_addr)
          throws java.lang.Exception

Throws:

java.lang.Exception

TcpServer

public TcpServer(java.net.InetAddress bind_addr,
                 int port)
          throws java.lang.Exception

Throws:

java.lang.Exception

TcpServer

public TcpServer(java.lang.String service_name,
                 ThreadFactory f,
                 SocketFactory socket_factory,
                 Receiver<Address> r,
                 java.net.InetAddress bind_addr,
                 java.net.InetAddress external_addr,
                 int external_port,
                 int srv_port,
                 int max_port,
                 long reaper_interval,
                 long conn_expire_time)
          throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

peerAddressReadTimeout

public int peerAddressReadTimeout()

peerAddressReadTimeout

public TcpServer peerAddressReadTimeout(int timeout)

sendQueueSize

public int sendQueueSize()

sendQueueSize

public TcpServer sendQueueSize(int send_queue_size)

useSendQueues

public boolean useSendQueues()

useSendQueues

public TcpServer useSendQueues(boolean flag)

start

public void start()
           throws java.lang.Exception

Description copied from interface: Server

Starts the server. Implementations will typically create a socket and start a select loop. Note that start() should return immediately, and work (e.g. select()) should be done in a separate thread

Specified by:

start in interface Server<Address>

Overrides:

start in class BaseServer<Address,TcpConnection>

Throws:

java.lang.Exception

stop

public void stop()

Description copied from interface: Server

Stops the server, e.g. by killing the thread calling select()

Specified by:

stop in interface Server<Address>

Overrides:

stop in class BaseServer<Address,TcpConnection>

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<Address,TcpConnection>

Throws:

java.lang.Exception