org.apache.cassandra/cassandra-all/3.11.5 : org/apache/cassandra/transport/DataType$Codec.class

DataType$Codec
https://cassandra.apache.org: The Apache Cassandra Project develops a highly scalable second-generation distributed database, bringing together Dynamo's fully distributed design and Bigtable's ColumnFamily-based data model.
The Apache Software License, Version 2.0
Andres de la Peña
Avinash Lakshman
Aleksey Yeschenko
Aaron Morton
Ariel Weisberg
Blake Eggleston
Benedict Elliott Smith
Benjamin Lerer
Branimir Lambov
Brandon Williams
Carl Yeksigian
David Brosiusd
Dikang Gu
Eric Evans
Gary Dusbabek
Chris Goffinet
Alex Petrov
Laine Jaakko Olavi
T Jake Luciani
Jason Brown
Jonathan Ellis
Jake Farrell
Jeff Jirsa
Joel Knighton
Josh McKenzie
Johan Oskarsson
Jun Rao
Jay Zhuang
Sankalp Kohli
Marcus Eriksson
Michael Semb Wever
Mikhail Stepura
Michael Shuler
Paulo Motta
Prashant Malik
Robert Stupp
Peter Schuller
Sam Tunnicliffe
Sylvain Lebresne
Stefania Alborghetti
Tyler Hobbs
Vijay Parthasarathy
Pavel Yaskevich
Yuki Morishita
Nate McCall
public final class org.apache.cassandra.transport.DataType$Codec
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: org.apache.cassandra.transport.DataType$Codec
  super_class: java.lang.Object
{
  private final org.apache.cassandra.transport.DataType[] ids;
    descriptor: [Lorg/apache/cassandra/transport/DataType;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=8, args_size=1
        start local 0 // org.apache.cassandra.transport.DataType$Codec this
         0: .line 311
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 313
            invokestatic org.apache.cassandra.transport.DataType.values:()[Lorg/apache/cassandra/transport/DataType;
            astore 1 /* values */
        start local 1 // org.apache.cassandra.transport.DataType[] values
         2: .line 314
            aload 0 /* this */
            aload 0 /* this */
            aload 1 /* values */
            invokevirtual org.apache.cassandra.transport.DataType$Codec.getMaxId:([Lorg/apache/cassandra/transport/DataType;)I
            iconst_1
            iadd
            anewarray org.apache.cassandra.transport.DataType
            putfield org.apache.cassandra.transport.DataType$Codec.ids:[Lorg/apache/cassandra/transport/DataType;
         3: .line 315
            aload 1 /* values */
            dup
            astore 5
            arraylength
            istore 4
            iconst_0
            istore 3
            goto 11
      StackMap locals: org.apache.cassandra.transport.DataType$Codec org.apache.cassandra.transport.DataType[] top int int org.apache.cassandra.transport.DataType[]
      StackMap stack:
         4: aload 5
            iload 3
            aaload
            astore 2 /* opt */
        start local 2 // org.apache.cassandra.transport.DataType opt
         5: .line 317
            aload 2 /* opt */
            aload 2 /* opt */
            invokevirtual org.apache.cassandra.transport.DataType.getProtocolVersion:()Lorg/apache/cassandra/transport/ProtocolVersion;
            invokevirtual org.apache.cassandra.transport.DataType.getId:(Lorg/apache/cassandra/transport/ProtocolVersion;)I
            istore 6 /* id */
        start local 6 // int id
         6: .line 318
            aload 0 /* this */
            getfield org.apache.cassandra.transport.DataType$Codec.ids:[Lorg/apache/cassandra/transport/DataType;
            iload 6 /* id */
            aaload
            astore 7 /* existingType */
        start local 7 // org.apache.cassandra.transport.DataType existingType
         7: .line 319
            aload 7 /* existingType */
            ifnull 9
         8: .line 320
            new java.lang.IllegalStateException
            dup
            ldc "Duplicate option id %d"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            iload 6 /* id */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
         9: .line 321
      StackMap locals: org.apache.cassandra.transport.DataType$Codec org.apache.cassandra.transport.DataType[] org.apache.cassandra.transport.DataType int int org.apache.cassandra.transport.DataType[] int org.apache.cassandra.transport.DataType
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.transport.DataType$Codec.ids:[Lorg/apache/cassandra/transport/DataType;
            iload 6 /* id */
            aload 2 /* opt */
            aastore
        end local 7 // org.apache.cassandra.transport.DataType existingType
        end local 6 // int id
        end local 2 // org.apache.cassandra.transport.DataType opt
        10: .line 315
            iinc 3 1
      StackMap locals: org.apache.cassandra.transport.DataType$Codec org.apache.cassandra.transport.DataType[] top int int org.apache.cassandra.transport.DataType[]
      StackMap stack:
        11: iload 3
            iload 4
            if_icmplt 4
        12: .line 323
            return
        end local 1 // org.apache.cassandra.transport.DataType[] values
        end local 0 // org.apache.cassandra.transport.DataType$Codec this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   13     0          this  Lorg/apache/cassandra/transport/DataType$Codec;
            2   13     1        values  [Lorg/apache/cassandra/transport/DataType;
            5   10     2           opt  Lorg/apache/cassandra/transport/DataType;
            6   10     6            id  I
            7   10     7  existingType  Lorg/apache/cassandra/transport/DataType;

  private int getMaxId(org.apache.cassandra.transport.DataType[]);
    descriptor: ([Lorg/apache/cassandra/transport/DataType;)I
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=7, args_size=2
        start local 0 // org.apache.cassandra.transport.DataType$Codec this
        start local 1 // org.apache.cassandra.transport.DataType[] values
         0: .line 327
            iconst_m1
            istore 2 /* maxId */
        start local 2 // int maxId
         1: .line 328
            aload 1 /* values */
            dup
            astore 6
            arraylength
            istore 5
            iconst_0
            istore 4
            goto 5
      StackMap locals: org.apache.cassandra.transport.DataType$Codec org.apache.cassandra.transport.DataType[] int top int int org.apache.cassandra.transport.DataType[]
      StackMap stack:
         2: aload 6
            iload 4
            aaload
            astore 3 /* opt */
        start local 3 // org.apache.cassandra.transport.DataType opt
         3: .line 329
            iload 2 /* maxId */
            aload 3 /* opt */
            getstatic org.apache.cassandra.transport.ProtocolVersion.CURRENT:Lorg/apache/cassandra/transport/ProtocolVersion;
            invokevirtual org.apache.cassandra.transport.DataType.getId:(Lorg/apache/cassandra/transport/ProtocolVersion;)I
            invokestatic java.lang.Math.max:(II)I
            istore 2 /* maxId */
        end local 3 // org.apache.cassandra.transport.DataType opt
         4: .line 328
            iinc 4 1
      StackMap locals:
      StackMap stack:
         5: iload 4
            iload 5
            if_icmplt 2
         6: .line 330
            iload 2 /* maxId */
            ireturn
        end local 2 // int maxId
        end local 1 // org.apache.cassandra.transport.DataType[] values
        end local 0 // org.apache.cassandra.transport.DataType$Codec this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    7     0    this  Lorg/apache/cassandra/transport/DataType$Codec;
            0    7     1  values  [Lorg/apache/cassandra/transport/DataType;
            1    7     2   maxId  I
            3    4     3     opt  Lorg/apache/cassandra/transport/DataType;
    MethodParameters:
        Name  Flags
      values  

  private org.apache.cassandra.transport.DataType fromId(int);
    descriptor: (I)Lorg/apache/cassandra/transport/DataType;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=7, locals=3, args_size=2
        start local 0 // org.apache.cassandra.transport.DataType$Codec this
        start local 1 // int id
         0: .line 335
            aload 0 /* this */
            getfield org.apache.cassandra.transport.DataType$Codec.ids:[Lorg/apache/cassandra/transport/DataType;
            iload 1 /* id */
            aaload
            astore 2 /* opt */
        start local 2 // org.apache.cassandra.transport.DataType opt
         1: .line 336
            aload 2 /* opt */
            ifnonnull 3
         2: .line 337
            new org.apache.cassandra.transport.ProtocolException
            dup
            ldc "Unknown option id %d"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            iload 1 /* id */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            invokespecial org.apache.cassandra.transport.ProtocolException.<init>:(Ljava/lang/String;)V
            athrow
         3: .line 338
      StackMap locals: org.apache.cassandra.transport.DataType
      StackMap stack:
            aload 2 /* opt */
            areturn
        end local 2 // org.apache.cassandra.transport.DataType opt
        end local 1 // int id
        end local 0 // org.apache.cassandra.transport.DataType$Codec this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/apache/cassandra/transport/DataType$Codec;
            0    4     1    id  I
            1    4     2   opt  Lorg/apache/cassandra/transport/DataType;
    MethodParameters:
      Name  Flags
      id    

  public org.apache.cassandra.utils.Pair<org.apache.cassandra.transport.DataType, java.lang.Object> decodeOne(io.netty.buffer.ByteBuf, org.apache.cassandra.transport.ProtocolVersion);
    descriptor: (Lio/netty/buffer/ByteBuf;Lorg/apache/cassandra/transport/ProtocolVersion;)Lorg/apache/cassandra/utils/Pair;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=5, args_size=3
        start local 0 // org.apache.cassandra.transport.DataType$Codec this
        start local 1 // io.netty.buffer.ByteBuf body
        start local 2 // org.apache.cassandra.transport.ProtocolVersion version
         0: .line 343
            aload 0 /* this */
            aload 1 /* body */
            invokevirtual io.netty.buffer.ByteBuf.readUnsignedShort:()I
            invokevirtual org.apache.cassandra.transport.DataType$Codec.fromId:(I)Lorg/apache/cassandra/transport/DataType;
            astore 3 /* opt */
        start local 3 // org.apache.cassandra.transport.DataType opt
         1: .line 344
            aload 3 /* opt */
            aload 1 /* body */
            aload 2 /* version */
            invokevirtual org.apache.cassandra.transport.DataType.readValue:(Lio/netty/buffer/ByteBuf;Lorg/apache/cassandra/transport/ProtocolVersion;)Ljava/lang/Object;
            astore 4 /* value */
        start local 4 // java.lang.Object value
         2: .line 345
            aload 3 /* opt */
            aload 4 /* value */
            invokestatic org.apache.cassandra.utils.Pair.create:(Ljava/lang/Object;Ljava/lang/Object;)Lorg/apache/cassandra/utils/Pair;
            areturn
        end local 4 // java.lang.Object value
        end local 3 // org.apache.cassandra.transport.DataType opt
        end local 2 // org.apache.cassandra.transport.ProtocolVersion version
        end local 1 // io.netty.buffer.ByteBuf body
        end local 0 // org.apache.cassandra.transport.DataType$Codec this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lorg/apache/cassandra/transport/DataType$Codec;
            0    3     1     body  Lio/netty/buffer/ByteBuf;
            0    3     2  version  Lorg/apache/cassandra/transport/ProtocolVersion;
            1    3     3      opt  Lorg/apache/cassandra/transport/DataType;
            2    3     4    value  Ljava/lang/Object;
    Signature: (Lio/netty/buffer/ByteBuf;Lorg/apache/cassandra/transport/ProtocolVersion;)Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/transport/DataType;Ljava/lang/Object;>;
    MethodParameters:
         Name  Flags
      body     
      version  

  public void writeOne(org.apache.cassandra.utils.Pair<org.apache.cassandra.transport.DataType, java.lang.Object>, io.netty.buffer.ByteBuf, org.apache.cassandra.transport.ProtocolVersion);
    descriptor: (Lorg/apache/cassandra/utils/Pair;Lio/netty/buffer/ByteBuf;Lorg/apache/cassandra/transport/ProtocolVersion;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=6, args_size=4
        start local 0 // org.apache.cassandra.transport.DataType$Codec this
        start local 1 // org.apache.cassandra.utils.Pair option
        start local 2 // io.netty.buffer.ByteBuf dest
        start local 3 // org.apache.cassandra.transport.ProtocolVersion version
         0: .line 350
            aload 1 /* option */
            getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
            checkcast org.apache.cassandra.transport.DataType
            astore 4 /* opt */
        start local 4 // org.apache.cassandra.transport.DataType opt
         1: .line 351
            aload 1 /* option */
            getfield org.apache.cassandra.utils.Pair.right:Ljava/lang/Object;
            astore 5 /* obj */
        start local 5 // java.lang.Object obj
         2: .line 352
            aload 2 /* dest */
            aload 4 /* opt */
            aload 3 /* version */
            invokevirtual org.apache.cassandra.transport.DataType.getId:(Lorg/apache/cassandra/transport/ProtocolVersion;)I
            invokevirtual io.netty.buffer.ByteBuf.writeShort:(I)Lio/netty/buffer/ByteBuf;
            pop
         3: .line 353
            aload 4 /* opt */
            aload 5 /* obj */
            aload 2 /* dest */
            aload 3 /* version */
            invokevirtual org.apache.cassandra.transport.DataType.writeValue:(Ljava/lang/Object;Lio/netty/buffer/ByteBuf;Lorg/apache/cassandra/transport/ProtocolVersion;)V
         4: .line 354
            return
        end local 5 // java.lang.Object obj
        end local 4 // org.apache.cassandra.transport.DataType opt
        end local 3 // org.apache.cassandra.transport.ProtocolVersion version
        end local 2 // io.netty.buffer.ByteBuf dest
        end local 1 // org.apache.cassandra.utils.Pair option
        end local 0 // org.apache.cassandra.transport.DataType$Codec this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    5     0     this  Lorg/apache/cassandra/transport/DataType$Codec;
            0    5     1   option  Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/transport/DataType;Ljava/lang/Object;>;
            0    5     2     dest  Lio/netty/buffer/ByteBuf;
            0    5     3  version  Lorg/apache/cassandra/transport/ProtocolVersion;
            1    5     4      opt  Lorg/apache/cassandra/transport/DataType;
            2    5     5      obj  Ljava/lang/Object;
    Signature: (Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/transport/DataType;Ljava/lang/Object;>;Lio/netty/buffer/ByteBuf;Lorg/apache/cassandra/transport/ProtocolVersion;)V
    MethodParameters:
         Name  Flags
      option   
      dest     
      version  

  public int oneSerializedSize(org.apache.cassandra.utils.Pair<org.apache.cassandra.transport.DataType, java.lang.Object>, org.apache.cassandra.transport.ProtocolVersion);
    descriptor: (Lorg/apache/cassandra/utils/Pair;Lorg/apache/cassandra/transport/ProtocolVersion;)I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=5, args_size=3
        start local 0 // org.apache.cassandra.transport.DataType$Codec this
        start local 1 // org.apache.cassandra.utils.Pair option
        start local 2 // org.apache.cassandra.transport.ProtocolVersion version
         0: .line 358
            aload 1 /* option */
            getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
            checkcast org.apache.cassandra.transport.DataType
            astore 3 /* opt */
        start local 3 // org.apache.cassandra.transport.DataType opt
         1: .line 359
            aload 1 /* option */
            getfield org.apache.cassandra.utils.Pair.right:Ljava/lang/Object;
            astore 4 /* obj */
        start local 4 // java.lang.Object obj
         2: .line 360
            iconst_2
            aload 3 /* opt */
            aload 4 /* obj */
            aload 2 /* version */
            invokevirtual org.apache.cassandra.transport.DataType.serializedValueSize:(Ljava/lang/Object;Lorg/apache/cassandra/transport/ProtocolVersion;)I
            iadd
            ireturn
        end local 4 // java.lang.Object obj
        end local 3 // org.apache.cassandra.transport.DataType opt
        end local 2 // org.apache.cassandra.transport.ProtocolVersion version
        end local 1 // org.apache.cassandra.utils.Pair option
        end local 0 // org.apache.cassandra.transport.DataType$Codec this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lorg/apache/cassandra/transport/DataType$Codec;
            0    3     1   option  Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/transport/DataType;Ljava/lang/Object;>;
            0    3     2  version  Lorg/apache/cassandra/transport/ProtocolVersion;
            1    3     3      opt  Lorg/apache/cassandra/transport/DataType;
            2    3     4      obj  Ljava/lang/Object;
    Signature: (Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/transport/DataType;Ljava/lang/Object;>;Lorg/apache/cassandra/transport/ProtocolVersion;)I
    MethodParameters:
         Name  Flags
      option   
      version  
}
SourceFile: "DataType.java"
NestHost: org.apache.cassandra.transport.DataType
InnerClasses:
  public final Codec = org.apache.cassandra.transport.DataType$Codec of org.apache.cassandra.transport.DataType
/

org.apache.cassandra/ cassandra-all/ 3.11.5/ org/apache/cassandra/transport/DataType$Codec.class
