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

Class CDRInputStream

java.lang.Object

java.io.InputStream

org.omg.CORBA.portable.InputStream

org.omg.CORBA_2_3.portable.InputStream

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

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable, MarshalInputStream, DataInputStream, IDLEntity, ValueBase, ValueInputStream

Direct Known Subclasses:

CDRInputObject, EncapsInputStream

public abstract class CDRInputStream
extends InputStream
implements MarshalInputStream, DataInputStream, ValueInputStream

This is delegates to the real implementation. NOTE: Before using the stream for valuetype unmarshaling, one must call performORBVersionSpecificInit().

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected CorbaMessageMediator	messageMediator

Constructor Summary

Constructors

Constructor and Description
CDRInputStream()
CDRInputStream(CDRInputStream is)
CDRInputStream(ORB orb, ByteBuffer byteBuffer, int size, boolean littleEndian, GIOPVersion version, byte encodingVersion, BufferManagerRead bufMgr)

Method Summary

Modifier and Type	Method and Description
String[]	_truncatable_ids()
void	alignOnBoundary(int octetBoundary) Aligns the current position on the given octet boundary if there are enough bytes available to do so.
int	available()
void	close()
void	consumeEndian()
protected CodeSetConversion.BTCConverter	createCharBTCConverter()
protected abstract CodeSetConversion.BTCConverter	createWCharBTCConverter()
abstract CDRInputStream	dup()
void	end_value()
int	getBufferLength()
BufferManagerRead	getBufferManager()
protected ByteBuffer	getByteBuffer()
CodeBase	getCodeBase()
GIOPVersion	getGIOPVersion()
protected int	getIndex()
MessageMediator	getMessageMediator()
int	getPosition()
boolean	isLittleEndian()
void	mark(int readlimit)
boolean	markSupported()
ORB	orb()
void	orb(ORB orb)
void	performORBVersionSpecificInit() This must be called after determining the proper ORB version, and setting it on the stream's ORB instance.
Object	read_abstract_interface()
Object	read_abstract_interface(Class clz)
Object	read_Abstract()
void	read_any_array(AnySeqHolder seq, int offset, int length)
Any	read_any()
void	read_boolean_array(boolean[] value, int offset, int length)
void	read_boolean_array(BooleanSeqHolder seq, int offset, int length)
boolean	read_boolean()
void	read_char_array(char[] value, int offset, int length)
void	read_char_array(CharSeqHolder seq, int offset, int length)
char	read_char()
Context	read_Context()
void	read_double_array(double[] value, int offset, int length)
void	read_double_array(DoubleSeqHolder seq, int offset, int length)
double	read_double()
BigDecimal	read_fixed()
BigDecimal	read_fixed(short digits, short scale)
void	read_float_array(float[] value, int offset, int length)
void	read_float_array(FloatSeqHolder seq, int offset, int length)
float	read_float()
void	read_long_array(int[] value, int offset, int length)
void	read_long_array(LongSeqHolder seq, int offset, int length)
int	read_long()
double	read_longdouble()
void	read_longlong_array(long[] value, int offset, int length)
void	read_longlong_array(LongLongSeqHolder seq, int offset, int length)
long	read_longlong()
Object	read_Object()
Object	read_Object(Class clz)
void	read_octet_array(byte[] value, int offset, int length)
void	read_octet_array(OctetSeqHolder seq, int offset, int length)
byte	read_octet()
Principal	read_Principal()
void	read_short_array(short[] value, int offset, int length)
void	read_short_array(ShortSeqHolder seq, int offset, int length)
short	read_short()
String	read_string()
TypeCode	read_TypeCode()
void	read_ulong_array(int[] value, int offset, int length)
void	read_ulong_array(ULongSeqHolder seq, int offset, int length)
int	read_ulong()
void	read_ulonglong_array(long[] value, int offset, int length)
void	read_ulonglong_array(ULongLongSeqHolder seq, int offset, int length)
long	read_ulonglong()
void	read_ushort_array(short[] value, int offset, int length)
void	read_ushort_array(UShortSeqHolder seq, int offset, int length)
short	read_ushort()
Serializable	read_value()
Serializable	read_Value()
Serializable	read_value(BoxedValueHelper factory)
Serializable	read_value(Class clz)
Serializable	read_value(Serializable value)
Serializable	read_value(String rep_id)
void	read_wchar_array(char[] value, int offset, int length)
void	read_wchar_array(WCharSeqHolder seq, int offset, int length)
char	read_wchar()
String	read_wstring()
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
void	reset()
void	resetCodeSetConverters() Resets any internal references to code set converters.
protected void	setBufferLength(int value)
protected void	setByteBuffer(ByteBuffer byteBuffer)
protected void	setByteBufferWithInfo(ByteBufferWithInfo bbwi)
void	setHeaderPadding(boolean headerPadding)
protected void	setIndex(int value)
void	setMessageMediator(MessageMediator messageMediator)
long	skip(long n)
void	start_value()

