Class RiverUnmarshaller

java.lang.Object

java.io.InputStream

org.jboss.marshalling.SimpleByteInput

org.jboss.marshalling.ByteInputStream

org.jboss.marshalling.SimpleDataInput

org.jboss.marshalling.AbstractObjectInput

org.jboss.marshalling.AbstractUnmarshaller

org.jboss.marshalling.river.RiverUnmarshaller

All Implemented Interfaces:

Closeable, DataInput, ObjectInput, AutoCloseable, ByteInput, Unmarshaller

public class RiverUnmarshaller
extends AbstractUnmarshaller

Field Summary

Fields

Modifier and Type	Field	Description
private BlockUnmarshaller	blockUnmarshaller
private final ArrayList<ClassDescriptor>	classCache
private final PrivilegedExceptionAction<RiverObjectInputStream>	createObjectInputStreamAction
private static final ReflectiveCreator	DEFAULT_CREATOR
private int	depth
private final ArrayList<Object>	instanceCache
private RiverObjectInputStream	objectInputStream
private static final Field	proxyInvocationHandler
private final SerializableClassRegistry	registry
private SortedSet<Validator>	validators
private int	validatorSeq
private int	version

Fields inherited from class AbstractUnmarshaller

classExternalizerFactory, classResolver, classTable, configuredVersion, exceptionListener, objectPreResolver, objectResolver, objectTable, serializabilityChecker, streamHeader

Fields inherited from class SimpleDataInput

buffer, limit, position

Fields inherited from class ByteInputStream

