Package org.apache.cassandra.utils.vint

Class VIntCoding

java.lang.Object

org.apache.cassandra.utils.vint.VIntCoding

public class VIntCoding
extends Object

Borrows idea from https://developers.google.com/protocol-buffers/docs/encoding#varints

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	VIntCoding.VIntOutOfRangeException	Throw when attempting to decode a vint and the output type doesn't have enough space to fit the value that was decoded

Field Summary

Fields

Modifier and Type	Field	Description
protected static final io.netty.util.concurrent.FastThreadLocal<byte[]>	encodingBuffer
static final int	MAX_SIZE

Constructor Summary

Constructors

Constructor	Description
VIntCoding()

Method Summary

Modifier and Type	Method	Description
static int	checkedCast(long value)
static int	computeUnsignedVIntSize(long value)	Compute the number of bytes that would be needed to encode an unsigned varint.
static int	computeUnsignedVIntSize(ByteBuffer input, int readerIndex)	Computes size of an unsigned vint that starts at readerIndex of the provided ByteBuf.
static int	computeUnsignedVIntSize(ByteBuffer input, int readerIndex, int readerLimit)
static int	computeVIntSize(long param)	Compute the number of bytes that would be needed to encode a varint.
static long	decodeZigZag64(long n)	Decode a ZigZag-encoded 64-bit value.
static int	encodeExtraBytesToRead(int extraBytesToRead)
static long	encodeZigZag64(long n)	Encode a ZigZag-encoded 64-bit value.
static int	firstByteValueMask(int extraBytesToRead)
static long	getUnsignedVInt(ByteBuffer input, int readerIndex)
static long	getUnsignedVInt(ByteBuffer input, int readerIndex, int readerLimit)
static <V> long	getUnsignedVInt(V input, ValueAccessor<V> accessor, int readerIndex)
static <V> long	getUnsignedVInt(V input, ValueAccessor<V> accessor, int readerIndex, int readerLimit)
static int	getUnsignedVInt32(ByteBuffer input, int readerIndex)	Read up to a 32-bit integer back, using the unsigned (no zigzag) encoding.
static <V> int	getUnsignedVInt32(V input, ValueAccessor<V> accessor, int readerIndex)
static long	getVInt(ByteBuffer input, int readerIndex)
static <V> long	getVInt(V input, ValueAccessor<V> accessor, int readerIndex)
static int	getVInt32(ByteBuffer input, int readerIndex)
static <V> int	getVInt32(V input, ValueAccessor<V> accessor, int readerIndex)
static int	numberOfExtraBytesToRead(int firstByte)
static long	readUnsignedVInt(DataInput input)
static int	readUnsignedVInt32(DataInput input)	Read up to a 32-bit integer.
static long	readVInt(DataInput input)
static int	readVInt32(DataInput input)	Read up to a signed 32-bit integer back.
static void	skipUnsignedVInt(DataInputPlus input)
static void	writeUnsignedVInt(int value, ByteBuffer output)	Deprecated. See CASSANDRA-18099
static void	writeUnsignedVInt(int value, DataOutputPlus output)	Deprecated. See CASSANDRA-18099
static void	writeUnsignedVInt(long value, ByteBuffer output)
static void	writeUnsignedVInt(long value, DataOutputPlus output)
static <V> int	writeUnsignedVInt(long value, V output, int offset, ValueAccessor<V> accessor)
static void	writeUnsignedVInt32(int value, ByteBuffer output)
static void	writeUnsignedVInt32(int value, DataOutputPlus output)
static <V> int	writeUnsignedVInt32(int value, V output, int offset, ValueAccessor<V> accessor)
static void	writeVInt(int value, ByteBuffer output)	Deprecated. See CASSANDRA-18099
static void	writeVInt(int value, DataOutputPlus output)	Deprecated. See CASSANDRA-18099
static void	writeVInt(long value, ByteBuffer output)
static void	writeVInt(long value, DataOutputPlus output)
static <V> int	writeVInt(long value, V output, int offset, ValueAccessor<V> accessor)
static void	writeVInt32(int value, ByteBuffer output)
static void	writeVInt32(int value, DataOutputPlus output)
static <V> int	writeVInt32(int value, V output, int offset, ValueAccessor<V> accessor)

Methods inherited from class java.lang.Object

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

Field Details

encodingBuffer

protected static final io.netty.util.concurrent.FastThreadLocal<byte[]> encodingBuffer

MAX_SIZE

public static final int MAX_SIZE

See Also:

• Constant Field Values

Constructor Details

VIntCoding

public VIntCoding()

Method Details

readUnsignedVInt

public static long readUnsignedVInt(DataInput input)
                             throws IOException

Throws:

IOException

skipUnsignedVInt

public static void skipUnsignedVInt(DataInputPlus input)
                             throws IOException

Throws:

IOException

getUnsignedVInt32

public static int getUnsignedVInt32(ByteBuffer input,
 int readerIndex)

Read up to a 32-bit integer back, using the unsigned (no zigzag) encoding. Note this method is the same as readUnsignedVInt(DataInput), except that we do *not* block if there are not enough bytes in the buffer to reconstruct the value.

Throws:

VIntCoding.VIntOutOfRangeException - If the vint doesn't fit into a 32-bit integer

getVInt32

public static int getVInt32(ByteBuffer input,
 int readerIndex)

getVInt

public static long getVInt(ByteBuffer input,
 int readerIndex)

getUnsignedVInt

public static long getUnsignedVInt(ByteBuffer input,
 int readerIndex)

getUnsignedVInt

public static long getUnsignedVInt(ByteBuffer input,
 int readerIndex,
 int readerLimit)

getUnsignedVInt32

public static <V> int getUnsignedVInt32(V input,
 ValueAccessor<V> accessor,
 int readerIndex)

getVInt32

public static <V> int getVInt32(V input,
 ValueAccessor<V> accessor,
 int readerIndex)

getVInt

public static <V> long getVInt(V input,
 ValueAccessor<V> accessor,
 int readerIndex)

getUnsignedVInt

public static <V> long getUnsignedVInt(V input,
 ValueAccessor<V> accessor,
 int readerIndex)

getUnsignedVInt

public static <V> long getUnsignedVInt(V input,
 ValueAccessor<V> accessor,
 int readerIndex,
 int readerLimit)

computeUnsignedVIntSize

public static int computeUnsignedVIntSize(ByteBuffer input,
 int readerIndex)

Computes size of an unsigned vint that starts at readerIndex of the provided ByteBuf.

Returns:

-1 if there are not enough bytes in the input to calculate the size; else, the vint unsigned value size in bytes.

computeUnsignedVIntSize

public static int computeUnsignedVIntSize(ByteBuffer input,
 int readerIndex,
 int readerLimit)

readVInt

public static long readVInt(DataInput input)
                     throws IOException

Throws:

IOException

readVInt32

public static int readVInt32(DataInput input)
                      throws IOException

Read up to a signed 32-bit integer back. Assumes the vint was written using writeVInt32(int, DataOutputPlus) or similar that zigzag encodes the integer.

Throws:

VIntCoding.VIntOutOfRangeException - If the vint doesn't fit into a 32-bit integer

IOException

readUnsignedVInt32

public static int readUnsignedVInt32(DataInput input)
                              throws IOException

Read up to a 32-bit integer. This method assumes the original integer was written using writeUnsignedVInt32(int, DataOutputPlus) or similar that doesn't zigzag encodes the vint.

Throws:

VIntCoding.VIntOutOfRangeException - If the vint doesn't fit into a 32-bit integer

IOException

firstByteValueMask

public static int firstByteValueMask(int extraBytesToRead)

encodeExtraBytesToRead

public static int encodeExtraBytesToRead(int extraBytesToRead)

numberOfExtraBytesToRead

public static int numberOfExtraBytesToRead(int firstByte)

writeUnsignedVInt

@Deprecated(since="5.0")
public static void writeUnsignedVInt(int value,
 DataOutputPlus output)
                              throws IOException

Deprecated.

See CASSANDRA-18099

Throws:

IOException

writeUnsignedVInt

@Inline
public static void writeUnsignedVInt(long value,
 DataOutputPlus output)
                              throws IOException

Throws:

IOException

writeUnsignedVInt32

public static void writeUnsignedVInt32(int value,
 DataOutputPlus output)
                                throws IOException

Throws:

IOException

writeUnsignedVInt

@Deprecated(since="5.0")
public static void writeUnsignedVInt(int value,
 ByteBuffer output)
                              throws IOException

Deprecated.

See CASSANDRA-18099

Throws:

IOException

writeUnsignedVInt

@Inline
public static void writeUnsignedVInt(long value,
 ByteBuffer output)

writeVInt

@Inline
public static <V> int writeVInt(long value,
 V output,
 int offset,
 ValueAccessor<V> accessor)

writeVInt32

@Inline
public static <V> int writeVInt32(int value,
 V output,
 int offset,
 ValueAccessor<V> accessor)

writeUnsignedVInt32

@Inline
public static <V> int writeUnsignedVInt32(int value,
 V output,
 int offset,
 ValueAccessor<V> accessor)

writeUnsignedVInt

@Inline
public static <V> int writeUnsignedVInt(long value,
 V output,
 int offset,
 ValueAccessor<V> accessor)

writeUnsignedVInt32

@Inline
public static void writeUnsignedVInt32(int value,
 ByteBuffer output)

writeVInt

@Deprecated(since="5.0")
public static void writeVInt(int value,
 DataOutputPlus output)
                      throws IOException

Deprecated.

See CASSANDRA-18099

Throws:

IOException

writeVInt

@Inline
public static void writeVInt(long value,
 DataOutputPlus output)
                      throws IOException

Throws:

IOException

writeVInt32

@Inline
public static void writeVInt32(int value,
 DataOutputPlus output)
                        throws IOException

Throws:

IOException

writeVInt

@Deprecated(since="5.0")
public static void writeVInt(int value,
 ByteBuffer output)

Deprecated.

See CASSANDRA-18099

writeVInt

@Inline
public static void writeVInt(long value,
 ByteBuffer output)

writeVInt32

@Inline
public static void writeVInt32(int value,
 ByteBuffer output)

decodeZigZag64

public static long decodeZigZag64(long n)

Decode a ZigZag-encoded 64-bit value. ZigZag encodes signed integers into values that can be efficiently encoded with varint. (Otherwise, negative values must be sign-extended to 64 bits to be varint encoded, thus always taking 10 bytes on the wire.)

Parameters:

n - An unsigned 64-bit integer, stored in a signed int because Java has no explicit unsigned support.

Returns:

A signed 64-bit integer.

encodeZigZag64

public static long encodeZigZag64(long n)

Encode a ZigZag-encoded 64-bit value. ZigZag encodes signed integers into values that can be efficiently encoded with varint. (Otherwise, negative values must be sign-extended to 64 bits to be varint encoded, thus always taking 10 bytes on the wire.)

Parameters:

n - A signed 64-bit integer.

Returns:

An unsigned 64-bit integer, stored in a signed int because Java has no explicit unsigned support.

computeVIntSize

public static int computeVIntSize(long param)

Compute the number of bytes that would be needed to encode a varint.

computeUnsignedVIntSize

public static int computeUnsignedVIntSize(long value)

Compute the number of bytes that would be needed to encode an unsigned varint.

checkedCast

public static int checkedCast(long value)