com.sun.corba.se.impl.encoding

Interface BufferManagerRead

All Known Implementing Classes:

BufferManagerReadGrow, BufferManagerReadStream

public interface BufferManagerRead

Method Summary

Modifier and Type	Method and Description
void	cancelProcessing(int requestId)
void	close(ByteBufferWithInfo bbwi)
com.sun.corba.se.impl.encoding.MarkAndResetHandler	getMarkAndResetHandler() Returns the mark/reset handler for this stream.
void	init(Message header) Called once after creating this buffer manager and before it begins processing.
void	processFragment(ByteBuffer byteBuffer, FragmentMessage header) Case: Called from ReaderThread on complete message or fragments.
ByteBufferWithInfo	underflow(ByteBufferWithInfo bbwi) Case: called from CDRInputStream.grow.

Method Detail

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

ByteBufferWithInfo underflow(ByteBufferWithInfo bbwi)

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)