Methods inherited from class java.lang.Object

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

Field Detail

messageMediator

protected CorbaMessageMediator messageMediator

Constructor Detail

CDRInputStream

public CDRInputStream()

CDRInputStream

public CDRInputStream(CDRInputStream is)

CDRInputStream

public CDRInputStream(ORB orb,
                      ByteBuffer byteBuffer,
                      int size,
                      boolean littleEndian,
                      GIOPVersion version,
                      byte encodingVersion,
                      BufferManagerRead bufMgr)

Method Detail

read_boolean

public final boolean read_boolean()

Specified by:

read_boolean in interface MarshalInputStream

Specified by:

read_boolean in interface DataInputStream

Specified by:

read_boolean in class InputStream

read_char

public final char read_char()

Specified by:

read_char in interface MarshalInputStream

Specified by:

read_char in interface DataInputStream

Specified by:

read_char in class InputStream

read_wchar

public final char read_wchar()

Specified by:

read_wchar in interface MarshalInputStream

Specified by:

read_wchar in interface DataInputStream

Specified by:

read_wchar in class InputStream

read_octet

public final byte read_octet()

Specified by:

read_octet in interface MarshalInputStream

Specified by:

read_octet in interface DataInputStream

Specified by:

read_octet in class InputStream

read_short

public final short read_short()

Specified by:

read_short in interface MarshalInputStream

Specified by:

read_short in interface DataInputStream

Specified by:

read_short in class InputStream

read_ushort

public final short read_ushort()

Specified by:

read_ushort in interface MarshalInputStream

Specified by:

read_ushort in interface DataInputStream

Specified by:

read_ushort in class InputStream

read_long

public final int read_long()

Specified by:

read_long in interface MarshalInputStream

Specified by:

read_long in interface DataInputStream

Specified by:

read_long in class InputStream

read_ulong

public final int read_ulong()

Specified by:

read_ulong in interface MarshalInputStream

Specified by:

read_ulong in interface DataInputStream

Specified by:

read_ulong in class InputStream

read_longdouble

public double read_longdouble()

read_longlong

public final long read_longlong()

Specified by:

read_longlong in interface MarshalInputStream

Specified by:

read_longlong in interface DataInputStream

Specified by:

read_longlong in class InputStream

read_ulonglong

public final long read_ulonglong()

Specified by:

read_ulonglong in interface MarshalInputStream

Specified by:

read_ulonglong in interface DataInputStream

Specified by:

read_ulonglong in class InputStream

read_float

public final float read_float()

Specified by:

read_float in interface MarshalInputStream

Specified by:

read_float in interface DataInputStream

Specified by:

read_float in class InputStream

read_double

public final double read_double()

Specified by:

read_double in interface MarshalInputStream

Specified by:

read_double in interface DataInputStream

Specified by:

read_double in class InputStream

read_string

public final String read_string()

Specified by:

read_string in interface MarshalInputStream

Specified by:

read_string in interface DataInputStream

Specified by:

read_string in class InputStream

read_wstring

public final String read_wstring()

Specified by:

read_wstring in interface MarshalInputStream

Specified by:

read_wstring in interface DataInputStream

Specified by:

read_wstring in class InputStream

read_boolean_array

public final void read_boolean_array(boolean[] value,
                                     int offset,
                                     int length)

Specified by:

read_boolean_array in interface MarshalInputStream

Specified by:

read_boolean_array in class InputStream

read_char_array

public final void read_char_array(char[] value,
                                  int offset,
                                  int length)

Specified by:

read_char_array in interface MarshalInputStream

Specified by:

read_char_array in class InputStream

read_wchar_array

public final void read_wchar_array(char[] value,
                                   int offset,
                                   int length)

Specified by:

read_wchar_array in interface MarshalInputStream

Specified by:

read_wchar_array in class InputStream

read_octet_array

public final void read_octet_array(byte[] value,
                                   int offset,
                                   int length)

Specified by:

read_octet_array in interface MarshalInputStream

Specified by:

read_octet_array in class InputStream

read_short_array

public final void read_short_array(short[] value,
                                   int offset,
                                   int length)

Specified by:

read_short_array in interface MarshalInputStream

Specified by:

read_short_array in class InputStream

read_ushort_array

public final void read_ushort_array(short[] value,
                                    int offset,
                                    int length)

