Package org.apache.mina.transport.vmpipe

Class VmPipeFilterChain

java.lang.Object

org.apache.mina.core.filterchain.DefaultIoFilterChain

org.apache.mina.transport.vmpipe.VmPipeFilterChain

All Implemented Interfaces:

IoFilterChain

class VmPipeFilterChain
extends DefaultIoFilterChain

TODO Add documentation

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	VmPipeFilterChain.VmPipeIoProcessor

Nested classes/interfaces inherited from interface org.apache.mina.core.filterchain.IoFilterChain

IoFilterChain.Entry

Field Summary

Fields

Modifier and Type	Field	Description
private final Queue<IoEvent>	eventQueue
private boolean	flushEnabled
private final IoProcessor<VmPipeSession>	processor
private boolean	sessionOpened

Fields inherited from class org.apache.mina.core.filterchain.DefaultIoFilterChain

SESSION_CREATED_FUTURE

Constructor Summary

Constructors

Constructor	Description
VmPipeFilterChain(AbstractIoSession session)

Method Summary

Modifier and Type	Method	Description
private void	fireEvent(IoEvent e)
void	fireEvent(FilterEvent event)	Fires a IoHandler.event(IoSession, FilterEvent) event.
void	fireExceptionCaught(Throwable cause)	Fires a IoHandler.exceptionCaught(IoSession, Throwable) event.
void	fireFilterClose()	Fires a IoSession.closeNow() or a IoSession.closeOnFlush() event.
void	fireFilterWrite(WriteRequest writeRequest)	Fires a IoSession.write(Object) event.
void	fireInputClosed()	Fires a IoHandler.inputClosed(IoSession) event.
void	fireMessageReceived(Object message)	Fires a IoHandler.messageReceived(IoSession, Object) event.
void	fireMessageSent(WriteRequest request)	Fires a IoHandler.messageSent(IoSession, Object) event.
void	fireSessionClosed()	Fires a IoHandler.sessionClosed(IoSession) event.
void	fireSessionCreated()	Fires a IoHandler.sessionCreated(IoSession) event.
void	fireSessionIdle(IdleStatus status)	Fires a IoHandler.sessionIdle(IoSession, IdleStatus) event.
void	fireSessionOpened()	Fires a IoHandler.sessionOpened(IoSession) event.
private void	flushEvents()
private static void	flushPendingDataQueues(VmPipeSession s)
(package private) IoProcessor<VmPipeSession>	getProcessor()
private void	pushEvent(IoEvent e)
private void	pushEvent(IoEvent e, boolean flushNow)
void	start()

Methods inherited from class org.apache.mina.core.filterchain.DefaultIoFilterChain

addAfter, addBefore, addFirst, addLast, clear, contains, contains, contains, get, get, getAll, getAllReversed, getEntry, getEntry, getEntry, getNextFilter, getNextFilter, getNextFilter, getSession, remove, remove, remove, replace, replace, replace, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

eventQueue

private final Queue<IoEvent> eventQueue

processor

private final IoProcessor<VmPipeSession> processor

flushEnabled

private volatile boolean flushEnabled

sessionOpened

private volatile boolean sessionOpened

Constructor Details

VmPipeFilterChain

VmPipeFilterChain(AbstractIoSession session)

Method Details

getProcessor

IoProcessor<VmPipeSession> getProcessor()

start

public void start()

pushEvent

private void pushEvent(IoEvent e)

pushEvent

private void pushEvent(IoEvent e,
 boolean flushNow)

flushEvents

private void flushEvents()

fireEvent

private void fireEvent(IoEvent e)

flushPendingDataQueues

private static void flushPendingDataQueues(VmPipeSession s)

fireEvent

public void fireEvent(FilterEvent event)

Description copied from class: DefaultIoFilterChain

Fires a IoHandler.event(IoSession, FilterEvent) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireEvent in interface IoFilterChain

Overrides:

fireEvent in class DefaultIoFilterChain

Parameters:

event - The specific event being fired

fireFilterClose

public void fireFilterClose()

Description copied from class: DefaultIoFilterChain

Fires a IoSession.closeNow() or a IoSession.closeOnFlush() event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireFilterClose in interface IoFilterChain

Overrides:

fireFilterClose in class DefaultIoFilterChain

fireInputClosed

public void fireInputClosed()

Description copied from class: DefaultIoFilterChain

Fires a IoHandler.inputClosed(IoSession) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireInputClosed in interface IoFilterChain

Overrides:

fireInputClosed in class DefaultIoFilterChain

fireFilterWrite

public void fireFilterWrite(WriteRequest writeRequest)

Description copied from class: DefaultIoFilterChain

Fires a IoSession.write(Object) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireFilterWrite in interface IoFilterChain

Overrides:

fireFilterWrite in class DefaultIoFilterChain

Parameters:

writeRequest - The message to write

fireExceptionCaught

public void fireExceptionCaught(Throwable cause)

Description copied from class: DefaultIoFilterChain

Fires a IoHandler.exceptionCaught(IoSession, Throwable) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireExceptionCaught in interface IoFilterChain

Overrides:

fireExceptionCaught in class DefaultIoFilterChain

Parameters:

cause - The exception cause

fireMessageSent

public void fireMessageSent(WriteRequest request)

Description copied from class: DefaultIoFilterChain

Fires a IoHandler.messageSent(IoSession, Object) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireMessageSent in interface IoFilterChain

Overrides:

fireMessageSent in class DefaultIoFilterChain

Parameters:

request - The sent request

fireSessionClosed

public void fireSessionClosed()

Description copied from class: DefaultIoFilterChain

Fires a IoHandler.sessionClosed(IoSession) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireSessionClosed in interface IoFilterChain

Overrides:

fireSessionClosed in class DefaultIoFilterChain

fireSessionCreated

public void fireSessionCreated()

Description copied from class: DefaultIoFilterChain

Fires a IoHandler.sessionCreated(IoSession) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireSessionCreated in interface IoFilterChain

Overrides:

fireSessionCreated in class DefaultIoFilterChain

fireSessionIdle

public void fireSessionIdle(IdleStatus status)

Description copied from class: DefaultIoFilterChain

Fires a IoHandler.sessionIdle(IoSession, IdleStatus) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireSessionIdle in interface IoFilterChain

Overrides:

fireSessionIdle in class DefaultIoFilterChain

Parameters:

status - The current status to propagate

fireSessionOpened

public void fireSessionOpened()

Description copied from class: DefaultIoFilterChain

Fires a IoHandler.sessionOpened(IoSession) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireSessionOpened in interface IoFilterChain

Overrides:

fireSessionOpened in class DefaultIoFilterChain

fireMessageReceived

public void fireMessageReceived(Object message)

Description copied from class: DefaultIoFilterChain

Fires a IoHandler.messageReceived(IoSession, Object) event. Most users don't need to call this method at all. Please use this method only when you implement a new transport or fire a virtual event.

Specified by:

fireMessageReceived in interface IoFilterChain

Overrides:

fireMessageReceived in class DefaultIoFilterChain

Parameters:

message - The received message