Class NioBaseServer

java.lang.Object

org.jgroups.blocks.cs.BaseServer

org.jgroups.blocks.cs.NioBaseServer

All Implemented Interfaces:

Closeable, AutoCloseable, ConnectionListener

Direct Known Subclasses:

NioClient, NioServer

public abstract class NioBaseServer
extends BaseServer

Base class for NIO clients / servers

Since:

3.6.5

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	NioBaseServer.Acceptor

Nested classes/interfaces inherited from class BaseServer

BaseServer.Reaper

Field Summary

Fields

Modifier and Type	Field	Description
protected Thread	acceptor
protected boolean	copy_on_partial_write
protected int	max_send_buffers
protected int	num_selects
protected long	reader_idle_time
protected final Lock	reg_lock
protected boolean	registration
protected Selector	selector
protected boolean	use_direct_memory

Fields inherited from class BaseServer

client_bind_addr, client_bind_port, conn_expire_time, conn_listeners, conns, defer_client_binding, factory, linger, local_addr, locks, log, log_details, max_length, reaper, reaperInterval, receiver, recv_buf_size, running, send_buf_size, sock_conn_timeout, socket_factory, tcp_nodelay, time_service, timer, use_peer_connections

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	NioBaseServer(ThreadFactory f, SocketFactory sf, int recv_buf_size)

Method Summary

Modifier and Type	Method	Description
protected void	acceptorDone()
boolean	acceptorRunning()
boolean	copyOnPartialWrite()
NioBaseServer	copyOnPartialWrite(boolean b)
protected NioConnection	createConnection(Address dest)	Creates a new connection object to target dest, but doesn't yet connect it
protected void	handleAccept(SelectionKey key)
int	maxSendBuffers()
NioBaseServer	maxSendBuffers(int num)
int	numDrops()
int	numPartialWrites()
int	numSelects()
String	printBuffers()	Prints send and receive buffers for all connections
long	readerIdleTime()
NioBaseServer	readerIdleTime(long t)
protected SelectionKey	register(SelectableChannel ch, int interest_ops, NioConnection conn)
boolean	selectorOpen()
boolean	useDirectMemory()
NioBaseServer	useDirectMemory(boolean b)

Methods inherited from class BaseServer

addConnectionListener, clearConnections, clearConnections, clientBindAddress, clientBindAddress, clientBindPort, clientBindPort, close, closeConnection, closeConnection, closeConnection, closeConnection, connected, connectionClosed, connectionEstablished, connectionEstablishedTo, connExpireTime, connExpireTimeout, deferClientBinding, deferClientBinding, explanation, flush, flushAll, forAllConnections, getConnection, getLock, getMaxLength, getNumConnections, getNumOpenConnections, handleIncomingConnection, handleOutgoingConnection, hasConnection, linger, linger, localAddress, localAddress, log, log, logDetails, logDetails, notifyConnectionClosed, notifyConnectionEstablished, printConnections, reaperInterval, reaperInterval, receive, receive, receive, receiveBufferSize, receiveBufferSize, receiver, receiver, removeConnectionIfPresent, removeConnectionListener, replaceConnection, retainAll, retainAll, running, send, send, sendBufferSize, sendBufferSize, sendToAll, sendToAll, setMaxLength, socketConnectionTimeout, socketConnectionTimeout, socketFactory, socketFactory, start, stop, tcpNodelay, tcpNodelay, timer, timer, timeService, timeService, toString, toString, useAcks, useAcks, usePeerConnections, usePeerConnections, validateArgs

Methods inherited from class Object

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

Field Details

selector

protected Selector selector

acceptor

protected Thread acceptor

reg_lock

protected final Lock reg_lock

registration

protected volatile boolean registration

max_send_buffers

protected int max_send_buffers

num_selects

protected int num_selects

copy_on_partial_write

protected boolean copy_on_partial_write

reader_idle_time

protected long reader_idle_time

use_direct_memory

protected boolean use_direct_memory

Constructor Details

NioBaseServer

protected NioBaseServer(ThreadFactory f,
 SocketFactory sf,
 int recv_buf_size)

Method Details

maxSendBuffers

public int maxSendBuffers()

maxSendBuffers

public NioBaseServer maxSendBuffers(int num)

selectorOpen

public boolean selectorOpen()

acceptorRunning

public boolean acceptorRunning()

numSelects

public int numSelects()

copyOnPartialWrite

public boolean copyOnPartialWrite()

readerIdleTime

public long readerIdleTime()

readerIdleTime

public NioBaseServer readerIdleTime(long t)

useDirectMemory

public boolean useDirectMemory()

useDirectMemory

public NioBaseServer useDirectMemory(boolean b)

copyOnPartialWrite

public NioBaseServer copyOnPartialWrite(boolean b)

numPartialWrites

public int numPartialWrites()

numDrops

public int numDrops()

printBuffers

public String printBuffers()

Prints send and receive buffers for all connections

register

protected SelectionKey register(SelectableChannel ch,
 int interest_ops,
 NioConnection conn)
                         throws Exception

Throws:

Exception

createConnection

protected NioConnection createConnection(Address dest)
                                  throws 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:

Exception

handleAccept

protected void handleAccept(SelectionKey key)
                     throws Exception

Throws:

Exception

acceptorDone

protected void acceptorDone()