Class VmPipeSessionImpl
- java.lang.Object
-
- org.apache.mina.common.support.BaseIoSession
-
- org.apache.mina.transport.vmpipe.support.VmPipeSessionImpl
-
- All Implemented Interfaces:
IoSession
public class VmPipeSessionImpl extends BaseIoSession
AIoSession
for in-VM transport (VM_PIPE).
-
-
Constructor Summary
Constructors Constructor Description VmPipeSessionImpl(IoService service, IoServiceConfig serviceConfig, IoServiceListenerSupport serviceListeners, java.net.SocketAddress localAddress, IoHandler handler, VmPipe remoteEntry)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
close0()
Implement this method to perform real close operation.IoSessionConfig
getConfig()
Returns the configuration of this session.IoFilterChain
getFilterChain()
Returns the filter chain that only affects this session.IoHandler
getHandler()
Returns theIoHandler
which handles this session.java.net.SocketAddress
getLocalAddress()
Returns the socket address of local machine which is associated with this session.java.net.SocketAddress
getRemoteAddress()
Returns the socket address of remote peer.VmPipeSessionImpl
getRemoteSession()
IoService
getService()
Returns theIoService
which provides I/O service to this session.java.net.SocketAddress
getServiceAddress()
Returns the socket address of theIoService
listens to to manage this session.IoServiceConfig
getServiceConfig()
Returns theIoServiceConfig
of this session.TransportType
getTransportType()
Returns transport type of this session.protected void
updateTrafficMask()
Signals theIoService
that theTrafficMask
of this session has been changed.protected void
write0(IoFilter.WriteRequest writeRequest)
Implement this method to perform real write operation with the specifiedwriteRequest
.-
Methods inherited from class org.apache.mina.common.support.BaseIoSession
close, containsAttribute, getAttachment, getAttribute, getAttributeKeys, getCloseFuture, getCreationTime, getIdleCount, getIdleTime, getIdleTimeInMillis, getLastIdleTime, getLastIoTime, getLastReadTime, getLastWriteTime, getReadBytes, getReadMessages, getScheduledWriteBytes, getScheduledWriteRequests, getTrafficMask, getWriteTimeout, getWriteTimeoutInMillis, getWrittenBytes, getWrittenMessages, getWrittenWriteRequests, increaseIdleCount, increaseReadBytes, increaseReadMessages, increaseScheduledWriteBytes, increaseScheduledWriteRequests, increaseWrittenBytes, increaseWrittenMessages, isClosing, isConnected, isIdle, isScheduledForFlush, removeAttribute, resumeRead, resumeWrite, setAttachment, setAttribute, setAttribute, setIdleTime, setScheduledForFlush, setTrafficMask, setWriteTimeout, suspendRead, suspendWrite, toString, write, write
-
-
-
-
Constructor Detail
-
VmPipeSessionImpl
public VmPipeSessionImpl(IoService service, IoServiceConfig serviceConfig, IoServiceListenerSupport serviceListeners, java.net.SocketAddress localAddress, IoHandler handler, VmPipe remoteEntry)
-
-
Method Detail
-
getService
public IoService getService()
Description copied from interface:IoSession
Returns theIoService
which provides I/O service to this session.
-
getServiceConfig
public IoServiceConfig getServiceConfig()
Description copied from interface:IoSession
Returns theIoServiceConfig
of this session.
-
getConfig
public IoSessionConfig getConfig()
Description copied from interface:IoSession
Returns the configuration of this session.
-
getFilterChain
public IoFilterChain getFilterChain()
Description copied from interface:IoSession
Returns the filter chain that only affects this session.
-
getRemoteSession
public VmPipeSessionImpl getRemoteSession()
-
getHandler
public IoHandler getHandler()
Description copied from interface:IoSession
Returns theIoHandler
which handles this session.
-
close0
protected void close0()
Description copied from class:BaseIoSession
Implement this method to perform real close operation. By default, this method is implemented to set the future to 'closed' immediately.- Overrides:
close0
in classBaseIoSession
-
write0
protected void write0(IoFilter.WriteRequest writeRequest)
Description copied from class:BaseIoSession
Implement this method to perform real write operation with the specifiedwriteRequest
. By default, this method is implemented to set the future to 'not written' immediately.- Overrides:
write0
in classBaseIoSession
- Parameters:
writeRequest
- Write request to make
-
getTransportType
public TransportType getTransportType()
Description copied from interface:IoSession
Returns transport type of this session.
-
getRemoteAddress
public java.net.SocketAddress getRemoteAddress()
Description copied from interface:IoSession
Returns the socket address of remote peer.
-
getLocalAddress
public java.net.SocketAddress getLocalAddress()
Description copied from interface:IoSession
Returns the socket address of local machine which is associated with this session.
-
getServiceAddress
public java.net.SocketAddress getServiceAddress()
Description copied from interface:IoSession
Returns the socket address of theIoService
listens to to manage this session. If this session is managed byIoAcceptor
, it returns theSocketAddress
which is specified as a parameter ofIoAcceptor.bind(SocketAddress, IoHandler)
. If this session is managed byIoConnector
, this method returns the same address with that ofIoSession.getRemoteAddress()
.
-
updateTrafficMask
protected void updateTrafficMask()
Description copied from class:BaseIoSession
Signals theIoService
that theTrafficMask
of this session has been changed.- Specified by:
updateTrafficMask
in classBaseIoSession
-
-