class org.apache.cassandra.service.StorageProxy$11 extends org.apache.cassandra.service.StorageProxy$HintRunnable
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.apache.cassandra.service.StorageProxy$11
super_class: org.apache.cassandra.service.StorageProxy$HintRunnable
{
private final org.apache.cassandra.db.Mutation val$mutation;
descriptor: Lorg/apache/cassandra/db/Mutation;
flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC
private final org.apache.cassandra.service.AbstractWriteResponseHandler val$responseHandler;
descriptor: Lorg/apache/cassandra/service/AbstractWriteResponseHandler;
flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC
void <init>(java.util.Collection, org.apache.cassandra.db.Mutation, org.apache.cassandra.service.AbstractWriteResponseHandler);
descriptor: (Ljava/util/Collection;Lorg/apache/cassandra/db/Mutation;Lorg/apache/cassandra/service/AbstractWriteResponseHandler;)V
flags: (0x0000)
Code:
stack=2, locals=4, args_size=4
start local 0 start local 1 0: aload 0
aload 2
putfield org.apache.cassandra.service.StorageProxy$11.val$mutation:Lorg/apache/cassandra/db/Mutation;
aload 0
aload 3
putfield org.apache.cassandra.service.StorageProxy$11.val$responseHandler:Lorg/apache/cassandra/service/AbstractWriteResponseHandler;
aload 0
aload 1
invokespecial org.apache.cassandra.service.StorageProxy$HintRunnable.<init>:(Ljava/util/Collection;)V
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/service/StorageProxy$11;
0 1 1 $anonymous0 Ljava/util/Collection<Ljava/net/InetAddress;>;
MethodParameters:
Name Flags
$anonymous0
val$mutation final
val$responseHandler final
public void runMayThrow();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=6, args_size=1
start local 0 0: new java.util.HashSet
dup
aload 0
getfield org.apache.cassandra.service.StorageProxy$11.targets:Ljava/util/Collection;
invokeinterface java.util.Collection.size:()I
invokespecial java.util.HashSet.<init>:(I)V
astore 1
start local 1 1: new java.util.HashSet
dup
aload 0
getfield org.apache.cassandra.service.StorageProxy$11.targets:Ljava/util/Collection;
invokeinterface java.util.Collection.size:()I
invokespecial java.util.HashSet.<init>:(I)V
astore 2
start local 2 2: aload 0
getfield org.apache.cassandra.service.StorageProxy$11.targets:Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 4
goto 10
StackMap locals: org.apache.cassandra.service.StorageProxy$11 java.util.Set java.util.Set top java.util.Iterator
StackMap stack:
3: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.net.InetAddress
astore 3
start local 3 4: getstatic org.apache.cassandra.service.StorageService.instance:Lorg/apache/cassandra/service/StorageService;
aload 3
invokevirtual org.apache.cassandra.service.StorageService.getHostIdForEndpoint:(Ljava/net/InetAddress;)Ljava/util/UUID;
astore 5
start local 5 5: aload 5
ifnull 9
6: aload 2
aload 5
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
7: aload 1
aload 3
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
8: goto 10
9: StackMap locals: org.apache.cassandra.service.StorageProxy$11 java.util.Set java.util.Set java.net.InetAddress java.util.Iterator java.util.UUID
StackMap stack:
getstatic org.apache.cassandra.service.StorageProxy.logger:Lorg/slf4j/Logger;
ldc "Discarding hint for endpoint not part of ring: {}"
aload 3
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
end local 5 end local 3 10: StackMap locals: org.apache.cassandra.service.StorageProxy$11 java.util.Set java.util.Set top java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
11: getstatic org.apache.cassandra.service.StorageProxy.logger:Lorg/slf4j/Logger;
ldc "Adding hints for {}"
aload 1
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
12: getstatic org.apache.cassandra.hints.HintsService.instance:Lorg/apache/cassandra/hints/HintsService;
aload 2
aload 0
getfield org.apache.cassandra.service.StorageProxy$11.val$mutation:Lorg/apache/cassandra/db/Mutation;
invokestatic java.lang.System.currentTimeMillis:()J
invokestatic org.apache.cassandra.hints.Hint.create:(Lorg/apache/cassandra/db/Mutation;J)Lorg/apache/cassandra/hints/Hint;
invokevirtual org.apache.cassandra.hints.HintsService.write:(Ljava/lang/Iterable;Lorg/apache/cassandra/hints/Hint;)V
13: aload 1
getstatic org.apache.cassandra.hints.HintsService.instance:Lorg/apache/cassandra/hints/HintsService;
getfield org.apache.cassandra.hints.HintsService.metrics:Lorg/apache/cassandra/metrics/HintedHandoffMetrics;
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic accept(Lorg/apache/cassandra/metrics/HintedHandoffMetrics;)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/metrics/HintedHandoffMetrics.incrCreatedHints(Ljava/net/InetAddress;)V (5)
(Ljava/net/InetAddress;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
14: aload 0
getfield org.apache.cassandra.service.StorageProxy$11.val$responseHandler:Lorg/apache/cassandra/service/AbstractWriteResponseHandler;
ifnull 16
aload 0
getfield org.apache.cassandra.service.StorageProxy$11.val$responseHandler:Lorg/apache/cassandra/service/AbstractWriteResponseHandler;
getfield org.apache.cassandra.service.AbstractWriteResponseHandler.consistencyLevel:Lorg/apache/cassandra/db/ConsistencyLevel;
getstatic org.apache.cassandra.db.ConsistencyLevel.ANY:Lorg/apache/cassandra/db/ConsistencyLevel;
if_acmpne 16
15: aload 0
getfield org.apache.cassandra.service.StorageProxy$11.val$responseHandler:Lorg/apache/cassandra/service/AbstractWriteResponseHandler;
aconst_null
invokevirtual org.apache.cassandra.service.AbstractWriteResponseHandler.response:(Lorg/apache/cassandra/net/MessageIn;)V
16: StackMap locals: org.apache.cassandra.service.StorageProxy$11 java.util.Set java.util.Set
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lorg/apache/cassandra/service/StorageProxy$11;
1 17 1 validTargets Ljava/util/Set<Ljava/net/InetAddress;>;
2 17 2 hostIds Ljava/util/Set<Ljava/util/UUID;>;
4 10 3 target Ljava/net/InetAddress;
5 10 5 hostId Ljava/util/UUID;
}
SourceFile: "StorageProxy.java"
EnclosingMethod: org.apache.cassandra.service.StorageProxy.submitHint:(Lorg/apache/cassandra/db/Mutation;Ljava/util/Collection;Lorg/apache/cassandra/service/AbstractWriteResponseHandler;)Ljava/util/concurrent/Future;
NestHost: org.apache.cassandra.service.StorageProxy
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
org.apache.cassandra.service.StorageProxy$11
private abstract HintRunnable = org.apache.cassandra.service.StorageProxy$HintRunnable of org.apache.cassandra.service.StorageProxy