Class CDRInputStream_1_0

java.lang.Object

java.io.InputStream

com.sun.corba.ee.impl.encoding.CDRInputStreamBase

com.sun.corba.ee.impl.encoding.CDRInputStream_1_0

All Implemented Interfaces:

RestorableInputStream, Closeable, AutoCloseable

Direct Known Subclasses:

CDRInputStream_1_1

public class CDRInputStream_1_0
extends CDRInputStreamBase
implements RestorableInputStream

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	CDRInputStream_1_0.StreamMemento

Field Summary

Fields

Modifier and Type	Field	Description
private static final String	_id
private static final String[]	_ids
protected int	blockLength
protected BufferManagerRead	bufferManagerRead
protected ByteBuffer	byteBuffer
private CodeSetConversion.BTCConverter	charConverter
private int	chunkedValueNestingLevel
private CacheTable<String>	codebaseCache
protected int	end_flag
protected boolean	isChunked
private static final String	K_READ_METHOD
protected MarkAndResetHandler	markAndResetHandler
private static final int	MAX_BLOCK_LENGTH
private static final OMGSystemException	omgWrapper
protected ORB	orb
private RepositoryIdStrings	repIdStrs
private RepositoryIdUtility	repIdUtil
private CacheTable<String>	repositoryIdCache
private boolean	specialNoOptionalDataState
protected int	stringIndirection
private CacheTable<Object>	valueCache
protected ValueHandler	valueHandler
protected int	valueIndirection
private CodeSetConversion.BTCConverter	wcharConverter
protected static final ORBUtilSystemException	wrapper

Fields inherited from class CDRInputStreamBase

parent

Constructor Summary

Constructors

Constructor	Description
CDRInputStream_1_0()

Method Summary

