Class TagWriterImpl

java.lang.Object

org.infinispan.protostream.impl.TagWriterImpl

All Implemented Interfaces:

ProtobufTagMarshaller.OperationContext, ProtobufTagMarshaller.WriteContext, TagWriter

public final class TagWriterImpl
extends Object
implements TagWriter, ProtobufTagMarshaller.WriteContext

Since:

3.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TagWriterImpl.ByteArrayEncoder	Writes to a user provided byte array.
private static final class	TagWriterImpl.ByteBufferEncoder	Writes to a ByteBuffer using put() operations.
private static class	TagWriterImpl.Encoder
private static final class	TagWriterImpl.HeapByteBufferEncoder	Writes directly to the underlying array of a heap ByteBuffer because is faster than the put() operation.
private static final class	TagWriterImpl.NoOpEncoder	An encoder that just counts the bytes and does not write anything and does not allocate buffers.
private static final class	TagWriterImpl.OutputStreamEncoder	Writes to an OutputStream and performs internal buffering to minimize the number of stream writes.
private static class	TagWriterImpl.OutputStreamNoBufferEncoder

Field Summary

Fields

Modifier and Type	Field	Description
private final int	depth
private final TagWriterImpl.Encoder	encoder
private static final Log	log
private Map<Object,Object>	params
private final TagWriterImpl	parent
private final SerializationContextImpl	serCtx
private ProtoStreamWriterImpl	writer	Deprecated.

Constructor Summary

Constructors

Modifier	Constructor	Description
private	TagWriterImpl(SerializationContextImpl serCtx, TagWriterImpl.Encoder encoder)
private	TagWriterImpl(TagWriterImpl parent, TagWriterImpl.Encoder encoder)

Method Summary

Modifier and Type	Method	Description
int	depth()
void	flush()
Object	getParam(Object key)
ProtoStreamWriterImpl	getProtoStreamWriter()
SerializationContextImpl	getSerializationContext()	Provides access to the ImmutableSerializationContext.
TagWriter	getWriter()
int	getWrittenBytes()
static TagWriterImpl	newInstance(ImmutableSerializationContext serCtx)
static TagWriterImpl	newInstance(ImmutableSerializationContext serCtx, byte[] buf)
static TagWriterImpl	newInstance(ImmutableSerializationContext serCtx, byte[] buf, int offset, int length)
static TagWriterImpl	newInstance(ImmutableSerializationContext serCtx, OutputStream output)
static TagWriterImpl	newInstance(ImmutableSerializationContext serCtx, OutputStream output, int bufferSize)	Deprecated. since 5.0.10 Please use newInstance(ImmutableSerializationContext, OutputStream) with a BufferedOutputStream instead
static TagWriterImpl	newInstance(ImmutableSerializationContext serCtx, ByteBuffer byteBuffer)
static TagWriterImpl	newInstanceNoBuffer(ImmutableSerializationContext ctx, OutputStream out)	Deprecated. since 5.0.10 Please use newInstance(ImmutableSerializationContext, OutputStream)
static TagWriterImpl	newNestedInstance(ProtobufTagMarshaller.WriteContext parent, byte[] buf)
static TagWriterImpl	newNestedInstance(ProtobufTagMarshaller.WriteContext parent, OutputStream output)
void	setParam(Object key, Object value)
void	writeBool(int number, boolean value)
void	writeBytes(int number, byte[] value)
void	writeBytes(int number, byte[] value, int offset, int length)
void	writeBytes(int number, ByteBuffer value)
void	writeDouble(int number, double value)
void	writeEnum(int number, int value)
void	writeFixed32(int number, int value)
void	writeFixed64(int number, long value)
void	writeFloat(int number, float value)
void	writeInt32(int number, int value)
void	writeInt64(int number, long value)
void	writeRawBytes(byte[] value, int offset, int length)
void	writeSFixed32(int number, int value)
void	writeSFixed64(int number, long value)
void	writeSInt32(int number, int value)
void	writeSInt64(int number, long value)
void	writeString(int number, String value)
void	writeTag(int number, int wireType)
void	writeTag(int number, WireType wireType)
void	writeUInt32(int number, int value)
void	writeUInt64(int number, long value)
void	writeVarint32(int value)
void	writeVarint64(long value)

Methods inherited from class Object

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

Field Details

log

private static final Log log

serCtx

private final SerializationContextImpl serCtx

encoder

private final TagWriterImpl.Encoder encoder

parent

private final TagWriterImpl parent

depth

private final int depth

params

private Map<Object,Object> params

writer

@Deprecated
private ProtoStreamWriterImpl writer

Deprecated.

Constructor Details

TagWriterImpl

private TagWriterImpl(TagWriterImpl parent,
 TagWriterImpl.Encoder encoder)

TagWriterImpl

private TagWriterImpl(SerializationContextImpl serCtx,
 TagWriterImpl.Encoder encoder)

Method Details

newNestedInstance

public static TagWriterImpl newNestedInstance(ProtobufTagMarshaller.WriteContext parent,
 OutputStream output)

newNestedInstance

public static TagWriterImpl newNestedInstance(ProtobufTagMarshaller.WriteContext parent,
 byte[] buf)

newInstance

public static TagWriterImpl newInstance(ImmutableSerializationContext serCtx,
 OutputStream output)

newInstance

@Deprecated
public static TagWriterImpl newInstance(ImmutableSerializationContext serCtx,
 OutputStream output,
 int bufferSize)

Deprecated.

