Package org.apache.cassandra.transport

Class CBUtil

java.lang.Object
org.apache.cassandra.transport.CBUtil
public abstract class CBUtil extends Object
ByteBuf utility methods. Note that contrarily to ByteBufferUtil, these method do "read" the ByteBuf advancing its (read) position. They also write by advancing the write position. Functions are also provided to create ByteBuf while avoiding copies.

  • Field Details

    • USE_HEAP_ALLOCATOR

      public static final boolean USE_HEAP_ALLOCATOR

    • allocator

      public static final io.netty.buffer.ByteBufAllocator allocator

  • Method Details

    • readString

      public static String readString(io.netty.buffer.ByteBuf cb)

    • writeAsciiString

      public static void writeAsciiString(String str, io.netty.buffer.ByteBuf cb)
      Write US-ASCII strings. It does not work if containing any char > 0x007F (127)
      Parameters:
      str - satisfies AsciiType i.e. seven-bit ASCII, a.k.a. ISO646-US

    • writeString

      public static void writeString(String str, io.netty.buffer.ByteBuf cb)

    • sizeOfString

      public static int sizeOfString(String str)

    • encodedUTF8Length

      public static int encodedUTF8Length(String str)
      Java uses a Modified UTF-8, whereas Netty uses UTF-8 proper... this means that the encoded UTF8 lengths do not match, and you must be careful to use the correct length method... When using ByteBufUtil.reserveAndWriteUtf8(ByteBuf, CharSequence, int) or similiar logic, you must use this method. When using DataOutput.writeUTF(String) you must use TypeSizes.encodedUTF8Length(String).
      See Also:

    • sizeOfAsciiString

      public static int sizeOfAsciiString(String str)
      Returns the ecoding size of a US-ASCII string. It does not work if containing any char > 0x007F (127)
      Parameters:
      str - satisfies AsciiType i.e. seven-bit ASCII, a.k.a. ISO646-US

    • readLongString

      public static String readLongString(io.netty.buffer.ByteBuf cb)

    • writeLongString

      public static void writeLongString(String str, io.netty.buffer.ByteBuf cb)

    • sizeOfLongString

      public static int sizeOfLongString(String str)

    • readBytes

      public static byte[] readBytes(io.netty.buffer.ByteBuf cb)

    • writeBytes

      public static void writeBytes(byte[] bytes, io.netty.buffer.ByteBuf cb)

    • sizeOfBytes

      public static int sizeOfBytes(byte[] bytes)

    • readBytesMap

      public static Map<String,ByteBuffer> readBytesMap(io.netty.buffer.ByteBuf cb)

    • writeBytesMap

      public static void writeBytesMap(Map<String,ByteBuffer> m, io.netty.buffer.ByteBuf cb)

    • sizeOfBytesMap

      public static int sizeOfBytesMap(Map<String,ByteBuffer> m)

    • readConsistencyLevel

      public static ConsistencyLevel readConsistencyLevel(io.netty.buffer.ByteBuf cb)

    • writeConsistencyLevel

      public static void writeConsistencyLevel(ConsistencyLevel consistency, io.netty.buffer.ByteBuf cb)

    • sizeOfConsistencyLevel

      public static int sizeOfConsistencyLevel(ConsistencyLevel consistency)

    • readEnumValue

      public static <T extends Enum<T>> T readEnumValue(Class<T> enumType, io.netty.buffer.ByteBuf cb)

    • writeEnumValue

      public static <T extends Enum<T>> void writeEnumValue(T enumValue, io.netty.buffer.ByteBuf cb)

    • sizeOfEnumValue

      public static <T extends Enum<T>> int sizeOfEnumValue(T enumValue)

    • readUUID

      public static UUID readUUID(io.netty.buffer.ByteBuf cb)

    • readTimeUUID

      public static TimeUUID readTimeUUID(io.netty.buffer.ByteBuf cb)

    • writeUUID

      public static void writeUUID(UUID uuid, io.netty.buffer.ByteBuf cb)

    • writeUUID

      public static void writeUUID(TimeUUID uuid, io.netty.buffer.ByteBuf cb)

    • sizeOfUUID

      public static int sizeOfUUID(UUID uuid)

    • readStringList

      public static List<String> readStringList(io.netty.buffer.ByteBuf cb)

    • writeStringList

      public static void writeStringList(List<String> l, io.netty.buffer.ByteBuf cb)

    • sizeOfStringList

      public static int sizeOfStringList(List<String> l)

    • readStringMap

      public static Map<String,String> readStringMap(io.netty.buffer.ByteBuf cb)

    • writeStringMap

      public static void writeStringMap(Map<String,String> m, io.netty.buffer.ByteBuf cb)

    • sizeOfStringMap

      public static int sizeOfStringMap(Map<String,String> m)

    • readStringToStringListMap

      public static Map<String,List<String>> readStringToStringListMap(io.netty.buffer.ByteBuf cb)

    • writeStringToStringListMap

      public static void writeStringToStringListMap(Map<String,List<String>> m, io.netty.buffer.ByteBuf cb)

    • sizeOfStringToStringListMap

      public static int sizeOfStringToStringListMap(Map<String,List<String>> m)

    • readValue

      public static ByteBuffer readValue(io.netty.buffer.ByteBuf cb)

    • readValueNoCopy

      public static ByteBuffer readValueNoCopy(io.netty.buffer.ByteBuf cb)

    • readBoundValue

      public static ByteBuffer readBoundValue(io.netty.buffer.ByteBuf cb, ProtocolVersion protocolVersion)

    • writeValue

      public static void writeValue(byte[] bytes, io.netty.buffer.ByteBuf cb)

    • writeValue

      public static void writeValue(ByteBuffer bytes, io.netty.buffer.ByteBuf cb)

    • addBytes

      public static void addBytes(ByteBuffer src, io.netty.buffer.ByteBuf dest)

    • sizeOfValue

      public static int sizeOfValue(byte[] bytes)

    • sizeOfValue

      public static int sizeOfValue(ByteBuffer bytes)

    • sizeOfValue

      public static int sizeOfValue(int valueSize)

    • readValueList

      public static List<ByteBuffer> readValueList(io.netty.buffer.ByteBuf cb, ProtocolVersion protocolVersion)

    • writeValueList

      public static void writeValueList(List<ByteBuffer> values, io.netty.buffer.ByteBuf cb)

    • sizeOfValueList

      public static int sizeOfValueList(List<ByteBuffer> values)

    • readNameAndValueList

      public static Pair<List<String>,List<ByteBuffer>> readNameAndValueList(io.netty.buffer.ByteBuf cb, ProtocolVersion protocolVersion)

    • readInet

      public static InetSocketAddress readInet(io.netty.buffer.ByteBuf cb)

    • writeInet

      public static void writeInet(InetSocketAddress inet, io.netty.buffer.ByteBuf cb)

    • sizeOfInet

      public static int sizeOfInet(InetSocketAddress inet)

    • readInetAddr

      public static InetAddress readInetAddr(io.netty.buffer.ByteBuf cb)

    • writeInetAddr

      public static void writeInetAddr(InetAddress inetAddr, io.netty.buffer.ByteBuf cb)

    • sizeOfInetAddr

      public static int sizeOfInetAddr(InetAddress inetAddr)

    • readRawBytes

      public static byte[] readRawBytes(io.netty.buffer.ByteBuf cb)