Modifier and Type	Method	Description
String[]	_truncatable_ids()
protected void	alignAndCheck(int align, int n)
(package private) void	alignOnBoundary(int octetBoundary)	Aligns the current position on the given octet boundary if there are enough bytes available to do so.
protected void	checkBlockLength(int align, int dataSize)
protected final void	checkForNegativeLength(int length)
private void	chunkedNestingLevel(int nl)
private void	className(String name)
void	close()
protected final int	computeAlignment(int index, int align)
final void	consumeEndian()
private void	createRepositoryIdHandlers()
Object	createStreamMemento()
CDRInputStreamBase	dup()
private void	end_block()
void	end_value()
private void	endFlag(int value)
private void	endTag(int endTag)
protected int	get_offset()
int	getBufferLength()
BufferManagerRead	getBufferManager()
ByteOrder	getByteOrder()
protected CodeSetConversion.BTCConverter	getCharConverter()
private Class<?>	getClassFromString(String repositoryIDString, String codebaseURL, Class<?> expectedType)	Attempts to find the class described by the given repository ID string and expected type.
(package private) CodeBase	getCodeBase()
(package private) char[]	getConvertedChars(int numBytes, CodeSetConversion.BTCConverter converter)
GIOPVersion	getGIOPVersion()
private List<String>	getInterfacesList(String[] interfaces)
int	getPosition()
protected CodeSetConversion.BTCConverter	getWCharConverter()
protected void	grow(int align, int n)
private void	handleEndOfValue()
private Serializable	handleIndirection()
private void	indirectionValue(int indir)
(package private) void	init(ORB orb, ByteBuffer byteBuffer, int bufferSize, ByteOrder byteOrder, BufferManagerRead bufferManager)
static Object	internalIORToObject(IOR ior, PresentationManager.StubFactory stubFactory, ORB orb)
private String	internalReadString(int len)
private boolean	isCustomType(ValueHelper helper)
void	mark(int readlimit)
(package private) final String	newEmptyString()
private void	noProxyInterfaces()
private void	notChunked()
private void	nullIOR()
ORB	orb()
void	orb(ORB orb)
private void	peekNextLong(long val)
(package private) void	performORBVersionSpecificInit()
Object	read_Abstract()
Object	read_abstract_interface()
Object	read_abstract_interface(Class clz)
Any	read_any()
final void	read_any_array(Any[] value, int offset, int length)
void	read_any_array(AnySeqHolder seq, int offset, int length)
final boolean	read_boolean()
final void	read_boolean_array(boolean[] value, int offset, int length)
void	read_boolean_array(BooleanSeqHolder seq, int offset, int length)
final char	read_char()
final void	read_char_array(char[] value, int offset, int length)
void	read_char_array(CharSeqHolder seq, int offset, int length)
private String	read_codebase_URL()
final double	read_double()
final void	read_double_array(double[] value, int offset, int length)
void	read_double_array(DoubleSeqHolder seq, int offset, int length)
BigDecimal	read_fixed()
BigDecimal	read_fixed(short digits, short scale)
private StringBuffer	read_fixed_buffer()
final float	read_float()
final void	read_float_array(float[] value, int offset, int length)
void	read_float_array(FloatSeqHolder seq, int offset, int length)
final int	read_long()
final void	read_long_array(int[] value, int offset, int length)
void	read_long_array(LongSeqHolder seq, int offset, int length)
final long	read_longlong()
final void	read_longlong_array(long[] value, int offset, int length)
void	read_longlong_array(LongLongSeqHolder seq, int offset, int length)
Object	read_Object()
Object	read_Object(Class clz)
final byte	read_octet()
final void	read_octet_array(byte[] buffer, int offset, int length)
void	read_octet_array(OctetSeqHolder seq, int offset, int length)
Principal	read_Principal()
private String	read_repositoryId()
private String	read_repositoryIds()
final short	read_short()
final void	read_short_array(short[] value, int offset, int length)
void	read_short_array(ShortSeqHolder seq, int offset, int length)
final String	read_string()
TypeCode	read_TypeCode()
final int	read_ulong()
final void	read_ulong_array(int[] value, int offset, int length)
void	read_ulong_array(ULongSeqHolder seq, int offset, int length)
final long	read_ulonglong()
final void	read_ulonglong_array(long[] value, int offset, int length)
void	read_ulonglong_array(ULongLongSeqHolder seq, int offset, int length)
final short	read_ushort()
final void	read_ushort_array(short[] value, int offset, int length)
void	read_ushort_array(UShortSeqHolder seq, int offset, int length)
Serializable	read_value()
Serializable	read_value(Serializable value)
Serializable	read_value(Class expectedType)
Serializable	read_value(String repositoryId)
Serializable	read_value(BoxedValueHelper factory)
Serializable	read_Value()
char	read_wchar()
final void	read_wchar_array(char[] value, int offset, int length)
void	read_wchar_array(WCharSeqHolder seq, int offset, int length)
String	read_wstring()
private Object	readBoxedIDLEntity(Class<?> clazz, String codebase)
private Class<?>	readClass()
private void	readClassCodebases(String codebases, String repoId)
private void	readEndTag()	End tags are only written for chunked valuetypes.
private Object	readIDLValue(int indirection, String repId, Class<?> clazz, ClassInfoCache.ClassInfo cinfo, String codebase)
private Object	readIDLValueWithHelper(ValueHelper helper, int indirection)
private String	readRepositoryIds(int valueTag, Class<?> expectedType, ClassInfoCache.ClassInfo cinfo, String expectedTypeRepId)
private String	readRepositoryIds(int valueTag, Class<?> expectedType, ClassInfoCache.ClassInfo cinfo, String expectedTypeRepId, BoxedValueHelper factory)	Examines the valuetag to see how many (if any) repository IDs are present on the wire.
private Object	readRMIIIOPValueType(int indirection, Class<?> valueClass, String repositoryIDString)
protected final String	readStringOrIndirection(boolean allowIndirection)
private int	readValueTag()
private void	repositoryIdString(String str)
void	reset()
void	resetCodeSetConverters()
void	restoreInternalState(Object streamMemento)
void	setBufferLength(int value)
(package private) void	setHeaderPadding(boolean headerPadding)
void	setIndex(int value)
private void	skipToOffset(int offset)
private void	start_block()
void	start_value()
private void	stubFactory(PresentationManager.StubFactory fact)
private void	unreadLastLong()
private void	valueClass(Class cls)
private void	valueTag(int value)

Methods inherited from class CDRInputStreamBase

markSupported, read, read_Context, setParent

Methods inherited from class InputStream

available, read, read, skip

Methods inherited from class Object

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

Field Details

wrapper

protected static final ORBUtilSystemException wrapper

omgWrapper

private static final OMGSystemException omgWrapper

K_READ_METHOD

private static final String K_READ_METHOD

See Also:

• Constant Field Values

MAX_BLOCK_LENGTH

private static final int MAX_BLOCK_LENGTH

See Also:

• Constant Field Values

bufferManagerRead

protected BufferManagerRead bufferManagerRead

byteBuffer

protected ByteBuffer byteBuffer

orb

protected ORB orb

valueHandler

protected ValueHandler valueHandler

valueCache

private CacheTable<Object> valueCache

repositoryIdCache

