org.apache.mina.transport.vmpipe

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 and Description
private VmPipeFilterChain	filterChain
private VmPipeAddress	localAddress
private java.util.concurrent.locks.Lock	lock
(package private) static TransportMetadata	METADATA
(package private) java.util.concurrent.BlockingQueue<java.lang.Object>	receivedMessageQueue Package protected
private VmPipeAddress	remoteAddress
private VmPipeSession	remoteSession
private VmPipeAddress	serviceAddress
private IoServiceListenerSupport	serviceListeners

Fields inherited from class org.apache.mina.core.session.AbstractIoSession

config

Constructor Summary

Constructors

Modifier	Constructor and 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 and Description
VmPipeSessionConfig	getConfig()
IoFilterChain	getFilterChain()
VmPipeAddress	getLocalAddress() Returns the socket address of local machine which is associated with this session.
(package private) java.util.concurrent.locks.Lock	getLock()
IoProcessor<VmPipeSession>	getProcessor()
VmPipeAddress	getRemoteAddress() Returns the socket address of remote peer.
VmPipeSession	getRemoteSession()
VmPipeAddress	getServiceAddress() Returns the socket address of the IoService listens to to manage this session.
(package private) IoServiceListenerSupport	getServiceListeners()
TransportMetadata	getTransportMetadata()
(package private) WriteRequestQueue	getWriteRequestQueue0()
(package private) void	increaseWrittenBytes0(int increment, long currentTime)

Methods inherited from class org.apache.mina.core.session.AbstractIoSession

close, close, containsAttribute, decreaseReadBufferSize, decreaseScheduledBytesAndMessages, 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, 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 java.lang.Object

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

Field Detail

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 java.util.concurrent.locks.Lock lock

receivedMessageQueue

final java.util.concurrent.BlockingQueue<java.lang.Object> receivedMessageQueue

Package protected

Constructor Detail

VmPipeSession

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

VmPipeSession

private VmPipeSession(VmPipeSession remoteSession,
                      VmPipe entry)

Method Detail

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()

Description copied from interface: IoSession

Returns the socket address of remote peer.

getLocalAddress

public VmPipeAddress getLocalAddress()

Description copied from interface: IoSession

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

getServiceAddress

public VmPipeAddress getServiceAddress()

Description copied from 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().

Specified by:

getServiceAddress in interface IoSession

Overrides:

getServiceAddress in class AbstractIoSession

increaseWrittenBytes0

void increaseWrittenBytes0(int increment,
                           long currentTime)

getWriteRequestQueue0

WriteRequestQueue getWriteRequestQueue0()

getLock

java.util.concurrent.locks.Lock getLock()