class org.apache.cassandra.dht.BootStrapper$1 implements org.apache.cassandra.streaming.StreamEventHandler
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.apache.cassandra.dht.BootStrapper$1
super_class: java.lang.Object
{
private final java.util.concurrent.atomic.AtomicInteger receivedFiles;
descriptor: Ljava/util/concurrent/atomic/AtomicInteger;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.AtomicInteger totalFilesToReceive;
descriptor: Ljava/util/concurrent/atomic/AtomicInteger;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
final org.apache.cassandra.dht.BootStrapper this$0;
descriptor: Lorg/apache/cassandra/dht/BootStrapper;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
private static volatile int[] $SWITCH_TABLE$org$apache$cassandra$streaming$StreamEvent$Type;
descriptor: [I
flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC
void <init>(org.apache.cassandra.dht.BootStrapper);
descriptor: (Lorg/apache/cassandra/dht/BootStrapper;)V
flags: (0x0000)
Code:
stack=3, locals=2, args_size=2
start local 0 0: aload 0
aload 1
putfield org.apache.cassandra.dht.BootStrapper$1.this$0:Lorg/apache/cassandra/dht/BootStrapper;
aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.atomic.AtomicInteger
dup
invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
putfield org.apache.cassandra.dht.BootStrapper$1.receivedFiles:Ljava/util/concurrent/atomic/AtomicInteger;
2: aload 0
new java.util.concurrent.atomic.AtomicInteger
dup
invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
putfield org.apache.cassandra.dht.BootStrapper$1.totalFilesToReceive:Ljava/util/concurrent/atomic/AtomicInteger;
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/dht/BootStrapper$1;
MethodParameters:
Name Flags
this$0 final
public void handleStreamEvent(org.apache.cassandra.streaming.StreamEvent);
descriptor: (Lorg/apache/cassandra/streaming/StreamEvent;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=8, args_size=2
start local 0 start local 1 0: invokestatic org.apache.cassandra.dht.BootStrapper$1.$SWITCH_TABLE$org$apache$cassandra$streaming$StreamEvent$Type:()[I
aload 1
getfield org.apache.cassandra.streaming.StreamEvent.eventType:Lorg/apache/cassandra/streaming/StreamEvent$Type;
invokevirtual org.apache.cassandra.streaming.StreamEvent$Type.ordinal:()I
iaload
tableswitch { // 1 - 3
1: 1
2: 12
3: 6
default: 15
}
1: StackMap locals:
StackMap stack:
aload 1
checkcast org.apache.cassandra.streaming.StreamEvent$SessionPreparedEvent
astore 2
start local 2 2: aload 0
getfield org.apache.cassandra.dht.BootStrapper$1.totalFilesToReceive:Ljava/util/concurrent/atomic/AtomicInteger;
aload 2
getfield org.apache.cassandra.streaming.StreamEvent$SessionPreparedEvent.session:Lorg/apache/cassandra/streaming/SessionInfo;
invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalFilesToReceive:()J
l2i
invokevirtual java.util.concurrent.atomic.AtomicInteger.addAndGet:(I)I
istore 3
start local 3 3: new org.apache.cassandra.utils.progress.ProgressEvent
dup
getstatic org.apache.cassandra.utils.progress.ProgressEventType.PROGRESS:Lorg/apache/cassandra/utils/progress/ProgressEventType;
aload 0
getfield org.apache.cassandra.dht.BootStrapper$1.receivedFiles:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
iload 3
new java.lang.StringBuilder
dup
ldc "prepare with "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
getfield org.apache.cassandra.streaming.StreamEvent$SessionPreparedEvent.session:Lorg/apache/cassandra/streaming/SessionInfo;
getfield org.apache.cassandra.streaming.SessionInfo.peer:Ljava/net/InetAddress;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc " complete"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial org.apache.cassandra.utils.progress.ProgressEvent.<init>:(Lorg/apache/cassandra/utils/progress/ProgressEventType;IILjava/lang/String;)V
astore 4
start local 4 4: aload 0
getfield org.apache.cassandra.dht.BootStrapper$1.this$0:Lorg/apache/cassandra/dht/BootStrapper;
ldc "bootstrap"
aload 4
invokestatic org.apache.cassandra.dht.BootStrapper.access$0:(Lorg/apache/cassandra/dht/BootStrapper;Ljava/lang/String;Lorg/apache/cassandra/utils/progress/ProgressEvent;)V
5: goto 15
end local 4 end local 3 end local 2 6: StackMap locals:
StackMap stack:
aload 1
checkcast org.apache.cassandra.streaming.StreamEvent$ProgressEvent
astore 5
start local 5 7: aload 5
getfield org.apache.cassandra.streaming.StreamEvent$ProgressEvent.progress:Lorg/apache/cassandra/streaming/ProgressInfo;
invokevirtual org.apache.cassandra.streaming.ProgressInfo.isCompleted:()Z
ifeq 15
8: aload 0
getfield org.apache.cassandra.dht.BootStrapper$1.receivedFiles:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.incrementAndGet:()I
istore 6
start local 6 9: new org.apache.cassandra.utils.progress.ProgressEvent
dup
getstatic org.apache.cassandra.utils.progress.ProgressEventType.PROGRESS:Lorg/apache/cassandra/utils/progress/ProgressEventType;
iload 6
aload 0
getfield org.apache.cassandra.dht.BootStrapper$1.totalFilesToReceive:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
new java.lang.StringBuilder
dup
ldc "received file "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 5
getfield org.apache.cassandra.streaming.StreamEvent$ProgressEvent.progress:Lorg/apache/cassandra/streaming/ProgressInfo;
getfield org.apache.cassandra.streaming.ProgressInfo.fileName:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial org.apache.cassandra.utils.progress.ProgressEvent.<init>:(Lorg/apache/cassandra/utils/progress/ProgressEventType;IILjava/lang/String;)V
astore 7
start local 7 10: aload 0
getfield org.apache.cassandra.dht.BootStrapper$1.this$0:Lorg/apache/cassandra/dht/BootStrapper;
ldc "bootstrap"
aload 7
invokestatic org.apache.cassandra.dht.BootStrapper.access$0:(Lorg/apache/cassandra/dht/BootStrapper;Ljava/lang/String;Lorg/apache/cassandra/utils/progress/ProgressEvent;)V
end local 7 end local 6 11: goto 15
end local 5 12: StackMap locals:
StackMap stack:
aload 1
checkcast org.apache.cassandra.streaming.StreamEvent$SessionCompleteEvent
astore 6
start local 6 13: new org.apache.cassandra.utils.progress.ProgressEvent
dup
getstatic org.apache.cassandra.utils.progress.ProgressEventType.PROGRESS:Lorg/apache/cassandra/utils/progress/ProgressEventType;
aload 0
getfield org.apache.cassandra.dht.BootStrapper$1.receivedFiles:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
aload 0
getfield org.apache.cassandra.dht.BootStrapper$1.totalFilesToReceive:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
new java.lang.StringBuilder
dup
ldc "session with "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 6
getfield org.apache.cassandra.streaming.StreamEvent$SessionCompleteEvent.peer:Ljava/net/InetAddress;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc " complete"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial org.apache.cassandra.utils.progress.ProgressEvent.<init>:(Lorg/apache/cassandra/utils/progress/ProgressEventType;IILjava/lang/String;)V
astore 7
start local 7 14: aload 0
getfield org.apache.cassandra.dht.BootStrapper$1.this$0:Lorg/apache/cassandra/dht/BootStrapper;
ldc "bootstrap"
aload 7
invokestatic org.apache.cassandra.dht.BootStrapper.access$0:(Lorg/apache/cassandra/dht/BootStrapper;Ljava/lang/String;Lorg/apache/cassandra/utils/progress/ProgressEvent;)V
end local 7 end local 6 15: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lorg/apache/cassandra/dht/BootStrapper$1;
0 16 1 event Lorg/apache/cassandra/streaming/StreamEvent;
2 6 2 prepared Lorg/apache/cassandra/streaming/StreamEvent$SessionPreparedEvent;
3 6 3 currentTotal I
4 6 4 prepareProgress Lorg/apache/cassandra/utils/progress/ProgressEvent;
7 12 5 progress Lorg/apache/cassandra/streaming/StreamEvent$ProgressEvent;
9 11 6 received I
10 11 7 currentProgress Lorg/apache/cassandra/utils/progress/ProgressEvent;
13 15 6 completeEvent Lorg/apache/cassandra/streaming/StreamEvent$SessionCompleteEvent;
14 15 7 completeProgress Lorg/apache/cassandra/utils/progress/ProgressEvent;
MethodParameters:
Name Flags
event
public void onSuccess(org.apache.cassandra.streaming.StreamState);
descriptor: (Lorg/apache/cassandra/streaming/StreamState;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.apache.cassandra.streaming.StreamState.hasFailedSession:()Z
ifeq 4
1: getstatic org.apache.cassandra.utils.progress.ProgressEventType.ERROR:Lorg/apache/cassandra/utils/progress/ProgressEventType;
astore 2
start local 2 2: ldc "Some bootstrap stream failed"
astore 3
start local 3 3: goto 6
end local 3 end local 2 4: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.utils.progress.ProgressEventType.SUCCESS:Lorg/apache/cassandra/utils/progress/ProgressEventType;
astore 2
start local 2 5: ldc "Bootstrap streaming success"
astore 3
start local 3 6: StackMap locals: org.apache.cassandra.utils.progress.ProgressEventType java.lang.String
StackMap stack:
new org.apache.cassandra.utils.progress.ProgressEvent
dup
aload 2
aload 0
getfield org.apache.cassandra.dht.BootStrapper$1.receivedFiles:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
aload 0
getfield org.apache.cassandra.dht.BootStrapper$1.totalFilesToReceive:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
aload 3
invokespecial org.apache.cassandra.utils.progress.ProgressEvent.<init>:(Lorg/apache/cassandra/utils/progress/ProgressEventType;IILjava/lang/String;)V
astore 4
start local 4 7: aload 0
getfield org.apache.cassandra.dht.BootStrapper$1.this$0:Lorg/apache/cassandra/dht/BootStrapper;
ldc "bootstrap"
aload 4
invokestatic org.apache.cassandra.dht.BootStrapper.access$0:(Lorg/apache/cassandra/dht/BootStrapper;Ljava/lang/String;Lorg/apache/cassandra/utils/progress/ProgressEvent;)V
8: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/dht/BootStrapper$1;
0 9 1 streamState Lorg/apache/cassandra/streaming/StreamState;
2 4 2 type Lorg/apache/cassandra/utils/progress/ProgressEventType;
5 9 2 type Lorg/apache/cassandra/utils/progress/ProgressEventType;
3 4 3 message Ljava/lang/String;
6 9 3 message Ljava/lang/String;
7 9 4 currentProgress Lorg/apache/cassandra/utils/progress/ProgressEvent;
MethodParameters:
Name Flags
streamState
public void onFailure(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=2
start local 0 start local 1 0: new org.apache.cassandra.utils.progress.ProgressEvent
dup
getstatic org.apache.cassandra.utils.progress.ProgressEventType.ERROR:Lorg/apache/cassandra/utils/progress/ProgressEventType;
aload 0
getfield org.apache.cassandra.dht.BootStrapper$1.receivedFiles:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
aload 0
getfield org.apache.cassandra.dht.BootStrapper$1.totalFilesToReceive:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
aload 1
invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
invokespecial org.apache.cassandra.utils.progress.ProgressEvent.<init>:(Lorg/apache/cassandra/utils/progress/ProgressEventType;IILjava/lang/String;)V
astore 2
start local 2 1: aload 0
getfield org.apache.cassandra.dht.BootStrapper$1.this$0:Lorg/apache/cassandra/dht/BootStrapper;
ldc "bootstrap"
aload 2
invokestatic org.apache.cassandra.dht.BootStrapper.access$0:(Lorg/apache/cassandra/dht/BootStrapper;Ljava/lang/String;Lorg/apache/cassandra/utils/progress/ProgressEvent;)V
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/dht/BootStrapper$1;
0 3 1 throwable Ljava/lang/Throwable;
1 3 2 currentProgress Lorg/apache/cassandra/utils/progress/ProgressEvent;
MethodParameters:
Name Flags
throwable
public void onSuccess(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast org.apache.cassandra.streaming.StreamState
invokevirtual org.apache.cassandra.dht.BootStrapper$1.onSuccess:(Lorg/apache/cassandra/streaming/StreamState;)V
return
LocalVariableTable:
Start End Slot Name Signature
static int[] $SWITCH_TABLE$org$apache$cassandra$streaming$StreamEvent$Type();
descriptor: ()[I
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=0
0: getstatic org.apache.cassandra.dht.BootStrapper$1.$SWITCH_TABLE$org$apache$cassandra$streaming$StreamEvent$Type:[I
dup
ifnull 1
areturn
StackMap locals:
StackMap stack: int[]
1: pop
invokestatic org.apache.cassandra.streaming.StreamEvent$Type.values:()[Lorg/apache/cassandra/streaming/StreamEvent$Type;
arraylength
newarray 10
astore 0
2: aload 0
getstatic org.apache.cassandra.streaming.StreamEvent$Type.FILE_PROGRESS:Lorg/apache/cassandra/streaming/StreamEvent$Type;
invokevirtual org.apache.cassandra.streaming.StreamEvent$Type.ordinal:()I
iconst_3
iastore
3: goto 5
StackMap locals: int[]
StackMap stack: java.lang.NoSuchFieldError
4: pop
StackMap locals:
StackMap stack:
5: aload 0
getstatic org.apache.cassandra.streaming.StreamEvent$Type.STREAM_COMPLETE:Lorg/apache/cassandra/streaming/StreamEvent$Type;
invokevirtual org.apache.cassandra.streaming.StreamEvent$Type.ordinal:()I
iconst_2
iastore
6: goto 8
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
7: pop
StackMap locals:
StackMap stack:
8: aload 0
getstatic org.apache.cassandra.streaming.StreamEvent$Type.STREAM_PREPARED:Lorg/apache/cassandra/streaming/StreamEvent$Type;
invokevirtual org.apache.cassandra.streaming.StreamEvent$Type.ordinal:()I
iconst_1
iastore
9: goto 11
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
10: pop
StackMap locals:
StackMap stack:
11: aload 0
dup
putstatic org.apache.cassandra.dht.BootStrapper$1.$SWITCH_TABLE$org$apache$cassandra$streaming$StreamEvent$Type:[I
areturn
LocalVariableTable:
Start End Slot Name Signature
Exception table:
from to target type
2 3 4 Class java.lang.NoSuchFieldError
5 6 7 Class java.lang.NoSuchFieldError
8 9 10 Class java.lang.NoSuchFieldError
}
SourceFile: "BootStrapper.java"
EnclosingMethod: org.apache.cassandra.dht.BootStrapper.bootstrap:(Lorg/apache/cassandra/dht/StreamStateStore;Z)Lcom/google/common/util/concurrent/ListenableFuture;
NestHost: org.apache.cassandra.dht.BootStrapper
InnerClasses:
org.apache.cassandra.dht.BootStrapper$1
public ProgressEvent = org.apache.cassandra.streaming.StreamEvent$ProgressEvent of org.apache.cassandra.streaming.StreamEvent
public SessionCompleteEvent = org.apache.cassandra.streaming.StreamEvent$SessionCompleteEvent of org.apache.cassandra.streaming.StreamEvent
public SessionPreparedEvent = org.apache.cassandra.streaming.StreamEvent$SessionPreparedEvent of org.apache.cassandra.streaming.StreamEvent
public final Type = org.apache.cassandra.streaming.StreamEvent$Type of org.apache.cassandra.streaming.StreamEvent