public class org.apache.cassandra.repair.SnapshotTask extends com.google.common.util.concurrent.AbstractFuture<java.net.InetAddress> implements java.util.concurrent.RunnableFuture<java.net.InetAddress>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.repair.SnapshotTask
super_class: com.google.common.util.concurrent.AbstractFuture
{
private final org.apache.cassandra.repair.RepairJobDesc desc;
descriptor: Lorg/apache/cassandra/repair/RepairJobDesc;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.net.InetAddress endpoint;
descriptor: Ljava/net/InetAddress;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
public void <init>(org.apache.cassandra.repair.RepairJobDesc, java.net.InetAddress);
descriptor: (Lorg/apache/cassandra/repair/RepairJobDesc;Ljava/net/InetAddress;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial com.google.common.util.concurrent.AbstractFuture.<init>:()V
1: aload 0
aload 1
putfield org.apache.cassandra.repair.SnapshotTask.desc:Lorg/apache/cassandra/repair/RepairJobDesc;
2: aload 0
aload 2
putfield org.apache.cassandra.repair.SnapshotTask.endpoint:Ljava/net/InetAddress;
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/repair/SnapshotTask;
0 4 1 desc Lorg/apache/cassandra/repair/RepairJobDesc;
0 4 2 endpoint Ljava/net/InetAddress;
MethodParameters:
Name Flags
desc
endpoint
public void run();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=1, args_size=1
start local 0 0: invokestatic org.apache.cassandra.net.MessagingService.instance:()Lorg/apache/cassandra/net/MessagingService;
new org.apache.cassandra.repair.messages.SnapshotMessage
dup
aload 0
getfield org.apache.cassandra.repair.SnapshotTask.desc:Lorg/apache/cassandra/repair/RepairJobDesc;
invokespecial org.apache.cassandra.repair.messages.SnapshotMessage.<init>:(Lorg/apache/cassandra/repair/RepairJobDesc;)V
invokevirtual org.apache.cassandra.repair.messages.SnapshotMessage.createMessage:()Lorg/apache/cassandra/net/MessageOut;
1: aload 0
getfield org.apache.cassandra.repair.SnapshotTask.endpoint:Ljava/net/InetAddress;
2: new org.apache.cassandra.repair.SnapshotTask$SnapshotCallback
dup
aload 0
invokespecial org.apache.cassandra.repair.SnapshotTask$SnapshotCallback.<init>:(Lorg/apache/cassandra/repair/SnapshotTask;)V
getstatic java.util.concurrent.TimeUnit.HOURS:Ljava/util/concurrent/TimeUnit;
lconst_1
invokevirtual java.util.concurrent.TimeUnit.toMillis:(J)J
iconst_1
3: invokevirtual org.apache.cassandra.net.MessagingService.sendRR:(Lorg/apache/cassandra/net/MessageOut;Ljava/net/InetAddress;Lorg/apache/cassandra/net/IAsyncCallback;JZ)I
pop
4: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/repair/SnapshotTask;
static boolean access$0(org.apache.cassandra.repair.SnapshotTask, java.lang.Object);
descriptor: (Lorg/apache/cassandra/repair/SnapshotTask;Ljava/lang/Object;)Z
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual org.apache.cassandra.repair.SnapshotTask.set:(Ljava/lang/Object;)Z
ireturn
LocalVariableTable:
Start End Slot Name Signature
static boolean access$1(org.apache.cassandra.repair.SnapshotTask, java.lang.Throwable);
descriptor: (Lorg/apache/cassandra/repair/SnapshotTask;Ljava/lang/Throwable;)Z
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual org.apache.cassandra.repair.SnapshotTask.setException:(Ljava/lang/Throwable;)Z
ireturn
LocalVariableTable:
Start End Slot Name Signature
}
Signature: Lcom/google/common/util/concurrent/AbstractFuture<Ljava/net/InetAddress;>;Ljava/util/concurrent/RunnableFuture<Ljava/net/InetAddress;>;
SourceFile: "SnapshotTask.java"
NestMembers:
org.apache.cassandra.repair.SnapshotTask$SnapshotCallback
InnerClasses:
SnapshotCallback = org.apache.cassandra.repair.SnapshotTask$SnapshotCallback of org.apache.cassandra.repair.SnapshotTask