org.jboss.com.sun.corba.se.impl.encoding

Class BufferManagerReadStream

java.lang.Object

org.jboss.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)
protected ByteBufferPool	getByteBufferPool()
org.jboss.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(org.jboss.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

clone, equals, finalize, 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

getByteBufferPool

protected ByteBufferPool getByteBufferPool()

mark

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

fragmentationOccured

public void fragmentationOccured(ByteBufferWithInfo newFragment)

reset

public void reset()

getMarkAndResetHandler

public org.jboss.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