Package org.infinispan.protostream.impl

Class ProtoStreamWriterImpl

java.lang.Object

org.infinispan.protostream.impl.ProtoStreamWriterImpl

All Implemented Interfaces:

MessageMarshaller.ProtoStreamWriter

final class ProtoStreamWriterImpl
extends Object
implements MessageMarshaller.ProtoStreamWriter

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	ProtoStreamWriterImpl.WriteMessageContext

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	CHUNK_SIZE	The size of the buffer used when copying stream to stream.
private static final Log	log
private ProtoStreamWriterImpl.WriteMessageContext	messageContext
private final SerializationContextImpl	serCtx

Constructor Summary

Constructors

Constructor	Description
ProtoStreamWriterImpl(SerializationContextImpl serCtx)

Method Summary

Modifier and Type	Method	Description
private void	checkFieldWrite(FieldDescriptor fd)	Check repeatability and write-once for a non-repeatable field.
private void	checkRepeatedFieldWrite(FieldDescriptor fd)	Check repeatability and write-once for a repeatable field.
(package private) ProtoStreamWriterImpl.WriteMessageContext	enterContext(FieldDescriptor fd, Descriptor messageDescriptor, TagWriterImpl out)
(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.
private void	validateElement(Object element, Class<?> elementClass)
private void	validateElementClass(Class<?> elementClass, Class<?> expectedElementClass)
<E> void	writeArray(String fieldName, E[] array, Class<? extends E> elementClass)
void	writeBoolean(String fieldName, boolean value)
void	writeBoolean(String fieldName, Boolean value)
void	writeBooleans(String fieldName, boolean[] array)
void	writeBytes(String fieldName, byte[] value)
void	writeBytes(String fieldName, InputStream input)
<E> void	writeCollection(String fieldName, Collection<? super E> collection, Class<E> elementClass)
void	writeDate(String fieldName, Date value)
void	writeDouble(String fieldName, double value)
void	writeDouble(String fieldName, Double value)
void	writeDoubles(String fieldName, double[] array)
<E extends Enum<E>> void	writeEnum(String fieldName, E value)	Writes an enum value.
private <T extends Enum<T>> void	writeEnum(FieldDescriptor fd, T value)
void	writeFloat(String fieldName, float value)
void	writeFloat(String fieldName, Float value)
void	writeFloats(String fieldName, float[] array)
private void	writeGroup(FieldDescriptor fd, Object value, Class<?> clazz)
void	writeInstant(String fieldName, Instant value)
void	writeInt(String fieldName, int value)
void	writeInt(String fieldName, Integer value)
void	writeInts(String fieldName, int[] array)
void	writeLong(String fieldName, long value)
void	writeLong(String fieldName, Long value)
void	writeLongs(String fieldName, long[] array)
<K, V> void	writeMap(String fieldName, Map<? super K,? super V> map, Class<K> keyClass, Class<V> valueClass)
private void	writeMessage(FieldDescriptor fd, Object value, Class<?> clazz)
<E> void	writeObject(String fieldName, E value, Class<? extends E> clazz)
void	writeString(String fieldName, String value)

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

CHUNK_SIZE

private static final int CHUNK_SIZE

The size of the buffer used when copying stream to stream.

See Also:

• Constant Field Values

serCtx

private final SerializationContextImpl serCtx

messageContext

private ProtoStreamWriterImpl.WriteMessageContext messageContext

Constructor Details

ProtoStreamWriterImpl

ProtoStreamWriterImpl(SerializationContextImpl serCtx)

Method Details

enterContext

ProtoStreamWriterImpl.WriteMessageContext enterContext(FieldDescriptor fd,
 Descriptor messageDescriptor,
 TagWriterImpl out)

exitContext

void exitContext()

getSerializationContext

public ImmutableSerializationContext getSerializationContext()

Description copied from interface: MessageMarshaller.ProtoStreamWriter

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.ProtoStreamWriter

writeInt

public void writeInt(String fieldName,
 int value)
              throws IOException

Specified by:

writeInt in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeInt

public void writeInt(String fieldName,
 Integer value)
              throws IOException

Specified by:

writeInt in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeInts

public void writeInts(String fieldName,
 int[] array)
               throws IOException

Specified by:

writeInts in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeLong

public void writeLong(String fieldName,
 long value)
               throws IOException

Specified by:

writeLong in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeLong

public void writeLong(String fieldName,
 Long value)
               throws IOException

Specified by:

writeLong in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeLongs

public void writeLongs(String fieldName,
 long[] array)
                throws IOException

Specified by:

writeLongs in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeDate

public void writeDate(String fieldName,
 Date value)
               throws IOException

Specified by:

writeDate in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeInstant

public void writeInstant(String fieldName,
 Instant value)
                  throws IOException

Specified by:

writeInstant in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeDouble

public void writeDouble(String fieldName,
 double value)
                 throws IOException

Specified by:

writeDouble in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeDouble

public void writeDouble(String fieldName,
 Double value)
                 throws IOException

Specified by:

writeDouble in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeDoubles

public void writeDoubles(String fieldName,
 double[] array)
                  throws IOException

Specified by:

writeDoubles in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeFloat

public void writeFloat(String fieldName,
 float value)
                throws IOException

Specified by:

writeFloat in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeFloat

public void writeFloat(String fieldName,
 Float value)
                throws IOException

Specified by:

writeFloat in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeFloats

public void writeFloats(String fieldName,
 float[] array)
                 throws IOException

Specified by:

writeFloats in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeBoolean

public void writeBoolean(String fieldName,
 boolean value)
                  throws IOException

Specified by:

writeBoolean in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeBoolean

public void writeBoolean(String fieldName,
 Boolean value)
                  throws IOException

Specified by:

writeBoolean in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeBooleans

public void writeBooleans(String fieldName,
 boolean[] array)
                   throws IOException

Specified by:

writeBooleans in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeString

public void writeString(String fieldName,
 String value)
                 throws IOException

Specified by:

writeString in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeBytes

public void writeBytes(String fieldName,
 byte[] value)
                throws IOException

Specified by:

writeBytes in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeBytes

public void writeBytes(String fieldName,
 InputStream input)
                throws IOException

Specified by:

writeBytes in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeObject

public <E> void writeObject(String fieldName,
 E value,
 Class<? extends E> clazz)
                     throws IOException

Specified by:

writeObject in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeEnum

public <E extends Enum<E>> void writeEnum(String fieldName,
 E value)
                                   throws IOException

Description copied from interface: MessageMarshaller.ProtoStreamWriter

Writes an enum value.

Specified by:

writeEnum in interface MessageMarshaller.ProtoStreamWriter

Parameters:

fieldName - the field name

value - the enum value

Throws:

IOException

writeMessage

private void writeMessage(FieldDescriptor fd,
 Object value,
 Class<?> clazz)
                   throws IOException

Throws:

IOException

writeGroup

private void writeGroup(FieldDescriptor fd,
 Object value,
 Class<?> clazz)
                 throws IOException

Throws:

IOException

writeEnum

private <T extends Enum<T>> void writeEnum(FieldDescriptor fd,
 T value)
                                    throws IOException

Throws:

IOException

writeCollection

public <E> void writeCollection(String fieldName,
 Collection<? super E> collection,
 Class<E> elementClass)
                         throws IOException

Specified by:

writeCollection in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeArray

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

Specified by:

writeArray in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

writeMap

public <K,
V> void writeMap(String fieldName,
 Map<? super K,? super V> map,
 Class<K> keyClass,
 Class<V> valueClass)
                     throws IOException

Specified by:

writeMap in interface MessageMarshaller.ProtoStreamWriter

Throws:

IOException

validateElementClass

private void validateElementClass(Class<?> elementClass,
 Class<?> expectedElementClass)

validateElement

private void validateElement(Object element,
 Class<?> elementClass)

checkFieldWrite

private void checkFieldWrite(FieldDescriptor fd)

Check repeatability and write-once for a non-repeatable field.

checkRepeatedFieldWrite

private void checkRepeatedFieldWrite(FieldDescriptor fd)

Check repeatability and write-once for a repeatable field.