private CacheTable<String> repositoryIdCache

codebaseCache

private CacheTable<String> codebaseCache

blockLength

protected int blockLength

end_flag

protected int end_flag

chunkedValueNestingLevel

private int chunkedValueNestingLevel

valueIndirection

protected int valueIndirection

stringIndirection

protected int stringIndirection

isChunked

protected boolean isChunked

repIdUtil

private RepositoryIdUtility repIdUtil

repIdStrs

private RepositoryIdStrings repIdStrs

charConverter

private CodeSetConversion.BTCConverter charConverter

wcharConverter

private CodeSetConversion.BTCConverter wcharConverter

specialNoOptionalDataState

private boolean specialNoOptionalDataState

_id

private static final String _id

See Also:

• Constant Field Values

_ids

private static final String[] _ids

markAndResetHandler

protected MarkAndResetHandler markAndResetHandler

Constructor Details

CDRInputStream_1_0

public CDRInputStream_1_0()

Method Details

newEmptyString

final String newEmptyString()

dup

public CDRInputStreamBase dup()

Specified by:

dup in class CDRInputStreamBase

init

void init(ORB orb,
 ByteBuffer byteBuffer,
 int bufferSize,
 ByteOrder byteOrder,
 BufferManagerRead bufferManager)

Specified by:

init in class CDRInputStreamBase

performORBVersionSpecificInit

void performORBVersionSpecificInit()

Specified by:

performORBVersionSpecificInit in class CDRInputStreamBase

createRepositoryIdHandlers

private void createRepositoryIdHandlers()

getGIOPVersion

public GIOPVersion getGIOPVersion()

Specified by:

getGIOPVersion in class CDRInputStreamBase

setHeaderPadding

void setHeaderPadding(boolean headerPadding)

Specified by:

setHeaderPadding in class CDRInputStreamBase

computeAlignment

protected final int computeAlignment(int index,
 int align)

notChunked

@InfoMethod
private void notChunked()

checkBlockLength

protected void checkBlockLength(int align,
 int dataSize)

alignAndCheck

protected void alignAndCheck(int align,
 int n)

grow

protected void grow(int align,
 int n)

consumeEndian

public final void consumeEndian()

Specified by:

consumeEndian in class CDRInputStreamBase

read_boolean

public final boolean read_boolean()

Specified by:

read_boolean in class CDRInputStreamBase

read_char

public final char read_char()

Specified by:

read_char in class CDRInputStreamBase

read_wchar

public char read_wchar()

Specified by:

read_wchar in class CDRInputStreamBase

read_octet

public final byte read_octet()

Specified by:

read_octet in class CDRInputStreamBase

read_short

public final short read_short()

Specified by:

read_short in class CDRInputStreamBase

read_ushort

public final short read_ushort()

Specified by:

read_ushort in class CDRInputStreamBase

read_long

public final int read_long()

Specified by:

read_long in class CDRInputStreamBase

read_ulong

public final int read_ulong()

Specified by:

read_ulong in class CDRInputStreamBase

read_longlong

public final long read_longlong()

Specified by:

read_longlong in class CDRInputStreamBase

read_ulonglong

public final long read_ulonglong()

Specified by:

read_ulonglong in class CDRInputStreamBase

read_float

public final float read_float()

Specified by:

read_float in class CDRInputStreamBase

read_double

public final double read_double()

Specified by:

read_double in class CDRInputStreamBase

checkForNegativeLength

protected final void checkForNegativeLength(int length)

readStringOrIndirection

protected final String readStringOrIndirection(boolean allowIndirection)

internalReadString

private String internalReadString(int len)

read_string

public final String read_string()

Specified by:

read_string in class CDRInputStreamBase

read_wstring

public String read_wstring()

Specified by:

read_wstring in class CDRInputStreamBase

read_octet_array

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

Specified by:

read_octet_array in class CDRInputStreamBase

read_Principal

public Principal read_Principal()

Specified by:

read_Principal in class CDRInputStreamBase

read_TypeCode

public TypeCode read_TypeCode()

Specified by:

read_TypeCode in class CDRInputStreamBase

read_any

public Any read_any()

Specified by:

read_any in class CDRInputStreamBase

read_Object

public Object read_Object()

Specified by:

read_Object in class CDRInputStreamBase

nullIOR

@InfoMethod
private void nullIOR()

className

@InfoMethod
private void className(String name)

stubFactory

@InfoMethod
private void stubFactory(PresentationManager.StubFactory fact)

read_Object

public Object read_Object(Class clz)

Specified by:

