org.infinispan.protostream.impl

Class ProtoStreamReaderImpl

java.lang.Object

org.infinispan.protostream.impl.ProtoStreamReaderImpl

All Implemented Interfaces:

MessageMarshaller.ProtoStreamReader

final class ProtoStreamReaderImpl
extends java.lang.Object
implements MessageMarshaller.ProtoStreamReader

Field Summary

Fields

Modifier and Type	Field and Description
private SerializationContextImpl	ctx
private static Log	log
private ReadMessageContext	messageContext
private static java.util.EnumSet<Type>	primitiveTypes

Constructor Summary

Constructors

Constructor and Description
ProtoStreamReaderImpl(SerializationContextImpl ctx)

Method Summary

Modifier and Type	Method and Description
private void	checkFieldRead(FieldDescriptor fd, boolean expectRepeated)
private java.lang.Object	convertWireTypeToJavaType(Type type, java.lang.Object o)
SerializationContext	getSerializationContext()
(package private) UnknownFieldSet	getUnknownFieldSet()
(package private) void	popContext()
(package private) ReadMessageContext	pushContext(FieldDescriptor fd, MessageMarshallerDelegate<?> marshallerDelegate, RawProtoStreamReader in)
<E> E[]	readArray(java.lang.String fieldName, java.lang.Class<? extends E> elementClass)
java.lang.Boolean	readBoolean(java.lang.String fieldName)
byte[]	readBytes(java.lang.String fieldName)
<E,C extends java.util.Collection<? super E>> C	readCollection(java.lang.String fieldName, C collection, java.lang.Class<E> elementClass)
java.util.Date	readDate(java.lang.String fieldName)
java.lang.Double	readDouble(java.lang.String fieldName)
java.lang.Float	readFloat(java.lang.String fieldName)
java.lang.Integer	readInt(java.lang.String fieldName) Can't return an int here because the field might be declared optional and missing so we might need to return a null.
java.lang.Long	readLong(java.lang.String fieldName)
private <A> A	readNestedObject(FieldDescriptor fd, java.lang.Class<A> clazz, RawProtoStreamReader in, int length) Read an Object or an Enum.
<E> E	readObject(java.lang.String fieldName, java.lang.Class<E> clazz)
private java.lang.Object	readPrimitive(java.lang.String fieldName, JavaType javaType)
private void	readPrimitiveCollection(FieldDescriptor fd, java.util.Collection<? super java.lang.Object> collection, java.lang.Class elementClass)
java.lang.String	readString(java.lang.String fieldName)

Methods inherited from class java.lang.Object

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

Field Detail

log

private static final Log log

primitiveTypes

private static final java.util.EnumSet<Type> primitiveTypes

ctx

private final SerializationContextImpl ctx

messageContext

private ReadMessageContext messageContext

Constructor Detail

ProtoStreamReaderImpl

public ProtoStreamReaderImpl(SerializationContextImpl ctx)

Method Detail

pushContext

ReadMessageContext pushContext(FieldDescriptor fd,
                               MessageMarshallerDelegate<?> marshallerDelegate,
                               RawProtoStreamReader in)

popContext

void popContext()

getUnknownFieldSet

UnknownFieldSet getUnknownFieldSet()

readPrimitive

private java.lang.Object readPrimitive(java.lang.String fieldName,
                                       JavaType javaType)
                                throws java.io.IOException

Throws:

java.io.IOException

convertWireTypeToJavaType

private java.lang.Object convertWireTypeToJavaType(Type type,
                                                   java.lang.Object o)

getSerializationContext

public SerializationContext getSerializationContext()

Specified by:

getSerializationContext in interface MessageMarshaller.ProtoStreamReader

readInt

public java.lang.Integer readInt(java.lang.String fieldName)
                          throws java.io.IOException

Description copied from interface: MessageMarshaller.ProtoStreamReader

Can't return an int here because the field might be declared optional and missing so we might need to return a null.

Specified by:

readInt in interface MessageMarshaller.ProtoStreamReader

Throws:

java.io.IOException

readLong

public java.lang.Long readLong(java.lang.String fieldName)
                        throws java.io.IOException

Specified by:

readLong in interface MessageMarshaller.ProtoStreamReader

Throws:

java.io.IOException

readDate

public java.util.Date readDate(java.lang.String fieldName)
                        throws java.io.IOException

Specified by:

readDate in interface MessageMarshaller.ProtoStreamReader

Throws:

java.io.IOException

readFloat

public java.lang.Float readFloat(java.lang.String fieldName)
                          throws java.io.IOException

Specified by:

readFloat in interface MessageMarshaller.ProtoStreamReader

Throws:

java.io.IOException

readDouble

public java.lang.Double readDouble(java.lang.String fieldName)
                            throws java.io.IOException

Specified by:

readDouble in interface MessageMarshaller.ProtoStreamReader

Throws:

java.io.IOException

readBoolean

public java.lang.Boolean readBoolean(java.lang.String fieldName)
                              throws java.io.IOException

Specified by:

readBoolean in interface MessageMarshaller.ProtoStreamReader

Throws:

java.io.IOException

readString

public java.lang.String readString(java.lang.String fieldName)
                            throws java.io.IOException

Specified by:

readString in interface MessageMarshaller.ProtoStreamReader

Throws:

java.io.IOException

readBytes

public byte[] readBytes(java.lang.String fieldName)
                 throws java.io.IOException

Specified by:

readBytes in interface MessageMarshaller.ProtoStreamReader

Throws:

java.io.IOException

readObject

public <E> E readObject(java.lang.String fieldName,
                        java.lang.Class<E> clazz)
                 throws java.io.IOException

Specified by:

readObject in interface MessageMarshaller.ProtoStreamReader

Throws:

java.io.IOException

readNestedObject

private <A> A readNestedObject(FieldDescriptor fd,
                               java.lang.Class<A> clazz,
                               RawProtoStreamReader in,
                               int length)
                        throws java.io.IOException

Read an Object or an Enum.

Parameters:

length - the actual length of the nested object or -1 if the length should be read from the stream

Throws:

java.io.IOException

readCollection

public <E,C extends java.util.Collection<? super E>> C readCollection(java.lang.String fieldName,
                                                                      C collection,
                                                                      java.lang.Class<E> elementClass)
                                                               throws java.io.IOException

Specified by:

readCollection in interface MessageMarshaller.ProtoStreamReader

Throws:

java.io.IOException

readPrimitiveCollection

private void readPrimitiveCollection(FieldDescriptor fd,
                                     java.util.Collection<? super java.lang.Object> collection,
                                     java.lang.Class elementClass)
                              throws java.io.IOException

Throws:

java.io.IOException

readArray

public <E> E[] readArray(java.lang.String fieldName,
                         java.lang.Class<? extends E> elementClass)
                  throws java.io.IOException

Specified by:

readArray in interface MessageMarshaller.ProtoStreamReader

Throws:

java.io.IOException

checkFieldRead

private void checkFieldRead(FieldDescriptor fd,
                            boolean expectRepeated)