Class Nio2Service

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

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, Closeable, IoService, IoServiceEventListenerManager

Direct Known Subclasses:

Nio2Acceptor, Nio2Connector

public abstract class Nio2Service
extends AbstractInnerCloseable
implements IoService

Nested Class Summary

Nested classes/interfaces inherited from class AbstractCloseable

AbstractCloseable.State

Field Summary

Fields

Modifier and Type	Field	Description
static final Map<Property<?>, AbstractMap.SimpleImmutableEntry<SocketOption<?>, Object>>	CONFIGURABLE_OPTIONS
protected final AtomicBoolean	disposing
private IoServiceEventListener	eventListener
private final ExecutorService	executor
private final AsynchronousChannelGroup	group
private final IoHandler	handler
private boolean	noMoreSessions
protected final PropertyResolver	propertyResolver
protected final Map<Long, IoSession>	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

Modifier	Constructor	Description
protected	Nio2Service(PropertyResolver propertyResolver, IoHandler handler, AsynchronousChannelGroup group, ExecutorService resumeTasks)

Method Summary

Modifier and Type	Method	Description
void	dispose()
protected AsynchronousChannelGroup	getChannelGroup()
protected ExecutorService	getExecutorService()
protected Closeable	getInnerCloseable()
IoHandler	getIoHandler()
IoServiceEventListener	getIoServiceEventListener()
Map<Long, IoSession>	getManagedSessions()	Returns the map of all sessions which are currently managed by this service.
protected IoSession	mapSession(IoSession session)
void	sessionClosed(Nio2Session session)
void	setIoServiceEventListener(IoServiceEventListener listener)
protected <T> boolean	setOption(NetworkChannel socket, Property<?> property, SocketOption<T> option, T defaultValue)
protected <S extends NetworkChannel> S	setSocketOptions(S socket)
private Collection<IoSession>	snapshot()
protected void	unmapSession(Long sessionId)

Methods inherited from class AbstractInnerCloseable

doCloseGracefully, doCloseImmediately

Methods inherited from class AbstractCloseable

addCloseFutureListener, builder, close, getFutureLock, isClosed, isClosing, preClose, 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, toString, wait, wait, wait

Methods inherited from interface Closeable

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

Field Details

CONFIGURABLE_OPTIONS

public static final Map<Property<?>, AbstractMap.SimpleImmutableEntry<SocketOption<?>, Object>> CONFIGURABLE_OPTIONS

sessions

protected final Map<Long, IoSession> sessions

disposing

protected final AtomicBoolean disposing

propertyResolver

protected final PropertyResolver propertyResolver

handler

private final IoHandler handler

group

private final AsynchronousChannelGroup group

executor

private final ExecutorService executor

eventListener

private IoServiceEventListener eventListener

noMoreSessions

private boolean noMoreSessions

Constructor Details

Nio2Service

protected Nio2Service(PropertyResolver propertyResolver,
 IoHandler handler,
 AsynchronousChannelGroup group,
 ExecutorService resumeTasks)

Method Details

getIoServiceEventListener

public IoServiceEventListener getIoServiceEventListener()

Specified by:

getIoServiceEventListener in interface IoServiceEventListenerManager

setIoServiceEventListener

public void setIoServiceEventListener(IoServiceEventListener listener)

Specified by:

setIoServiceEventListener in interface IoServiceEventListenerManager

getChannelGroup

protected AsynchronousChannelGroup getChannelGroup()

getExecutorService

protected ExecutorService getExecutorService()

getIoHandler

public IoHandler getIoHandler()

dispose

public void dispose()

getInnerCloseable

protected Closeable getInnerCloseable()

Specified by:

getInnerCloseable in class AbstractInnerCloseable

getManagedSessions

public Map<Long, IoSession> getManagedSessions()

Description copied from interface: IoService

Returns the map of all sessions which are currently managed by this service. The key of map is the ID of the session.

Specified by:

getManagedSessions in interface IoService

Returns:

the sessions. An empty collection if there's no session.

sessionClosed

public void sessionClosed(Nio2Session session)

snapshot

private Collection<IoSession> snapshot()

mapSession

protected IoSession mapSession(IoSession session)

unmapSession

protected void unmapSession(Long sessionId)

setSocketOptions

protected <S extends NetworkChannel> S setSocketOptions(S socket)
                                                 throws IOException

Throws:

IOException

setOption

protected <T> boolean setOption(NetworkChannel socket,
 Property<?> property,
 SocketOption<T> option,
 T defaultValue)
                         throws IOException

Throws:

IOException