Class BufferManagerReadStream

java.lang.Object
com.sun.corba.ee.impl.encoding.BufferManagerReadStream
All Implemented Interfaces:
BufferManagerRead
public class BufferManagerReadStream extends Object implements BufferManagerRead

  • Method Details

    • cancelProcessing

      public void cancelProcessing(int requestId)
      Description copied from interface: BufferManagerRead
      Signals that the processing be cancelled.
      Specified by:
      cancelProcessing in interface BufferManagerRead
      Parameters:
      requestId - ID of the request to cancel

    • processFragment

      public void processFragment(ByteBuffer byteBuffer, FragmentMessage msg)
      Description copied from interface: BufferManagerRead
      Case: Called from ReaderThread on complete message or fragments. The given buffer may be entire message or a fragment. The ReaderThread finds the ReadBufferManager instance either in in a fragment map (when collecting - GIOP 1.2 phase 1) or in an active server requests map (when streaming - GIOP 1.2 phase 2). As a model for implementation see IIOPInputStream's constructor of the same name. There are going to be some variations.
      Specified by:
      processFragment in interface BufferManagerRead
      Parameters:
      byteBuffer - buffer to read from
      msg - header of fragment

    • underflow

      public ByteBuffer underflow(ByteBuffer byteBuffer)
      Description copied from interface: BufferManagerRead
      Invoked when we run out of data to read. Obtains more data from the stream.
      Specified by:
      underflow in interface BufferManagerRead
      Parameters:
      byteBuffer - Current buffer, to return to pool
      Returns:
      Buffer containing new data
      See Also:

    • isFragmentOnUnderflow

      public boolean isFragmentOnUnderflow()
      Description copied from interface: BufferManagerRead
      Returns true if this buffer manager reads fragments when it underflows.
      Specified by:
      isFragmentOnUnderflow in interface BufferManagerRead
      Returns:
      if fragments will be read.
      See Also:

    • init

      public void init(Message msg)
      Description copied from interface: BufferManagerRead
      Called once after creating this buffer manager and before it begins processing.
      Specified by:
      init in interface BufferManagerRead
      Parameters:
      msg - message header

    • close

      public void close(ByteBuffer byteBuffer)
      Description copied from interface: BufferManagerRead
      Close BufferManagerRead and perform any outstanding cleanup.
      Specified by:
      close in interface BufferManagerRead
      Parameters:
      byteBuffer - buffer to return to the pool

    • getByteBufferPool

      protected ByteBufferPool getByteBufferPool()

    • mark

      public void mark(com.sun.corba.ee.impl.encoding.RestorableInputStream inputStream)

    • fragmentationOccured

      public void fragmentationOccured(ByteBuffer newFrament)

    • reset

      public void reset()

    • getMarkAndResetHandler

      public com.sun.corba.ee.impl.encoding.MarkAndResetHandler getMarkAndResetHandler()
      Description copied from interface: BufferManagerRead
      Returns the mark/reset handler for this stream.
      Specified by:
      getMarkAndResetHandler in interface BufferManagerRead
      Returns:
      The mark/reset handler for this stream.