Package org.apache.sshd.netty

Class NettyIoService

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.netty.NettyIoService

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, Closeable, IoService, IoServiceEventListenerManager

Direct Known Subclasses:

NettyIoAcceptor, NettyIoConnector

public abstract class NettyIoService
extends org.apache.sshd.common.util.closeable.AbstractCloseable
implements IoService

Author:

Julien Viet, Apache MINA SSHD Project

Nested Class Summary

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 io.netty.channel.group.ChannelGroup	channelGroup
static final io.netty.util.AttributeKey<IoConnectFuture>	CONNECT_FUTURE_KEY
protected final NettyIoServiceFactory	factory
protected final IoHandler	handler
protected final Map<Long,IoSession>	sessions
protected final AtomicLong	sessionSeq

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

Modifier	Constructor	Description
protected	NettyIoService(NettyIoServiceFactory factory, IoHandler handler, String channelGroupName)

Method Summary

Modifier and Type	Method	Description
protected void	doCloseImmediately()
IoServiceEventListener	getIoServiceEventListener()
Map<Long,IoSession>	getManagedSessions()
protected void	mapSession(IoSession session)
protected void	registerChannel(io.netty.channel.Channel channel)
void	setIoServiceEventListener(IoServiceEventListener listener)

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

addCloseFutureListener, builder, close, doCloseGracefully, getFutureLock, isClosed, isClosing, preClose, 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 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, isClosed, isClosing, isOpen, removeCloseFutureListener

Field Details

CONNECT_FUTURE_KEY

public static final io.netty.util.AttributeKey<IoConnectFuture> CONNECT_FUTURE_KEY

sessionSeq

protected final AtomicLong sessionSeq

sessions

protected final Map<Long,IoSession> sessions

channelGroup

protected final io.netty.channel.group.ChannelGroup channelGroup

factory

protected final NettyIoServiceFactory factory

handler

protected final IoHandler handler

Constructor Details

NettyIoService

protected NettyIoService(NettyIoServiceFactory factory,
 IoHandler handler,
 String channelGroupName)

Method Details

doCloseImmediately

protected void doCloseImmediately()

Overrides:

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

registerChannel

protected void registerChannel(io.netty.channel.Channel channel)
                        throws CancellationException

Throws:

CancellationException

mapSession

protected void mapSession(IoSession session)
                   throws CancellationException

Throws:

CancellationException

getIoServiceEventListener

public IoServiceEventListener getIoServiceEventListener()

Specified by:

getIoServiceEventListener in interface IoServiceEventListenerManager

setIoServiceEventListener

public void setIoServiceEventListener(IoServiceEventListener listener)

Specified by:

setIoServiceEventListener in interface IoServiceEventListenerManager

getManagedSessions

public Map<Long,IoSession> getManagedSessions()

Specified by:

getManagedSessions in interface IoService