org.apache.sshd.common.io.nio2

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:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel, FactoryManagerHolder, IoService, IoServiceEventListenerManager

Direct Known Subclasses:

Nio2Acceptor, Nio2Connector

public abstract class Nio2Service
extends AbstractInnerCloseable
implements IoService, FactoryManagerHolder

Nested Class Summary

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

AbstractCloseable.State

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.Map<java.lang.String,java.util.AbstractMap.SimpleImmutableEntry<java.net.SocketOption<?>,java.lang.Object>>	CONFIGURABLE_OPTIONS
protected java.util.concurrent.atomic.AtomicBoolean	disposing
private IoServiceEventListener	eventListener
private java.nio.channels.AsynchronousChannelGroup	group
private IoHandler	handler
private FactoryManager	manager
protected java.util.Map<java.lang.Long,IoSession>	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

Fields inherited from interface org.apache.sshd.common.Closeable

CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Nio2Service(FactoryManager manager, IoHandler handler, java.nio.channels.AsynchronousChannelGroup group)

Method Summary

Modifier and Type	Method and Description
void	dispose()
protected java.nio.channels.AsynchronousChannelGroup	getChannelGroup()
FactoryManager	getFactoryManager()
protected Closeable	getInnerCloseable()
IoHandler	getIoHandler()
IoServiceEventListener	getIoServiceEventListener()
java.util.Map<java.lang.Long,IoSession>	getManagedSessions() Returns the map of all sessions which are currently managed by this service.
void	sessionClosed(Nio2Session session)
void	setIoServiceEventListener(IoServiceEventListener listener)
protected <T> boolean	setOption(java.nio.channels.NetworkChannel socket, java.lang.String property, java.net.SocketOption<T> option, T defaultValue)
protected <S extends java.nio.channels.NetworkChannel> S	setSocketOptions(S socket)
protected void	unmapSession(java.lang.Long sessionId)

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, preClose, removeCloseFutureListener

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

getSimplifiedLogger

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.sshd.common.Closeable

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

Field Detail

CONFIGURABLE_OPTIONS

public static final java.util.Map<java.lang.String,java.util.AbstractMap.SimpleImmutableEntry<java.net.SocketOption<?>,java.lang.Object>> CONFIGURABLE_OPTIONS

sessions

protected final java.util.Map<java.lang.Long,IoSession> sessions

disposing

protected final java.util.concurrent.atomic.AtomicBoolean disposing

manager

private final FactoryManager manager

handler

private final IoHandler handler

group

private final java.nio.channels.AsynchronousChannelGroup group

eventListener

private IoServiceEventListener eventListener

Constructor Detail

Nio2Service

protected Nio2Service(FactoryManager manager,
                      IoHandler handler,
                      java.nio.channels.AsynchronousChannelGroup group)

Method Detail

getIoServiceEventListener

public IoServiceEventListener getIoServiceEventListener()

Specified by:

getIoServiceEventListener in interface IoServiceEventListenerManager

setIoServiceEventListener

public void setIoServiceEventListener(IoServiceEventListener listener)

Specified by:

setIoServiceEventListener in interface IoServiceEventListenerManager

getChannelGroup

protected java.nio.channels.AsynchronousChannelGroup getChannelGroup()

getFactoryManager

public FactoryManager getFactoryManager()

Specified by:

getFactoryManager in interface FactoryManagerHolder

Returns:

The currently associated FactoryManager

getIoHandler

public IoHandler getIoHandler()

dispose

public void dispose()

getInnerCloseable

protected Closeable getInnerCloseable()

Specified by:

getInnerCloseable in class AbstractInnerCloseable

getManagedSessions

public java.util.Map<java.lang.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)

unmapSession

protected void unmapSession(java.lang.Long sessionId)

setSocketOptions

protected <S extends java.nio.channels.NetworkChannel> S setSocketOptions(S socket)
                                                                   throws java.io.IOException

Throws:

java.io.IOException

setOption

protected <T> boolean setOption(java.nio.channels.NetworkChannel socket,
                                java.lang.String property,
                                java.net.SocketOption<T> option,
                                T defaultValue)
                         throws java.io.IOException

Throws:

java.io.IOException