- 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.db.ReadCommandVerbHandler implements org.apache.cassandra.net.IVerbHandler<org.apache.cassandra.db.ReadCommand>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.db.ReadCommandVerbHandler
super_class: java.lang.Object
{
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 // org.apache.cassandra.db.ReadCommandVerbHandler this
0: .line 29
aload 0 /* this */
invokespecial java.lang.Object.<init>:()V
return
end local 0 // org.apache.cassandra.db.ReadCommandVerbHandler this
LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/ReadCommandVerbHandler;
protected org.apache.cassandra.io.IVersionedSerializer<org.apache.cassandra.db.ReadResponse> serializer();
descriptor: ()Lorg/apache/cassandra/io/IVersionedSerializer;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 // org.apache.cassandra.db.ReadCommandVerbHandler this
0: .line 33
getstatic org.apache.cassandra.db.ReadResponse.serializer:Lorg/apache/cassandra/io/IVersionedSerializer;
areturn
end local 0 // org.apache.cassandra.db.ReadCommandVerbHandler this
LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/ReadCommandVerbHandler;
Signature: ()Lorg/apache/cassandra/io/IVersionedSerializer<Lorg/apache/cassandra/db/ReadResponse;>;
public void doVerb(org.apache.cassandra.net.MessageIn<org.apache.cassandra.db.ReadCommand>, );
descriptor: (Lorg/apache/cassandra/net/MessageIn;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=9, args_size=3
start local 0 // org.apache.cassandra.db.ReadCommandVerbHandler this
start local 1 // org.apache.cassandra.net.MessageIn message
start local 2 // int id
0: .line 38
getstatic org.apache.cassandra.service.StorageService.instance:Lorg/apache/cassandra/service/StorageService;
invokevirtual org.apache.cassandra.service.StorageService.isBootstrapMode:()Z
ifeq 2
1: .line 40
new java.lang.RuntimeException
dup
ldc "Cannot service reads while bootstrapping!"
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
2: .line 43
StackMap locals:
StackMap stack:
aload 1 /* message */
getfield org.apache.cassandra.net.MessageIn.payload:Ljava/lang/Object;
checkcast org.apache.cassandra.db.ReadCommand
astore 3 /* command */
start local 3 // org.apache.cassandra.db.ReadCommand command
3: .line 44
aload 3 /* command */
aload 1 /* message */
getfield org.apache.cassandra.net.MessageIn.constructionTime:J
aload 1 /* message */
invokevirtual org.apache.cassandra.net.MessageIn.isCrossNode:()Z
aload 1 /* message */
invokevirtual org.apache.cassandra.net.MessageIn.getTimeout:()J
aload 1 /* message */
invokevirtual org.apache.cassandra.net.MessageIn.getSlowQueryTimeout:()J
invokevirtual org.apache.cassandra.db.ReadCommand.setMonitoringTime:(JZJJ)V
4: .line 47
aconst_null
astore 5
aconst_null
astore 6
5: aload 3 /* command */
invokevirtual org.apache.cassandra.db.ReadCommand.executionController:()Lorg/apache/cassandra/db/ReadExecutionController;
astore 7 /* executionController */
start local 7 // org.apache.cassandra.db.ReadExecutionController executionController
6: .line 48
aload 3 /* command */
aload 7 /* executionController */
invokevirtual org.apache.cassandra.db.ReadCommand.executeLocally:(Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
astore 8 /* iterator */
start local 8 // org.apache.cassandra.db.partitions.UnfilteredPartitionIterator iterator
7: .line 50
aload 3 /* command */
aload 8 /* iterator */
invokevirtual org.apache.cassandra.db.ReadCommand.createResponse:(Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;)Lorg/apache/cassandra/db/ReadResponse;
astore 4 /* response */
start local 4 // org.apache.cassandra.db.ReadResponse response
8: .line 51
aload 8 /* iterator */
ifnull 11
aload 8 /* iterator */
invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.close:()V
goto 11
end local 4 // org.apache.cassandra.db.ReadResponse response
StackMap locals: org.apache.cassandra.db.ReadCommandVerbHandler org.apache.cassandra.net.MessageIn int org.apache.cassandra.db.ReadCommand top java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.db.partitions.UnfilteredPartitionIterator
StackMap stack: java.lang.Throwable
9: astore 5
aload 8 /* iterator */
ifnull 10
aload 8 /* iterator */
invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.close:()V
end local 8 // org.apache.cassandra.db.partitions.UnfilteredPartitionIterator iterator
StackMap locals:
StackMap stack:
10: aload 5
athrow
start local 4 // org.apache.cassandra.db.ReadResponse response
StackMap locals: org.apache.cassandra.db.ReadCommandVerbHandler org.apache.cassandra.net.MessageIn int org.apache.cassandra.db.ReadCommand org.apache.cassandra.db.ReadResponse java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController
StackMap stack:
11: aload 7 /* executionController */
ifnull 19
aload 7 /* executionController */
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
goto 19
end local 4 // org.apache.cassandra.db.ReadResponse response
StackMap locals: org.apache.cassandra.db.ReadCommandVerbHandler org.apache.cassandra.net.MessageIn int org.apache.cassandra.db.ReadCommand top java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController
StackMap stack: java.lang.Throwable
12: astore 6
aload 5
ifnonnull 13
aload 6
astore 5
goto 14
StackMap locals:
StackMap stack:
13: aload 5
aload 6
if_acmpeq 14
aload 5
aload 6
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
14: aload 7 /* executionController */
ifnull 15
aload 7 /* executionController */
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
end local 7 // org.apache.cassandra.db.ReadExecutionController executionController
StackMap locals:
StackMap stack:
15: aload 5
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
16: astore 6
aload 5
ifnonnull 17
aload 6
astore 5
goto 18
StackMap locals:
StackMap stack:
17: aload 5
aload 6
if_acmpeq 18
aload 5
aload 6
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
18: aload 5
athrow
start local 4 // org.apache.cassandra.db.ReadResponse response
19: .line 53
StackMap locals: org.apache.cassandra.db.ReadCommandVerbHandler org.apache.cassandra.net.MessageIn int org.apache.cassandra.db.ReadCommand org.apache.cassandra.db.ReadResponse
StackMap stack:
aload 3 /* command */
invokevirtual org.apache.cassandra.db.ReadCommand.complete:()Z
ifne 23
20: .line 55
ldc "Discarding partial response to {} (timed out)"
aload 1 /* message */
getfield org.apache.cassandra.net.MessageIn.from:Ljava/net/InetAddress;
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;Ljava/lang/Object;)V
21: .line 56
invokestatic org.apache.cassandra.net.MessagingService.instance:()Lorg/apache/cassandra/net/MessagingService;
aload 1 /* message */
aload 1 /* message */
invokevirtual org.apache.cassandra.net.MessageIn.getLifetimeInMS:()J
invokevirtual org.apache.cassandra.net.MessagingService.incrementDroppedMessages:(Lorg/apache/cassandra/net/MessageIn;J)V
22: .line 57
return
23: .line 60
StackMap locals:
StackMap stack:
ldc "Enqueuing response to {}"
aload 1 /* message */
getfield org.apache.cassandra.net.MessageIn.from:Ljava/net/InetAddress;
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;Ljava/lang/Object;)V
24: .line 61
new org.apache.cassandra.net.MessageOut
dup
getstatic org.apache.cassandra.net.MessagingService$Verb.REQUEST_RESPONSE:Lorg/apache/cassandra/net/MessagingService$Verb;
aload 4 /* response */
aload 0 /* this */
invokevirtual org.apache.cassandra.db.ReadCommandVerbHandler.serializer:()Lorg/apache/cassandra/io/IVersionedSerializer;
invokespecial org.apache.cassandra.net.MessageOut.<init>:(Lorg/apache/cassandra/net/MessagingService$Verb;Ljava/lang/Object;Lorg/apache/cassandra/io/IVersionedSerializer;)V
astore 5 /* reply */
start local 5 // org.apache.cassandra.net.MessageOut reply
25: .line 62
invokestatic org.apache.cassandra.net.MessagingService.instance:()Lorg/apache/cassandra/net/MessagingService;
aload 5 /* reply */
iload 2 /* id */
aload 1 /* message */
getfield org.apache.cassandra.net.MessageIn.from:Ljava/net/InetAddress;
invokevirtual org.apache.cassandra.net.MessagingService.sendReply:(Lorg/apache/cassandra/net/MessageOut;ILjava/net/InetAddress;)V
26: .line 63
return
end local 5 // org.apache.cassandra.net.MessageOut reply
end local 4 // org.apache.cassandra.db.ReadResponse response
end local 3 // org.apache.cassandra.db.ReadCommand command
end local 2 // int id
end local 1 // org.apache.cassandra.net.MessageIn message
end local 0 // org.apache.cassandra.db.ReadCommandVerbHandler this
LocalVariableTable:
Start End Slot Name Signature
0 27 0 this Lorg/apache/cassandra/db/ReadCommandVerbHandler;
0 27 1 message Lorg/apache/cassandra/net/MessageIn<Lorg/apache/cassandra/db/ReadCommand;>;
0 27 2 id I
3 27 3 command Lorg/apache/cassandra/db/ReadCommand;
8 9 4 response Lorg/apache/cassandra/db/ReadResponse;
11 12 4 response Lorg/apache/cassandra/db/ReadResponse;
19 27 4 response Lorg/apache/cassandra/db/ReadResponse;
6 15 7 executionController Lorg/apache/cassandra/db/ReadExecutionController;
7 10 8 iterator Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
25 27 5 reply Lorg/apache/cassandra/net/MessageOut<Lorg/apache/cassandra/db/ReadResponse;>;
Exception table:
from to target type
7 8 9 any
6 11 12 any
5 16 16 any
Signature: (Lorg/apache/cassandra/net/MessageIn<Lorg/apache/cassandra/db/ReadCommand;>;I)V
MethodParameters:
Name Flags
message
id
}
Signature: Ljava/lang/Object;Lorg/apache/cassandra/net/IVerbHandler<Lorg/apache/cassandra/db/ReadCommand;>;
SourceFile: "ReadCommandVerbHandler.java"
InnerClasses:
public Verb = org.apache.cassandra.net.MessagingService$Verb of org.apache.cassandra.net.MessagingService