since 5.0.10 Please use newInstance(ImmutableSerializationContext, OutputStream) with a BufferedOutputStream instead

newInstance

public static TagWriterImpl newInstance(ImmutableSerializationContext serCtx,
 byte[] buf)

newInstance

public static TagWriterImpl newInstance(ImmutableSerializationContext serCtx,
 byte[] buf,
 int offset,
 int length)

newInstance

public static TagWriterImpl newInstance(ImmutableSerializationContext serCtx,
 ByteBuffer byteBuffer)

newInstance

public static TagWriterImpl newInstance(ImmutableSerializationContext serCtx)

newInstanceNoBuffer

@Deprecated
public static TagWriterImpl newInstanceNoBuffer(ImmutableSerializationContext ctx,
 OutputStream out)

Deprecated.

since 5.0.10 Please use newInstance(ImmutableSerializationContext, OutputStream)

getWrittenBytes

public int getWrittenBytes()

flush

public void flush()
           throws IOException

Specified by:

flush in interface TagWriter

Throws:

IOException

writeTag

public void writeTag(int number,
 int wireType)
              throws IOException

Specified by:

writeTag in interface TagWriter

Throws:

IOException

writeTag

public void writeTag(int number,
 WireType wireType)
              throws IOException

Specified by:

writeTag in interface TagWriter

Throws:

IOException

writeVarint32

public void writeVarint32(int value)
                   throws IOException

Specified by:

writeVarint32 in interface TagWriter

Throws:

IOException

writeVarint64

public void writeVarint64(long value)
                   throws IOException

Specified by:

writeVarint64 in interface TagWriter

Throws:

IOException

writeString

public void writeString(int number,
 String value)
                 throws IOException

Specified by:

writeString in interface TagWriter

Throws:

IOException

writeInt32

public void writeInt32(int number,
 int value)
                throws IOException

Specified by:

writeInt32 in interface TagWriter

Throws:

IOException

writeUInt32

public void writeUInt32(int number,
 int value)
                 throws IOException

Specified by:

writeUInt32 in interface TagWriter

Throws:

IOException

writeSInt32

public void writeSInt32(int number,
 int value)
                 throws IOException

Specified by:

writeSInt32 in interface TagWriter

Throws:

IOException

writeFixed32

public void writeFixed32(int number,
 int value)
                  throws IOException

Specified by:

writeFixed32 in interface TagWriter

Throws:

IOException

writeSFixed32

public void writeSFixed32(int number,
 int value)
                   throws IOException

Specified by:

writeSFixed32 in interface TagWriter

Throws:

IOException

writeInt64

public void writeInt64(int number,
 long value)
                throws IOException

Specified by:

writeInt64 in interface TagWriter

Throws:

IOException

writeUInt64

public void writeUInt64(int number,
 long value)
                 throws IOException

Specified by:

writeUInt64 in interface TagWriter

Throws:

IOException

writeSInt64

public void writeSInt64(int number,
 long value)
                 throws IOException

Specified by:

writeSInt64 in interface TagWriter

Throws:

IOException

writeFixed64

public void writeFixed64(int number,
 long value)
                  throws IOException

Specified by:

writeFixed64 in interface TagWriter

Throws:

IOException

writeSFixed64

public void writeSFixed64(int number,
 long value)
                   throws IOException

Specified by:

writeSFixed64 in interface TagWriter

Throws:

IOException

writeEnum

public void writeEnum(int number,
 int value)
               throws IOException

Specified by:

writeEnum in interface TagWriter

Throws:

IOException

writeBool

public void writeBool(int number,
 boolean value)
               throws IOException

Specified by:

writeBool in interface TagWriter

Throws:

IOException

writeDouble

public void writeDouble(int number,
 double value)
                 throws IOException

Specified by:

writeDouble in interface TagWriter

Throws:

IOException

writeFloat

public void writeFloat(int number,
 float value)
                throws IOException

Specified by:

writeFloat in interface TagWriter

Throws:

IOException

writeBytes

public void writeBytes(int number,
 ByteBuffer value)
                throws IOException

Specified by:

writeBytes in interface TagWriter

Throws:

IOException

writeBytes

public void writeBytes(int number,
 byte[] value)
                throws IOException

Specified by:

writeBytes in interface TagWriter

Throws:

IOException

writeBytes

public void writeBytes(int number,
 byte[] value,
 int offset,
 int length)
                throws IOException

Specified by:

writeBytes in interface TagWriter

Throws:

IOException

writeRawBytes

public void writeRawBytes(byte[] value,
 int offset,
 int length)
                   throws IOException

Specified by:

writeRawBytes in interface TagWriter

Throws:

IOException

getSerializationContext

public SerializationContextImpl getSerializationContext()

Description copied from interface: ProtobufTagMarshaller.OperationContext

Provides access to the ImmutableSerializationContext.

Specified by:

getSerializationContext in interface ProtobufTagMarshaller.OperationContext

getParam

public Object getParam(Object key)

Specified by:

getParam in interface ProtobufTagMarshaller.OperationContext

setParam

public void setParam(Object key,
 Object value)

Specified by:

setParam in interface ProtobufTagMarshaller.OperationContext

getWriter

public TagWriter getWriter()

Specified by:

getWriter in interface ProtobufTagMarshaller.WriteContext

depth

public int depth()

Specified by:

depth in interface ProtobufTagMarshaller.WriteContext

getProtoStreamWriter

public ProtoStreamWriterImpl getProtoStreamWriter()