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, org.apache.sshd.common.Closeable, org.apache.sshd.common.io.IoAcceptor, org.apache.sshd.common.io.IoService, org.apache.sshd.common.io.IoServiceEventListenerManager

public class Nio2Acceptor
extends Nio2Service
implements org.apache.sshd.common.io.IoAcceptor

Author:

Apache MINA SSHD Project

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	Nio2Acceptor.AcceptCompletionHandler

Nested classes/interfaces inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable

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

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<SocketAddress, AsynchronousServerSocketChannel>	channels

Fields inherited from class Nio2Service

CONFIGURABLE_OPTIONS, disposing, propertyResolver, sessions

Fields inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable

closeFuture, futureLock, state

Fields inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean

log

Fields inherited from interface org.apache.sshd.common.io.IoService

DEFAULT_REUSE_ADDRESS

Constructor Summary

Constructors

Constructor	Description
Nio2Acceptor(Nio2ServiceFactory nio2ServiceFactory, org.apache.sshd.common.PropertyResolver propertyResolver, org.apache.sshd.common.io.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 org.apache.sshd.common.Closeable	getInnerCloseable()
protected AsynchronousServerSocketChannel	openAsynchronousServerSocketChannel(SocketAddress address, AsynchronousChannelGroup group)
protected void	preClose()
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 org.apache.sshd.common.util.closeable.AbstractInnerCloseable

doCloseGracefully, doCloseImmediately

Methods inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable

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

Methods inherited from class org.apache.sshd.common.util.logging.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 org.apache.sshd.common.Closeable

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

Methods inherited from interface org.apache.sshd.common.io.IoService

getManagedSessions

Methods inherited from interface org.apache.sshd.common.io.IoServiceEventListenerManager

getIoServiceEventListener, setIoServiceEventListener

Field Details

channels

protected final Map<SocketAddress, AsynchronousServerSocketChannel> channels

Constructor Details

Nio2Acceptor

public Nio2Acceptor(Nio2ServiceFactory nio2ServiceFactory,
 org.apache.sshd.common.PropertyResolver propertyResolver,
 org.apache.sshd.common.io.IoHandler handler,
 AsynchronousChannelGroup group,
 ExecutorService resumeTasks)

Method Details

bind

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

Specified by:

bind in interface org.apache.sshd.common.io.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 org.apache.sshd.common.io.IoAcceptor

Throws:

IOException

unbind

public void unbind()

Specified by:

unbind in interface org.apache.sshd.common.io.IoAcceptor

unbind

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

Specified by:

unbind in interface org.apache.sshd.common.io.IoAcceptor

unbind

public void unbind(SocketAddress address)

Specified by:

unbind in interface org.apache.sshd.common.io.IoAcceptor

getBoundAddresses

public Set<SocketAddress> getBoundAddresses()

Specified by:

getBoundAddresses in interface org.apache.sshd.common.io.IoAcceptor

preClose

protected void preClose()

Overrides:

preClose in class org.apache.sshd.common.util.closeable.AbstractCloseable

getInnerCloseable

protected org.apache.sshd.common.Closeable getInnerCloseable()

Overrides:

getInnerCloseable in class Nio2Service

closeImmediately0

protected void closeImmediately0()

toString

public String toString()

Overrides:

toString in class Object