Interface BufferManagerRead

All Known Implementing Classes:
BufferManagerReadGrow, BufferManagerReadStream

public interface BufferManagerRead
  • Method Details

    • processFragment

      void processFragment(ByteBuffer byteBuffer, FragmentMessage header)
      Case: Called from ReaderThread on complete message or fragments. The given buf 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.
    • underflow

      Case: called from CDRInputStream.grow. Does: this.bufQ.get() If streaming then sync on bufQ and wait if empty.
    • init

      void init(Message header)
      Called once after creating this buffer manager and before it begins processing.
    • getMarkAndResetHandler

      com.sun.corba.se.impl.encoding.MarkAndResetHandler getMarkAndResetHandler()
      Returns the mark/reset handler for this stream.
    • cancelProcessing

      void cancelProcessing(int requestId)
    • close

      void close(ByteBufferWithInfo bbwi)