Package com.sun.corba.se.impl.encoding
Interface BufferManagerRead
- All Known Implementing Classes:
BufferManagerReadGrow,BufferManagerReadStream
public interface BufferManagerRead
-
Method Summary
Modifier and TypeMethodDescriptionvoidcancelProcessing(int requestId) voidclose(ByteBufferWithInfo bbwi) com.sun.corba.se.impl.encoding.MarkAndResetHandlerReturns the mark/reset handler for this stream.voidCalled once after creating this buffer manager and before it begins processing.voidprocessFragment(ByteBuffer byteBuffer, FragmentMessage header) Case: Called from ReaderThread on complete message or fragments.underflow(ByteBufferWithInfo bbwi) Case: called from CDRInputStream.grow.
-
Method Details
-
processFragment
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
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
-