Package org.infinispan.protostream.impl

Class ProtoStreamReaderImpl

java.lang.Object

org.infinispan.protostream.impl.ProtoStreamReaderImpl

All Implemented Interfaces:

MessageMarshaller.ProtoStreamReader

final class ProtoStreamReaderImpl
extends Object
implements MessageMarshaller.ProtoStreamReader

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	ProtoStreamReaderImpl.ReadMessageContext

Field Summary

Fields

Modifier and Type	Field	Description
private final TagReaderImpl	ctx
private static final Log	log
private final boolean	logOutOfSequenceReads
private ProtoStreamReaderImpl.ReadMessageContext	messageContext
private static final EnumSet<Type>	primitiveTypes
private final SerializationContextImpl	serCtx

Constructor Summary

Constructors

Constructor	Description
ProtoStreamReaderImpl(TagReaderImpl ctx, SerializationContextImpl serCtx)

Method Summary

Modifier and Type	Method	Description
private void	checkFieldRead(FieldDescriptor fd, boolean expectRepeated)
private Object	convertWireTypeToJavaType(Type type, Object o)
(package private) ProtoStreamReaderImpl.ReadMessageContext	enterContext(FieldDescriptor fd, Descriptor messageDescriptor, TagReaderImpl in)
(package private) void	exitContext()
ImmutableSerializationContext	getSerializationContext()	During reading, a marshaller can obtain the current ImmutableSerializationContext and use it in order to access the schema or marshaller information.
(package private) UnknownFieldSet	getUnknownFieldSet()
<E> E[]	readArray(String fieldName, Class<? extends E> elementClass)
Boolean	readBoolean(String fieldName)
boolean[]	readBooleans(String fieldName)
byte[]	readBytes(String fieldName)
InputStream	readBytesAsInputStream(String fieldName)
<E, C extends Collection<? super E>> C	readCollection(String fieldName, C collection, Class<E> elementClass)
Date	readDate(String fieldName)
Double	readDouble(String fieldName)
double[]	readDoubles(String fieldName)
<E extends Enum<E>> E	readEnum(String fieldName, Class<E> clazz)
Float	readFloat(String fieldName)
float[]	readFloats(String fieldName)
Instant	readInstant(String fieldName)
Integer	readInt(String fieldName)	Reads an integer field given a field name.
int[]	readInts(String fieldName)
Long	readLong(String fieldName)
long[]	readLongs(String fieldName)
<K, V, M extends Map<? super K, ? super V>> M	readMap(String fieldName, M map, Class<K> keyClass, Class<V> valueClass)
private <K, V, M extends Map<? super K, ? super V>> void	readMapEntry(M map, Class<V> valueClass, TagReaderImpl in, MapDescriptor md)
private <A> A	readNestedObject(FieldDescriptor fd, Class<A> clazz, ProtobufTagMarshaller.ReadContext ctx, int length)	Read an Object or an Enum.
<E> E	readObject(String fieldName, Class<E> clazz)
private Object	readPrimitive(String fieldName, JavaType javaType)
private void	readPrimitiveCollection(FieldDescriptor fd, Collection<? super Object> collection, Class<?> elementClass)
String	readString(String fieldName)

Methods inherited from class java.lang.Object

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

Field Details

log

private static final Log log

primitiveTypes

private static final EnumSet<Type> primitiveTypes

logOutOfSequenceReads

private final boolean logOutOfSequenceReads

ctx

private final TagReaderImpl ctx

serCtx

private final SerializationContextImpl serCtx

messageContext

private ProtoStreamReaderImpl.ReadMessageContext messageContext

Constructor Details

ProtoStreamReaderImpl

ProtoStreamReaderImpl(TagReaderImpl ctx,
 SerializationContextImpl serCtx)

Method Details

enterContext

ProtoStreamReaderImpl.ReadMessageContext enterContext(FieldDescriptor fd,
 Descriptor messageDescriptor,
 TagReaderImpl in)

