Class BufferManagerReadGrow

    • Constructor Detail

      • BufferManagerReadGrow

        public BufferManagerReadGrow()
    • Method Detail

      • processFragment

        public void processFragment​(java.nio.ByteBuffer byteBuffer,
                                    FragmentMessage header)
        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
        header - header of fragment
      • 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
      • underflow

        public java.nio.ByteBuffer underflow​(java.nio.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:
        BufferManagerRead.isFragmentOnUnderflow()
      • 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
      • close

        public void close​(java.nio.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