org.apache.mina.transport.vmpipe.support
Class VmPipeSessionImpl

java.lang.Object
  extended by org.apache.mina.common.support.BaseIoSession
      extended by org.apache.mina.transport.vmpipe.support.VmPipeSessionImpl
All Implemented Interfaces:
IoSession

public class VmPipeSessionImpl
extends BaseIoSession

A IoSession for in-VM transport (VM_PIPE).


Constructor Summary
VmPipeSessionImpl(IoService service, IoServiceConfig serviceConfig, IoServiceListenerSupport serviceListeners, java.net.SocketAddress localAddress, IoHandler handler, VmPipe remoteEntry)
           
 
Method Summary
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 the IoHandler 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 the IoService which provides I/O service to this session.
 java.net.SocketAddress getServiceAddress()
          Returns the socket address of the IoService listens to to manage this session.
 IoServiceConfig getServiceConfig()
          Returns the IoServiceConfig of this session.
 TransportType getTransportType()
          Returns transport type of this session.
protected  void updateTrafficMask()
          Signals the IoService that the TrafficMask of this session has been changed.
protected  void write0(IoFilter.WriteRequest writeRequest)
          Implement this method to perform real write operation with the specified writeRequest.
 
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

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 the IoService which provides I/O service to this session.


getServiceConfig

public IoServiceConfig getServiceConfig()
Description copied from interface: IoSession
Returns the IoServiceConfig 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 the IoHandler 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 class BaseIoSession

write0

protected void write0(IoFilter.WriteRequest writeRequest)
Description copied from class: BaseIoSession
Implement this method to perform real write operation with the specified writeRequest. By default, this method is implemented to set the future to 'not written' immediately.

Overrides:
write0 in class BaseIoSession
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 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(SocketAddress, IoHandler). If this session is managed by IoConnector, this method returns the same address with that of IoSession.getRemoteAddress().


updateTrafficMask

protected void updateTrafficMask()
Description copied from class: BaseIoSession
Signals the IoService that the TrafficMask of this session has been changed.

Specified by:
updateTrafficMask in class BaseIoSession