org.jacorb.orb

Class CDRInputStream

public class CDRInputStream extends InputStream

Read CDR encoded data

Author: Gerald Brose, FU Berlin $Id: CDRInputStream.java,v 1.115 2007/04/27 19:14:06 francisco Exp $

Field Summary
protected byte[]	buffer indices into the actual buffer
protected int	giop_minor
protected int	index
boolean	littleEndian
protected int	pos

Constructor Summary
	CDRInputStream(ORB orb, byte[] buf)
	CDRInputStream(ORB orb, byte[] buf, boolean littleEndian)
	CDRInputStream(byte[] buffer, boolean littleEndian)

Method Summary
int	available()
void	close()
void	closeEncapsulation() close a CDR encapsulation and restore index and byte order information
byte[]	getBufferCopy()
int	getGIOPMinor()
int	get_pos()
void	mark(int readLimit)
boolean	markSupported()
void	openEncapsulatedArray()
int	openEncapsulation() open a CDR encapsulation and restore index and byte order information
ORB	orb()
int	read() Reads the next byte of data from the input stream.
int	read(byte[] b) Has the effect of read(b, 0, b.length);
int	read(byte[] b, int off, int len) Performs as described by `java.io.InputStream.read(byte[], int, int)`, but never blocks.
Object	read_abstract_interface() Reads an abstract interface from this stream.
Object	read_abstract_interface(Class clazz) Reads an abstract interface from this stream.
Any	read_any()
boolean	read_boolean()
void	read_boolean_array(boolean[] value, int offset, int length) arrays
char	read_char() `read_char` reads a character from the stream.
void	read_char_array(char[] value, int offset, int length) `read_char_array` reads an character array from the stream.
double	read_double()
void	read_double_array(double[] value, int offset, int length)
BigDecimal	read_fixed()
BigDecimal	read_fixed(short digits, short scale)
float	read_float()
void	read_float_array(float[] value, int offset, int length)
int	read_long()
long	read_longlong()
void	read_longlong_array(long[] value, int offset, int length)
void	read_long_array(int[] value, int offset, int length)
byte	read_octet()
void	read_octet_array(byte[] value, int offset, int length)
Object	read_Object()
Object	read_Object(Class clazz)
Principal	read_Principal()
short	read_short() Read methods for big-endian as well as little endian data input contributed by Mark Allerton
void	read_short_array(short[] value, int offset, int length)
String	read_string() `read_string` reads a string from the buffer.
TypeCode	read_TypeCode()
int	read_ulong()
long	read_ulonglong()
void	read_ulonglong_array(long[] value, int offset, int length)
void	read_ulong_array(int[] value, int offset, int length)
short	read_ushort()
void	read_ushort_array(short[] value, int offset, int length)
Serializable	read_value()
Serializable	read_value(String rep_id) Overrides read_value(java.io.Serializable value) in org.omg.CORBA_2_3.portable.InputStream
Serializable	read_value(Serializable value) Unmarshals a valuetype instance from this stream.
Serializable	read_value(Class clz) Overrides read_value(clz) in org.omg.CORBA_2_3.portable.InputStream
Serializable	read_value(BoxedValueHelper factory) Overrides read_value(factory) in org.omg.CORBA_2_3.portable.InputStream
char	read_wchar()
void	read_wchar_array(char[] value, int offset, int length)
String	read_wstring()
void	register_value(Serializable value) Stores `value' into this stream's valueMap.
void	reset()
void	setCodeSet(int codeSet, int codeSetWide)
void	setGIOPMinor(int giop_minor)
void	setLittleEndian(boolean b)
protected void	skip(int distance)
void	updateMutatorConnection(GIOPConnection connection) `updateMutatorConnection` is an accessor that updates the ior mutator.

Field Detail

buffer

protected byte[] buffer

indices into the actual buffer

Constructor Detail

CDRInputStream

public CDRInputStream(ORB orb, byte[] buf)

CDRInputStream

public CDRInputStream(ORB orb, byte[] buf, boolean littleEndian)

CDRInputStream

public CDRInputStream(byte[] buffer, boolean littleEndian)

Method Detail

available

public int available()

Returns: the number of bytes that can be read (or skipped over) from this input stream. This is not necessarily the number of 'valid' bytes.

closeEncapsulation

public final void closeEncapsulation()

close a CDR encapsulation and restore index and byte order information

openEncapsulatedArray

public final void openEncapsulatedArray()

openEncapsulation

public final int openEncapsulation()

open a CDR encapsulation and restore index and byte order information

Reads the next byte of data from the input stream. The value byte is returned as an int in the range 0 to 255. If no byte is available because the end of the stream has been reached, the value -1 is returned.

Returns: the next byte of data, or -1 if the end of the stream is reached.

Throws: java.io.IOException if stream is closed.

read

public int read(byte[] b)

Has the effect of read(b, 0, b.length);

read

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

Performs as described by java.io.InputStream.read(byte[], int, int), but never blocks.

read_abstract_interface

public Object read_abstract_interface()

Reads an abstract interface from this stream. The abstract interface Reads an abstract interface from this stream. The abstract interface appears as a union with a boolean discriminator, which is true if the union contains a CORBA object reference, or false if the union contains a value.

read_abstract_interface

public Object read_abstract_interface(Class clazz)

Reads an abstract interface from this stream. The abstract interface appears as a union with a boolean discriminator, which is true if the union contains a CORBA object reference, or false if the union contains a value.

read_any

public final Any read_any()

read_boolean

public final boolean read_boolean()

read_boolean_array

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

arrays

read_char

public final char read_char()

read_char reads a character from the stream.

Returns: a char value

read_char_array

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

read_char_array reads an character array from the stream.

Parameters: value a char[], the result array. offset an int, an offset into value length an int, the length of the array to read

read_double

public final double read_double()

read_double_array

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

read_fixed

public final BigDecimal read_fixed()

read_fixed

public final BigDecimal read_fixed(short digits, short scale)

read_float

public final float read_float()

read_float_array

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

read_long

public final int read_long()

read_longlong

public final long read_longlong()

read_longlong_array

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

read_long_array

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

read_octet

public final byte read_octet()

read_octet_array

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

read_Object

public final Object read_Object()

read_Object

public Object read_Object(Class clazz)

read_Principal

public final Principal read_Principal()

read_short

public final short read_short()

Read methods for big-endian as well as little endian data input contributed by Mark Allerton

read_short_array

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

read_string

public final String read_string()

read_string reads a string from the buffer. It is optimized for whether it is reading a blank string, and whether codeset translation is active.

Returns: a String value, possibly blank, never null.

read_TypeCode

public final TypeCode read_TypeCode()

read_ulong

public final int read_ulong()

read_ulonglong

public final long read_ulonglong()

read_ulonglong_array

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

read_ulong_array

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

read_ushort

public final short read_ushort()

read_ushort_array

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

read_value

public Serializable read_value()

read_value

public Serializable read_value(String rep_id)

Overrides read_value(java.io.Serializable value) in org.omg.CORBA_2_3.portable.InputStream

read_value

public Serializable read_value(Serializable value)

Unmarshals a valuetype instance from this stream. The value returned is the same value passed in, with all the data unmarshaled (IDL-to-Java Mapping 1.2, August 2002, 1.13.1, p. 1-39). The specified value is an uninitialized value that is added to the ORB's indirection table before unmarshaling (1.21.4.1, p. 1-117). This method is intended to be called from custom valuetype factories. Unlike the other read_value() methods in this class, this method does not expect a GIOP value tag nor a repository id in the stream. Overrides read_value(value) in org.omg.CORBA_2_3.portable.InputStream

read_value

public Serializable read_value(Class clz)

Overrides read_value(clz) in org.omg.CORBA_2_3.portable.InputStream

read_value

public Serializable read_value(BoxedValueHelper factory)

Overrides read_value(factory) in org.omg.CORBA_2_3.portable.InputStream

read_wchar

public final char read_wchar()

read_wchar_array

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

read_wstring

public final String read_wstring()

register_value

public void register_value(Serializable value)

Stores `value' into this stream's valueMap. This is provided as a callback for value factories, so that a value factory can store an object into the map before actually reading its state. This is essential for unmarshalling recursive values.

reset

public void reset()

setCodeSet

public void setCodeSet(int codeSet, int codeSetWide)

setGIOPMinor

public void setGIOPMinor(int giop_minor)

setLittleEndian

public final void setLittleEndian(boolean b)

skip

protected final void skip(int distance)

updateMutatorConnection

public void updateMutatorConnection(GIOPConnection connection)

updateMutatorConnection is an accessor that updates the ior mutator. By making callers pass in a GIOPConnection not a transport this allows callers to not have to call getTransport which would require a synchronized lock. Therefore if the mutator has not been enabled this is effectively a NOP.

Parameters: connection an org.omg.ETF.Connection value