Class Nio2ServiceFactory

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.io.AbstractIoServiceFactory

org.apache.sshd.common.io.nio2.Nio2ServiceFactory

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, Closeable, FactoryManagerHolder, IoServiceEventListenerManager, IoServiceFactory, ExecutorServiceCarrier

public class Nio2ServiceFactory
extends AbstractIoServiceFactory

Nested Class Summary

Nested classes/interfaces inherited from class AbstractCloseable

AbstractCloseable.State

Field Summary

Fields

Modifier and Type	Field	Description
private final AsynchronousChannelGroup	group
private final CloseableExecutorService	resuming

Fields inherited from class AbstractCloseable

closeFuture, futureLock, state

Fields inherited from class AbstractLoggingBean

log

Constructor Summary

Constructors

Constructor	Description
Nio2ServiceFactory(FactoryManager factoryManager, CloseableExecutorService service, CloseableExecutorService resumeTasks)

Method Summary

Modifier and Type	Method	Description
IoAcceptor	createAcceptor(IoHandler handler)
IoConnector	createConnector(IoHandler handler)
Nio2Session	createSession(Nio2Service service, IoHandler handler, AsynchronousSocketChannel socket, SocketAddress address)
protected void	doCloseImmediately()	doCloseImmediately is called once and only once with state == Immediate

Methods inherited from class AbstractIoServiceFactory

autowireCreatedService, getExecutorService, getFactoryManager, getIoServiceEventListener, getNioWorkers, setIoServiceEventListener

Methods inherited from class AbstractCloseable

addCloseFutureListener, builder, close, doCloseGracefully, 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

group

private final AsynchronousChannelGroup group

resuming

private final CloseableExecutorService resuming

Constructor Details

Nio2ServiceFactory

public Nio2ServiceFactory(FactoryManager factoryManager,
 CloseableExecutorService service,
 CloseableExecutorService resumeTasks)

Method Details

createConnector

public IoConnector createConnector(IoHandler handler)

createAcceptor

public IoAcceptor createAcceptor(IoHandler handler)

createSession

public Nio2Session createSession(Nio2Service service,
 IoHandler handler,
 AsynchronousSocketChannel socket,
 SocketAddress address)
                          throws Throwable

Throws:

Throwable

doCloseImmediately

protected void doCloseImmediately()

Description copied from class: AbstractCloseable

doCloseImmediately is called once and only once with state == Immediate

Overriding methods should always call the base implementation. It may be called concurrently while preClose() or doCloseGracefully is executing

Overrides:

doCloseImmediately in class AbstractIoServiceFactory