Class VmPipeSession
java.lang.Object
org.apache.mina.core.session.AbstractIoSession
org.apache.mina.transport.vmpipe.VmPipeSession
- All Implemented Interfaces:
IoSession
A
IoSession for in-VM transport (VM_PIPE).-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final VmPipeFilterChainprivate final VmPipeAddressprivate final Lock(package private) static final TransportMetadata(package private) final BlockingQueue<Object> Package protectedprivate final VmPipeAddressprivate final VmPipeSessionprivate final VmPipeAddressprivate final IoServiceListenerSupportFields inherited from class AbstractIoSession
CLOSE_REQUEST, config, MESSAGE_SENT_REQUEST -
Constructor Summary
ConstructorsModifierConstructorDescription(package private)VmPipeSession(IoService service, IoServiceListenerSupport serviceListeners, VmPipeAddress localAddress, IoHandler handler, VmPipe remoteEntry) privateVmPipeSession(VmPipeSession remoteSession, VmPipe entry) -
Method Summary
Modifier and TypeMethodDescription(package private) LockgetLock()(package private) IoServiceListenerSupport(package private) WriteRequestQueue(package private) voidincreaseWrittenBytes0(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
-
Field Details
-
METADATA
-
serviceListeners
-
localAddress
-
remoteAddress
-
serviceAddress
-
filterChain
-
remoteSession
-
lock
-
receivedMessageQueue
Package protected
-
-
Constructor Details
-
VmPipeSession
VmPipeSession(IoService service, IoServiceListenerSupport serviceListeners, VmPipeAddress localAddress, IoHandler handler, VmPipe remoteEntry) -
VmPipeSession
-
-
Method Details
-
getProcessor
- Specified by:
getProcessorin classAbstractIoSession- Returns:
- The associated IoProcessor for this session
-
getServiceListeners
IoServiceListenerSupport getServiceListeners() -
getConfig
Description copied from class:AbstractIoSession- Specified by:
getConfigin interfaceIoSession- Overrides:
getConfigin classAbstractIoSession- Returns:
- the configuration of this session.
-
getFilterChain
- Returns:
- the filter chain that only affects this session.
-
getRemoteSession
-
getTransportMetadata
- Returns:
- the
TransportMetadatathat this session runs on.
-
getRemoteAddress
- Returns:
- the socket address of remote peer.
-
getLocalAddress
- Returns:
- the socket address of local machine which is associated with this session.
-
getServiceAddress
Description copied from class:AbstractIoSession- Specified by:
getServiceAddressin interfaceIoSession- Overrides:
getServiceAddressin classAbstractIoSession- Returns:
- the socket address of the
IoServicelistens to to manage this session. If this session is managed byIoAcceptor, it returns theSocketAddresswhich is specified as a parameter ofIoAcceptor.bind(). If this session is managed byIoConnector, this method returns the same address with that ofIoSession.getRemoteAddress().
-
increaseWrittenBytes0
void increaseWrittenBytes0(int increment, long currentTime) -
getWriteRequestQueue0
WriteRequestQueue getWriteRequestQueue0() -
getLock
Lock getLock()
-