read_Object in class CDRInputStreamBase

internalIORToObject

public static Object internalIORToObject(IOR ior,
 PresentationManager.StubFactory stubFactory,
 ORB orb)

read_abstract_interface

public Object read_abstract_interface()

Specified by:

read_abstract_interface in class CDRInputStreamBase

read_abstract_interface

public Object read_abstract_interface(Class clz)

Specified by:

read_abstract_interface in class CDRInputStreamBase

read_value

public Serializable read_value()

Specified by:

read_value in class CDRInputStreamBase

indirectionValue

@InfoMethod
private void indirectionValue(int indir)

handleIndirection

private Serializable handleIndirection()

readRepositoryIds

private String readRepositoryIds(int valueTag,
 Class<?> expectedType,
 ClassInfoCache.ClassInfo cinfo,
 String expectedTypeRepId)

readRepositoryIds

private String readRepositoryIds(int valueTag,
 Class<?> expectedType,
 ClassInfoCache.ClassInfo cinfo,
 String expectedTypeRepId,
 BoxedValueHelper factory)

Examines the valuetag to see how many (if any) repository IDs are present on the wire. If no repository ID information is on the wire but the expectedType or expectedTypeRepId is known, it will return one of those (favoring the expectedType's repId). Failing that, it uses the supplied BoxedValueHelper to obtain the repository ID, as a last resort.

readRMIIIOPValueType

private Object readRMIIIOPValueType(int indirection,
 Class<?> valueClass,
 String repositoryIDString)

repositoryIdString

@InfoMethod
private void repositoryIdString(String str)

valueClass

@InfoMethod
private void valueClass(Class cls)

noProxyInterfaces

@InfoMethod
private void noProxyInterfaces()

read_value

public Serializable read_value(Class expectedType)

Specified by:

read_value in class CDRInputStreamBase

getInterfacesList

private List<String> getInterfacesList(String[] interfaces)

read_value

public Serializable read_value(BoxedValueHelper factory)

Specified by:

read_value in class CDRInputStreamBase

isCustomType

private boolean isCustomType(ValueHelper helper)

read_value

public Serializable read_value(Serializable value)

Specified by:

read_value in class CDRInputStreamBase

read_value

public Serializable read_value(String repositoryId)

Specified by:

read_value in class CDRInputStreamBase

readClassCodebases

@InfoMethod
private void readClassCodebases(String codebases,
 String repoId)

readClass

private Class<?> readClass()

readIDLValueWithHelper

private Object readIDLValueWithHelper(ValueHelper helper,
 int indirection)

readBoxedIDLEntity

private Object readBoxedIDLEntity(Class<?> clazz,
 String codebase)

readIDLValue

private Object readIDLValue(int indirection,
 String repId,
 Class<?> clazz,
 ClassInfoCache.ClassInfo cinfo,
 String codebase)

endTag

@InfoMethod
private void endTag(int endTag)

chunkedNestingLevel

@InfoMethod
private void chunkedNestingLevel(int nl)

endFlag

@InfoMethod
private void endFlag(int value)

readEndTag

private void readEndTag()

End tags are only written for chunked valuetypes. Before Merlin, our ORBs wrote end tags which took into account all enclosing valuetypes. This was changed by an interop resolution (see details around chunkedValueNestingLevel) to only include enclosing chunked types. ORB versioning and end tag compaction are handled here.

get_offset

protected int get_offset()

unreadLastLong

@InfoMethod
private void unreadLastLong()

start_block

private void start_block()

peekNextLong

@InfoMethod
private void peekNextLong(long val)

handleEndOfValue

private void handleEndOfValue()

end_block

private void end_block()

readValueTag

private int readValueTag()

orb

public ORB orb()

Specified by:

orb in class CDRInputStreamBase

read_boolean_array

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

Specified by:

read_boolean_array in class CDRInputStreamBase

read_char_array

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

Specified by:

read_char_array in class CDRInputStreamBase

read_wchar_array

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

Specified by:

read_wchar_array in class CDRInputStreamBase

read_short_array

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

Specified by:

read_short_array in class CDRInputStreamBase

read_ushort_array

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

Specified by:

read_ushort_array in class CDRInputStreamBase

read_long_array

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

Specified by:

read_long_array in class CDRInputStreamBase

read_ulong_array

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

Specified by:

read_ulong_array in class CDRInputStreamBase

read_longlong_array

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

Specified by:

read_longlong_array in class CDRInputStreamBase

read_ulonglong_array

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

Specified by:

read_ulonglong_array in class CDRInputStreamBase

read_float_array

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

Specified by:

read_float_array in class CDRInputStreamBase

read_double_array

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

Specified by:

read_double_array in class CDRInputStreamBase

read_any_array

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

read_repositoryIds

private String read_repositoryIds()

read_repositoryId

private String read_repositoryId()

read_codebase_URL

private String read_codebase_URL()

read_Abstract

public Object read_Abstract()

Specified by:

read_Abstract in class CDRInputStreamBase

read_Value

public Serializable read_Value()

Specified by:

read_Value in class CDRInputStreamBase

read_any_array

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

Specified by:

read_any_array in class CDRInputStreamBase

read_boolean_array

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

Specified by:

read_boolean_array in class CDRInputStreamBase

read_char_array

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

Specified by:

read_char_array in class CDRInputStreamBase

read_wchar_array

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

Specified by:

read_wchar_array in class CDRInputStreamBase

read_octet_array

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

Specified by:

read_octet_array in class CDRInputStreamBase

read_short_array

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

Specified by:

read_short_array in class CDRInputStreamBase

read_ushort_array

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

Specified by:

read_ushort_array in class CDRInputStreamBase

read_long_array

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

Specified by:

read_long_array in class CDRInputStreamBase

read_ulong_array

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

Specified by:

read_ulong_array in class CDRInputStreamBase

read_ulonglong_array

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

Specified by:

read_ulonglong_array in class CDRInputStreamBase

read_longlong_array

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

Specified by:

read_longlong_array in class CDRInputStreamBase

read_float_array

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

Specified by:

read_float_array in class CDRInputStreamBase

read_double_array

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

Specified by:

read_double_array in class CDRInputStreamBase

read_fixed

public BigDecimal read_fixed(short digits,
 short scale)

Specified by:

read_fixed in class CDRInputStreamBase

read_fixed

public BigDecimal read_fixed()

Specified by:

read_fixed in class CDRInputStreamBase

read_fixed_buffer

private StringBuffer read_fixed_buffer()

_truncatable_ids

public String[] _truncatable_ids()

Specified by:

_truncatable_ids in class CDRInputStreamBase

getBufferLength

public int getBufferLength()

Specified by:

getBufferLength in class CDRInputStreamBase

setBufferLength

public void setBufferLength(int value)

Specified by:

setBufferLength in class CDRInputStreamBase

setIndex

public void setIndex(int value)

Specified by:

setIndex in class CDRInputStreamBase

getByteOrder

public ByteOrder getByteOrder()

Specified by:

getByteOrder in class CDRInputStreamBase

orb

public void orb(ORB orb)

Specified by:

orb in class CDRInputStreamBase

getBufferManager

public BufferManagerRead getBufferManager()

Specified by:

getBufferManager in class CDRInputStreamBase

skipToOffset

private void skipToOffset(int offset)

createStreamMemento

public Object createStreamMemento()

Specified by:

createStreamMemento in interface RestorableInputStream

restoreInternalState

public void restoreInternalState(Object streamMemento)

Specified by:

restoreInternalState in interface RestorableInputStream

getPosition

public int getPosition()

Specified by:

getPosition in class CDRInputStreamBase

mark

public void mark(int readlimit)

Specified by:

mark in class CDRInputStreamBase

reset

public void reset()

Specified by:

reset in class CDRInputStreamBase

getCodeBase

CodeBase getCodeBase()

Specified by:

getCodeBase in class CDRInputStreamBase

getClassFromString

private Class<?> getClassFromString(String repositoryIDString,
 String codebaseURL,
 Class<?> expectedType)

Attempts to find the class described by the given repository ID string and expected type. The first attempt is to find the class locally, falling back on the URL that came with the value. The second attempt is to use a URL from the remote CodeBase.

getConvertedChars

char[] getConvertedChars(int numBytes,
 CodeSetConversion.BTCConverter converter)

getCharConverter

protected CodeSetConversion.BTCConverter getCharConverter()

getWCharConverter

protected CodeSetConversion.BTCConverter getWCharConverter()

alignOnBoundary

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.

Specified by:

alignOnBoundary in class CDRInputStreamBase

resetCodeSetConverters

public void resetCodeSetConverters()

Specified by:

resetCodeSetConverters in class CDRInputStreamBase

valueTag

@InfoMethod
private void valueTag(int value)

start_value

public void start_value()

Specified by:

start_value in class CDRInputStreamBase

end_value

public void end_value()

Specified by:

end_value in class CDRInputStreamBase

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class InputStream

Throws:

IOException