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.
  • 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 class org.apache.cassandra.transport.Message$ProtocolDecoder extends io.netty.handler.codec.MessageToMessageDecoder<org.apache.cassandra.transport.Frame>
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.transport.Message$ProtocolDecoder
  super_class: io.netty.handler.codec.MessageToMessageDecoder
{
  static final boolean $assertionsDisabled;
    descriptor: Z
    flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 270
            ldc Lorg/apache/cassandra/transport/Message;
            invokevirtual java.lang.Class.desiredAssertionStatus:()Z
            ifne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: putstatic org.apache.cassandra.transport.Message$ProtocolDecoder.$assertionsDisabled:Z
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.transport.Message$ProtocolDecoder this
         0: .line 270
            aload 0 /* this */
            invokespecial io.netty.handler.codec.MessageToMessageDecoder.<init>:()V
            return
        end local 0 // org.apache.cassandra.transport.Message$ProtocolDecoder this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/transport/Message$ProtocolDecoder;

  public void decode(io.netty.channel.ChannelHandlerContext, org.apache.cassandra.transport.Frame, java.util.List);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Lorg/apache/cassandra/transport/Frame;Ljava/util/List;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=14, args_size=4
        start local 0 // org.apache.cassandra.transport.Message$ProtocolDecoder this
        start local 1 // io.netty.channel.ChannelHandlerContext ctx
        start local 2 // org.apache.cassandra.transport.Frame frame
        start local 3 // java.util.List results
         0: .line 274
            aload 2 /* frame */
            getfield org.apache.cassandra.transport.Frame.header:Lorg/apache/cassandra/transport/Frame$Header;
            getfield org.apache.cassandra.transport.Frame$Header.type:Lorg/apache/cassandra/transport/Message$Type;
            getfield org.apache.cassandra.transport.Message$Type.direction:Lorg/apache/cassandra/transport/Message$Direction;
            getstatic org.apache.cassandra.transport.Message$Direction.REQUEST:Lorg/apache/cassandra/transport/Message$Direction;
            if_acmpne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: istore 4 /* isRequest */
        start local 4 // boolean isRequest
         3: .line 275
            aload 2 /* frame */
            getfield org.apache.cassandra.transport.Frame.header:Lorg/apache/cassandra/transport/Frame$Header;
            getfield org.apache.cassandra.transport.Frame$Header.flags:Ljava/util/EnumSet;
            getstatic org.apache.cassandra.transport.Frame$Header$Flag.TRACING:Lorg/apache/cassandra/transport/Frame$Header$Flag;
            invokevirtual java.util.EnumSet.contains:(Ljava/lang/Object;)Z
            istore 5 /* isTracing */
        start local 5 // boolean isTracing
         4: .line 276
            aload 2 /* frame */
            getfield org.apache.cassandra.transport.Frame.header:Lorg/apache/cassandra/transport/Frame$Header;
            getfield org.apache.cassandra.transport.Frame$Header.flags:Ljava/util/EnumSet;
            getstatic org.apache.cassandra.transport.Frame$Header$Flag.CUSTOM_PAYLOAD:Lorg/apache/cassandra/transport/Frame$Header$Flag;
            invokevirtual java.util.EnumSet.contains:(Ljava/lang/Object;)Z
            istore 6 /* isCustomPayload */
        start local 6 // boolean isCustomPayload
         5: .line 277
            aload 2 /* frame */
            getfield org.apache.cassandra.transport.Frame.header:Lorg/apache/cassandra/transport/Frame$Header;
            getfield org.apache.cassandra.transport.Frame$Header.flags:Ljava/util/EnumSet;
            getstatic org.apache.cassandra.transport.Frame$Header$Flag.WARNING:Lorg/apache/cassandra/transport/Frame$Header$Flag;
            invokevirtual java.util.EnumSet.contains:(Ljava/lang/Object;)Z
            istore 7 /* hasWarning */
        start local 7 // boolean hasWarning
         6: .line 279
            iload 4 /* isRequest */
            ifne 7
            iload 5 /* isTracing */
            ifne 8
      StackMap locals: org.apache.cassandra.transport.Message$ProtocolDecoder io.netty.channel.ChannelHandlerContext org.apache.cassandra.transport.Frame java.util.List int int int int
      StackMap stack:
         7: aconst_null
            goto 9
      StackMap locals:
      StackMap stack:
         8: aload 2 /* frame */
            getfield org.apache.cassandra.transport.Frame.body:Lio/netty/buffer/ByteBuf;
            invokestatic org.apache.cassandra.transport.CBUtil.readUUID:(Lio/netty/buffer/ByteBuf;)Ljava/util/UUID;
      StackMap locals:
      StackMap stack: java.util.UUID
         9: astore 8 /* tracingId */
        start local 8 // java.util.UUID tracingId
        10: .line 280
            iload 4 /* isRequest */
            ifne 11
            iload 7 /* hasWarning */
            ifne 12
      StackMap locals: java.util.UUID
      StackMap stack:
        11: aconst_null
            goto 13
      StackMap locals:
      StackMap stack:
        12: aload 2 /* frame */
            getfield org.apache.cassandra.transport.Frame.body:Lio/netty/buffer/ByteBuf;
            invokestatic org.apache.cassandra.transport.CBUtil.readStringList:(Lio/netty/buffer/ByteBuf;)Ljava/util/List;
      StackMap locals:
      StackMap stack: java.util.List
        13: astore 9 /* warnings */
        start local 9 // java.util.List warnings
        14: .line 281
            iload 6 /* isCustomPayload */
            ifne 15
            aconst_null
            goto 16
      StackMap locals: java.util.List
      StackMap stack:
        15: aload 2 /* frame */
            getfield org.apache.cassandra.transport.Frame.body:Lio/netty/buffer/ByteBuf;
            invokestatic org.apache.cassandra.transport.CBUtil.readBytesMap:(Lio/netty/buffer/ByteBuf;)Ljava/util/Map;
      StackMap locals:
      StackMap stack: java.util.Map
        16: astore 10 /* customPayload */
        start local 10 // java.util.Map customPayload
        17: .line 285
            iload 6 /* isCustomPayload */
            ifeq 19
            aload 2 /* frame */
            getfield org.apache.cassandra.transport.Frame.header:Lorg/apache/cassandra/transport/Frame$Header;
            getfield org.apache.cassandra.transport.Frame$Header.version:Lorg/apache/cassandra/transport/ProtocolVersion;
            getstatic org.apache.cassandra.transport.ProtocolVersion.V4:Lorg/apache/cassandra/transport/ProtocolVersion;
            invokevirtual org.apache.cassandra.transport.ProtocolVersion.isSmallerThan:(Lorg/apache/cassandra/transport/ProtocolVersion;)Z
            ifeq 19
        18: .line 286
            new org.apache.cassandra.transport.ProtocolException
            dup
            ldc "Received frame with CUSTOM_PAYLOAD flag for native protocol version < 4"
            invokespecial org.apache.cassandra.transport.ProtocolException.<init>:(Ljava/lang/String;)V
            athrow
        19: .line 288
      StackMap locals: java.util.Map
      StackMap stack:
            aload 2 /* frame */
            getfield org.apache.cassandra.transport.Frame.header:Lorg/apache/cassandra/transport/Frame$Header;
            getfield org.apache.cassandra.transport.Frame$Header.type:Lorg/apache/cassandra/transport/Message$Type;
            getfield org.apache.cassandra.transport.Message$Type.codec:Lorg/apache/cassandra/transport/Message$Codec;
            aload 2 /* frame */
            getfield org.apache.cassandra.transport.Frame.body:Lio/netty/buffer/ByteBuf;
            aload 2 /* frame */
            getfield org.apache.cassandra.transport.Frame.header:Lorg/apache/cassandra/transport/Frame$Header;
            getfield org.apache.cassandra.transport.Frame$Header.version:Lorg/apache/cassandra/transport/ProtocolVersion;
            invokeinterface org.apache.cassandra.transport.Message$Codec.decode:(Lio/netty/buffer/ByteBuf;Lorg/apache/cassandra/transport/ProtocolVersion;)Ljava/lang/Object;
            checkcast org.apache.cassandra.transport.Message
            astore 11 /* message */
        start local 11 // org.apache.cassandra.transport.Message message
        20: .line 289
            aload 11 /* message */
            aload 2 /* frame */
            getfield org.apache.cassandra.transport.Frame.header:Lorg/apache/cassandra/transport/Frame$Header;
            getfield org.apache.cassandra.transport.Frame$Header.streamId:I
            invokevirtual org.apache.cassandra.transport.Message.setStreamId:(I)Lorg/apache/cassandra/transport/Message;
            pop
        21: .line 290
            aload 11 /* message */
            aload 2 /* frame */
            invokevirtual org.apache.cassandra.transport.Message.setSourceFrame:(Lorg/apache/cassandra/transport/Frame;)V
        22: .line 291
            aload 11 /* message */
            aload 10 /* customPayload */
            invokevirtual org.apache.cassandra.transport.Message.setCustomPayload:(Ljava/util/Map;)V
        23: .line 293
            iload 4 /* isRequest */
            ifeq 31
        24: .line 295
            getstatic org.apache.cassandra.transport.Message$ProtocolDecoder.$assertionsDisabled:Z
            ifne 25
            aload 11 /* message */
            instanceof org.apache.cassandra.transport.Message$Request
            ifne 25
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        25: .line 296
      StackMap locals: org.apache.cassandra.transport.Message
      StackMap stack:
            aload 11 /* message */
            checkcast org.apache.cassandra.transport.Message$Request
            astore 12 /* req */
        start local 12 // org.apache.cassandra.transport.Message$Request req
        26: .line 297
            aload 1 /* ctx */
            invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
            getstatic org.apache.cassandra.transport.Connection.attributeKey:Lio/netty/util/AttributeKey;
            invokeinterface io.netty.channel.Channel.attr:(Lio/netty/util/AttributeKey;)Lio/netty/util/Attribute;
            invokeinterface io.netty.util.Attribute.get:()Ljava/lang/Object;
            checkcast org.apache.cassandra.transport.Connection
            astore 13 /* connection */
        start local 13 // org.apache.cassandra.transport.Connection connection
        27: .line 298
            aload 12 /* req */
            aload 13 /* connection */
            invokevirtual org.apache.cassandra.transport.Message$Request.attach:(Lorg/apache/cassandra/transport/Connection;)V
        28: .line 299
            iload 5 /* isTracing */
            ifeq 36
        29: .line 300
            aload 12 /* req */
            invokevirtual org.apache.cassandra.transport.Message$Request.setTracingRequested:()V
        end local 13 // org.apache.cassandra.transport.Connection connection
        end local 12 // org.apache.cassandra.transport.Message$Request req
        30: .line 301
            goto 36
        31: .line 304
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.transport.Message$ProtocolDecoder.$assertionsDisabled:Z
            ifne 32
            aload 11 /* message */
            instanceof org.apache.cassandra.transport.Message$Response
            ifne 32
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        32: .line 305
      StackMap locals:
      StackMap stack:
            iload 5 /* isTracing */
            ifeq 34
        33: .line 306
            aload 11 /* message */
            checkcast org.apache.cassandra.transport.Message$Response
            aload 8 /* tracingId */
            invokevirtual org.apache.cassandra.transport.Message$Response.setTracingId:(Ljava/util/UUID;)Lorg/apache/cassandra/transport/Message;
            pop
        34: .line 307
      StackMap locals:
      StackMap stack:
            iload 7 /* hasWarning */
            ifeq 36
        35: .line 308
            aload 11 /* message */
            checkcast org.apache.cassandra.transport.Message$Response
            aload 9 /* warnings */
            invokevirtual org.apache.cassandra.transport.Message$Response.setWarnings:(Ljava/util/List;)Lorg/apache/cassandra/transport/Message;
            pop
        36: .line 311
      StackMap locals:
      StackMap stack:
            aload 3 /* results */
            aload 11 /* message */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        end local 11 // org.apache.cassandra.transport.Message message
        37: .line 312
            goto 41
        38: .line 313
      StackMap locals: org.apache.cassandra.transport.Message$ProtocolDecoder io.netty.channel.ChannelHandlerContext org.apache.cassandra.transport.Frame java.util.List int int int int java.util.UUID java.util.List java.util.Map
      StackMap stack: java.lang.Throwable
            astore 11 /* ex */
        start local 11 // java.lang.Throwable ex
        39: .line 315
            aload 2 /* frame */
            invokevirtual org.apache.cassandra.transport.Frame.release:()Z
            pop
        40: .line 317
            aload 11 /* ex */
            aload 2 /* frame */
            getfield org.apache.cassandra.transport.Frame.header:Lorg/apache/cassandra/transport/Frame$Header;
            getfield org.apache.cassandra.transport.Frame$Header.streamId:I
            invokestatic org.apache.cassandra.transport.messages.ErrorMessage.wrap:(Ljava/lang/Throwable;I)Ljava/lang/RuntimeException;
            athrow
        end local 11 // java.lang.Throwable ex
        41: .line 319
      StackMap locals:
      StackMap stack:
            return
        end local 10 // java.util.Map customPayload
        end local 9 // java.util.List warnings
        end local 8 // java.util.UUID tracingId
        end local 7 // boolean hasWarning
        end local 6 // boolean isCustomPayload
        end local 5 // boolean isTracing
        end local 4 // boolean isRequest
        end local 3 // java.util.List results
        end local 2 // org.apache.cassandra.transport.Frame frame
        end local 1 // io.netty.channel.ChannelHandlerContext ctx
        end local 0 // org.apache.cassandra.transport.Message$ProtocolDecoder this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   42     0             this  Lorg/apache/cassandra/transport/Message$ProtocolDecoder;
            0   42     1              ctx  Lio/netty/channel/ChannelHandlerContext;
            0   42     2            frame  Lorg/apache/cassandra/transport/Frame;
            0   42     3          results  Ljava/util/List;
            3   42     4        isRequest  Z
            4   42     5        isTracing  Z
            5   42     6  isCustomPayload  Z
            6   42     7       hasWarning  Z
           10   42     8        tracingId  Ljava/util/UUID;
           14   42     9         warnings  Ljava/util/List<Ljava/lang/String;>;
           17   42    10    customPayload  Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;
           20   37    11          message  Lorg/apache/cassandra/transport/Message;
           26   30    12              req  Lorg/apache/cassandra/transport/Message$Request;
           27   30    13       connection  Lorg/apache/cassandra/transport/Connection;
           39   41    11               ex  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
          17    37      38  Class java.lang.Throwable
    MethodParameters:
         Name  Flags
      ctx      
      frame    
      results  

  public void decode(io.netty.channel.ChannelHandlerContext, java.lang.Object, java.util.List);
    descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;Ljava/util/List;)V
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=4
         0: .line 1
            aload 0
            aload 1
            aload 2
            checkcast org.apache.cassandra.transport.Frame
            aload 3
            checkcast java.util.List
            invokevirtual org.apache.cassandra.transport.Message$ProtocolDecoder.decode:(Lio/netty/channel/ChannelHandlerContext;Lorg/apache/cassandra/transport/Frame;Ljava/util/List;)V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Exceptions:
      throws java.lang.Exception
}
Signature: Lio/netty/handler/codec/MessageToMessageDecoder<Lorg/apache/cassandra/transport/Frame;>;
SourceFile: "Message.java"
NestHost: org.apache.cassandra.transport.Message
InnerClasses:
  public abstract Sharable = io.netty.channel.ChannelHandler$Sharable of io.netty.channel.ChannelHandler
  public Header = org.apache.cassandra.transport.Frame$Header of org.apache.cassandra.transport.Frame
  public final Flag = org.apache.cassandra.transport.Frame$Header$Flag of org.apache.cassandra.transport.Frame$Header
  public abstract Codec = org.apache.cassandra.transport.Message$Codec of org.apache.cassandra.transport.Message
  public final Direction = org.apache.cassandra.transport.Message$Direction of org.apache.cassandra.transport.Message
  public ProtocolDecoder = org.apache.cassandra.transport.Message$ProtocolDecoder of org.apache.cassandra.transport.Message
  public abstract Request = org.apache.cassandra.transport.Message$Request of org.apache.cassandra.transport.Message
  public abstract Response = org.apache.cassandra.transport.Message$Response of org.apache.cassandra.transport.Message
  public final Type = org.apache.cassandra.transport.Message$Type of org.apache.cassandra.transport.Message
    RuntimeVisibleAnnotations: 
      io.netty.channel.ChannelHandler$Sharable()