Class VmPipeSession

java.lang.Object

org.apache.mina.core.session.AbstractIoSession

org.apache.mina.transport.vmpipe.VmPipeSession

All Implemented Interfaces:

IoSession

class VmPipeSession
extends AbstractIoSession

A IoSession for in-VM transport (VM_PIPE).

Field Summary

Fields

Modifier and Type	Field	Description
private final VmPipeFilterChain	filterChain
private final VmPipeAddress	localAddress
private final Lock	lock
(package private) static final TransportMetadata	METADATA
(package private) final BlockingQueue<Object>	receivedMessageQueue	Package protected
private final VmPipeAddress	remoteAddress
private final VmPipeSession	remoteSession
private final VmPipeAddress	serviceAddress
private final IoServiceListenerSupport	serviceListeners

Fields inherited from class AbstractIoSession

CLOSE_REQUEST, config, MESSAGE_SENT_REQUEST

Constructor Summary

Constructors

Modifier	Constructor	Description
(package private)	VmPipeSession(IoService service, IoServiceListenerSupport serviceListeners, VmPipeAddress localAddress, IoHandler handler, VmPipe remoteEntry)
private	VmPipeSession(VmPipeSession remoteSession, VmPipe entry)

Method Summary

Modifier and Type	Method	Description
VmPipeSessionConfig	getConfig()
IoFilterChain	getFilterChain()
VmPipeAddress	getLocalAddress()
(package private) Lock	getLock()
IoProcessor<VmPipeSession>	getProcessor()
VmPipeAddress	getRemoteAddress()
VmPipeSession	getRemoteSession()
VmPipeAddress	getServiceAddress()
(package private) IoServiceListenerSupport	getServiceListeners()
TransportMetadata	getTransportMetadata()
(package private) WriteRequestQueue	getWriteRequestQueue0()
(package private) void	increaseWrittenBytes0(int increment, long currentTime)

Methods inherited from class AbstractIoSession

close, close, closeNow, closeOnFlush, containsAttribute, decreaseReadBufferSize, decreaseScheduledBytesAndMessages, destroy, equals, getAttachment, getAttribute, getAttribute, getAttributeKeys, getAttributeMap, getBothIdleCount, getCloseFuture, getCreationTime, getCurrentWriteMessage, getCurrentWriteRequest, getHandler, getId, getIdleCount, getLastBothIdleTime, getLastIdleTime, getLastIoTime, getLastReaderIdleTime, getLastReadTime, getLastWriterIdleTime, getLastWriteTime, getReadBytes, getReadBytesThroughput, getReaderIdleCount, getReadMessages, getReadMessagesThroughput, getScheduledWriteBytes, getScheduledWriteMessages, getService, getWriteRequestQueue, getWriterIdleCount, getWrittenBytes, getWrittenBytesThroughput, getWrittenMessages, getWrittenMessagesThroughput, hashCode, increaseIdleCount, increaseReadBufferSize, increaseReadBytes, increaseReadMessages, increaseScheduledWriteBytes, increaseScheduledWriteMessages, increaseWrittenBytes, increaseWrittenMessages, isActive, isBothIdle, isClosing, isConnected, isIdle, isReaderIdle, isReadSuspended, isScheduledForFlush, isSecured, isWriterIdle, isWriteSuspended, notifyIdleness, notifyIdleSession, offerClosedReadFuture, offerFailedReadFuture, offerReadFuture, read, removeAttribute, removeAttribute, replaceAttribute, resumeRead, resumeWrite, scheduledForFlush, setAttachment, setAttribute, setAttribute, setAttributeIfAbsent, setAttributeIfAbsent, setAttributeMap, setCurrentWriteRequest, setScheduledForFlush, setScheduledWriteBytes, setScheduledWriteMessages, setWriteRequestQueue, suspendRead, suspendWrite, toString, unscheduledForFlush, updateThroughput, write, write

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

METADATA

static final TransportMetadata METADATA

serviceListeners

private final IoServiceListenerSupport serviceListeners

localAddress

private final VmPipeAddress localAddress

remoteAddress

private final VmPipeAddress remoteAddress

serviceAddress

private final VmPipeAddress serviceAddress

filterChain

private final VmPipeFilterChain filterChain

remoteSession

private final VmPipeSession remoteSession

lock

private final Lock lock

receivedMessageQueue

final BlockingQueue<Object> receivedMessageQueue

Package protected

Constructor Details

VmPipeSession

VmPipeSession(IoService service,
 IoServiceListenerSupport serviceListeners,
 VmPipeAddress localAddress,
 IoHandler handler,
 VmPipe remoteEntry)

VmPipeSession

private VmPipeSession(VmPipeSession remoteSession,
 VmPipe entry)

Method Details

getProcessor

public IoProcessor<VmPipeSession> getProcessor()

Specified by:

getProcessor in class AbstractIoSession

Returns:

The associated IoProcessor for this session

getServiceListeners

IoServiceListenerSupport getServiceListeners()

getConfig

public VmPipeSessionConfig getConfig()

Description copied from class: AbstractIoSession

Specified by:

getConfig in interface IoSession

Overrides:

getConfig in class AbstractIoSession

Returns:

the configuration of this session.

getFilterChain

public IoFilterChain getFilterChain()

Returns:

the filter chain that only affects this session.

getRemoteSession

public VmPipeSession getRemoteSession()

getTransportMetadata

public TransportMetadata getTransportMetadata()

Returns:

the TransportMetadata that this session runs on.

getRemoteAddress

public VmPipeAddress getRemoteAddress()

Returns:

the socket address of remote peer.

getLocalAddress

public VmPipeAddress getLocalAddress()

Returns:

the socket address of local machine which is associated with this session.

getServiceAddress

public VmPipeAddress getServiceAddress()

Description copied from class: AbstractIoSession

Specified by:

getServiceAddress in interface IoSession

Overrides:

getServiceAddress in class AbstractIoSession

Returns:

the socket address of the IoService listens to to manage this session. If this session is managed by IoAcceptor, it returns the SocketAddress which is specified as a parameter of IoAcceptor.bind(). If this session is managed by IoConnector, this method returns the same address with that of IoSession.getRemoteAddress().

increaseWrittenBytes0

void increaseWrittenBytes0(int increment,
 long currentTime)

getWriteRequestQueue0

WriteRequestQueue getWriteRequestQueue0()

getLock

Lock getLock()