Package org.apache.mina.transport.vmpipe

Class VmPipeFilterChain.VmPipeIoProcessor

java.lang.Object

org.apache.mina.transport.vmpipe.VmPipeFilterChain.VmPipeIoProcessor

All Implemented Interfaces:

IoProcessor<VmPipeSession>

Enclosing class:

VmPipeFilterChain

private class VmPipeFilterChain.VmPipeIoProcessor
extends java.lang.Object
implements IoProcessor<VmPipeSession>

Constructor Summary

Constructors

Modifier	Constructor	Description
private	VmPipeIoProcessor()

Method Summary

Modifier and Type	Method	Description
void	add(VmPipeSession session)	Adds the specified session to the I/O processor so that the I/O processor starts to perform any I/O operations related with the session.
void	dispose()	Releases any resources allocated by this processor.
void	flush(VmPipeSession session)	Flushes the internal write request queue of the specified session.
private java.lang.Object	getMessageCopy(java.lang.Object message)
boolean	isDisposed()
boolean	isDisposing()
void	remove(VmPipeSession session)	Removes and closes the specified session from the I/O processor so that the I/O processor closes the connection associated with the session and releases any other related resources.
void	updateTrafficControl(VmPipeSession session)	Controls the traffic of the specified session depending of the IoSession.isReadSuspended() and IoSession.isWriteSuspended() flags
void	write(VmPipeSession session, WriteRequest writeRequest)	Writes the WriteRequest for the specified session.

Methods inherited from class java.lang.Object

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

Constructor Detail

VmPipeIoProcessor

private VmPipeIoProcessor()

Method Detail

flush

public void flush(VmPipeSession session)

Description copied from interface: IoProcessor

Flushes the internal write request queue of the specified session.

Specified by:

flush in interface IoProcessor<VmPipeSession>

Parameters:

session - The session we want the message to be written

write

public void write(VmPipeSession session,
                  WriteRequest writeRequest)

Writes the WriteRequest for the specified session.

Specified by:

write in interface IoProcessor<VmPipeSession>

Parameters:

session - The session we want the message to be written

writeRequest - the WriteRequest to write

getMessageCopy

private java.lang.Object getMessageCopy(java.lang.Object message)

remove

public void remove(VmPipeSession session)

Description copied from interface: IoProcessor

Removes and closes the specified session from the I/O processor so that the I/O processor closes the connection associated with the session and releases any other related resources.

Specified by:

remove in interface IoProcessor<VmPipeSession>

Parameters:

session - The session to be removed

add

public void add(VmPipeSession session)

Description copied from interface: IoProcessor

Adds the specified session to the I/O processor so that the I/O processor starts to perform any I/O operations related with the session.

Specified by:

add in interface IoProcessor<VmPipeSession>

Parameters:

session - The added session

updateTrafficControl

public void updateTrafficControl(VmPipeSession session)

Description copied from interface: IoProcessor

Controls the traffic of the specified session depending of the IoSession.isReadSuspended() and IoSession.isWriteSuspended() flags

Specified by:

updateTrafficControl in interface IoProcessor<VmPipeSession>

Parameters:

session - The session to be updated

dispose

public void dispose()

Description copied from interface: IoProcessor

Releases any resources allocated by this processor. Please note that the resources might not be released as long as there are any sessions managed by this processor. Most implementations will close all sessions immediately and release the related resources.

Specified by:

dispose in interface IoProcessor<VmPipeSession>

isDisposed

public boolean isDisposed()

Specified by:

isDisposed in interface IoProcessor<VmPipeSession>

Returns:

true if and if only all resources of this processor have been disposed.

isDisposing

public boolean isDisposing()

Specified by:

isDisposing in interface IoProcessor<VmPipeSession>

Returns:

true if and if only IoProcessor.dispose() method has been called. Please note that this method will return true even after all the related resources are released.