Class Nio2Acceptor

java.lang.Object

org.apache.sshd.common.util.logging.AbstractLoggingBean

org.apache.sshd.common.util.closeable.IoBaseCloseable

org.apache.sshd.common.util.closeable.AbstractCloseable

org.apache.sshd.common.util.closeable.AbstractInnerCloseable

org.apache.sshd.common.io.nio2.Nio2Service

org.apache.sshd.common.io.nio2.Nio2Acceptor

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, Closeable, IoAcceptor, IoService, IoServiceEventListenerManager

public class Nio2Acceptor
extends Nio2Service
implements IoAcceptor

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	Nio2Acceptor.AcceptCompletionHandler

Nested classes/interfaces inherited from class AbstractCloseable

AbstractCloseable.State

Field Summary

Fields

Modifier and Type	Field	Description
private int	backlog
protected final Map<SocketAddress, AsynchronousServerSocketChannel>	channels
private final Nio2ServiceFactory	nio2ServiceFactory

Fields inherited from class Nio2Service

CONFIGURABLE_OPTIONS, disposing, propertyResolver, sessions

Fields inherited from class AbstractCloseable

closeFuture, futureLock, state

Fields inherited from class AbstractLoggingBean

log

Fields inherited from interface IoService

DEFAULT_REUSE_ADDRESS

Constructor Summary

Constructors

Constructor	Description
Nio2Acceptor(Nio2ServiceFactory nio2ServiceFactory, PropertyResolver propertyResolver, IoHandler handler, AsynchronousChannelGroup group, ExecutorService resumeTasks)

Method Summary

Modifier and Type	Method	Description
void	bind(SocketAddress address)
void	bind(Collection<? extends SocketAddress> addresses)
protected void	closeImmediately0()
protected CompletionHandler<AsynchronousSocketChannel, ? super SocketAddress>	createSocketCompletionHandler(Map<SocketAddress, AsynchronousServerSocketChannel> channelsMap, AsynchronousServerSocketChannel socket)
Set<SocketAddress>	getBoundAddresses()
protected Closeable	getInnerCloseable()
protected AsynchronousServerSocketChannel	openAsynchronousServerSocketChannel(SocketAddress address, AsynchronousChannelGroup group)
protected void	preClose()	preClose is guaranteed to be called before doCloseGracefully or doCloseImmediately.
protected Closeable	protectInProgressBinding(SocketAddress address, AsynchronousServerSocketChannel asyncChannel)
String	toString()
void	unbind()
void	unbind(SocketAddress address)
void	unbind(Collection<? extends SocketAddress> addresses)

Methods inherited from class Nio2Service

dispose, getChannelGroup, getExecutorService, getIoHandler, getIoServiceEventListener, getManagedSessions, mapSession, sessionClosed, setIoServiceEventListener, setOption, setSocketOptions, unmapSession

Methods inherited from class AbstractInnerCloseable

doCloseGracefully, doCloseImmediately

Methods inherited from class AbstractCloseable

addCloseFutureListener, builder, close, getFutureLock, isClosed, isClosing, removeCloseFutureListener

Methods inherited from class AbstractLoggingBean

debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn

Methods inherited from class Object

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

Methods inherited from interface Closeable

addCloseFutureListener, close, close, isClosed, isClosing, isOpen, removeCloseFutureListener

Methods inherited from interface IoService

getManagedSessions

Methods inherited from interface IoServiceEventListenerManager

getIoServiceEventListener, setIoServiceEventListener

Field Details

channels

protected final Map<SocketAddress, AsynchronousServerSocketChannel> channels

nio2ServiceFactory

private final Nio2ServiceFactory nio2ServiceFactory

backlog

private int backlog

Constructor Details

Nio2Acceptor

public Nio2Acceptor(Nio2ServiceFactory nio2ServiceFactory,
 PropertyResolver propertyResolver,
 IoHandler handler,
 AsynchronousChannelGroup group,
 ExecutorService resumeTasks)

Method Details

bind

public void bind(Collection<? extends SocketAddress> addresses)
          throws IOException

Specified by:

bind in interface IoAcceptor

Throws:

IOException

protectInProgressBinding

protected Closeable protectInProgressBinding(SocketAddress address,
 AsynchronousServerSocketChannel asyncChannel)

openAsynchronousServerSocketChannel

protected AsynchronousServerSocketChannel openAsynchronousServerSocketChannel(SocketAddress address,
 AsynchronousChannelGroup group)
                                                                       throws IOException

Throws:

IOException

createSocketCompletionHandler

protected CompletionHandler<AsynchronousSocketChannel, ? super SocketAddress> createSocketCompletionHandler(Map<SocketAddress, AsynchronousServerSocketChannel> channelsMap,
 AsynchronousServerSocketChannel socket)
                                                                                                     throws IOException

Throws:

IOException

bind

public void bind(SocketAddress address)
          throws IOException

Specified by:

bind in interface IoAcceptor

Throws:

IOException

unbind

public void unbind()

Specified by:

unbind in interface IoAcceptor

unbind

public void unbind(Collection<? extends SocketAddress> addresses)

Specified by:

unbind in interface IoAcceptor

unbind

public void unbind(SocketAddress address)

Specified by:

unbind in interface IoAcceptor

getBoundAddresses

public Set<SocketAddress> getBoundAddresses()

Specified by:

getBoundAddresses in interface IoAcceptor

preClose

protected void preClose()

Description copied from class: AbstractCloseable

preClose is guaranteed to be called before doCloseGracefully or doCloseImmediately. When preClose() is called, isClosing() == true

Overrides:

preClose in class AbstractCloseable

getInnerCloseable

protected Closeable getInnerCloseable()

Overrides:

getInnerCloseable in class Nio2Service

closeImmediately0

protected void closeImmediately0()

toString

public String toString()

Overrides:

toString in class Object