| Package | Description |
|---|---|
| org.apache.mina.core |
Common types required for users to use MINA.
|
| org.apache.mina.core.filterchain | |
| org.apache.mina.core.future | |
| 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.codec.demux |
Protocol codecs that helps you to implement even more complex protocols by
splitting a codec into multiple sub-codecs.
|
| org.apache.mina.filter.codec.prefixedstring | |
| org.apache.mina.filter.codec.serialization |
Protocol codecs which uses Java object serilization and leads to rapid protocol
implementation.
|
| org.apache.mina.filter.codec.statemachine | |
| org.apache.mina.filter.codec.textline |
A protocol codec for text-based protocols.
|
| 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.handler.chain |
A handler implementation that helps you implement sequentially layered protocols
using Chains of Responsibility pattern.
|
| org.apache.mina.handler.demux |
A handler implementation that helps you implement complex protocols
by splitting messageReceived handlers into multiple sub-handlers.
|
| org.apache.mina.handler.multiton |
Enables creating a handler per session instead of having one handler for many
sessions, using
Multiton pattern.
|
| org.apache.mina.handler.stream | |
| org.apache.mina.http | |
| org.apache.mina.proxy | |
| org.apache.mina.proxy.event | |
| org.apache.mina.proxy.filter | |
| org.apache.mina.proxy.handlers.http.digest | |
| org.apache.mina.proxy.session | |
| 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 | Field and Description |
|---|---|
private static IoSession[] |
IoUtil.EMPTY_SESSIONS |
| Modifier and Type | Method and Description |
|---|---|
static java.util.List<WriteFuture> |
IoUtil.broadcast(java.lang.Object message,
IoSession... sessions)
Writes the specified
message to the specified sessions. |
| Modifier and Type | Method and Description |
|---|---|
static java.util.List<WriteFuture> |
IoUtil.broadcast(java.lang.Object message,
java.util.Collection<IoSession> sessions)
Writes the specified
message to the specified sessions. |
static java.util.List<WriteFuture> |
IoUtil.broadcast(java.lang.Object message,
java.lang.Iterable<IoSession> sessions)
Writes the specified
message to the specified sessions. |
static java.util.List<WriteFuture> |
IoUtil.broadcast(java.lang.Object message,
java.util.Iterator<IoSession> sessions)
Writes the specified
message to the specified sessions. |
private static void |
IoUtil.broadcast(java.lang.Object message,
java.util.Iterator<IoSession> sessions,
java.util.Collection<WriteFuture> answer) |
| Modifier and Type | Method and Description |
|---|---|
IoSession |
DefaultIoFilterChain.getSession() |
IoSession |
IoFilterChain.getSession()
Returns the parent
IoSession of this chain. |
| Modifier and Type | Method and Description |
|---|---|
private void |
DefaultIoFilterChain.callNextExceptionCaught(IoFilterChain.Entry entry,
IoSession session,
java.lang.Throwable cause) |
private void |
DefaultIoFilterChain.callNextInputClosed(IoFilterChain.Entry entry,
IoSession session) |
private void |
DefaultIoFilterChain.callNextMessageReceived(IoFilterChain.Entry entry,
IoSession session,
java.lang.Object message) |
private void |
DefaultIoFilterChain.callNextMessageSent(IoFilterChain.Entry entry,
IoSession session,
WriteRequest writeRequest) |
private void |
DefaultIoFilterChain.callNextSessionClosed(IoFilterChain.Entry entry,
IoSession session) |
private void |
DefaultIoFilterChain.callNextSessionCreated(IoFilterChain.Entry entry,
IoSession session) |
private void |
DefaultIoFilterChain.callNextSessionIdle(IoFilterChain.Entry entry,
IoSession session,
IdleStatus status) |
private void |
DefaultIoFilterChain.callNextSessionOpened(IoFilterChain.Entry entry,
IoSession session) |
private void |
DefaultIoFilterChain.callPreviousFilterClose(IoFilterChain.Entry entry,
IoSession session) |
private void |
DefaultIoFilterChain.callPreviousFilterWrite(IoFilterChain.Entry entry,
IoSession session,
WriteRequest writeRequest) |
void |
DefaultIoFilterChain.TailFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
IoFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
IoFilterAdapter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
IoFilter.NextFilter.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Forwards exceptionCaught event to next filter.
|
void |
DefaultIoFilterChain.HeadFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
DefaultIoFilterChain.TailFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
IoFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
close() method invocation. |
void |
IoFilterAdapter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
close() method invocation. |
void |
IoFilter.NextFilter.filterClose(IoSession session)
Forwards filterClose event to next filter.
|
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
write(Object) method invocation. |
void |
IoFilterAdapter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
write(Object) method invocation. |
void |
IoFilter.NextFilter.filterWrite(IoSession session,
WriteRequest writeRequest)
Forwards filterWrite event to next filter.
|
void |
DefaultIoFilterChain.TailFilter.inputClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
IoFilter.inputClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.inputClosed(IoSession) event. |
void |
IoFilterAdapter.inputClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.inputClosed(IoSession) event. |
void |
IoFilter.NextFilter.inputClosed(IoSession session) |
void |
DefaultIoFilterChain.TailFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
IoFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
IoFilterAdapter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
IoFilter.NextFilter.messageReceived(IoSession session,
java.lang.Object message)
Forwards messageReceived event to next filter.
|
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.
|
void |
DefaultIoFilterChain.TailFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
IoFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
void |
IoFilterAdapter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
void |
IoFilter.NextFilter.sessionClosed(IoSession session)
Forwards sessionClosed event to next filter.
|
void |
DefaultIoFilterChain.TailFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
IoFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionCreated(IoSession) event. |
void |
IoFilterAdapter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionCreated(IoSession) event. |
void |
IoFilter.NextFilter.sessionCreated(IoSession session)
Forwards sessionCreated event to next filter.
|
void |
DefaultIoFilterChain.TailFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
IoFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
void |
IoFilterAdapter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
void |
IoFilter.NextFilter.sessionIdle(IoSession session,
IdleStatus status)
Forwards sessionIdle event to next filter.
|
void |
DefaultIoFilterChain.TailFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
IoFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
void |
IoFilterAdapter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
void |
IoFilter.NextFilter.sessionOpened(IoSession session)
Forwards sessionOpened event to next filter.
|
| Constructor and Description |
|---|
IoFilterEvent(IoFilter.NextFilter nextFilter,
IoEventType type,
IoSession session,
java.lang.Object parameter) |
| Modifier and Type | Field and Description |
|---|---|
private IoSession |
DefaultIoFuture.session
The associated session
|
| Modifier and Type | Method and Description |
|---|---|
IoSession |
ConnectFuture.getSession()
Returns
IoSession which is the result of connect operation. |
IoSession |
DefaultConnectFuture.getSession() |
IoSession |
DefaultIoFuture.getSession()
Returns the
IoSession which is associated with this future. |
IoSession |
IoFuture.getSession()
Returns the
IoSession which is associated with this future. |
| Modifier and Type | Method and Description |
|---|---|
static WriteFuture |
DefaultWriteFuture.newNotWrittenFuture(IoSession session,
java.lang.Throwable cause)
Returns a new
DefaultWriteFuture which is already marked as 'not written'. |
static WriteFuture |
DefaultWriteFuture.newWrittenFuture(IoSession session)
Returns a new
DefaultWriteFuture which is already marked as 'written'. |
void |
ConnectFuture.setSession(IoSession session)
Sets the newly connected session and notifies all threads waiting for
this future.
|
void |
DefaultConnectFuture.setSession(IoSession session) |
| Constructor and Description |
|---|
DefaultCloseFuture(IoSession session)
Creates a new instance.
|
DefaultIoFuture(IoSession session)
Creates a new instance associated with an
IoSession. |
DefaultReadFuture(IoSession session)
Creates a new instance.
|
DefaultWriteFuture(IoSession session)
Creates a new instance.
|
| Modifier and Type | Method and Description |
|---|---|
IoSession |
AbstractPollingIoAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
(Optional) Returns an
IoSession that is bound to the specified
localAddress and the specified remoteAddress which
reuses the local address that is already bound by this service. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
IoProcessor<S extends IoSession>
An internal interface to represent an 'I/O processor' that performs
actual I/O operations for
IoSessions. |
| Modifier and Type | Field and Description |
|---|---|
private java.util.concurrent.ConcurrentMap<java.lang.Long,IoSession> |
IoServiceListenerSupport.managedSessions
Tracks managed sessions.
|
private java.util.Map<java.lang.Long,IoSession> |
IoServiceListenerSupport.readOnlyManagedSessions
Read only version of
IoServiceListenerSupport.managedSessions. |
| Modifier and Type | Method and Description |
|---|---|
IoSession |
IoAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
(Optional) Returns an
IoSession that is bound to the specified
localAddress and the specified remoteAddress which
reuses the local address that is already bound by this service. |
| Modifier and Type | Method and Description |
|---|---|
java.util.Map<java.lang.Long,IoSession> |
AbstractIoService.getManagedSessions()
Returns the map of all sessions which are currently managed by this
service.
|
java.util.Map<java.lang.Long,IoSession> |
IoService.getManagedSessions()
Returns the map of all sessions which are currently managed by this
service.
|
java.util.Map<java.lang.Long,IoSession> |
IoServiceListenerSupport.getManagedSessions() |
| Modifier and Type | Method and Description |
|---|---|
void |
IoHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Invoked when any exception is thrown by user
IoHandler
implementation or by MINA. |
void |
IoHandlerAdapter.exceptionCaught(IoSession session,
java.lang.Throwable cause) |
protected void |
AbstractIoConnector.finishSessionInitialization0(IoSession session,
IoFuture future)
Adds required internal attributes and
IoFutureListeners
related with event notifications to the specified session
and future. |
protected void |
AbstractIoService.finishSessionInitialization0(IoSession session,
IoFuture future)
Implement this method to perform additional tasks required for session
initialization.
|
void |
IoServiceListenerSupport.fireSessionCreated(IoSession session)
Calls
IoServiceListener.sessionCreated(IoSession) for all registered listeners. |
void |
IoServiceListenerSupport.fireSessionDestroyed(IoSession session)
Calls
IoServiceListener.sessionDestroyed(IoSession) for all registered listeners. |
protected void |
AbstractIoService.initSession(IoSession session,
IoFuture future,
IoSessionInitializer sessionInitializer) |
void |
IoHandler.inputClosed(IoSession session)
Handle the closure of an half-duplex TCP channel
|
void |
IoHandlerAdapter.inputClosed(IoSession session) |
void |
IoHandler.messageReceived(IoSession session,
java.lang.Object message)
Invoked when a message is received.
|
void |
IoHandlerAdapter.messageReceived(IoSession session,
java.lang.Object message) |
void |
IoHandler.messageSent(IoSession session,
java.lang.Object message)
Invoked when a message written by
write(Object) is
sent out. |
void |
IoHandlerAdapter.messageSent(IoSession session,
java.lang.Object message) |
void |
IoHandler.sessionClosed(IoSession session)
Invoked when a connection is closed.
|
void |
IoHandlerAdapter.sessionClosed(IoSession session) |
void |
IoServiceListener.sessionClosed(IoSession session)
Invoked when a new session is closed by an
IoService. |
void |
IoHandler.sessionCreated(IoSession session)
Invoked from an I/O processor thread when a new connection has been created.
|
void |
IoHandlerAdapter.sessionCreated(IoSession session) |
void |
IoServiceListener.sessionCreated(IoSession session)
Invoked when a new session is created by an
IoService. |
void |
IoServiceListener.sessionDestroyed(IoSession session)
Invoked when a session is being destroyed by an
IoService. |
void |
IoHandler.sessionIdle(IoSession session,
IdleStatus status)
Invoked with the related
IdleStatus when a connection becomes idle. |
void |
IoHandlerAdapter.sessionIdle(IoSession session,
IdleStatus status) |
void |
IoHandler.sessionOpened(IoSession session)
Invoked when a connection has been opened.
|
void |
IoHandlerAdapter.sessionOpened(IoSession session) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractIoSession
Base implementation of
IoSession. |
class |
DummySession
|
| Modifier and Type | Field and Description |
|---|---|
private IoSession |
IoEvent.session |
| Modifier and Type | Field and Description |
|---|---|
private IoProcessor<IoSession> |
DummySession.processor |
private ExpiringMap<java.net.SocketAddress,IoSession> |
ExpiringSessionRecycler.sessionMap |
| Modifier and Type | Method and Description |
|---|---|
IoSession |
IoEvent.getSession() |
IoSession |
ExpiringSessionRecycler.recycle(java.net.SocketAddress remoteAddress) |
IoSession |
IoSessionRecycler.recycle(java.net.SocketAddress remoteAddress)
Attempts to retrieve a recycled
IoSession. |
| Modifier and Type | Method and Description |
|---|---|
IoProcessor<IoSession> |
DummySession.getProcessor() |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractIoSession.CloseAwareWriteQueue.clear(IoSession session)
Removes all the requests from this session's queue.
|
void |
DefaultIoSessionDataStructureFactory.DefaultWriteRequestQueue.clear(IoSession session)
Removes all the requests from this session's queue.
|
boolean |
DefaultIoSessionDataStructureFactory.DefaultIoSessionAttributeMap.containsAttribute(IoSession session,
java.lang.Object key)
Returns true if this session contains the attribute with
the specified key.
|
boolean |
IoSessionAttributeMap.containsAttribute(IoSession session,
java.lang.Object key)
Returns true if this session contains the attribute with
the specified key.
|
void |
AbstractIoSession.CloseAwareWriteQueue.dispose(IoSession session)
Disposes any releases associated with the specified session.
|
void |
DefaultIoSessionDataStructureFactory.DefaultIoSessionAttributeMap.dispose(IoSession session)
Disposes any releases associated with the specified session.
|
void |
DefaultIoSessionDataStructureFactory.DefaultWriteRequestQueue.dispose(IoSession session)
Disposes any releases associated with the specified session.
|
void |
IoSessionAttributeMap.dispose(IoSession session)
Disposes any releases associated with the specified session.
|
void |
ExpiringSessionRecycler.DefaultExpirationListener.expired(IoSession expiredSession) |
java.lang.Object |
DefaultIoSessionDataStructureFactory.DefaultIoSessionAttributeMap.getAttribute(IoSession session,
java.lang.Object key,
java.lang.Object defaultValue)
Returns the value of user defined attribute associated with the
specified key.
|
java.lang.Object |
IoSessionAttributeMap.getAttribute(IoSession session,
java.lang.Object key,
java.lang.Object defaultValue)
Returns the value of user defined attribute associated with the
specified key.
|
java.util.Set<java.lang.Object> |
DefaultIoSessionDataStructureFactory.DefaultIoSessionAttributeMap.getAttributeKeys(IoSession session)
Returns the set of keys of all user-defined attributes.
|
java.util.Set<java.lang.Object> |
IoSessionAttributeMap.getAttributeKeys(IoSession session)
Returns the set of keys of all user-defined attributes.
|
IoSessionAttributeMap |
DefaultIoSessionDataStructureFactory.getAttributeMap(IoSession session) |
IoSessionAttributeMap |
IoSessionDataStructureFactory.getAttributeMap(IoSession session)
Returns an
IoSessionAttributeMap which is going to be associated
with the specified session. |
WriteRequestQueue |
DefaultIoSessionDataStructureFactory.getWriteRequestQueue(IoSession session) |
WriteRequestQueue |
IoSessionDataStructureFactory.getWriteRequestQueue(IoSession session)
Returns an
WriteRequest which is going to be associated with
the specified session. |
void |
IoSessionInitializer.initializeSession(IoSession session,
T future) |
boolean |
AbstractIoSession.CloseAwareWriteQueue.isEmpty(IoSession session)
Tells if the WriteRequest queue is empty or not for a session
|
boolean |
DefaultIoSessionDataStructureFactory.DefaultWriteRequestQueue.isEmpty(IoSession session)
Tells if the WriteRequest queue is empty or not for a session
|
static void |
AbstractIoSession.notifyIdleSession(IoSession session,
long currentTime)
Fires a
IoEventType.SESSION_IDLE event if applicable for the
specified session. |
private static void |
AbstractIoSession.notifyIdleSession0(IoSession session,
long currentTime,
long idleTime,
IdleStatus status,
long lastIoTime) |
private static void |
AbstractIoSession.notifyWriteTimeout(IoSession session,
long currentTime) |
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
|
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.
|
void |
ExpiringSessionRecycler.put(IoSession session) |
void |
IoSessionRecycler.put(IoSession session)
Called when the underlying transport creates or writes a new
IoSession. |
void |
ExpiringSessionRecycler.remove(IoSession session) |
void |
IoSessionRecycler.remove(IoSession session)
Called when an
IoSession is explicitly closed. |
java.lang.Object |
DefaultIoSessionDataStructureFactory.DefaultIoSessionAttributeMap.removeAttribute(IoSession session,
java.lang.Object key)
Removes a user-defined attribute with the specified key.
|
java.lang.Object |
IoSessionAttributeMap.removeAttribute(IoSession session,
java.lang.Object key)
Removes a user-defined attribute with the specified key.
|
boolean |
DefaultIoSessionDataStructureFactory.DefaultIoSessionAttributeMap.removeAttribute(IoSession session,
java.lang.Object key,
java.lang.Object value)
Removes a user defined attribute with the specified key if the current
attribute value is equal to the specified value.
|
boolean |
IoSessionAttributeMap.removeAttribute(IoSession session,
java.lang.Object key,
java.lang.Object value)
Removes a user defined attribute with the specified key if the current
attribute value is equal to the specified value.
|
boolean |
DefaultIoSessionDataStructureFactory.DefaultIoSessionAttributeMap.replaceAttribute(IoSession session,
java.lang.Object key,
java.lang.Object oldValue,
java.lang.Object newValue)
Replaces a user defined attribute with the specified key if the
value of the attribute is equals to the specified old value.
|
boolean |
IoSessionAttributeMap.replaceAttribute(IoSession session,
java.lang.Object key,
java.lang.Object oldValue,
java.lang.Object newValue)
Replaces a user defined attribute with the specified key if the
value of the attribute is equals to the specified old value.
|
java.lang.Object |
DefaultIoSessionDataStructureFactory.DefaultIoSessionAttributeMap.setAttribute(IoSession session,
java.lang.Object key,
java.lang.Object value)
Sets a user-defined attribute.
|
java.lang.Object |
IoSessionAttributeMap.setAttribute(IoSession session,
java.lang.Object key,
java.lang.Object value)
Sets a user-defined attribute.
|
java.lang.Object |
DefaultIoSessionDataStructureFactory.DefaultIoSessionAttributeMap.setAttributeIfAbsent(IoSession session,
java.lang.Object key,
java.lang.Object value)
Sets a user defined attribute if the attribute with the specified key
is not set yet.
|
java.lang.Object |
IoSessionAttributeMap.setAttributeIfAbsent(IoSession session,
java.lang.Object key,
java.lang.Object value)
Sets a user defined attribute if the attribute with the specified key
is not set yet.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
AbstractIoSession.notifyIdleness(java.util.Iterator<? extends IoSession> sessions,
long currentTime)
Fires a
IoEventType.SESSION_IDLE event to any applicable sessions
in the specified collection. |
| Constructor and Description |
|---|
IoEvent(IoEventType type,
IoSession session,
java.lang.Object parameter) |
| Modifier and Type | Method and Description |
|---|---|
void |
WriteRequestQueue.clear(IoSession session)
Removes all the requests from this session's queue.
|
void |
WriteRequestQueue.dispose(IoSession session)
Disposes any releases associated with the specified session.
|
boolean |
WriteRequestQueue.isEmpty(IoSession session)
Tells if the WriteRequest queue is empty or not for a session
|
void |
WriteRequestQueue.offer(IoSession session,
WriteRequest writeRequest)
Add a new WriteRequest to the session write's queue
|
WriteRequest |
WriteRequestQueue.poll(IoSession session)
Get the first request available in the queue for a session.
|
| Modifier and Type | Field and Description |
|---|---|
private LazyInitializedCacheMap<IoSession,IoBuffer> |
BufferedWriteFilter.buffersMap
|
| Modifier and Type | Method and Description |
|---|---|
void |
BufferedWriteFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
BufferedWriteFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
write(Object) method invocation. |
void |
BufferedWriteFilter.flush(IoSession session)
Flushes the buffered data.
|
private void |
BufferedWriteFilter.free(IoSession session)
Internal method that actually frees the
IoBuffer that contains
the buffered data that has not been flushed. |
private void |
BufferedWriteFilter.internalFlush(IoFilter.NextFilter nextFilter,
IoSession session,
IoBuffer buf)
Internal method that actually flushes the buffered data.
|
void |
BufferedWriteFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
private void |
BufferedWriteFilter.write(IoSession session,
IoBuffer data)
Writes an
IoBuffer to the session's buffer. |
private void |
BufferedWriteFilter.write(IoSession session,
IoBuffer data,
IoBuffer buf)
|
| Constructor and Description |
|---|
BufferedWriteFilter(int bufferSize,
LazyInitializedCacheMap<IoSession,IoBuffer> buffersMap)
Constructor which sets buffer size to
bufferSize. |
| Modifier and Type | Class and Description |
|---|---|
class |
ProtocolCodecSession
|
| Modifier and Type | Field and Description |
|---|---|
private IoSession |
ProtocolCodecFilter.ProtocolEncoderOutputImpl.session |
| Modifier and Type | Method and Description |
|---|---|
void |
CumulativeProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Cumulates content of in into internal buffer and forwards
decoding request to
CumulativeProtocolDecoder.doDecode(IoSession, IoBuffer, ProtocolDecoderOutput). |
void |
ProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
SynchronizedProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
void |
CumulativeProtocolDecoder.dispose(IoSession session)
Releases the cumulative buffer used by the specified session.
|
void |
ProtocolDecoder.dispose(IoSession session)
Releases all resources related with this decoder.
|
void |
ProtocolDecoderAdapter.dispose(IoSession session)
Override this method to dispose all resources related with this decoder.
|
void |
ProtocolEncoder.dispose(IoSession session)
Releases all resources related with this encoder.
|
void |
ProtocolEncoderAdapter.dispose(IoSession session)
Override this method dispose all resources related with this encoder.
|
void |
SynchronizedProtocolDecoder.dispose(IoSession session) |
void |
SynchronizedProtocolEncoder.dispose(IoSession session) |
private void |
ProtocolCodecFilter.disposeCodec(IoSession session)
Dispose the encoder, decoder, and the callback for the decoded
messages.
|
private void |
ProtocolCodecFilter.disposeDecoder(IoSession session)
Dispose the decoder, removing its instance from the
session's attributes, and calling the associated
dispose method.
|
private void |
ProtocolCodecFilter.disposeDecoderOut(IoSession session)
Remove the decoder callback from the session's attributes.
|
private void |
ProtocolCodecFilter.disposeEncoder(IoSession session)
Dispose the encoder, removing its instance from the
session's attributes, and calling the associated
dispose method.
|
protected abstract boolean |
CumulativeProtocolDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Implement this method to consume the specified cumulative buffer and
decode its content into message(s).
|
void |
ProtocolEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
void |
SynchronizedProtocolEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
void |
ProtocolCodecFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed.
|
void |
ProtocolDecoderAdapter.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Override this method to deal with the closed connection.
|
void |
SynchronizedProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out) |
void |
ProtocolCodecFilter.ProtocolDecoderOutputImpl.flush(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ProtocolDecoderOutput.flush(IoFilter.NextFilter nextFilter,
IoSession session)
Flushes all messages you wrote via
ProtocolDecoderOutput.write(Object) to
the next filter. |
ProtocolDecoder |
ProtocolCodecFactory.getDecoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolDecoder which
decodes binary or protocol-specific data into message objects. |
private ProtocolDecoderOutput |
ProtocolCodecFilter.getDecoderOut(IoSession session,
IoFilter.NextFilter nextFilter)
Return a reference to the decoder callback.
|
ProtocolEncoder |
ProtocolCodecFactory.getEncoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolEncoder which
encodes message objects into binary or protocol-specific data. |
ProtocolEncoder |
ProtocolCodecFilter.getEncoder(IoSession session)
Get the encoder instance from a given session.
|
private ProtocolEncoderOutput |
ProtocolCodecFilter.getEncoderOut(IoSession session,
IoFilter.NextFilter nextFilter,
WriteRequest writeRequest) |
void |
ProtocolCodecFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message)
Process the incoming message, calling the session decoder.
|
void |
ProtocolCodecFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
private void |
CumulativeProtocolDecoder.removeSessionBuffer(IoSession session) |
void |
ProtocolCodecFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
private void |
CumulativeProtocolDecoder.storeRemainingInSession(IoBuffer buf,
IoSession session) |
| Constructor and Description |
|---|
ProtocolEncoderOutputImpl(IoSession session,
IoFilter.NextFilter nextFilter,
WriteRequest writeRequest) |
| Modifier and Type | Method and Description |
|---|---|
MessageDecoderResult |
MessageDecoder.decodable(IoSession session,
IoBuffer in)
Checks the specified buffer is decodable by this decoder.
|
MessageDecoderResult |
MessageDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
DemuxingProtocolDecoder.dispose(IoSession session)
Releases the cumulative buffer used by the specified session.
|
void |
DemuxingProtocolEncoder.dispose(IoSession session)
Releases all resources related with this encoder.
|
protected boolean |
DemuxingProtocolDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Implement this method to consume the specified cumulative buffer and
decode its content into message(s).
|
void |
DemuxingProtocolEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
void |
MessageEncoder.encode(IoSession session,
T message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
void |
DemuxingProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Override this method to deal with the closed connection.
|
void |
MessageDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed while this decoder was
parsing the data.
|
void |
MessageDecoderAdapter.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Override this method to deal with the closed connection.
|
ProtocolDecoder |
DemuxingProtocolCodecFactory.getDecoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolDecoder which
decodes binary or protocol-specific data into message objects. |
ProtocolEncoder |
DemuxingProtocolCodecFactory.getEncoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolEncoder which
encodes message objects into binary or protocol-specific data. |
private DemuxingProtocolDecoder.State |
DemuxingProtocolDecoder.getState(IoSession session) |
private DemuxingProtocolEncoder.State |
DemuxingProtocolEncoder.getState(IoSession session) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
PrefixedStringDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
void |
PrefixedStringEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
ProtocolDecoder |
PrefixedStringCodecFactory.getDecoder(IoSession session) |
ProtocolEncoder |
PrefixedStringCodecFactory.getEncoder(IoSession session) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
ObjectSerializationDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
void |
ObjectSerializationEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
ProtocolDecoder |
ObjectSerializationCodecFactory.getDecoder(IoSession session) |
ProtocolEncoder |
ObjectSerializationCodecFactory.getEncoder(IoSession session) |
| Modifier and Type | Field and Description |
|---|---|
private IoSession |
DecodingStateProtocolDecoder.session |
| Modifier and Type | Method and Description |
|---|---|
void |
DecodingStateProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
DecodingStateProtocolDecoder.dispose(IoSession session)
Releases all resources related with this decoder.
|
void |
DecodingStateProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TextLineDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
private void |
TextLineDecoder.decodeAuto(TextLineDecoder.Context ctx,
IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decode a line using the default delimiter on the current system
|
private void |
TextLineDecoder.decodeNormal(TextLineDecoder.Context ctx,
IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decode a line using the delimiter defined by the caller
|
void |
TextLineDecoder.dispose(IoSession session)
Releases all resources related with this decoder.
|
void |
TextLineEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
void |
TextLineDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed.
|
private TextLineDecoder.Context |
TextLineDecoder.getContext(IoSession session)
Return the context for this session
|
ProtocolDecoder |
TextLineCodecFactory.getDecoder(IoSession session) |
ProtocolEncoder |
TextLineCodecFactory.getEncoder(IoSession session) |
protected void |
TextLineDecoder.writeText(IoSession session,
java.lang.String text,
ProtocolDecoderOutput out)
By default, this method propagates the decoded line of text to
ProtocolDecoderOutput#write(Object). |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
CompressionFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CompressionFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
| Modifier and Type | Method and Description |
|---|---|
void |
ErrorGeneratingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
private IoBuffer |
ErrorGeneratingFilter.insertBytesToNewIoBuffer(IoSession session,
IoBuffer buffer) |
private void |
ErrorGeneratingFilter.manipulateIoBuffer(IoSession session,
IoBuffer buffer) |
void |
ErrorGeneratingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
| Modifier and Type | Field and Description |
|---|---|
private static IoSession |
OrderedThreadPoolExecutor.EXIT_SIGNAL |
| Modifier and Type | Field and Description |
|---|---|
private java.util.concurrent.BlockingQueue<IoSession> |
OrderedThreadPoolExecutor.waitingSessions
A queue used to store the available sessions
|
| Modifier and Type | Method and Description |
|---|---|
private IoSession |
OrderedThreadPoolExecutor.Worker.fetchSession() |
| Modifier and Type | Method and Description |
|---|---|
void |
ExecutorFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
ExecutorFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
close() method invocation. |
void |
ExecutorFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
write(Object) method invocation. |
void |
WriteRequestFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
private OrderedThreadPoolExecutor.SessionTasksQueue |
OrderedThreadPoolExecutor.getSessionTasksQueue(IoSession session)
Get the session's tasks queue.
|
void |
ExecutorFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
ExecutorFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
ExecutorFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
void |
ExecutorFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
void |
ExecutorFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
| Modifier and Type | Method and Description |
|---|---|
private void |
BlacklistFilter.blockSession(IoSession session) |
private boolean |
BlacklistFilter.isBlocked(IoSession session) |
protected boolean |
ConnectionThrottleFilter.isConnectionOk(IoSession session)
Method responsible for deciding if a connection is OK
to continue
|
void |
BlacklistFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
BlacklistFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
BlacklistFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
BlacklistFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ConnectionThrottleFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
BlacklistFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
BlacklistFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
| Modifier and Type | Method and Description |
|---|---|
java.lang.Object |
KeepAliveMessageFactory.getRequest(IoSession session)
Returns a (new) keep-alive request message.
|
java.lang.Object |
KeepAliveMessageFactory.getResponse(IoSession session,
java.lang.Object request)
Returns a (new) response message for the specified keep-alive request.
|
private void |
KeepAliveFilter.handlePingTimeout(IoSession session) |
private boolean |
KeepAliveFilter.isKeepAliveMessage(IoSession session,
java.lang.Object message) |
boolean |
KeepAliveMessageFactory.isRequest(IoSession session,
java.lang.Object message)
Returns true if and only if the specified message is a
keep-alive request message.
|
boolean |
KeepAliveMessageFactory.isResponse(IoSession session,
java.lang.Object message)
Returns true if and only if the specified message is a
keep-alive response message;
|
void |
KeepAliveRequestTimeoutHandler.keepAliveRequestTimedOut(KeepAliveFilter filter,
IoSession session)
Invoked when
KeepAliveFilter couldn't receive the response for
the sent keep alive message. |
private void |
KeepAliveFilter.markStatus(IoSession session) |
void |
KeepAliveFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
KeepAliveFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
private void |
KeepAliveFilter.resetStatus(IoSession session) |
void |
KeepAliveFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
| Modifier and Type | Method and Description |
|---|---|
void |
LoggingFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
protected void |
MdcInjectionFilter.fillContext(IoSession session,
java.util.Map<java.lang.String,java.lang.String> context)
write key properties of the session to the Mapped Diagnostic Context
sub-classes could override this method to map more/other attributes
|
private java.util.Map<java.lang.String,java.lang.String> |
MdcInjectionFilter.getAndFillContext(IoSession session) |
private static java.util.Map<java.lang.String,java.lang.String> |
MdcInjectionFilter.getContext(IoSession session) |
static java.lang.String |
MdcInjectionFilter.getProperty(IoSession session,
java.lang.String key) |
void |
LoggingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
LoggingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
static void |
MdcInjectionFilter.removeProperty(IoSession session,
java.lang.String key) |
void |
LoggingFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
LoggingFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
LoggingFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
LoggingFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
static void |
MdcInjectionFilter.setProperty(IoSession session,
java.lang.String key,
java.lang.String value)
Add a property to the context for the given session
This property will be added to the MDC for all subsequent events
|
| Modifier and Type | Field and Description |
|---|---|
private IoSession |
SslHandler.session
The current session
|
| Modifier and Type | Method and Description |
|---|---|
(package private) IoSession |
SslHandler.getSession() |
| Modifier and Type | Method and Description |
|---|---|
void |
SslFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
SslFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
SslFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
(package private) java.lang.String |
SslFilter.getSessionInfo(IoSession session)
An extended toString() method for sessions.
|
javax.net.ssl.SSLSession |
SslFilter.getSslSession(IoSession session)
Returns the underlying
SSLSession for the specified session. |
private SslHandler |
SslFilter.getSslSessionHandler(IoSession session) |
private WriteFuture |
SslFilter.initiateClosure(IoFilter.NextFilter nextFilter,
IoSession session) |
private void |
SslFilter.initiateHandshake(IoFilter.NextFilter nextFilter,
IoSession session) |
boolean |
SslFilter.isSslStarted(IoSession session)
Returns true if and only if the specified session is
encrypted/decrypted over SSL/TLS currently.
|
void |
SslFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
SslFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
SslFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
boolean |
SslFilter.startSsl(IoSession session)
(Re)starts SSL session for the specified session if not started yet.
|
WriteFuture |
SslFilter.stopSsl(IoSession session)
Stops the SSL session by sending TLS close_notify message to
initiate TLS closure.
|
| Constructor and Description |
|---|
SslHandler(SslFilter sslFilter,
IoSession session)
Create a new SSL Handler, and initialize it.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ProfilerTimerFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message)
Profile a MessageReceived event.
|
void |
ProfilerTimerFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Profile a MessageSent event.
|
void |
ProfilerTimerFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Profile a SessionClosed event.
|
void |
ProfilerTimerFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Profile a SessionCreated event.
|
void |
ProfilerTimerFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Profile a SessionIdle event.
|
void |
ProfilerTimerFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Profile a SessionOpened event.
|
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractStreamWriteFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
private java.util.Queue<WriteRequest> |
AbstractStreamWriteFilter.getWriteRequestQueue(IoSession session) |
void |
AbstractStreamWriteFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
private java.util.Queue<WriteRequest> |
AbstractStreamWriteFilter.removeWriteRequestQueue(IoSession session) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract java.lang.Object |
WriteRequestFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CommonEventFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
ReferenceCountingFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
CommonEventFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ReferenceCountingFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
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.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
ReferenceCountingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
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) |
void |
CommonEventFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ReferenceCountingFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
CommonEventFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ReferenceCountingFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
SessionAttributeInitializingFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Puts all pre-configured attributes into the actual session attribute
map and forward the event to the next filter.
|
void |
CommonEventFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
ReferenceCountingFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
CommonEventFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ReferenceCountingFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
| Modifier and Type | Method and Description |
|---|---|
private void |
IoHandlerChain.callNextCommand(IoHandlerChain.Entry entry,
IoSession session,
java.lang.Object message) |
void |
IoHandlerChain.execute(IoHandlerCommand.NextCommand next,
IoSession session,
java.lang.Object message) |
void |
IoHandlerCommand.execute(IoHandlerCommand.NextCommand next,
IoSession session,
java.lang.Object message)
Execute a unit of processing work to be performed.
|
void |
IoHandlerCommand.NextCommand.execute(IoSession session,
java.lang.Object message)
Forwards the request to the next
IoHandlerCommand in the
IoHandlerChain. |
void |
ChainedIoHandler.messageReceived(IoSession session,
java.lang.Object message)
Handles the specified messageReceived event with the
IoHandlerCommand or IoHandlerChain you specified
in the constructor. |
| Modifier and Type | Method and Description |
|---|---|
void |
ExceptionHandler.exceptionCaught(IoSession session,
E cause)
Invoked when the specific type of exception is caught from the
specified
session. |
void |
DemuxingIoHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Invoked when any exception is thrown by user IoHandler implementation
or by MINA.
|
void |
MessageHandler.handleMessage(IoSession session,
E message)
Invoked when the specific type of message is received from or sent to
the specified
session. |
void |
DemuxingIoHandler.messageReceived(IoSession session,
java.lang.Object message)
Forwards the received events into the appropriate
MessageHandler
which is registered by DemuxingIoHandler.addReceivedMessageHandler(Class, MessageHandler). |
void |
DemuxingIoHandler.messageSent(IoSession session,
java.lang.Object message)
Invoked when a message written by IoSession.write(Object) is sent out.
|
| Modifier and Type | Field and Description |
|---|---|
private IoSession |
SingleSessionIoHandlerAdapter.session
Deprecated.
The session to which the handler is assigned.
|
| Modifier and Type | Method and Description |
|---|---|
protected IoSession |
SingleSessionIoHandlerAdapter.getSession()
Deprecated.
Retrieves the session to which this handler is assigned.
|
| Modifier and Type | Method and Description |
|---|---|
void |
SingleSessionIoHandlerDelegate.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Deprecated.
Delegates the method call to the
SingleSessionIoHandler.exceptionCaught(Throwable) method of the
handler assigned to this session. |
SingleSessionIoHandler |
SingleSessionIoHandlerFactory.getHandler(IoSession session)
Deprecated.
Returns a
SingleSessionIoHandler for the given session. |
void |
SingleSessionIoHandler.inputClosed(IoSession session)
Deprecated.
|
void |
SingleSessionIoHandlerAdapter.inputClosed(IoSession session)
Deprecated.
|
void |
SingleSessionIoHandlerDelegate.inputClosed(IoSession session)
Deprecated.
|
void |
SingleSessionIoHandlerDelegate.messageReceived(IoSession session,
java.lang.Object message)
Deprecated.
Delegates the method call to the
SingleSessionIoHandler.messageReceived(Object) method of the
handler assigned to this session. |
void |
SingleSessionIoHandlerDelegate.messageSent(IoSession session,
java.lang.Object message)
Deprecated.
Delegates the method call to the
SingleSessionIoHandler.messageSent(Object) method of the handler
assigned to this session. |
void |
SingleSessionIoHandlerDelegate.sessionClosed(IoSession session)
Deprecated.
Delegates the method call to the
SingleSessionIoHandler.sessionClosed() method of the handler
assigned to this session. |
void |
SingleSessionIoHandlerDelegate.sessionCreated(IoSession session)
Deprecated.
Creates a new instance with the factory passed to the constructor of
this class.
|
void |
SingleSessionIoHandlerDelegate.sessionIdle(IoSession session,
IdleStatus status)
Deprecated.
Delegates the method call to the
SingleSessionIoHandler.sessionIdle(IdleStatus) method of the
handler assigned to this session. |
void |
SingleSessionIoHandlerDelegate.sessionOpened(IoSession session)
Deprecated.
Delegates the method call to the
SingleSessionIoHandler.sessionOpened() method of the handler
assigned to this session. |
| Constructor and Description |
|---|
SingleSessionIoHandlerAdapter(IoSession session)
Deprecated.
Creates a new instance that is assigned to the passed in session.
|
| Modifier and Type | Field and Description |
|---|---|
private IoSession |
IoSessionOutputStream.session |
| Modifier and Type | Method and Description |
|---|---|
void |
StreamIoHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Forwards caught exceptions to input stream.
|
void |
StreamIoHandler.messageReceived(IoSession session,
java.lang.Object buf)
Forwards read data to input stream.
|
protected abstract void |
StreamIoHandler.processStreamIo(IoSession session,
java.io.InputStream in,
java.io.OutputStream out)
Implement this method to execute your stream I/O logic;
please note that you must forward the process request to other
thread or thread pool.
|
void |
StreamIoHandler.sessionClosed(IoSession session)
Closes streams
|
void |
StreamIoHandler.sessionIdle(IoSession session,
IdleStatus status)
Handles read timeout.
|
void |
StreamIoHandler.sessionOpened(IoSession session)
Initializes streams and timeout settings.
|
| Constructor and Description |
|---|
IoSessionOutputStream(IoSession session) |
| Modifier and Type | Method and Description |
|---|---|
void |
HttpClientDecoder.decode(IoSession session,
IoBuffer msg,
ProtocolDecoderOutput out) |
void |
HttpServerDecoder.decode(IoSession session,
IoBuffer msg,
ProtocolDecoderOutput out) |
void |
HttpClientDecoder.dispose(IoSession session) |
void |
HttpClientEncoder.dispose(IoSession arg0) |
void |
HttpServerDecoder.dispose(IoSession session) |
void |
HttpServerEncoder.dispose(IoSession session) |
void |
HttpClientEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
void |
HttpServerEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
void |
HttpClientDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out) |
void |
HttpServerDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out) |
void |
HttpClientCodec.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
HttpServerCodec.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
| Modifier and Type | Method and Description |
|---|---|
protected IoSession |
AbstractProxyLogicHandler.getSession()
Returns the session.
|
| Modifier and Type | Method and Description |
|---|---|
protected ConnectFuture |
ProxyConnector.fireConnected(IoSession session)
Fires the connection event on the real future to notify the client.
|
abstract void |
AbstractProxyIoHandler.proxySessionOpened(IoSession session)
Method called only when handshake has completed.
|
void |
AbstractProxyIoHandler.sessionOpened(IoSession session)
Hooked session opened event.
|
| Modifier and Type | Field and Description |
|---|---|
private IoSession |
IoSessionEvent.session
The session.
|
| Modifier and Type | Method and Description |
|---|---|
IoSession |
IoSessionEvent.getSession()
Returns the session on which the event occured.
|
| Modifier and Type | Method and Description |
|---|---|
private static void |
IoSessionEvent.deliverEvent(IoFilter.NextFilter nextFilter,
IoSession session,
IoSessionEventType type,
IdleStatus status)
Static method which effectively delivers the specified event to the next filter
nextFilter on the session. |
| Constructor and Description |
|---|
IoSessionEvent(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Creates an instance of this class when event type is
IoSessionEventType.IDLE. |
IoSessionEvent(IoFilter.NextFilter nextFilter,
IoSession session,
IoSessionEventType type)
Creates an instance of this class when event type differs from
IoSessionEventType.IDLE. |
| Modifier and Type | Method and Description |
|---|---|
void |
ProxyFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause)
Called when an exception occurs in the chain.
|
void |
ProxyFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters outgoing writes, queueing them up if necessary while a handshake
is ongoing.
|
private ProxyLogicHandler |
ProxyFilter.getProxyHandler(IoSession session)
Get the
ProxyLogicHandler for a given session. |
void |
ProxyFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message)
Receives data from the remote host, passes to the handler if a handshake is in progress,
otherwise passes on transparently.
|
void |
ProxyFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filter handshake related messages from reaching the messageSent callbacks of
downstream filters.
|
void |
ProxyFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Event is stored in an
IoSessionEventQueue for later delivery to the next filter
in the chain when the handshake would have succeed. |
void |
ProxyFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Called when the session is created.
|
void |
ProxyFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Event is stored in an
IoSessionEventQueue for later delivery to the next filter
in the chain when the handshake would have succeed. |
void |
ProxyFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Event is stored in an
IoSessionEventQueue for later delivery to the next filter
in the chain when the handshake would have succeed. |
void |
ProxyFilter.writeData(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest,
boolean isHandshakeData)
Actually write data.
|
| Modifier and Type | Method and Description |
|---|---|
static java.lang.String |
DigestUtilities.computeResponseValue(IoSession session,
java.util.HashMap<java.lang.String,java.lang.String> map,
java.lang.String method,
java.lang.String pwd,
java.lang.String charsetName,
java.lang.String body)
Computes the response to the DIGEST challenge.
|
| Modifier and Type | Field and Description |
|---|---|
private IoSession |
ProxyIoSession.session
The session.
|
| Modifier and Type | Method and Description |
|---|---|
IoSession |
ProxyIoSession.getSession()
Returns the current
IoSession. |
| Modifier and Type | Method and Description |
|---|---|
void |
ProxyIoSessionInitializer.initializeSession(IoSession session,
T future) |
void |
ProxyIoSession.setSession(IoSession session)
Sets the
IoSession in use. |
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
NioDatagramSession
An
IoSession for datagram transport (UDP/IP). |
class |
NioSession
An
IoSession which is managed by the NIO transport. |
(package private) class |
NioSocketSession
An
IoSession for socket transport (TCP/IP). |
| Modifier and Type | Method and Description |
|---|---|
IoSession |
NioDatagramAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
(Optional) Returns an
IoSession that is bound to the specified
localAddress and the specified remoteAddress which
reuses the local address that is already bound by this service. |
private IoSession |
NioDatagramAcceptor.newSessionWithoutLock(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress) |
| Modifier and Type | Class and Description |
|---|---|
(package private) class |
VmPipeSession
A
IoSession for in-VM transport (VM_PIPE). |
| Modifier and Type | Method and Description |
|---|---|
IoSession |
VmPipeAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress) |
| Modifier and Type | Method and Description |
|---|---|
(package private) void |
VmPipeAcceptor.doFinishSessionInitialization(IoSession session,
IoFuture future) |