public class BufferManagerReadStream extends Object implements BufferManagerRead
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.
|
public void cancelProcessing(int requestId)
cancelProcessing
in interface BufferManagerRead
public void processFragment(ByteBuffer byteBuffer, FragmentMessage msg)
BufferManagerRead
processFragment
in interface BufferManagerRead
public ByteBufferWithInfo underflow(ByteBufferWithInfo bbwi)
BufferManagerRead
underflow
in interface BufferManagerRead
public void init(Message msg)
BufferManagerRead
init
in interface BufferManagerRead
public void close(ByteBufferWithInfo bbwi)
close
in interface BufferManagerRead
protected ByteBufferPool getByteBufferPool()
public void mark(org.jboss.com.sun.corba.se.impl.encoding.RestorableInputStream inputStream)
public void fragmentationOccured(ByteBufferWithInfo newFragment)
public void reset()
public org.jboss.com.sun.corba.se.impl.encoding.MarkAndResetHandler getMarkAndResetHandler()
BufferManagerRead
getMarkAndResetHandler
in interface BufferManagerRead
Copyright © 2018 JBoss by Red Hat. All rights reserved.