byteInput

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RiverUnmarshaller(RiverMarshallerFactory marshallerFactory, SerializableClassRegistry registry, MarshallingConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
(package private) void	addValidation(ObjectInputValidation validation, int prio)
void	clearClassCache()	Discard the class cache.
void	clearInstanceCache()	Discard the instance cache.
void	close()
private RiverObjectInputStream	createObjectInputStream()
protected void	discardFields(SerializableClassDescriptor descriptor)
private void	doInitSerializable(Object obj, SerializableClassDescriptor descriptor, boolean discardMissing)
private Object	doReadArray(int cnt, boolean unshared, boolean discardMissing)
private Object	doReadBooleanArray(int cnt, boolean unshared)
private Object	doReadByteArray(int cnt, boolean unshared)
private Object	doReadCharArray(int cnt, boolean unshared)
(package private) ClassDescriptor	doReadClassDescriptor(int classType, boolean required)
(package private) Object	doReadCollectionObject(boolean unshared, int idx, int size, boolean discardMissing)
private Object	doReadDoubleArray(int cnt, boolean unshared)
private Object	doReadFloatArray(int cnt, boolean unshared)
private Object	doReadIntArray(int cnt, boolean unshared)
private Object	doReadLongArray(int cnt, boolean unshared)
(package private) Object	doReadMapObject(boolean unshared, int idx, int size, boolean key, boolean discardMissing)
(package private) Object	doReadNestedObject(boolean unshared, String enclosingClassName)
protected Object	doReadNewObject(int streamClassType, boolean unshared, boolean discardMissing)
protected Object	doReadObject(boolean unshared)	Implementation of the actual object-reading method.
(package private) Object	doReadObject(boolean unshared, boolean discardMissing)
(package private) Object	doReadObject(int leadByte, boolean unshared, boolean discardMissing)
private Object	doReadObjectArray(int cnt, Class<?> type, boolean unshared, boolean discardMissing)
private Object	doReadShortArray(int cnt, boolean unshared)
void	finish()	Finish reading from the current input.
private BlockUnmarshaller	getBlockUnmarshaller()
private RiverObjectInputStream	getObjectInputStream()
private Object	readCollectionData(boolean unshared, int cacheIdx, int len, Collection target, boolean discardMissing)
protected void	readFields(Object obj, SerializableClassDescriptor descriptor, boolean discardMissing)
private Object	readMapData(boolean unshared, int cacheIdx, int len, Map target, boolean discardMissing)
private Object	readSortedMapData(boolean unshared, int cacheIdx, int len, SortedMap target, boolean discardMissing)
private Object	readSortedSetData(boolean unshared, int cacheIdx, int len, SortedSet target, boolean discardMissing)
protected String	readString()
String	readUTF()
private Object	replace(Object object)
private static Enum	resolveEnumConstant(ClassDescriptor descriptor, String name)
private static InvalidObjectException	sharedMismatch()
void	start(ByteInput byteInput)	Start reading from the given input.

Methods inherited from class AbstractObjectInput

readObject, readObject, readObjectUnshared, readObjectUnshared

Methods inherited from class SimpleDataInput

available, read, read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readIntDirect, readLine, readLong, readLongDirect, readShort, readUnsignedByte, readUnsignedByteDirect, readUnsignedShort, skip, skipBytes

Methods inherited from class InputStream

mark, markSupported, nullInputStream, readAllBytes, readNBytes, readNBytes, reset, skipNBytes, transferTo

Methods inherited from class Object

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

Methods inherited from interface ByteInput

available, read, read, read, skip

Methods inherited from interface DataInput

readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, skipBytes

Methods inherited from interface ObjectInput

available, read, read, read, readObject, skip

Methods inherited from interface Unmarshaller

readObject, readObjectUnshared, readObjectUnshared

Field Details

DEFAULT_CREATOR

private static final ReflectiveCreator DEFAULT_CREATOR

instanceCache

private final ArrayList<Object> instanceCache

classCache

private final ArrayList<ClassDescriptor> classCache

registry

private final SerializableClassRegistry registry

version

private int version

depth

private int depth

blockUnmarshaller

private BlockUnmarshaller blockUnmarshaller

objectInputStream

private RiverObjectInputStream objectInputStream

validators

private SortedSet<Validator> validators

validatorSeq

private int validatorSeq

proxyInvocationHandler

private static final Field proxyInvocationHandler

createObjectInputStreamAction

private final PrivilegedExceptionAction<RiverObjectInputStream> createObjectInputStreamAction

Constructor Details

RiverUnmarshaller

protected RiverUnmarshaller(RiverMarshallerFactory marshallerFactory,
 SerializableClassRegistry registry,
 MarshallingConfiguration configuration)

Method Details

clearInstanceCache

public void clearInstanceCache()
                        throws IOException

Description copied from interface: Unmarshaller

Discard the instance cache.

Throws:

IOException - if an error occurs

clearClassCache

public void clearClassCache()
                     throws IOException

Description copied from interface: Unmarshaller

Discard the class cache. Implicitly also discards the instance cache.

Throws:

IOException - if an error occurs

close

public void close()
           throws IOException

Description copied from class: SimpleDataInput

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface ObjectInput

Overrides:

close in class SimpleDataInput

Throws:

IOException

finish

public void finish()
            throws IOException

Description copied from class: AbstractUnmarshaller

Finish reading from the current input. The internal buffer is discarded, not flushed.

Specified by:

finish in interface Unmarshaller

Overrides:

finish in class AbstractUnmarshaller

Throws:

IOException - not thrown by this implementation, but may be overridden to be thrown if a problem occurs

getBlockUnmarshaller

private BlockUnmarshaller getBlockUnmarshaller()

getObjectInputStream

private RiverObjectInputStream getObjectInputStream()
                                             throws IOException

Throws:

IOException

createObjectInputStream

private RiverObjectInputStream createObjectInputStream()
                                                throws IOException

Throws:

IOException

doReadNestedObject

Object doReadNestedObject(boolean unshared,
 String enclosingClassName)
                   throws ClassNotFoundException,
IOException

Throws:

ClassNotFoundException

IOException

doReadCollectionObject

Object doReadCollectionObject(boolean unshared,
 int idx,
 int size,
 boolean discardMissing)
                       throws ClassNotFoundException,
IOException

Throws:

ClassNotFoundException

IOException

doReadMapObject

Object doReadMapObject(boolean unshared,
 int idx,
 int size,
 boolean key,
 boolean discardMissing)
                throws ClassNotFoundException,
IOException

Throws:

ClassNotFoundException

IOException

doReadObject

protected Object doReadObject(boolean unshared)
                       throws ClassNotFoundException,
IOException

Description copied from class: AbstractObjectInput

Implementation of the actual object-reading method.

Specified by:

doReadObject in class AbstractObjectInput

Parameters:

unshared - true if the instance should be unshared, false if it is shared

Returns:

the object to read

Throws:

ClassNotFoundException - if the class for the object could not be loaded

IOException - if an I/O error occurs

doReadObject

Object doReadObject(boolean unshared,
 boolean discardMissing)
             throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

doReadObject

Object doReadObject(int leadByte,
 boolean unshared,
 boolean discardMissing)
             throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

readCollectionData

private Object readCollectionData(boolean unshared,
 int cacheIdx,
 int len,
 Collection target,
 boolean discardMissing)
                           throws ClassNotFoundException,
IOException

Throws:

ClassNotFoundException

IOException

readSortedSetData

private Object readSortedSetData(boolean unshared,
 int cacheIdx,
 int len,
 SortedSet target,
 boolean discardMissing)
                          throws ClassNotFoundException,
IOException

Throws:

ClassNotFoundException

IOException

readMapData

private Object readMapData(boolean unshared,
 int cacheIdx,
 int len,
 Map target,
 boolean discardMissing)
                    throws ClassNotFoundException,
IOException

Throws:

ClassNotFoundException

IOException

readSortedMapData

private Object readSortedMapData(boolean unshared,
 int cacheIdx,
 int len,
 SortedMap target,
 boolean discardMissing)
                          throws ClassNotFoundException,
IOException

Throws:

ClassNotFoundException

IOException

sharedMismatch

private static InvalidObjectException sharedMismatch()

doReadClassDescriptor

ClassDescriptor doReadClassDescriptor(int classType,
 boolean required)
                               throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

readString

protected String readString()
                     throws IOException

Throws:

IOException

start

public void start(ByteInput byteInput)
           throws IOException

Description copied from class: AbstractUnmarshaller

Start reading from the given input. The internal buffer is discarded.

Specified by:

start in interface Unmarshaller

Overrides:

start in class AbstractUnmarshaller

Parameters:

byteInput - the new input from which to read

Throws:

IOException - not thrown by this implementation, but may be overridden to be thrown if a problem occurs

doReadNewObject

protected Object doReadNewObject(int streamClassType,
 boolean unshared,
 boolean discardMissing)
                          throws ClassNotFoundException,
IOException

Throws:

ClassNotFoundException

IOException

doReadDoubleArray

private Object doReadDoubleArray(int cnt,
 boolean unshared)
                          throws IOException

Throws:

IOException

doReadFloatArray

private Object doReadFloatArray(int cnt,
 boolean unshared)
                         throws IOException

Throws:

IOException

doReadCharArray

private Object doReadCharArray(int cnt,
 boolean unshared)
                        throws IOException

Throws:

IOException

doReadLongArray

private Object doReadLongArray(int cnt,
 boolean unshared)
                        throws IOException

Throws:

IOException

doReadIntArray

private Object doReadIntArray(int cnt,
 boolean unshared)
                       throws IOException

Throws:

IOException

doReadShortArray

private Object doReadShortArray(int cnt,
 boolean unshared)
                         throws IOException

Throws:

IOException

doReadByteArray

private Object doReadByteArray(int cnt,
 boolean unshared)
                        throws IOException

Throws:

IOException

doReadBooleanArray

private Object doReadBooleanArray(int cnt,
 boolean unshared)
                           throws IOException

Throws:

IOException

doReadObjectArray

private Object doReadObjectArray(int cnt,
 Class<?> type,
 boolean unshared,
 boolean discardMissing)
                          throws ClassNotFoundException,
IOException

Throws:

ClassNotFoundException

IOException

doReadArray

private Object doReadArray(int cnt,
 boolean unshared,
 boolean discardMissing)
                    throws ClassNotFoundException,
IOException

Throws:

ClassNotFoundException

IOException

resolveEnumConstant

private static Enum resolveEnumConstant(ClassDescriptor descriptor,
 String name)

doInitSerializable

private void doInitSerializable(Object obj,
 SerializableClassDescriptor descriptor,
 boolean discardMissing)
                         throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

readFields

protected void readFields(Object obj,
 SerializableClassDescriptor descriptor,
 boolean discardMissing)
                   throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

discardFields

protected void discardFields(SerializableClassDescriptor descriptor)
                      throws IOException

Throws:

IOException

addValidation

void addValidation(ObjectInputValidation validation,
 int prio)

readUTF

public String readUTF()
               throws IOException

Description copied from class: SimpleDataInput

Specified by:

readUTF in interface DataInput

Overrides:

readUTF in class SimpleDataInput

Throws:

IOException

replace

private Object replace(Object object)