public abstract class NioBaseServer extends BaseServer
Modifier and Type | Class and Description |
---|---|
protected class |
NioBaseServer.Acceptor |
BaseServer.Reaper
Modifier and Type | Field and 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 Lock |
reg_lock |
protected boolean |
registration |
protected Selector |
selector |
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, use_peer_connections
Modifier | Constructor and Description |
---|---|
protected |
NioBaseServer(ThreadFactory f,
SocketFactory sf) |
Modifier and Type | Method and Description |
---|---|
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 |
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() |
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, receive, receiveBufferSize, receiveBufferSize, receiver, receiver, removeConnectionIfPresent, removeConnectionListener, replaceConnection, retainAll, running, send, send, sendBufferSize, sendBufferSize, sendToAll, sendToAll, socketConnectionTimeout, socketConnectionTimeout, socketFactory, socketFactory, start, stop, tcpNodelay, tcpNodelay, timeService, timeService, toString, usePeerConnections, usePeerConnections, validateArgs
protected Selector selector
protected Thread acceptor
protected final Lock reg_lock
protected volatile boolean registration
protected int max_send_buffers
protected int num_selects
protected boolean copy_on_partial_write
protected long reader_idle_time
protected NioBaseServer(ThreadFactory f, SocketFactory sf)
public int maxSendBuffers()
public NioBaseServer maxSendBuffers(int num)
public boolean selectorOpen()
public boolean acceptorRunning()
public int numSelects()
public boolean copyOnPartialWrite()
public long readerIdleTime()
public NioBaseServer readerIdleTime(long t)
public NioBaseServer copyOnPartialWrite(boolean b)
public int numPartialWrites()
public String printBuffers()
protected SelectionKey register(SelectableChannel ch, int interest_ops, NioConnection conn) throws Exception
Exception
protected NioConnection createConnection(Address dest) throws Exception
BaseServer
createConnection
in class BaseServer
Exception
protected void handleAccept(SelectionKey key) throws Exception
Exception
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.