exitContext

void exitContext()

getUnknownFieldSet

UnknownFieldSet getUnknownFieldSet()

readPrimitive

private Object readPrimitive(String fieldName,
 JavaType javaType)
                      throws IOException

Throws:

IOException

convertWireTypeToJavaType

private Object convertWireTypeToJavaType(Type type,
 Object o)

getSerializationContext

public ImmutableSerializationContext getSerializationContext()

Description copied from interface: MessageMarshaller.ProtoStreamReader

During reading, a marshaller can obtain the current ImmutableSerializationContext and use it in order to access the schema or marshaller information.

Specified by:

getSerializationContext in interface MessageMarshaller.ProtoStreamReader

readInt

public Integer readInt(String fieldName)
                throws IOException

Description copied from interface: MessageMarshaller.ProtoStreamReader

Reads an integer field given a field name. The field name and type are checked against the schema first. Can't return an int here because the field might be declared optional and actually missing so we have to be able to signal that by returning null.

Specified by:

readInt in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readInts

public int[] readInts(String fieldName)
               throws IOException

Specified by:

readInts in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readLong

public Long readLong(String fieldName)
              throws IOException

Specified by:

readLong in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readLongs

public long[] readLongs(String fieldName)
                 throws IOException

Specified by:

readLongs in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readDate

public Date readDate(String fieldName)
              throws IOException

Specified by:

readDate in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readInstant

public Instant readInstant(String fieldName)
                    throws IOException

Specified by:

readInstant in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readFloat

public Float readFloat(String fieldName)
                throws IOException

Specified by:

readFloat in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readFloats

public float[] readFloats(String fieldName)
                   throws IOException

Specified by:

readFloats in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readDouble

public Double readDouble(String fieldName)
                  throws IOException

Specified by:

readDouble in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readDoubles

public double[] readDoubles(String fieldName)
                     throws IOException

Specified by:

readDoubles in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readBoolean

public Boolean readBoolean(String fieldName)
                    throws IOException

Specified by:

readBoolean in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readBooleans

public boolean[] readBooleans(String fieldName)
                       throws IOException

Specified by:

readBooleans in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readString

public String readString(String fieldName)
                  throws IOException

Specified by:

readString in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readBytes

public byte[] readBytes(String fieldName)
                 throws IOException

Specified by:

readBytes in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readBytesAsInputStream

public InputStream readBytesAsInputStream(String fieldName)
                                   throws IOException

Specified by:

readBytesAsInputStream in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readEnum

public <E extends Enum<E>> E readEnum(String fieldName,
 Class<E> clazz)
                               throws IOException

Specified by:

readEnum in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readObject

public <E> E readObject(String fieldName,
 Class<E> clazz)
                 throws IOException

Specified by:

readObject in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readNestedObject

private <A> A readNestedObject(FieldDescriptor fd,
 Class<A> clazz,
 ProtobufTagMarshaller.ReadContext ctx,
 int length)
                        throws 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:

IOException

readCollection

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

Specified by:

readCollection in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readPrimitiveCollection

private void readPrimitiveCollection(FieldDescriptor fd,
 Collection<? super Object> collection,
 Class<?> elementClass)
                              throws IOException

Throws:

IOException

readArray

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

Specified by:

readArray in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

checkFieldRead

private void checkFieldRead(FieldDescriptor fd,
 boolean expectRepeated)

readMap

public <K,
V,
M extends Map<? super K,
? super V>>
M readMap(String fieldName,
 M map,
 Class<K> keyClass,
 Class<V> valueClass)
   throws IOException

Specified by:

readMap in interface MessageMarshaller.ProtoStreamReader

Throws:

IOException

readMapEntry

private <K,
V,
M extends Map<? super K,
? super V>>
void readMapEntry(M map,
 Class<V> valueClass,
 TagReaderImpl in,
 MapDescriptor md)
           throws IOException

Throws:

IOException