org.apache.sshd.common.io

Class AbstractIoServiceFactory

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

All Implemented Interfaces:

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

Direct Known Subclasses:

Nio2ServiceFactory

public abstract class AbstractIoServiceFactory
extends AbstractCloseable
implements IoServiceFactory, FactoryManagerHolder, ExecutorServiceCarrier

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
private IoServiceEventListener	eventListener
private CloseableExecutorService	executor
private FactoryManager	manager

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

closeFuture, lock, state

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

log

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

CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractIoServiceFactory(FactoryManager factoryManager, CloseableExecutorService executorService)

Method Summary

Modifier and Type	Method and Description
protected <S extends IoService> S	autowireCreatedService(S service)
protected void	doCloseImmediately() doCloseImmediately is called once and only once with state == Immediate
CloseableExecutorService	getExecutorService()
FactoryManager	getFactoryManager()
IoServiceEventListener	getIoServiceEventListener()
static int	getNioWorkers(FactoryManager manager)
void	setIoServiceEventListener(IoServiceEventListener listener)

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

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

createAcceptor, createConnector

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

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

Field Detail

eventListener

private IoServiceEventListener eventListener

manager

private final FactoryManager manager

executor

private final CloseableExecutorService executor

Constructor Detail

AbstractIoServiceFactory

protected AbstractIoServiceFactory(FactoryManager factoryManager,
                                   CloseableExecutorService executorService)

Method Detail

getFactoryManager

public final FactoryManager getFactoryManager()

Specified by:

getFactoryManager in interface FactoryManagerHolder

Returns:

The currently associated FactoryManager

getExecutorService

public final CloseableExecutorService getExecutorService()

Specified by:

getExecutorService in interface ExecutorServiceCarrier

Returns:

The CloseableExecutorService to use

getIoServiceEventListener

public IoServiceEventListener getIoServiceEventListener()

Specified by:

getIoServiceEventListener in interface IoServiceEventListenerManager

setIoServiceEventListener

public void setIoServiceEventListener(IoServiceEventListener listener)

Specified by:

setIoServiceEventListener in interface IoServiceEventListenerManager

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 AbstractCloseable

autowireCreatedService

protected <S extends IoService> S autowireCreatedService(S service)

getNioWorkers

public static int getNioWorkers(FactoryManager manager)