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, org.apache.sshd.common.Closeable, org.apache.sshd.common.io.IoService, org.apache.sshd.common.io.IoServiceEventListenerManager
Direct Known Subclasses:
NettyIoAcceptor, NettyIoConnector
public abstract class NettyIoService extends org.apache.sshd.common.util.closeable.AbstractCloseable implements org.apache.sshd.common.io.IoService

  • 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<org.apache.sshd.common.io.IoConnectFuture>
    CONNECT_FUTURE_KEY
     
    private org.apache.sshd.common.io.IoServiceEventListener
    eventListener
     
    protected final NettyIoServiceFactory
    factory
     
    protected final org.apache.sshd.common.io.IoHandler
    handler
     
    private boolean
    noMoreSessions
     
    protected final Map<Long, org.apache.sshd.common.io.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, org.apache.sshd.common.io.IoHandler handler, String channelGroupName)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    doCloseImmediately()
     
    org.apache.sshd.common.io.IoServiceEventListener
    getIoServiceEventListener()
     
    Map<Long, org.apache.sshd.common.io.IoSession>
    getManagedSessions()
     
    protected void
    mapSession(org.apache.sshd.common.io.IoSession session)
     
    protected void
    registerChannel(io.netty.channel.Channel channel)
     
    void
    setIoServiceEventListener(org.apache.sshd.common.io.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 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<org.apache.sshd.common.io.IoConnectFuture> CONNECT_FUTURE_KEY

    • sessionSeq

      protected final AtomicLong sessionSeq

    • sessions

      protected final Map<Long, org.apache.sshd.common.io.IoSession> sessions

    • channelGroup

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

    • factory

      protected final NettyIoServiceFactory factory

    • handler

      protected final org.apache.sshd.common.io.IoHandler handler

    • noMoreSessions

      private boolean noMoreSessions

    • eventListener

      private org.apache.sshd.common.io.IoServiceEventListener eventListener

  • Constructor Details

    • NettyIoService

      protected NettyIoService(NettyIoServiceFactory factory, org.apache.sshd.common.io.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(org.apache.sshd.common.io.IoSession session) throws CancellationException
      Throws:
      CancellationException

    • getIoServiceEventListener

      public org.apache.sshd.common.io.IoServiceEventListener getIoServiceEventListener()
      Specified by:
      getIoServiceEventListener in interface org.apache.sshd.common.io.IoServiceEventListenerManager

    • setIoServiceEventListener

      public void setIoServiceEventListener(org.apache.sshd.common.io.IoServiceEventListener listener)
      Specified by:
      setIoServiceEventListener in interface org.apache.sshd.common.io.IoServiceEventListenerManager

    • getManagedSessions

      public Map<Long, org.apache.sshd.common.io.IoSession> getManagedSessions()
      Specified by:
      getManagedSessions in interface org.apache.sshd.common.io.IoService