public class Nio2Acceptor extends Nio2Service implements IoAcceptor
Modifier and Type | Class and Description |
---|---|
protected class |
Nio2Acceptor.AcceptCompletionHandler |
AbstractCloseable.State
Modifier and Type | Field and Description |
---|---|
private int |
backlog |
protected java.util.Map<java.net.SocketAddress,java.nio.channels.AsynchronousServerSocketChannel> |
channels |
CONFIGURABLE_OPTIONS, disposing, sessions
closeFuture, lock, state
log
DEFAULT_BACKLOG
DEFAULT_REUSE_ADDRESS
CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT
Constructor and Description |
---|
Nio2Acceptor(FactoryManager manager,
IoHandler handler,
java.nio.channels.AsynchronousChannelGroup group) |
Modifier and Type | Method and Description |
---|---|
void |
bind(java.util.Collection<? extends java.net.SocketAddress> addresses) |
void |
bind(java.net.SocketAddress address) |
protected void |
closeImmediately0() |
protected java.nio.channels.CompletionHandler<java.nio.channels.AsynchronousSocketChannel,? super java.net.SocketAddress> |
createSocketCompletionHandler(java.util.Map<java.net.SocketAddress,java.nio.channels.AsynchronousServerSocketChannel> channelsMap,
java.nio.channels.AsynchronousServerSocketChannel socket) |
java.util.Set<java.net.SocketAddress> |
getBoundAddresses() |
protected Closeable |
getInnerCloseable() |
protected java.nio.channels.AsynchronousServerSocketChannel |
openAsynchronousServerSocketChannel(java.net.SocketAddress address,
java.nio.channels.AsynchronousChannelGroup group) |
protected void |
preClose()
preClose is guaranteed to be called before doCloseGracefully or doCloseImmediately.
|
protected java.io.Closeable |
protectInProgressBinding(java.net.SocketAddress address,
java.nio.channels.AsynchronousServerSocketChannel asyncChannel) |
java.lang.String |
toString() |
void |
unbind() |
void |
unbind(java.util.Collection<? extends java.net.SocketAddress> addresses) |
void |
unbind(java.net.SocketAddress address) |
dispose, getChannelGroup, getFactoryManager, getIoHandler, getIoServiceEventListener, getManagedSessions, sessionClosed, setIoServiceEventListener, setOption, setSocketOptions, unmapSession
doCloseGracefully, doCloseImmediately
addCloseFutureListener, builder, close, isClosed, isClosing, removeCloseFutureListener
getSimplifiedLogger
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getManagedSessions
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
getIoServiceEventListener, setIoServiceEventListener
protected final java.util.Map<java.net.SocketAddress,java.nio.channels.AsynchronousServerSocketChannel> channels
private int backlog
public Nio2Acceptor(FactoryManager manager, IoHandler handler, java.nio.channels.AsynchronousChannelGroup group)
public void bind(java.util.Collection<? extends java.net.SocketAddress> addresses) throws java.io.IOException
bind
in interface IoAcceptor
java.io.IOException
protected java.io.Closeable protectInProgressBinding(java.net.SocketAddress address, java.nio.channels.AsynchronousServerSocketChannel asyncChannel)
protected java.nio.channels.AsynchronousServerSocketChannel openAsynchronousServerSocketChannel(java.net.SocketAddress address, java.nio.channels.AsynchronousChannelGroup group) throws java.io.IOException
java.io.IOException
protected java.nio.channels.CompletionHandler<java.nio.channels.AsynchronousSocketChannel,? super java.net.SocketAddress> createSocketCompletionHandler(java.util.Map<java.net.SocketAddress,java.nio.channels.AsynchronousServerSocketChannel> channelsMap, java.nio.channels.AsynchronousServerSocketChannel socket) throws java.io.IOException
java.io.IOException
public void bind(java.net.SocketAddress address) throws java.io.IOException
bind
in interface IoAcceptor
java.io.IOException
public void unbind()
unbind
in interface IoAcceptor
public void unbind(java.util.Collection<? extends java.net.SocketAddress> addresses)
unbind
in interface IoAcceptor
public void unbind(java.net.SocketAddress address)
unbind
in interface IoAcceptor
public java.util.Set<java.net.SocketAddress> getBoundAddresses()
getBoundAddresses
in interface IoAcceptor
protected void preClose()
AbstractCloseable
preClose
in class AbstractCloseable
protected Closeable getInnerCloseable()
getInnerCloseable
in class Nio2Service
protected void closeImmediately0()
public java.lang.String toString()
toString
in class java.lang.Object