public final class org.apache.cassandra.hints.HintVerbHandler implements org.apache.cassandra.net.IVerbHandler<org.apache.cassandra.hints.HintMessage>
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: org.apache.cassandra.hints.HintVerbHandler
super_class: java.lang.Object
{
private static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/hints/HintVerbHandler;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.hints.HintVerbHandler.logger:Lorg/slf4j/Logger;
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 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/hints/HintVerbHandler;
public void doVerb(org.apache.cassandra.net.MessageIn<org.apache.cassandra.hints.HintMessage>, );
descriptor: (Lorg/apache/cassandra/net/MessageIn;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 1
getfield org.apache.cassandra.net.MessageIn.payload:Ljava/lang/Object;
checkcast org.apache.cassandra.hints.HintMessage
getfield org.apache.cassandra.hints.HintMessage.hostId:Ljava/util/UUID;
astore 3
start local 3 1: aload 1
getfield org.apache.cassandra.net.MessageIn.payload:Ljava/lang/Object;
checkcast org.apache.cassandra.hints.HintMessage
getfield org.apache.cassandra.hints.HintMessage.hint:Lorg/apache/cassandra/hints/Hint;
astore 4
start local 4 2: getstatic org.apache.cassandra.service.StorageService.instance:Lorg/apache/cassandra/service/StorageService;
aload 3
invokevirtual org.apache.cassandra.service.StorageService.getEndpointForHostId:(Ljava/util/UUID;)Ljava/net/InetAddress;
astore 5
start local 5 3: aload 4
ifnonnull 11
4: getstatic org.apache.cassandra.hints.HintVerbHandler.logger:Lorg/slf4j/Logger;
ldc "Failed to decode and apply a hint for {}: {} - table with id {} is unknown"
iconst_3
anewarray java.lang.Object
dup
iconst_0
5: aload 5
aastore
dup
iconst_1
6: aload 3
aastore
dup
iconst_2
7: aload 1
getfield org.apache.cassandra.net.MessageIn.payload:Ljava/lang/Object;
checkcast org.apache.cassandra.hints.HintMessage
getfield org.apache.cassandra.hints.HintMessage.unknownTableID:Ljava/util/UUID;
aastore
8: invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;[Ljava/lang/Object;)V
9: iload 2
aload 1
getfield org.apache.cassandra.net.MessageIn.from:Ljava/net/InetAddress;
invokestatic org.apache.cassandra.hints.HintVerbHandler.reply:(ILjava/net/InetAddress;)V
10: return
11: StackMap locals: java.util.UUID org.apache.cassandra.hints.Hint java.net.InetAddress
StackMap stack:
aload 4
getfield org.apache.cassandra.hints.Hint.mutation:Lorg/apache/cassandra/db/Mutation;
invokevirtual org.apache.cassandra.db.Mutation.getPartitionUpdates:()Ljava/util/Collection;
invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/partitions/PartitionUpdate.validate()V (5)
(Lorg/apache/cassandra/db/partitions/PartitionUpdate;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
12: goto 17
13: StackMap locals:
StackMap stack: org.apache.cassandra.serializers.MarshalException
pop
14: getstatic org.apache.cassandra.hints.HintVerbHandler.logger:Lorg/slf4j/Logger;
ldc "Failed to validate a hint for {}: {} - skipped"
aload 5
aload 3
invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
15: iload 2
aload 1
getfield org.apache.cassandra.net.MessageIn.from:Ljava/net/InetAddress;
invokestatic org.apache.cassandra.hints.HintVerbHandler.reply:(ILjava/net/InetAddress;)V
16: return
17: StackMap locals:
StackMap stack:
aload 3
getstatic org.apache.cassandra.service.StorageService.instance:Lorg/apache/cassandra/service/StorageService;
invokevirtual org.apache.cassandra.service.StorageService.getLocalHostUUID:()Ljava/util/UUID;
invokevirtual java.util.UUID.equals:(Ljava/lang/Object;)Z
ifne 21
18: getstatic org.apache.cassandra.hints.HintsService.instance:Lorg/apache/cassandra/hints/HintsService;
aload 3
aload 4
invokevirtual org.apache.cassandra.hints.HintsService.write:(Ljava/util/UUID;Lorg/apache/cassandra/hints/Hint;)V
19: iload 2
aload 1
getfield org.apache.cassandra.net.MessageIn.from:Ljava/net/InetAddress;
invokestatic org.apache.cassandra.hints.HintVerbHandler.reply:(ILjava/net/InetAddress;)V
20: goto 26
21: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.service.StorageProxy.instance:Lorg/apache/cassandra/service/StorageProxy;
aload 4
getfield org.apache.cassandra.hints.Hint.mutation:Lorg/apache/cassandra/db/Mutation;
invokevirtual org.apache.cassandra.service.StorageProxy.appliesLocally:(Lorg/apache/cassandra/db/Mutation;)Z
ifne 25
22: getstatic org.apache.cassandra.hints.HintsService.instance:Lorg/apache/cassandra/hints/HintsService;
aload 4
invokevirtual org.apache.cassandra.hints.HintsService.writeForAllReplicas:(Lorg/apache/cassandra/hints/Hint;)V
23: iload 2
aload 1
getfield org.apache.cassandra.net.MessageIn.from:Ljava/net/InetAddress;
invokestatic org.apache.cassandra.hints.HintVerbHandler.reply:(ILjava/net/InetAddress;)V
24: goto 26
25: StackMap locals:
StackMap stack:
aload 4
invokevirtual org.apache.cassandra.hints.Hint.applyFuture:()Ljava/util/concurrent/CompletableFuture;
iload 2
aload 1
invokedynamic accept(ILorg/apache/cassandra/net/MessageIn;)Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/hints/HintVerbHandler.lambda$1(ILorg/apache/cassandra/net/MessageIn;Ljava/lang/Object;)V (6)
(Ljava/lang/Object;)V
invokevirtual java.util.concurrent.CompletableFuture.thenAccept:(Ljava/util/function/Consumer;)Ljava/util/concurrent/CompletableFuture;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/hints/HintVerbHandler.lambda$2(Ljava/lang/Throwable;)Ljava/lang/Void; (6)
(Ljava/lang/Throwable;)Ljava/lang/Void;
invokevirtual java.util.concurrent.CompletableFuture.exceptionally:(Ljava/util/function/Function;)Ljava/util/concurrent/CompletableFuture;
pop
26: StackMap locals:
StackMap stack:
return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 27 0 this Lorg/apache/cassandra/hints/HintVerbHandler;
0 27 1 message Lorg/apache/cassandra/net/MessageIn<Lorg/apache/cassandra/hints/HintMessage;>;
0 27 2 id I
1 27 3 hostId Ljava/util/UUID;
2 27 4 hint Lorg/apache/cassandra/hints/Hint;
3 27 5 address Ljava/net/InetAddress;
Exception table:
from to target type
11 12 13 Class org.apache.cassandra.serializers.MarshalException
Signature: (Lorg/apache/cassandra/net/MessageIn<Lorg/apache/cassandra/hints/HintMessage;>;I)V
MethodParameters:
Name Flags
message
id
private static void reply(int, java.net.InetAddress);
descriptor: (ILjava/net/InetAddress;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: invokestatic org.apache.cassandra.net.MessagingService.instance:()Lorg/apache/cassandra/net/MessagingService;
getstatic org.apache.cassandra.hints.HintResponse.message:Lorg/apache/cassandra/net/MessageOut;
iload 0
aload 1
invokevirtual org.apache.cassandra.net.MessagingService.sendReply:(Lorg/apache/cassandra/net/MessageOut;ILjava/net/InetAddress;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 id I
0 2 1 to Ljava/net/InetAddress;
MethodParameters:
Name Flags
id
to
private static void lambda$1(int, org.apache.cassandra.net.MessageIn, java.lang.Object);
descriptor: (ILorg/apache/cassandra/net/MessageIn;Ljava/lang/Object;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 2 0: iload 0
aload 1
getfield org.apache.cassandra.net.MessageIn.from:Ljava/net/InetAddress;
invokestatic org.apache.cassandra.hints.HintVerbHandler.reply:(ILjava/net/InetAddress;)V
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 1 2 o Ljava/lang/Object;
private static java.lang.Void lambda$2(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Ljava/lang/Void;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.hints.HintVerbHandler.logger:Lorg/slf4j/Logger;
ldc "Failed to apply hint"
aload 0
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Throwable;)V
aconst_null
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 e Ljava/lang/Throwable;
}
Signature: Ljava/lang/Object;Lorg/apache/cassandra/net/IVerbHandler<Lorg/apache/cassandra/hints/HintMessage;>;
SourceFile: "HintVerbHandler.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles