Package | Description |
---|---|
org.apache.mina.core.polling |
Base class for implementing transport based on active polling strategies like NIO select call,
or any API based on I/O polling system calls (epoll, poll, select, kqueue, etc).
|
org.apache.mina.core.service | |
org.apache.mina.core.session | |
org.apache.mina.transport.socket.apr | |
org.apache.mina.transport.socket.nio |
Socket (TCP/IP) and Datagram (UDP/IP) support based on Java NIO (New I/O) API.
|
Modifier and Type | Class | Description |
---|---|---|
class |
AbstractPollingIoProcessor<S extends AbstractIoSession> |
An abstract implementation of
IoProcessor which helps transport
developers to write an IoProcessor easily. |
Modifier and Type | Method | Description |
---|---|---|
protected abstract S |
AbstractPollingIoAcceptor.accept(IoProcessor<S> processor,
H handle) |
Accept a client connection for a server socket and return a new
IoSession
associated with the given IoProcessor |
protected abstract T |
AbstractPollingIoConnector.newSession(IoProcessor<T> processor,
H handle) |
Create a new
IoSession from a connected socket client handle. |
Constructor | Description |
---|---|
AbstractPollingIoAcceptor(IoSessionConfig sessionConfig,
Executor executor,
IoProcessor<S> processor) |
Constructor for
AbstractPollingIoAcceptor . |
AbstractPollingIoAcceptor(IoSessionConfig sessionConfig,
IoProcessor<S> processor) |
Constructor for
AbstractPollingIoAcceptor . |
AbstractPollingIoConnector(IoSessionConfig sessionConfig,
Executor executor,
IoProcessor<T> processor) |
Constructor for
AbstractPollingIoConnector . |
AbstractPollingIoConnector(IoSessionConfig sessionConfig,
IoProcessor<T> processor) |
Constructor for
AbstractPollingIoConnector . |
Constructor | Description |
---|---|
AbstractPollingIoAcceptor(IoSessionConfig sessionConfig,
Class<? extends IoProcessor<S>> processorClass) |
Constructor for
AbstractPollingIoAcceptor . |
AbstractPollingIoAcceptor(IoSessionConfig sessionConfig,
Class<? extends IoProcessor<S>> processorClass,
int processorCount) |
Constructor for
AbstractPollingIoAcceptor . |
AbstractPollingIoAcceptor(IoSessionConfig sessionConfig,
Class<? extends IoProcessor<S>> processorClass,
int processorCount,
SelectorProvider selectorProvider) |
Constructor for
AbstractPollingIoAcceptor . |
AbstractPollingIoConnector(IoSessionConfig sessionConfig,
Class<? extends IoProcessor<T>> processorClass) |
Constructor for
AbstractPollingIoConnector . |
AbstractPollingIoConnector(IoSessionConfig sessionConfig,
Class<? extends IoProcessor<T>> processorClass,
int processorCount) |
Constructor for
AbstractPollingIoConnector . |
Modifier and Type | Class | Description |
---|---|---|
class |
SimpleIoProcessorPool<S extends AbstractIoSession> |
Constructor | Description |
---|---|
SimpleIoProcessorPool(Class<? extends IoProcessor<S>> processorType) |
Creates a new instance of SimpleIoProcessorPool with a default
size of NbCPUs +1.
|
SimpleIoProcessorPool(Class<? extends IoProcessor<S>> processorType,
int size) |
Creates a new instance of SimpleIoProcessorPool with a defined
number of IoProcessors in the pool
|
SimpleIoProcessorPool(Class<? extends IoProcessor<S>> processorType,
int size,
SelectorProvider selectorProvider) |
Creates a new instance of SimpleIoProcessorPool with a defined
number of IoProcessors in the pool
|
SimpleIoProcessorPool(Class<? extends IoProcessor<S>> processorType,
Executor executor) |
Creates a new instance of SimpleIoProcessorPool with an executor
|
SimpleIoProcessorPool(Class<? extends IoProcessor<S>> processorType,
Executor executor,
int size,
SelectorProvider selectorProvider) |
Creates a new instance of SimpleIoProcessorPool with an executor
|
Modifier and Type | Method | Description |
---|---|---|
abstract IoProcessor |
AbstractIoSession.getProcessor() |
|
IoProcessor<IoSession> |
DummySession.getProcessor() |
Modifier and Type | Class | Description |
---|---|---|
class |
AprIoProcessor |
The class in charge of processing socket level IO events for the
AprSocketConnector |
Modifier and Type | Method | Description |
---|---|---|
IoProcessor<AprSession> |
AprSession.getProcessor() |
Modifier and Type | Method | Description |
---|---|---|
protected AprSession |
AprSocketAcceptor.accept(IoProcessor<AprSession> processor,
Long handle) |
Accept a client connection for a server socket and return a new
IoSession
associated with the given IoProcessor |
protected AprSession |
AprSocketConnector.newSession(IoProcessor<AprSession> processor,
Long handle) |
Create a new
IoSession from a connected socket client handle. |
Constructor | Description |
---|---|
AprSocketAcceptor(Executor executor,
IoProcessor<AprSession> processor) |
Constructor for
AprSocketAcceptor with a given Executor for handling
connection events and a given AprIoProcessor for handling I/O events, useful for
sharing the same processor and executor over multiple IoService of the same type. |
AprSocketAcceptor(IoProcessor<AprSession> processor) |
Constructor for
AprSocketAcceptor with default configuration but a
specific AprIoProcessor , useful for sharing the same processor over multiple
IoService of the same type. |
AprSocketConnector(Executor executor,
IoProcessor<AprSession> processor) |
Constructor for
AprSocketConnector with a given Executor for handling
connection events and a given IoProcessor for handling I/O events, useful for sharing
the same processor and executor over multiple IoService of the same type. |
AprSocketConnector(IoProcessor<AprSession> processor) |
Constructor for
AprSocketConnector with default configuration but a
specific IoProcessor , useful for sharing the same processor over multiple
IoService of the same type. |
Modifier and Type | Class | Description |
---|---|---|
class |
NioDatagramAcceptor |
IoAcceptor for datagram transport (UDP/IP). |
class |
NioProcessor |
TODO Add documentation
|
Modifier and Type | Field | Description |
---|---|---|
protected IoProcessor<NioSession> |
NioSession.processor |
The NioSession processor
|
Modifier and Type | Method | Description |
---|---|---|
IoProcessor<NioSession> |
NioSession.getProcessor() |
Modifier and Type | Method | Description |
---|---|---|
protected NioSession |
NioSocketAcceptor.accept(IoProcessor<NioSession> processor,
ServerSocketChannel handle) |
Accept a client connection for a server socket and return a new
IoSession
associated with the given IoProcessor |
protected NioSession |
NioDatagramAcceptor.newSession(IoProcessor<NioSession> processor,
DatagramChannel handle,
SocketAddress remoteAddress) |
|
protected NioSession |
NioDatagramConnector.newSession(IoProcessor<NioSession> processor,
DatagramChannel handle) |
|
protected NioSession |
NioSocketConnector.newSession(IoProcessor<NioSession> processor,
SocketChannel handle) |
Create a new
IoSession from a connected socket client handle. |
Constructor | Description |
---|---|
NioDatagramConnector(IoProcessor<NioSession> processor) |
Creates a new instance.
|
NioSession(IoProcessor<NioSession> processor,
IoService service,
Channel channel) |
Creates a new instance of NioSession, with its associated IoProcessor.
|
NioSocketAcceptor(Executor executor,
IoProcessor<NioSession> processor) |
Constructor for
NioSocketAcceptor with a given Executor for handling
connection events and a given IoProcessor for handling I/O events, useful for
sharing the same processor and executor over multiple IoService of the same type. |
NioSocketAcceptor(IoProcessor<NioSession> processor) |
Constructor for
NioSocketAcceptor with default configuration but a
specific IoProcessor , useful for sharing the same processor over multiple
IoService of the same type. |
NioSocketConnector(Executor executor,
IoProcessor<NioSession> processor) |
Constructor for
NioSocketConnector with a given Executor for handling
connection events and a given IoProcessor for handling I/O events, useful for sharing
the same processor and executor over multiple IoService of the same type. |
NioSocketConnector(IoProcessor<NioSession> processor) |
Constructor for
NioSocketConnector with default configuration but a
specific IoProcessor , useful for sharing the same processor over multiple
IoService of the same type. |
Constructor | Description |
---|---|
NioDatagramConnector(Class<? extends IoProcessor<NioSession>> processorClass) |
Constructor for
NioDatagramConnector with default configuration with default configuration which will use a built-in
thread pool executor to manage the default number of processor instances. |
NioDatagramConnector(Class<? extends IoProcessor<NioSession>> processorClass,
int processorCount) |
Constructor for
NioDatagramConnector with default configuration which will use a built-in
thread pool executor to manage the given number of processor instances. |
NioSocketConnector(Class<? extends IoProcessor<NioSession>> processorClass) |
Constructor for
NioSocketConnector with default configuration with default configuration which will use a built-in
thread pool executor to manage the default number of processor instances. |
NioSocketConnector(Class<? extends IoProcessor<NioSession>> processorClass,
int processorCount) |
Constructor for
NioSocketConnector with default configuration which will use a built-in
thread pool executor to manage the given number of processor instances. |
Copyright © 2004–2018 Apache MINA Project. All rights reserved.