| Methods Summary |
|---|
| public void | cancelProcessing(int requestId)
|
| public void | close(com.sun.corba.se.impl.encoding.ByteBufferWithInfo bbwi)
|
| public MarkAndResetHandler | getMarkAndResetHandler()Returns the mark/reset handler for this stream.
|
| public void | init(com.sun.corba.se.impl.protocol.giopmsgheaders.Message header)Called once after creating this buffer manager and before
it begins processing.
|
| public void | processFragment(java.nio.ByteBuffer byteBuffer, com.sun.corba.se.impl.protocol.giopmsgheaders.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.
|
| public com.sun.corba.se.impl.encoding.ByteBufferWithInfo | underflow(com.sun.corba.se.impl.encoding.ByteBufferWithInfo bbwi)Case: called from CDRInputStream.grow.
Does:
this.bufQ.get()
If streaming then sync on bufQ and wait if empty.
|
