Package org.jboss.marshalling.river
Class RiverObjectInputStream
- java.lang.Object
-
- java.io.InputStream
-
- java.io.ObjectInputStream
-
- org.jboss.marshalling.MarshallerObjectInputStream
-
- org.jboss.marshalling.river.RiverObjectInputStream
-
- All Implemented Interfaces:
java.io.Closeable
,java.io.DataInput
,java.io.ObjectInput
,java.io.ObjectStreamConstants
,java.lang.AutoCloseable
,ByteInput
public class RiverObjectInputStream extends MarshallerObjectInputStream
-
-
Field Summary
Fields Modifier and Type Field Description private BlockUnmarshaller
blockUnmarshaller
private java.lang.Object
current
private static int
OFF
private static int
ON
private int
restoreIdx
private SerializableClassDescriptor
serializableClassDescriptor
private int
state
private RiverUnmarshaller
unmarshaller
private static int
UNREAD_FIELDS
private static int
UNREAD_FIELDS_EOB
-
Fields inherited from interface java.io.ObjectStreamConstants
baseWireHandle, PROTOCOL_VERSION_1, PROTOCOL_VERSION_2, SC_BLOCK_DATA, SC_ENUM, SC_EXTERNALIZABLE, SC_SERIALIZABLE, SC_WRITE_METHOD, SERIAL_FILTER_PERMISSION, STREAM_MAGIC, STREAM_VERSION, SUBCLASS_IMPLEMENTATION_PERMISSION, SUBSTITUTION_PERMISSION, TC_ARRAY, TC_BASE, TC_BLOCKDATA, TC_BLOCKDATALONG, TC_CLASS, TC_CLASSDESC, TC_ENDBLOCKDATA, TC_ENUM, TC_EXCEPTION, TC_LONGSTRING, TC_MAX, TC_NULL, TC_OBJECT, TC_PROXYCLASSDESC, TC_REFERENCE, TC_RESET, TC_STRING
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
RiverObjectInputStream(RiverUnmarshaller riverUnmarshaller, BlockUnmarshaller delegateUnmarshaller)
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description private void
checkState()
void
defaultReadObject()
(package private) void
discardReadObject()
protected void
finish(int restoreState)
protected void
fullReset()
private int
getAndSet(int set)
protected int
getRestoreIdx()
protected void
noCustomData()
int
read()
Reads the next byte of data from the input stream.int
read(byte[] buf)
Read some bytes from the input stream into the given array.int
read(byte[] buf, int off, int len)
Read some bytes from the input stream into the given array.boolean
readBoolean()
byte
readByte()
char
readChar()
double
readDouble()
java.io.ObjectInputStream.GetField
readFields()
float
readFloat()
void
readFully(byte[] buf)
void
readFully(byte[] buf, int off, int len)
int
readInt()
java.lang.String
readLine()
Deprecated.long
readLong()
protected java.lang.Object
readObjectOverride()
short
readShort()
java.lang.Object
readUnshared()
int
readUnsignedByte()
int
readUnsignedShort()
java.lang.String
readUTF()
void
registerValidation(java.io.ObjectInputValidation obj, int prio)
long
skip(long n)
Skips over and discards up ton
bytes of data from this input stream.int
skipBytes(int len)
protected int
start()
protected SerializableClassDescriptor
swapClass(SerializableClassDescriptor descriptor)
protected java.lang.Object
swapCurrent(java.lang.Object obj)
-
Methods inherited from class org.jboss.marshalling.MarshallerObjectInputStream
available, close, enableResolveObject, mark, markSupported, readClassDescriptor, readStreamHeader, reset, resolveClass, resolveObject, resolveProxyClass
-
Methods inherited from class java.io.ObjectInputStream
getObjectInputFilter, readObject, setObjectInputFilter
-
-
-
-
Field Detail
-
OFF
private static final int OFF
- See Also:
- Constant Field Values
-
UNREAD_FIELDS
private static final int UNREAD_FIELDS
- See Also:
- Constant Field Values
-
UNREAD_FIELDS_EOB
private static final int UNREAD_FIELDS_EOB
- See Also:
- Constant Field Values
-
ON
private static final int ON
- See Also:
- Constant Field Values
-
unmarshaller
private final RiverUnmarshaller unmarshaller
-
blockUnmarshaller
private final BlockUnmarshaller blockUnmarshaller
-
state
private int state
-
serializableClassDescriptor
private SerializableClassDescriptor serializableClassDescriptor
-
current
private java.lang.Object current
-
restoreIdx
private int restoreIdx
-
-
Constructor Detail
-
RiverObjectInputStream
protected RiverObjectInputStream(RiverUnmarshaller riverUnmarshaller, BlockUnmarshaller delegateUnmarshaller) throws java.io.IOException, java.lang.SecurityException
- Throws:
java.io.IOException
java.lang.SecurityException
-
-
Method Detail
-
getAndSet
private int getAndSet(int set)
-
defaultReadObject
public void defaultReadObject() throws java.io.IOException, java.lang.ClassNotFoundException
Description copied from class:MarshallerObjectInputStream
- Specified by:
defaultReadObject
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
java.lang.ClassNotFoundException
-
discardReadObject
void discardReadObject() throws java.io.IOException
- Throws:
java.io.IOException
-
readFields
public java.io.ObjectInputStream.GetField readFields() throws java.io.IOException, java.lang.ClassNotFoundException
Description copied from class:MarshallerObjectInputStream
- Specified by:
readFields
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
java.lang.ClassNotFoundException
-
registerValidation
public void registerValidation(java.io.ObjectInputValidation obj, int prio) throws java.io.NotActiveException, java.io.InvalidObjectException
Description copied from class:MarshallerObjectInputStream
- Specified by:
registerValidation
in classMarshallerObjectInputStream
- Throws:
java.io.NotActiveException
java.io.InvalidObjectException
-
swapClass
protected SerializableClassDescriptor swapClass(SerializableClassDescriptor descriptor)
-
swapCurrent
protected java.lang.Object swapCurrent(java.lang.Object obj)
-
start
protected int start()
-
finish
protected void finish(int restoreState) throws java.io.IOException
- Throws:
java.io.IOException
-
checkState
private void checkState() throws java.io.IOException
- Throws:
java.io.IOException
-
readObjectOverride
protected java.lang.Object readObjectOverride() throws java.io.IOException, java.lang.ClassNotFoundException
Description copied from class:MarshallerObjectInputStream
- Overrides:
readObjectOverride
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
java.lang.ClassNotFoundException
-
readUnshared
public java.lang.Object readUnshared() throws java.io.IOException, java.lang.ClassNotFoundException
Description copied from class:MarshallerObjectInputStream
- Overrides:
readUnshared
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
java.lang.ClassNotFoundException
-
read
public int read() throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
Reads the next byte of data from the input stream. If no byte is available because the end of the stream has been reached, the value -1 is returned. This method blocks until input data is available, the end of the stream is detected, or an exception is thrown.- Specified by:
read
in interfaceByteInput
- Specified by:
read
in interfacejava.io.ObjectInput
- Overrides:
read
in classMarshallerObjectInputStream
- Returns:
- the next byte, or -1 if the end of stream has been reached
- Throws:
java.io.IOException
- if an error occurs
-
read
public int read(byte[] buf) throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
Read some bytes from the input stream into the given array. Returns the number of bytes actually read (possibly zero), or -1 if the end of stream has been reached.- Specified by:
read
in interfaceByteInput
- Specified by:
read
in interfacejava.io.ObjectInput
- Overrides:
read
in classMarshallerObjectInputStream
- Parameters:
buf
- the destination array- Returns:
- the number of bytes read (possibly zero), or -1 if the end of stream has been reached
- Throws:
java.io.IOException
- if an error occurs
-
read
public int read(byte[] buf, int off, int len) throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
Read some bytes from the input stream into the given array. Returns the number of bytes actually read (possibly zero), or -1 if the end of stream has been reached.- Specified by:
read
in interfaceByteInput
- Specified by:
read
in interfacejava.io.ObjectInput
- Overrides:
read
in classMarshallerObjectInputStream
- Parameters:
buf
- the destination arrayoff
- the offset into the array into which data should be readlen
- the number of bytes to attempt to fill in the destination array- Returns:
- the number of bytes read (possibly zero), or -1 if the end of stream has been reached
- Throws:
java.io.IOException
- if an error occurs
-
readBoolean
public boolean readBoolean() throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
- Specified by:
readBoolean
in interfacejava.io.DataInput
- Overrides:
readBoolean
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
-
readByte
public byte readByte() throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
- Specified by:
readByte
in interfacejava.io.DataInput
- Overrides:
readByte
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
-
readUnsignedByte
public int readUnsignedByte() throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
- Specified by:
readUnsignedByte
in interfacejava.io.DataInput
- Overrides:
readUnsignedByte
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
-
readChar
public char readChar() throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
- Specified by:
readChar
in interfacejava.io.DataInput
- Overrides:
readChar
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
-
readShort
public short readShort() throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
- Specified by:
readShort
in interfacejava.io.DataInput
- Overrides:
readShort
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
-
readUnsignedShort
public int readUnsignedShort() throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
- Specified by:
readUnsignedShort
in interfacejava.io.DataInput
- Overrides:
readUnsignedShort
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
-
readInt
public int readInt() throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
- Specified by:
readInt
in interfacejava.io.DataInput
- Overrides:
readInt
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
-
readLong
public long readLong() throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
- Specified by:
readLong
in interfacejava.io.DataInput
- Overrides:
readLong
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
-
readFloat
public float readFloat() throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
- Specified by:
readFloat
in interfacejava.io.DataInput
- Overrides:
readFloat
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
-
readDouble
public double readDouble() throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
- Specified by:
readDouble
in interfacejava.io.DataInput
- Overrides:
readDouble
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
-
readFully
public void readFully(byte[] buf) throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
- Specified by:
readFully
in interfacejava.io.DataInput
- Overrides:
readFully
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
-
readFully
public void readFully(byte[] buf, int off, int len) throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
- Specified by:
readFully
in interfacejava.io.DataInput
- Overrides:
readFully
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
-
skipBytes
public int skipBytes(int len) throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
- Specified by:
skipBytes
in interfacejava.io.DataInput
- Overrides:
skipBytes
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
-
readLine
@Deprecated public java.lang.String readLine() throws java.io.IOException
Deprecated.Description copied from class:MarshallerObjectInputStream
- Specified by:
readLine
in interfacejava.io.DataInput
- Overrides:
readLine
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
-
readUTF
public java.lang.String readUTF() throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
- Specified by:
readUTF
in interfacejava.io.DataInput
- Overrides:
readUTF
in classMarshallerObjectInputStream
- Throws:
java.io.IOException
-
skip
public long skip(long n) throws java.io.IOException
Description copied from class:MarshallerObjectInputStream
Skips over and discards up ton
bytes of data from this input stream. If the end of stream is reached, this method returns0
in order to be consistent withInputStream.skip(long)
.- Specified by:
skip
in interfaceByteInput
- Specified by:
skip
in interfacejava.io.ObjectInput
- Overrides:
skip
in classMarshallerObjectInputStream
- Parameters:
n
- the number of bytes to attempt to skip- Returns:
- the number of bytes skipped
- Throws:
java.io.IOException
- if an error occurs
-
fullReset
protected void fullReset()
-
noCustomData
protected void noCustomData()
-
getRestoreIdx
protected int getRestoreIdx()
-
-