com.sun.corba.se.impl.encoding

Class BufferManagerWriteStream

java.lang.Object

com.sun.corba.se.impl.encoding.BufferManagerWrite

com.sun.corba.se.impl.encoding.BufferManagerWriteStream

public class BufferManagerWriteStream
extends BufferManagerWrite

Streaming buffer manager.

Field Summary

Fields inherited from class com.sun.corba.se.impl.encoding.BufferManagerWrite

orb, outputObject, sentFullMessage, wrapper

Method Summary

Modifier and Type	Method and Description
void	close() Close the BufferManagerWrite and do any outstanding cleanup.
int	getBufferSize() Returns the correct buffer size for this type of buffer manager as set in the ORB.
void	overflow(ByteBufferWithInfo bbwi)
void	sendMessage() Called after Stub._invoke (i.e., before complete message has been sent).
boolean	sentFragment() Has the stream sent out any fragments so far?

Methods inherited from class com.sun.corba.se.impl.encoding.BufferManagerWrite

sentFullMessage, setOutputObject

Methods inherited from class java.lang.Object

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

Method Detail

sentFragment

public boolean sentFragment()

Description copied from class: BufferManagerWrite

Has the stream sent out any fragments so far?

Specified by:

sentFragment in class BufferManagerWrite

getBufferSize

public int getBufferSize()

Returns the correct buffer size for this type of buffer manager as set in the ORB.

Specified by:

getBufferSize in class BufferManagerWrite

overflow

public void overflow(ByteBufferWithInfo bbwi)

Specified by:

overflow in class BufferManagerWrite

sendMessage

public void sendMessage()

Description copied from class: BufferManagerWrite

Called after Stub._invoke (i.e., before complete message has been sent). IIOPOutputStream.writeTo called from IIOPOutputStream.invoke Case: overflow was never called (bbwi.buf contains complete message). Backpatch size field. If growing or collecting: this.bufQ.put(bbwi). this.bufQ.iterate // However, see comment in getBufferQ this.connection.send(fragment) If streaming: this.connection.send(bbwi). Case: overflow was called N times (bbwi.buf contains last buffer). If growing or collecting: this.bufQ.put(bbwi). backpatch size field in first buffer. this.bufQ.iterate // However, see comment in getBufferQ this.connection.send(fragment) If streaming: backpatch fragment size field in bbwi.buf. Set no more fragments bit. this.connection.send(bbwi).

Specified by:

sendMessage in class BufferManagerWrite

close

public void close()

Close the BufferManagerWrite and do any outstanding cleanup. No work to do for a BufferManagerWriteStream

Specified by:

close in class BufferManagerWrite