| Package | Description |
|---|---|
| org.apache.mina.core.filterchain | |
| 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.core.write | |
| org.apache.mina.filter.buffer | |
| org.apache.mina.filter.codec |
Filter implementations that helps you to implement complex protocols
via 'codec' concept.
|
| org.apache.mina.filter.compression | |
| org.apache.mina.filter.errorgenerating |
An IoFilter that provides flexible error generation facilities.
|
| org.apache.mina.filter.executor |
IoFilters that provide flexible thread model and event queue
monitoring interface.
|
| org.apache.mina.filter.firewall |
Classes that implement IoFilter and provide host blocking and throttling.
|
| org.apache.mina.filter.keepalive |
IoFilter that provides the ability for connections to remain open when data is not being transferred.
|
| org.apache.mina.filter.logging |
Classes that implement IoFilter and provide logging of the events and data that flows through a MINA-based system.
|
| org.apache.mina.filter.ssl |
Classes that implement IoFilter and provide Secure Sockets Layer functionality.
|
| org.apache.mina.filter.statistic |
Classes that implement IoFilter and provide the ability for filters to be timed on their performance.
|
| org.apache.mina.filter.stream |
Stream based IoFilter implementation.
|
| org.apache.mina.filter.util |
Utility classes for the MINA filtering portion of the library.
|
| org.apache.mina.proxy | |
| org.apache.mina.proxy.filter | |
| org.apache.mina.transport.socket.nio |
Socket (TCP/IP) and Datagram (UDP/IP) support based on Java
NIO (New I/O) API.
|
| org.apache.mina.transport.vmpipe |
In-VM pipe support which removes the overhead of local loopback communication.
|
| Modifier and Type | Method and Description |
|---|---|
private void |
DefaultIoFilterChain.callNextMessageSent(IoFilterChain.Entry entry,
IoSession session,
WriteRequest writeRequest) |
private void |
DefaultIoFilterChain.callPreviousFilterWrite(IoFilterChain.Entry entry,
IoSession session,
WriteRequest writeRequest) |
void |
DefaultIoFilterChain.HeadFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
DefaultIoFilterChain.TailFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
IoFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoSession.write(Object) method invocation. |
void |
IoFilterAdapter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoSession.write(Object) method invocation. |
void |
IoFilter.NextFilter.filterWrite(IoSession session,
WriteRequest writeRequest)
Forwards filterWrite event to next filter.
|
void |
DefaultIoFilterChain.fireFilterWrite(WriteRequest writeRequest) |
void |
IoFilterChain.fireFilterWrite(WriteRequest writeRequest)
Fires a
IoSession.write(Object) event. |
void |
DefaultIoFilterChain.fireMessageSent(WriteRequest request) |
void |
IoFilterChain.fireMessageSent(WriteRequest request)
Fires a
IoHandler.messageSent(IoSession, Object) event. |
void |
DefaultIoFilterChain.TailFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
IoFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
IoFilterAdapter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
IoFilter.NextFilter.messageSent(IoSession session,
WriteRequest writeRequest)
Forwards messageSent event to next filter.
|
| Modifier and Type | Method and Description |
|---|---|
private void |
AbstractPollingIoProcessor.fireMessageSent(S session,
WriteRequest req) |
void |
AbstractPollingIoProcessor.write(S session,
WriteRequest writeRequest)
Writes the WriteRequest for the specified
session. |
private int |
AbstractPollingIoProcessor.writeBuffer(S session,
WriteRequest req,
boolean hasFragmentation,
int maxLength,
long currentTime) |
private int |
AbstractPollingIoProcessor.writeFile(S session,
WriteRequest req,
boolean hasFragmentation,
int maxLength,
long currentTime) |
| Modifier and Type | Method and Description |
|---|---|
void |
IoProcessor.write(S session,
WriteRequest writeRequest)
Writes the WriteRequest for the specified
session. |
void |
SimpleIoProcessorPool.write(S session,
WriteRequest writeRequest)
Writes the WriteRequest for the specified
session. |
| Modifier and Type | Field and Description |
|---|---|
private static WriteRequest |
AbstractIoSession.CLOSE_REQUEST
An internal write request object that triggers session close.
|
private WriteRequest |
AbstractIoSession.currentWriteRequest |
| Modifier and Type | Field and Description |
|---|---|
private java.util.Queue<WriteRequest> |
DefaultIoSessionDataStructureFactory.DefaultWriteRequestQueue.q
A queue to store incoming write requests
|
| Modifier and Type | Method and Description |
|---|---|
WriteRequest |
AbstractIoSession.getCurrentWriteRequest()
Returns the
WriteRequest which is being processed by
IoService. |
WriteRequest |
IoSession.getCurrentWriteRequest()
Returns the
WriteRequest which is being processed by
IoService. |
WriteRequest |
AbstractIoSession.CloseAwareWriteQueue.poll(IoSession session)
Get the first request available in the queue for a session.
|
WriteRequest |
DefaultIoSessionDataStructureFactory.DefaultWriteRequestQueue.poll(IoSession session)
Get the first request available in the queue for a session.
|
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractIoSession.decreaseScheduledBytesAndMessages(WriteRequest request)
TODO Add method documentation
|
void |
AbstractIoSession.increaseWrittenMessages(WriteRequest request,
long currentTime)
TODO Add method documentation
|
void |
AbstractIoSession.CloseAwareWriteQueue.offer(IoSession session,
WriteRequest e)
Add a new WriteRequest to the session write's queue
|
void |
DefaultIoSessionDataStructureFactory.DefaultWriteRequestQueue.offer(IoSession session,
WriteRequest writeRequest)
Add a new WriteRequest to the session write's queue
|
void |
AbstractIoSession.setCurrentWriteRequest(WriteRequest currentWriteRequest)
Associate the current write request with the session
|
void |
IoSession.setCurrentWriteRequest(WriteRequest currentWriteRequest)
Associate the current write request with the session
|
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultWriteRequest
The default implementation of
WriteRequest. |
class |
WriteRequestWrapper
A wrapper for an existing
WriteRequest. |
| Modifier and Type | Field and Description |
|---|---|
private WriteRequest |
WriteRequestWrapper.parentRequest |
| Modifier and Type | Field and Description |
|---|---|
private java.util.List<WriteRequest> |
WriteException.requests |
| Modifier and Type | Method and Description |
|---|---|
WriteRequest |
DefaultWriteRequest.getOriginalRequest() |
WriteRequest |
WriteRequest.getOriginalRequest()
Returns the
WriteRequest which was requested originally,
which is not transformed by any IoFilter. |
WriteRequest |
WriteRequestWrapper.getOriginalRequest() |
WriteRequest |
WriteRequestWrapper.getParentRequest()
Returns the wrapped request object.
|
WriteRequest |
WriteException.getRequest()
Returns the firstly failed
WriteRequest. |
WriteRequest |
WriteRequestQueue.poll(IoSession session)
Get the first request available in the queue for a session.
|
| Modifier and Type | Method and Description |
|---|---|
private static java.util.List<WriteRequest> |
WriteException.asRequestList(java.util.Collection<WriteRequest> requests) |
private static java.util.List<WriteRequest> |
WriteException.asRequestList(WriteRequest request) |
java.util.List<WriteRequest> |
WriteException.getRequests()
Returns the list of the failed
WriteRequest, in the order of occurrance. |
| Modifier and Type | Method and Description |
|---|---|
private static java.util.List<WriteRequest> |
WriteException.asRequestList(WriteRequest request) |
void |
WriteRequestQueue.offer(IoSession session,
WriteRequest writeRequest)
Add a new WriteRequest to the session write's queue
|
| Modifier and Type | Method and Description |
|---|---|
private static java.util.List<WriteRequest> |
WriteException.asRequestList(java.util.Collection<WriteRequest> requests) |
| Constructor and Description |
|---|
NothingWrittenException(WriteRequest request) |
NothingWrittenException(WriteRequest request,
java.lang.String s) |
NothingWrittenException(WriteRequest request,
java.lang.String message,
java.lang.Throwable cause) |
NothingWrittenException(WriteRequest request,
java.lang.Throwable cause) |
WriteException(WriteRequest request)
Creates a new exception.
|
WriteException(WriteRequest request,
java.lang.String s)
Creates a new exception.
|
WriteException(WriteRequest request,
java.lang.String message,
java.lang.Throwable cause)
Creates a new exception.
|
WriteException(WriteRequest request,
java.lang.Throwable cause)
Creates a new exception.
|
WriteRequestWrapper(WriteRequest parentRequest)
Creates a new instance that wraps the specified request.
|
WriteTimeoutException(WriteRequest request) |
WriteTimeoutException(WriteRequest request,
java.lang.String s) |
WriteTimeoutException(WriteRequest request,
java.lang.String message,
java.lang.Throwable cause) |
WriteTimeoutException(WriteRequest request,
java.lang.Throwable cause) |
WriteToClosedSessionException(WriteRequest request) |
WriteToClosedSessionException(WriteRequest request,
java.lang.String s) |
WriteToClosedSessionException(WriteRequest request,
java.lang.String message,
java.lang.Throwable cause) |
WriteToClosedSessionException(WriteRequest request,
java.lang.Throwable cause) |
| Constructor and Description |
|---|
NothingWrittenException(java.util.Collection<WriteRequest> requests) |
NothingWrittenException(java.util.Collection<WriteRequest> requests,
java.lang.String s) |
NothingWrittenException(java.util.Collection<WriteRequest> requests,
java.lang.String message,
java.lang.Throwable cause) |
NothingWrittenException(java.util.Collection<WriteRequest> requests,
java.lang.Throwable cause) |
WriteException(java.util.Collection<WriteRequest> requests)
Creates a new exception.
|
WriteException(java.util.Collection<WriteRequest> requests,
java.lang.String s)
Creates a new exception.
|
WriteException(java.util.Collection<WriteRequest> requests,
java.lang.String message,
java.lang.Throwable cause)
Creates a new exception.
|
WriteException(java.util.Collection<WriteRequest> requests,
java.lang.Throwable cause)
Creates a new exception.
|
WriteTimeoutException(java.util.Collection<WriteRequest> requests) |
WriteTimeoutException(java.util.Collection<WriteRequest> requests,
java.lang.String s) |
WriteTimeoutException(java.util.Collection<WriteRequest> requests,
java.lang.String message,
java.lang.Throwable cause) |
WriteTimeoutException(java.util.Collection<WriteRequest> requests,
java.lang.Throwable cause) |
WriteToClosedSessionException(java.util.Collection<WriteRequest> requests) |
WriteToClosedSessionException(java.util.Collection<WriteRequest> requests,
java.lang.String s) |
WriteToClosedSessionException(java.util.Collection<WriteRequest> requests,
java.lang.String message,
java.lang.Throwable cause) |
WriteToClosedSessionException(java.util.Collection<WriteRequest> requests,
java.lang.Throwable cause) |
| Modifier and Type | Method and Description |
|---|---|
void |
BufferedWriteFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoSession.write(Object) method invocation. |
| Modifier and Type | Class and Description |
|---|---|
private static class |
ProtocolCodecFilter.EncodedWriteRequest |
private static class |
ProtocolCodecFilter.MessageWriteRequest |
| Modifier and Type | Method and Description |
|---|---|
void |
ProtocolCodecFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
private ProtocolEncoderOutput |
ProtocolCodecFilter.getEncoderOut(IoSession session,
IoFilter.NextFilter nextFilter,
WriteRequest writeRequest) |
void |
ProtocolCodecFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
| Constructor and Description |
|---|
MessageWriteRequest(WriteRequest writeRequest) |
ProtocolEncoderOutputImpl(IoSession session,
IoFilter.NextFilter nextFilter,
WriteRequest writeRequest) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
CompressionFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
| Modifier and Type | Method and Description |
|---|---|
void |
ErrorGeneratingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
| Modifier and Type | Method and Description |
|---|---|
void |
ExecutorFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoSession.write(Object) method invocation. |
void |
WriteRequestFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ExecutorFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
| Modifier and Type | Method and Description |
|---|---|
void |
BlacklistFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
| Modifier and Type | Method and Description |
|---|---|
void |
KeepAliveFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
| Modifier and Type | Method and Description |
|---|---|
void |
LoggingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
| Modifier and Type | Class and Description |
|---|---|
private static class |
SslFilter.EncryptedWriteRequest |
| Modifier and Type | Method and Description |
|---|---|
void |
SslFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
SslFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
(package private) void |
SslHandler.scheduleFilterWrite(IoFilter.NextFilter nextFilter,
WriteRequest writeRequest) |
(package private) void |
SslHandler.schedulePreHandshakeWriteRequest(IoFilter.NextFilter nextFilter,
WriteRequest writeRequest) |
| Constructor and Description |
|---|
EncryptedWriteRequest(WriteRequest writeRequest,
IoBuffer encryptedMessage) |
| Modifier and Type | Method and Description |
|---|---|
void |
ProfilerTimerFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Profile a MessageSent event.
|
| Modifier and Type | Method and Description |
|---|---|
private java.util.Queue<WriteRequest> |
AbstractStreamWriteFilter.getWriteRequestQueue(IoSession session) |
private java.util.Queue<WriteRequest> |
AbstractStreamWriteFilter.removeWriteRequestQueue(IoSession session) |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractStreamWriteFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
AbstractStreamWriteFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
| Modifier and Type | Class and Description |
|---|---|
private class |
WriteRequestFilter.FilteredWriteRequest |
| Modifier and Type | Method and Description |
|---|---|
protected abstract java.lang.Object |
WriteRequestFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CommonEventFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
WriteRequestFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CommonEventFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
WriteRequestFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
| Constructor and Description |
|---|
FilteredWriteRequest(java.lang.Object filteredMessage,
WriteRequest writeRequest) |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractProxyLogicHandler.enqueueWriteRequest(IoFilter.NextFilter nextFilter,
WriteRequest writeRequest)
Enqueue a message to be written once handshaking is complete.
|
void |
ProxyLogicHandler.enqueueWriteRequest(IoFilter.NextFilter nextFilter,
WriteRequest writeRequest)
Enqueue a message to be written once handshaking is complete.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ProxyFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters outgoing writes, queueing them up if necessary while a handshake
is ongoing.
|
void |
ProxyFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filter handshake related messages from reaching the messageSent callbacks of
downstream filters.
|
void |
ProxyFilter.writeData(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest,
boolean isHandshakeData)
Actually write data.
|
| Modifier and Type | Method and Description |
|---|---|
void |
NioDatagramAcceptor.write(NioSession session,
WriteRequest writeRequest)
Writes the WriteRequest for the specified
session. |
| Modifier and Type | Method and Description |
|---|---|
void |
VmPipeFilterChain.fireFilterWrite(WriteRequest writeRequest) |
void |
VmPipeFilterChain.fireMessageSent(WriteRequest request) |
void |
VmPipeFilterChain.VmPipeIoProcessor.write(VmPipeSession session,
WriteRequest writeRequest)
Writes the WriteRequest for the specified
session. |