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
AIoSessionfor 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 voidclose0()Implement this method to perform real close operation.IoSessionConfiggetConfig()Returns the configuration of this session.IoFilterChaingetFilterChain()Returns the filter chain that only affects this session.IoHandlergetHandler()Returns theIoHandlerwhich handles this session.java.net.SocketAddressgetLocalAddress()Returns the socket address of local machine which is associated with this session.java.net.SocketAddressgetRemoteAddress()Returns the socket address of remote peer.VmPipeSessionImplgetRemoteSession()IoServicegetService()Returns theIoServicewhich provides I/O service to this session.java.net.SocketAddressgetServiceAddress()Returns the socket address of theIoServicelistens to to manage this session.IoServiceConfiggetServiceConfig()Returns theIoServiceConfigof this session.TransportTypegetTransportType()Returns transport type of this session.protected voidupdateTrafficMask()Signals theIoServicethat theTrafficMaskof this session has been changed.protected voidwrite0(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:IoSessionReturns theIoServicewhich provides I/O service to this session.
-
getServiceConfig
public IoServiceConfig getServiceConfig()
Description copied from interface:IoSessionReturns theIoServiceConfigof this session.
-
getConfig
public IoSessionConfig getConfig()
Description copied from interface:IoSessionReturns the configuration of this session.
-
getFilterChain
public IoFilterChain getFilterChain()
Description copied from interface:IoSessionReturns the filter chain that only affects this session.
-
getRemoteSession
public VmPipeSessionImpl getRemoteSession()
-
getHandler
public IoHandler getHandler()
Description copied from interface:IoSessionReturns theIoHandlerwhich handles this session.
-
close0
protected void close0()
Description copied from class:BaseIoSessionImplement this method to perform real close operation. By default, this method is implemented to set the future to 'closed' immediately.- Overrides:
close0in classBaseIoSession
-
write0
protected void write0(IoFilter.WriteRequest writeRequest)
Description copied from class:BaseIoSessionImplement 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:
write0in classBaseIoSession- Parameters:
writeRequest- Write request to make
-
getTransportType
public TransportType getTransportType()
Description copied from interface:IoSessionReturns transport type of this session.
-
getRemoteAddress
public java.net.SocketAddress getRemoteAddress()
Description copied from interface:IoSessionReturns the socket address of remote peer.
-
getLocalAddress
public java.net.SocketAddress getLocalAddress()
Description copied from interface:IoSessionReturns the socket address of local machine which is associated with this session.
-
getServiceAddress
public java.net.SocketAddress getServiceAddress()
Description copied from interface:IoSessionReturns the socket address of theIoServicelistens to to manage this session. If this session is managed byIoAcceptor, it returns theSocketAddresswhich 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:BaseIoSessionSignals theIoServicethat theTrafficMaskof this session has been changed.- Specified by:
updateTrafficMaskin classBaseIoSession
-
-