Specified by:

read_ushort_array in interface MarshalInputStream

Specified by:

read_ushort_array in class InputStream

read_long_array

public final void read_long_array(int[] value,
                                  int offset,
                                  int length)

Specified by:

read_long_array in interface MarshalInputStream

Specified by:

read_long_array in class InputStream

read_ulong_array

public final void read_ulong_array(int[] value,
                                   int offset,
                                   int length)

Specified by:

read_ulong_array in interface MarshalInputStream

Specified by:

read_ulong_array in class InputStream

read_longlong_array

public final void read_longlong_array(long[] value,
                                      int offset,
                                      int length)

Specified by:

read_longlong_array in interface MarshalInputStream

Specified by:

read_longlong_array in class InputStream

read_ulonglong_array

public final void read_ulonglong_array(long[] value,
                                       int offset,
                                       int length)

Specified by:

read_ulonglong_array in interface MarshalInputStream

Specified by:

read_ulonglong_array in class InputStream

read_float_array

public final void read_float_array(float[] value,
                                   int offset,
                                   int length)

Specified by:

read_float_array in interface MarshalInputStream

Specified by:

read_float_array in class InputStream

read_double_array

public final void read_double_array(double[] value,
                                    int offset,
                                    int length)

Specified by:

read_double_array in interface MarshalInputStream

Specified by:

read_double_array in class InputStream

read_Object

public final Object read_Object()

Specified by:

read_Object in interface MarshalInputStream

Specified by:

read_Object in interface DataInputStream

Specified by:

read_Object in class InputStream

read_TypeCode

public final TypeCode read_TypeCode()

Specified by:

read_TypeCode in interface MarshalInputStream

Specified by:

read_TypeCode in interface DataInputStream

Specified by:

read_TypeCode in class InputStream

read_any

public final Any read_any()

Specified by:

read_any in interface MarshalInputStream

Specified by:

read_any in interface DataInputStream

Specified by:

read_any in class InputStream

read_Principal

public final Principal read_Principal()

Specified by:

read_Principal in interface MarshalInputStream

Overrides:

read_Principal in class InputStream

read

public final int read()
               throws IOException

Overrides:

read in class InputStream

Throws:

IOException

read_fixed

public final BigDecimal read_fixed()

Overrides:

read_fixed in class InputStream

read_Context

public final Context read_Context()

Overrides:

read_Context in class InputStream

read_Object

public final Object read_Object(Class clz)

Specified by:

read_Object in interface MarshalInputStream

Overrides:

read_Object in class InputStream

orb

public final ORB orb()

Overrides:

orb in class InputStream

read_value

public final Serializable read_value()

Specified by:

read_value in interface MarshalInputStream

Overrides:

read_value in class InputStream

read_value

public final Serializable read_value(Class clz)

Overrides:

read_value in class InputStream

read_value

public final Serializable read_value(BoxedValueHelper factory)

Overrides:

read_value in class InputStream

read_value

public final Serializable read_value(String rep_id)

Overrides:

read_value in class InputStream

read_value

public final Serializable read_value(Serializable value)

Overrides:

read_value in class InputStream

read_abstract_interface

public final Object read_abstract_interface()

Overrides:

read_abstract_interface in class InputStream

read_abstract_interface

public final Object read_abstract_interface(Class clz)

Overrides:

read_abstract_interface in class InputStream

consumeEndian

public final void consumeEndian()

Specified by:

consumeEndian in interface MarshalInputStream

getPosition

public final int getPosition()

Specified by:

getPosition in interface MarshalInputStream

read_Abstract

public final Object read_Abstract()

Specified by:

read_Abstract in interface DataInputStream

read_Value

public final Serializable read_Value()

Specified by:

read_Value in interface DataInputStream

read_any_array

public final void read_any_array(AnySeqHolder seq,
                                 int offset,
                                 int length)

Specified by:

read_any_array in interface DataInputStream

read_boolean_array

public final void read_boolean_array(BooleanSeqHolder seq,
                                     int offset,
                                     int length)

Specified by:

read_boolean_array in interface DataInputStream

read_char_array

public final void read_char_array(CharSeqHolder seq,
                                  int offset,
                                  int length)

Specified by:

read_char_array in interface DataInputStream

read_wchar_array

public final void read_wchar_array(WCharSeqHolder seq,
                                   int offset,
                                   int length)

Specified by:

read_wchar_array in interface DataInputStream

read_octet_array

public final void read_octet_array(OctetSeqHolder seq,
                                   int offset,
                                   int length)

Specified by:

read_octet_array in interface DataInputStream

read_short_array

