com.sun.corba.se.impl.encoding

Class BufferManagerReadStream

java.lang.Object

com.sun.corba.se.impl.encoding.BufferManagerReadStream

All Implemented Interfaces:

BufferManagerRead

public class BufferManagerReadStream
extends Object
implements BufferManagerRead

Method Summary

Methods

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

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

cancelProcessing

public void cancelProcessing(int requestId)

Specified by:

cancelProcessing in interface BufferManagerRead

processFragment

public void processFragment(ByteBuffer byteBuffer,
                   FragmentMessage msg)

Description copied from interface: BufferManagerRead

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.

Specified by:

processFragment in interface BufferManagerRead

underflow

public ByteBufferWithInfo underflow(ByteBufferWithInfo bbwi)

Description copied from interface: BufferManagerRead

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

Specified by:

underflow in interface BufferManagerRead

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

close

public void close(ByteBufferWithInfo bbwi)

Specified by:

close in interface BufferManagerRead

mark

public void mark(com.sun.corba.se.impl.encoding.RestorableInputStream inputStream)

fragmentationOccured

public void fragmentationOccured(ByteBufferWithInfo newFragment)

reset

public void reset()

getMarkAndResetHandler

public com.sun.corba.se.impl.encoding.MarkAndResetHandler getMarkAndResetHandler()

Description copied from interface: BufferManagerRead

Returns the mark/reset handler for this stream.

Specified by:

getMarkAndResetHandler in interface BufferManagerRead