public final void read_short_array(ShortSeqHolder seq,
                                   int offset,
                                   int length)

Specified by:

read_short_array in interface DataInputStream

read_ushort_array

public final void read_ushort_array(UShortSeqHolder seq,
                                    int offset,
                                    int length)

Specified by:

read_ushort_array in interface DataInputStream

read_long_array

public final void read_long_array(LongSeqHolder seq,
                                  int offset,
                                  int length)

Specified by:

read_long_array in interface DataInputStream

read_ulong_array

public final void read_ulong_array(ULongSeqHolder seq,
                                   int offset,
                                   int length)

Specified by:

read_ulong_array in interface DataInputStream

read_ulonglong_array

public final void read_ulonglong_array(ULongLongSeqHolder seq,
                                       int offset,
                                       int length)

Specified by:

read_ulonglong_array in interface DataInputStream

read_longlong_array

public final void read_longlong_array(LongLongSeqHolder seq,
                                      int offset,
                                      int length)

Specified by:

read_longlong_array in interface DataInputStream

read_float_array

public final void read_float_array(FloatSeqHolder seq,
                                   int offset,
                                   int length)

Specified by:

read_float_array in interface DataInputStream

read_double_array

public final void read_double_array(DoubleSeqHolder seq,
                                    int offset,
                                    int length)

Specified by:

read_double_array in interface DataInputStream

_truncatable_ids

public final String[] _truncatable_ids()

Specified by:

_truncatable_ids in interface ValueBase

read

public final int read(byte[] b)
               throws IOException

Overrides:

read in class InputStream

Throws:

IOException

read

public final int read(byte[] b,
                      int off,
                      int len)
               throws IOException

Overrides:

read in class InputStream

Throws:

IOException

skip

public final long skip(long n)
                throws IOException

Overrides:

skip in class InputStream

Throws:

IOException

available

public final int available()
                    throws IOException

Overrides:

available in class InputStream

Throws:

IOException

close

public final void close()
                 throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class InputStream

Throws:

IOException

mark

public final void mark(int readlimit)

Specified by:

mark in interface MarshalInputStream

Overrides:

mark in class InputStream

reset

public final void reset()

Specified by:

reset in interface MarshalInputStream

Overrides:

reset in class InputStream

markSupported

public final boolean markSupported()

Overrides:

markSupported in class InputStream

dup

public abstract CDRInputStream dup()

read_fixed

public final BigDecimal read_fixed(short digits,
                                   short scale)

isLittleEndian

public final boolean isLittleEndian()

getByteBuffer

protected final ByteBuffer getByteBuffer()

setByteBuffer

protected final void setByteBuffer(ByteBuffer byteBuffer)

setByteBufferWithInfo

protected final void setByteBufferWithInfo(ByteBufferWithInfo bbwi)

getBufferLength

public final int getBufferLength()

setBufferLength

protected final void setBufferLength(int value)

getIndex

protected final int getIndex()

setIndex

protected final void setIndex(int value)

orb

public final void orb(ORB orb)

getGIOPVersion

public final GIOPVersion getGIOPVersion()

getBufferManager

public final BufferManagerRead getBufferManager()

getCodeBase

public CodeBase getCodeBase()

createCharBTCConverter

protected CodeSetConversion.BTCConverter createCharBTCConverter()

createWCharBTCConverter

protected abstract CodeSetConversion.BTCConverter createWCharBTCConverter()

alignOnBoundary

public void alignOnBoundary(int octetBoundary)

Aligns the current position on the given octet boundary if there are enough bytes available to do so. Otherwise, it just returns. This is used for some (but not all) GIOP 1.2 message headers.

setHeaderPadding

public void setHeaderPadding(boolean headerPadding)

performORBVersionSpecificInit

public void performORBVersionSpecificInit()

This must be called after determining the proper ORB version, and setting it on the stream's ORB instance. It can be called after reading the service contexts, since that is the only place we can get the ORB version info. Trying to unmarshal things requiring repository IDs before calling this will result in NullPtrExceptions.

Specified by:

performORBVersionSpecificInit in interface MarshalInputStream

resetCodeSetConverters

public void resetCodeSetConverters()

Resets any internal references to code set converters. This is useful for forcing the CDR stream to reacquire converters (probably from its subclasses) when state has changed.

Specified by:

resetCodeSetConverters in interface MarshalInputStream

setMessageMediator

public void setMessageMediator(MessageMediator messageMediator)

getMessageMediator

public MessageMediator getMessageMediator()

start_value

public void start_value()

Specified by:

start_value in interface ValueInputStream

end_value

public void end_value()

Specified by:

end_value in interface ValueInputStream