public class org.apache.cassandra.streaming.StreamSession implements org.apache.cassandra.gms.IEndpointStateChangeSubscriber
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.streaming.StreamSession
super_class: java.lang.Object
{
private static final org.apache.cassandra.utils.CassandraVersion STREAM_KEEP_ALIVE;
descriptor: Lorg/apache/cassandra/utils/CassandraVersion;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor keepAliveExecutor;
descriptor: Lorg/apache/cassandra/concurrent/DebuggableScheduledThreadPoolExecutor;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
public final java.net.InetAddress peer;
descriptor: Ljava/net/InetAddress;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
private final int index;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
public final java.net.InetAddress connecting;
descriptor: Ljava/net/InetAddress;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
private org.apache.cassandra.streaming.StreamResultFuture streamResult;
descriptor: Lorg/apache/cassandra/streaming/StreamResultFuture;
flags: (0x0002) ACC_PRIVATE
protected final java.util.Set<org.apache.cassandra.streaming.StreamRequest> requests;
descriptor: Ljava/util/Set;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
Signature: Ljava/util/Set<Lorg/apache/cassandra/streaming/StreamRequest;>;
protected final java.util.concurrent.ConcurrentHashMap<java.util.UUID, org.apache.cassandra.streaming.StreamTransferTask> transfers;
descriptor: Ljava/util/concurrent/ConcurrentHashMap;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
Signature: Ljava/util/concurrent/ConcurrentHashMap<Ljava/util/UUID;Lorg/apache/cassandra/streaming/StreamTransferTask;>;
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
private final java.util.Map<java.util.UUID, org.apache.cassandra.streaming.StreamReceiveTask> receivers;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/util/UUID;Lorg/apache/cassandra/streaming/StreamReceiveTask;>;
private final org.apache.cassandra.metrics.StreamingMetrics metrics;
descriptor: Lorg/apache/cassandra/metrics/StreamingMetrics;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.streaming.StreamConnectionFactory factory;
descriptor: Lorg/apache/cassandra/streaming/StreamConnectionFactory;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
public final java.util.Map<java.lang.String, java.util.Set<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>>> transferredRangesPerKeyspace;
descriptor: Ljava/util/Map;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/String;Ljava/util/Set<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;>;
public final org.apache.cassandra.streaming.ConnectionHandler handler;
descriptor: Lorg/apache/cassandra/streaming/ConnectionHandler;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
private java.util.concurrent.atomic.AtomicBoolean isAborted;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0002) ACC_PRIVATE
private final boolean keepSSTableLevel;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final boolean isIncremental;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private java.util.concurrent.ScheduledFuture<?> keepAliveFuture;
descriptor: Ljava/util/concurrent/ScheduledFuture;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/concurrent/ScheduledFuture<*>;
private volatile org.apache.cassandra.streaming.StreamSession$State state;
descriptor: Lorg/apache/cassandra/streaming/StreamSession$State;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile boolean completeSent;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
private static volatile int[] $SWITCH_TABLE$org$apache$cassandra$streaming$messages$StreamMessage$Type;
descriptor: [I
flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/streaming/StreamSession;
invokevirtual java.lang.Class.desiredAssertionStatus:()Z
ifne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: putstatic org.apache.cassandra.streaming.StreamSession.$assertionsDisabled:Z
3: new org.apache.cassandra.utils.CassandraVersion
dup
ldc "3.10"
invokespecial org.apache.cassandra.utils.CassandraVersion.<init>:(Ljava/lang/String;)V
putstatic org.apache.cassandra.streaming.StreamSession.STREAM_KEEP_ALIVE:Lorg/apache/cassandra/utils/CassandraVersion;
4: ldc Lorg/apache/cassandra/streaming/StreamSession;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.streaming.StreamSession.logger:Lorg/slf4j/Logger;
5: new org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor
dup
ldc "StreamKeepAliveExecutor"
invokespecial org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor.<init>:(Ljava/lang/String;)V
putstatic org.apache.cassandra.streaming.StreamSession.keepAliveExecutor:Lorg/apache/cassandra/concurrent/DebuggableScheduledThreadPoolExecutor;
6: getstatic org.apache.cassandra.streaming.StreamSession.keepAliveExecutor:Lorg/apache/cassandra/concurrent/DebuggableScheduledThreadPoolExecutor;
iconst_1
invokevirtual org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor.setRemoveOnCancelPolicy:(Z)V
7: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(java.net.InetAddress, java.net.InetAddress, org.apache.cassandra.streaming.StreamConnectionFactory, int, boolean, boolean);
descriptor: (Ljava/net/InetAddress;Ljava/net/InetAddress;Lorg/apache/cassandra/streaming/StreamConnectionFactory;IZZ)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=7, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
invokestatic com.google.common.collect.Sets.newConcurrentHashSet:()Ljava/util/Set;
putfield org.apache.cassandra.streaming.StreamSession.requests:Ljava/util/Set;
2: aload 0
new java.util.concurrent.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
putfield org.apache.cassandra.streaming.StreamSession.transfers:Ljava/util/concurrent/ConcurrentHashMap;
3: aload 0
new java.util.concurrent.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
putfield org.apache.cassandra.streaming.StreamSession.receivers:Ljava/util/Map;
4: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield org.apache.cassandra.streaming.StreamSession.transferredRangesPerKeyspace:Ljava/util/Map;
5: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
iconst_0
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
putfield org.apache.cassandra.streaming.StreamSession.isAborted:Ljava/util/concurrent/atomic/AtomicBoolean;
6: aload 0
aconst_null
putfield org.apache.cassandra.streaming.StreamSession.keepAliveFuture:Ljava/util/concurrent/ScheduledFuture;
7: aload 0
getstatic org.apache.cassandra.streaming.StreamSession$State.INITIALIZED:Lorg/apache/cassandra/streaming/StreamSession$State;
putfield org.apache.cassandra.streaming.StreamSession.state:Lorg/apache/cassandra/streaming/StreamSession$State;
8: aload 0
iconst_0
putfield org.apache.cassandra.streaming.StreamSession.completeSent:Z
9: aload 0
aload 1
putfield org.apache.cassandra.streaming.StreamSession.peer:Ljava/net/InetAddress;
10: aload 0
aload 2
putfield org.apache.cassandra.streaming.StreamSession.connecting:Ljava/net/InetAddress;
11: aload 0
iload 4
putfield org.apache.cassandra.streaming.StreamSession.index:I
12: aload 0
aload 3
putfield org.apache.cassandra.streaming.StreamSession.factory:Lorg/apache/cassandra/streaming/StreamConnectionFactory;
13: aload 0
14: new org.apache.cassandra.streaming.ConnectionHandler
dup
aload 0
aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.isKeepAliveSupported:()Z
ifeq 16
15: getstatic java.util.concurrent.TimeUnit.SECONDS:Ljava/util/concurrent/TimeUnit;
iconst_2
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getStreamingKeepAlivePeriod:()I
imul
i2l
invokevirtual java.util.concurrent.TimeUnit.toMillis:(J)J
l2i
goto 17
16: StackMap locals: org.apache.cassandra.streaming.StreamSession java.net.InetAddress java.net.InetAddress org.apache.cassandra.streaming.StreamConnectionFactory int int int
StackMap stack: org.apache.cassandra.streaming.StreamSession new 14 new 14 org.apache.cassandra.streaming.StreamSession
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getStreamingSocketTimeout:()I
StackMap locals: org.apache.cassandra.streaming.StreamSession java.net.InetAddress java.net.InetAddress org.apache.cassandra.streaming.StreamConnectionFactory int int int
StackMap stack: org.apache.cassandra.streaming.StreamSession new 14 new 14 org.apache.cassandra.streaming.StreamSession int
17: invokespecial org.apache.cassandra.streaming.ConnectionHandler.<init>:(Lorg/apache/cassandra/streaming/StreamSession;I)V
18: putfield org.apache.cassandra.streaming.StreamSession.handler:Lorg/apache/cassandra/streaming/ConnectionHandler;
19: aload 0
aload 2
invokestatic org.apache.cassandra.metrics.StreamingMetrics.get:(Ljava/net/InetAddress;)Lorg/apache/cassandra/metrics/StreamingMetrics;
putfield org.apache.cassandra.streaming.StreamSession.metrics:Lorg/apache/cassandra/metrics/StreamingMetrics;
20: aload 0
iload 5
putfield org.apache.cassandra.streaming.StreamSession.keepSSTableLevel:Z
21: aload 0
iload 6
putfield org.apache.cassandra.streaming.StreamSession.isIncremental:Z
22: return
end local 6 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 23 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 23 1 peer Ljava/net/InetAddress;
0 23 2 connecting Ljava/net/InetAddress;
0 23 3 factory Lorg/apache/cassandra/streaming/StreamConnectionFactory;
0 23 4 index I
0 23 5 keepSSTableLevel Z
0 23 6 isIncremental Z
MethodParameters:
Name Flags
peer
connecting
factory
index
keepSSTableLevel
isIncremental
public java.util.UUID planId();
descriptor: ()Ljava/util/UUID;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.streamResult:Lorg/apache/cassandra/streaming/StreamResultFuture;
ifnonnull 1
aconst_null
goto 2
StackMap locals:
StackMap stack:
1: aload 0
getfield org.apache.cassandra.streaming.StreamSession.streamResult:Lorg/apache/cassandra/streaming/StreamResultFuture;
getfield org.apache.cassandra.streaming.StreamResultFuture.planId:Ljava/util/UUID;
StackMap locals:
StackMap stack: java.util.UUID
2: areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/streaming/StreamSession;
public int sessionIndex();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.index:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/streaming/StreamSession;
public java.lang.String description();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.streamResult:Lorg/apache/cassandra/streaming/StreamResultFuture;
ifnonnull 1
aconst_null
goto 2
StackMap locals:
StackMap stack:
1: aload 0
getfield org.apache.cassandra.streaming.StreamSession.streamResult:Lorg/apache/cassandra/streaming/StreamResultFuture;
getfield org.apache.cassandra.streaming.StreamResultFuture.description:Ljava/lang/String;
StackMap locals:
StackMap stack: java.lang.String
2: areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/streaming/StreamSession;
public boolean keepSSTableLevel();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.keepSSTableLevel:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/streaming/StreamSession;
public boolean isIncremental();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.isIncremental:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/streaming/StreamSession;
org.apache.cassandra.streaming.StreamReceiveTask getReceivingTask(java.util.UUID);
descriptor: (Ljava/util/UUID;)Lorg/apache/cassandra/streaming/StreamReceiveTask;
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.streaming.StreamSession.$assertionsDisabled:Z
ifne 1
aload 0
getfield org.apache.cassandra.streaming.StreamSession.receivers:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.streaming.StreamSession.receivers:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamReceiveTask
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 2 1 cfId Ljava/util/UUID;
MethodParameters:
Name Flags
cfId
private boolean isKeepAliveSupported();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=1
start local 0 0: getstatic org.apache.cassandra.gms.Gossiper.instance:Lorg/apache/cassandra/gms/Gossiper;
aload 0
getfield org.apache.cassandra.streaming.StreamSession.peer:Ljava/net/InetAddress;
invokevirtual org.apache.cassandra.gms.Gossiper.getReleaseVersion:(Ljava/net/InetAddress;)Lorg/apache/cassandra/utils/CassandraVersion;
astore 1
start local 1 1: getstatic org.apache.cassandra.streaming.StreamSession.STREAM_KEEP_ALIVE:Lorg/apache/cassandra/utils/CassandraVersion;
aload 1
invokevirtual org.apache.cassandra.utils.CassandraVersion.isSupportedBy:(Lorg/apache/cassandra/utils/CassandraVersion;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/streaming/StreamSession;
1 2 1 peerVersion Lorg/apache/cassandra/utils/CassandraVersion;
public void init(org.apache.cassandra.streaming.StreamResultFuture);
descriptor: (Lorg/apache/cassandra/streaming/StreamResultFuture;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield org.apache.cassandra.streaming.StreamSession.streamResult:Lorg/apache/cassandra/streaming/StreamResultFuture;
1: getstatic org.apache.cassandra.streaming.StreamHook.instance:Lorg/apache/cassandra/streaming/StreamHook;
aload 0
aload 1
invokeinterface org.apache.cassandra.streaming.StreamHook.reportStreamFuture:(Lorg/apache/cassandra/streaming/StreamSession;Lorg/apache/cassandra/streaming/StreamResultFuture;)V
2: aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.isKeepAliveSupported:()Z
ifeq 4
3: aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.scheduleKeepAliveTask:()V
goto 5
4: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.streaming.StreamSession.logger:Lorg/slf4j/Logger;
ldc "Peer {} does not support keep-alive."
aload 0
getfield org.apache.cassandra.streaming.StreamSession.peer:Ljava/net/InetAddress;
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
5: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 6 1 streamResult Lorg/apache/cassandra/streaming/StreamResultFuture;
MethodParameters:
Name Flags
streamResult
public void start();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.requests:Ljava/util/Set;
invokeinterface java.util.Set.isEmpty:()Z
ifeq 4
aload 0
getfield org.apache.cassandra.streaming.StreamSession.transfers:Ljava/util/concurrent/ConcurrentHashMap;
invokevirtual java.util.concurrent.ConcurrentHashMap.isEmpty:()Z
ifeq 4
1: getstatic org.apache.cassandra.streaming.StreamSession.logger:Lorg/slf4j/Logger;
ldc "[Stream #{}] Session does not have any tasks."
aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.planId:()Ljava/util/UUID;
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;)V
2: aload 0
getstatic org.apache.cassandra.streaming.StreamSession$State.COMPLETE:Lorg/apache/cassandra/streaming/StreamSession$State;
invokevirtual org.apache.cassandra.streaming.StreamSession.closeSession:(Lorg/apache/cassandra/streaming/StreamSession$State;)V
3: return
4: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.streaming.StreamSession.logger:Lorg/slf4j/Logger;
ldc "[Stream #{}] Starting streaming to {}{}"
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.planId:()Ljava/util/UUID;
aastore
dup
iconst_1
5: aload 0
getfield org.apache.cassandra.streaming.StreamSession.peer:Ljava/net/InetAddress;
aastore
dup
iconst_2
6: aload 0
getfield org.apache.cassandra.streaming.StreamSession.peer:Ljava/net/InetAddress;
aload 0
getfield org.apache.cassandra.streaming.StreamSession.connecting:Ljava/net/InetAddress;
invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
ifeq 7
ldc ""
goto 8
StackMap locals: org.apache.cassandra.streaming.StreamSession
StackMap stack: org.slf4j.Logger java.lang.String java.lang.Object[] java.lang.Object[] int
7: new java.lang.StringBuilder
dup
ldc " through "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.apache.cassandra.streaming.StreamSession.connecting:Ljava/net/InetAddress;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
StackMap locals: org.apache.cassandra.streaming.StreamSession
StackMap stack: org.slf4j.Logger java.lang.String java.lang.Object[] java.lang.Object[] int java.lang.String
8: aastore
9: invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;[Ljava/lang/Object;)V
10: aload 0
getfield org.apache.cassandra.streaming.StreamSession.handler:Lorg/apache/cassandra/streaming/ConnectionHandler;
invokevirtual org.apache.cassandra.streaming.ConnectionHandler.initiate:()V
11: aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.onInitializationComplete:()V
12: goto 16
13: StackMap locals:
StackMap stack: java.lang.Exception
astore 1
start local 1 14: aload 1
invokestatic org.apache.cassandra.utils.JVMStabilityInspector.inspectThrowable:(Ljava/lang/Throwable;)V
15: aload 0
aload 1
invokevirtual org.apache.cassandra.streaming.StreamSession.onError:(Ljava/lang/Throwable;)V
end local 1 16: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lorg/apache/cassandra/streaming/StreamSession;
14 16 1 e Ljava/lang/Exception;
Exception table:
from to target type
4 12 13 Class java.lang.Exception
public java.net.Socket createConnection();
descriptor: ()Ljava/net/Socket;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.streaming.StreamSession.$assertionsDisabled:Z
ifne 1
aload 0
getfield org.apache.cassandra.streaming.StreamSession.factory:Lorg/apache/cassandra/streaming/StreamConnectionFactory;
ifnonnull 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.streaming.StreamSession.factory:Lorg/apache/cassandra/streaming/StreamConnectionFactory;
aload 0
getfield org.apache.cassandra.streaming.StreamSession.connecting:Ljava/net/InetAddress;
invokeinterface org.apache.cassandra.streaming.StreamConnectionFactory.createConnection:(Ljava/net/InetAddress;)Ljava/net/Socket;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/streaming/StreamSession;
Exceptions:
throws java.io.IOException
public void addStreamRequest(java.lang.String, java.util.Collection<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>>, java.util.Collection<java.lang.String>, );
descriptor: (Ljava/lang/String;Ljava/util/Collection;Ljava/util/Collection;J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.requests:Ljava/util/Set;
new org.apache.cassandra.streaming.StreamRequest
dup
aload 1
aload 2
aload 3
lload 4
invokespecial org.apache.cassandra.streaming.StreamRequest.<init>:(Ljava/lang/String;Ljava/util/Collection;Ljava/util/Collection;J)V
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
1: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 2 1 keyspace Ljava/lang/String;
0 2 2 ranges Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
0 2 3 columnFamilies Ljava/util/Collection<Ljava/lang/String;>;
0 2 4 repairedAt J
Signature: (Ljava/lang/String;Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;Ljava/util/Collection<Ljava/lang/String;>;J)V
MethodParameters:
Name Flags
keyspace
ranges
columnFamilies
repairedAt
public synchronized void addTransferRanges(java.lang.String, java.util.Collection<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>>, java.util.Collection<java.lang.String>, boolean, );
descriptor: (Ljava/lang/String;Ljava/util/Collection;Ljava/util/Collection;ZJ)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=5, locals=14, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.failIfFinished:()V
1: aload 0
aload 1
aload 3
invokevirtual org.apache.cassandra.streaming.StreamSession.getColumnFamilyStores:(Ljava/lang/String;Ljava/util/Collection;)Ljava/util/Collection;
astore 7
start local 7 2: iload 4
ifeq 4
3: aload 0
aload 7
invokevirtual org.apache.cassandra.streaming.StreamSession.flushSSTables:(Ljava/lang/Iterable;)V
4: StackMap locals: java.util.Collection
StackMap stack:
aload 2
invokestatic org.apache.cassandra.dht.Range.normalize:(Ljava/util/Collection;)Ljava/util/List;
astore 8
start local 8 5: aload 8
aload 7
lload 5
aload 0
getfield org.apache.cassandra.streaming.StreamSession.isIncremental:Z
invokestatic org.apache.cassandra.streaming.StreamSession.getSSTableSectionsForRanges:(Ljava/util/Collection;Ljava/util/Collection;JZ)Ljava/util/List;
astore 9
start local 9 6: aload 0
aload 9
invokevirtual org.apache.cassandra.streaming.StreamSession.addTransferFiles:(Ljava/util/Collection;)V
7: aload 0
getfield org.apache.cassandra.streaming.StreamSession.transferredRangesPerKeyspace:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.util.Set
astore 10
start local 10 8: aload 10
ifnonnull 10
9: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 10
10: StackMap locals: java.util.List java.util.List java.util.Set
StackMap stack:
aload 10
aload 2
invokeinterface java.util.Set.addAll:(Ljava/util/Collection;)Z
pop
11: aload 0
getfield org.apache.cassandra.streaming.StreamSession.transferredRangesPerKeyspace:Ljava/util/Map;
aload 1
aload 10
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 10 12: goto 19
13: StackMap locals: org.apache.cassandra.streaming.StreamSession java.lang.String java.util.Collection java.util.Collection int long java.util.Collection java.util.List java.util.List
StackMap stack: java.lang.Throwable
astore 11
14: aload 9
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 13
goto 17
StackMap locals: org.apache.cassandra.streaming.StreamSession java.lang.String java.util.Collection java.util.Collection int long java.util.Collection java.util.List java.util.List top java.lang.Throwable top java.util.Iterator
StackMap stack:
15: aload 13
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections
astore 12
start local 12 16: aload 12
getfield org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections.ref:Lorg/apache/cassandra/utils/concurrent/Ref;
invokevirtual org.apache.cassandra.utils.concurrent.Ref.release:()V
end local 12 17: StackMap locals:
StackMap stack:
aload 13
invokeinterface java.util.Iterator.hasNext:()Z
ifne 15
18: aload 11
athrow
19: StackMap locals: org.apache.cassandra.streaming.StreamSession java.lang.String java.util.Collection java.util.Collection int long java.util.Collection java.util.List java.util.List
StackMap stack:
aload 9
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 13
goto 22
StackMap locals: org.apache.cassandra.streaming.StreamSession java.lang.String java.util.Collection java.util.Collection int long java.util.Collection java.util.List java.util.List top top top java.util.Iterator
StackMap stack:
20: aload 13
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections
astore 12
start local 12 21: aload 12
getfield org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections.ref:Lorg/apache/cassandra/utils/concurrent/Ref;
invokevirtual org.apache.cassandra.utils.concurrent.Ref.release:()V
end local 12 22: StackMap locals:
StackMap stack:
aload 13
invokeinterface java.util.Iterator.hasNext:()Z
ifne 20
23: return
end local 9 end local 8 end local 7 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 24 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 24 1 keyspace Ljava/lang/String;
0 24 2 ranges Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
0 24 3 columnFamilies Ljava/util/Collection<Ljava/lang/String;>;
0 24 4 flushTables Z
0 24 5 repairedAt J
2 24 7 stores Ljava/util/Collection<Lorg/apache/cassandra/db/ColumnFamilyStore;>;
5 24 8 normalizedRanges Ljava/util/List<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
6 24 9 sections Ljava/util/List<Lorg/apache/cassandra/streaming/StreamSession$SSTableStreamingSections;>;
8 12 10 toBeUpdated Ljava/util/Set<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
16 17 12 release Lorg/apache/cassandra/streaming/StreamSession$SSTableStreamingSections;
21 22 12 release Lorg/apache/cassandra/streaming/StreamSession$SSTableStreamingSections;
Exception table:
from to target type
6 13 13 any
Signature: (Ljava/lang/String;Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;Ljava/util/Collection<Ljava/lang/String;>;ZJ)V
MethodParameters:
Name Flags
keyspace
ranges
columnFamilies
flushTables
repairedAt
private void failIfFinished();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.state:()Lorg/apache/cassandra/streaming/StreamSession$State;
getstatic org.apache.cassandra.streaming.StreamSession$State.COMPLETE:Lorg/apache/cassandra/streaming/StreamSession$State;
if_acmpeq 1
aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.state:()Lorg/apache/cassandra/streaming/StreamSession$State;
getstatic org.apache.cassandra.streaming.StreamSession$State.FAILED:Lorg/apache/cassandra/streaming/StreamSession$State;
if_acmpne 2
1: StackMap locals:
StackMap stack:
new java.lang.RuntimeException
dup
ldc "Stream %s is finished with state %s"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.planId:()Ljava/util/UUID;
aastore
dup
iconst_1
aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.state:()Lorg/apache/cassandra/streaming/StreamSession$State;
invokevirtual org.apache.cassandra.streaming.StreamSession$State.name:()Ljava/lang/String;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/streaming/StreamSession;
private java.util.Collection<org.apache.cassandra.db.ColumnFamilyStore> getColumnFamilyStores(java.lang.String, java.util.Collection<java.lang.String>);
descriptor: (Ljava/lang/String;Ljava/util/Collection;)Ljava/util/Collection;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=6, args_size=3
start local 0 start local 1 start local 2 0: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 3
start local 3 1: aload 2
invokeinterface java.util.Collection.isEmpty:()Z
ifeq 4
2: aload 3
aload 1
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStores:()Ljava/util/Collection;
invokeinterface java.util.Collection.addAll:(Ljava/util/Collection;)Z
pop
3: goto 8
4: StackMap locals: java.util.Collection
StackMap stack:
aload 2
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 5
goto 7
StackMap locals: org.apache.cassandra.streaming.StreamSession java.lang.String java.util.Collection java.util.Collection top java.util.Iterator
StackMap stack:
5: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.String
astore 4
start local 4 6: aload 3
aload 1
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
aload 4
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStore:(Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStore;
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
pop
end local 4 7: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
8: StackMap locals: org.apache.cassandra.streaming.StreamSession java.lang.String java.util.Collection java.util.Collection
StackMap stack:
aload 3
areturn
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/streaming/StreamSession;
0 9 1 keyspace Ljava/lang/String;
0 9 2 columnFamilies Ljava/util/Collection<Ljava/lang/String;>;
1 9 3 stores Ljava/util/Collection<Lorg/apache/cassandra/db/ColumnFamilyStore;>;
6 7 4 cf Ljava/lang/String;
Signature: (Ljava/lang/String;Ljava/util/Collection<Ljava/lang/String;>;)Ljava/util/Collection<Lorg/apache/cassandra/db/ColumnFamilyStore;>;
MethodParameters:
Name Flags
keyspace
columnFamilies
public static java.util.List<org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections> getSSTableSectionsForRanges(java.util.Collection<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>>, java.util.Collection<org.apache.cassandra.db.ColumnFamilyStore>, long, boolean);
descriptor: (Ljava/util/Collection;Ljava/util/Collection;JZ)Ljava/util/List;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=9, locals=11, args_size=4
start local 0 start local 1 start local 2 start local 4 0: new org.apache.cassandra.utils.concurrent.Refs
dup
invokespecial org.apache.cassandra.utils.concurrent.Refs.<init>:()V
astore 5
start local 5 1: aload 1
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 7
goto 11
StackMap locals: java.util.Collection java.util.Collection long int org.apache.cassandra.utils.concurrent.Refs top java.util.Iterator
StackMap stack:
2: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 6
start local 6 3: new java.util.ArrayList
dup
aload 0
invokeinterface java.util.Collection.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 8
start local 8 4: aload 0
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 10
goto 7
StackMap locals: java.util.Collection java.util.Collection long int org.apache.cassandra.utils.concurrent.Refs org.apache.cassandra.db.ColumnFamilyStore java.util.Iterator java.util.List top java.util.Iterator
StackMap stack:
5: aload 10
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.Range
astore 9
start local 9 6: aload 8
aload 9
invokestatic org.apache.cassandra.dht.Range.makeRowRange:(Lorg/apache/cassandra/dht/Range;)Lorg/apache/cassandra/dht/Range;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 9 7: StackMap locals:
StackMap stack:
aload 10
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
8: aload 5
aload 6
aload 8
iload 4
invokedynamic apply(Ljava/util/List;Z)Lcom/google/common/base/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/streaming/StreamSession.lambda$0(Ljava/util/List;ZLorg/apache/cassandra/db/lifecycle/View;)Ljava/lang/Iterable; (6)
(Lorg/apache/cassandra/db/lifecycle/View;)Ljava/lang/Iterable;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.selectAndReference:(Lcom/google/common/base/Function;)Lorg/apache/cassandra/db/ColumnFamilyStore$RefViewFragment;
9: getfield org.apache.cassandra.db.ColumnFamilyStore$RefViewFragment.refs:Lorg/apache/cassandra/utils/concurrent/Refs;
10: invokevirtual org.apache.cassandra.utils.concurrent.Refs.addAll:(Lorg/apache/cassandra/utils/concurrent/Refs;)Lorg/apache/cassandra/utils/concurrent/Refs;
pop
end local 8 end local 6 11: StackMap locals: java.util.Collection java.util.Collection long int org.apache.cassandra.utils.concurrent.Refs top java.util.Iterator
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
12: new java.util.ArrayList
dup
aload 5
invokevirtual org.apache.cassandra.utils.concurrent.Refs.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 6
start local 6 13: aload 5
invokevirtual org.apache.cassandra.utils.concurrent.Refs.iterator:()Ljava/util/Iterator;
astore 8
goto 23
StackMap locals: java.util.Collection java.util.Collection long int org.apache.cassandra.utils.concurrent.Refs java.util.List top java.util.Iterator
StackMap stack:
14: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 7
start local 7 15: lload 2
lstore 9
start local 9 16: lload 2
lconst_0
lcmp
ifne 18
17: aload 7
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getSSTableMetadata:()Lorg/apache/cassandra/io/sstable/metadata/StatsMetadata;
getfield org.apache.cassandra.io.sstable.metadata.StatsMetadata.repairedAt:J
lstore 9
18: StackMap locals: java.util.Collection java.util.Collection long int org.apache.cassandra.utils.concurrent.Refs java.util.List org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator long
StackMap stack:
aload 6
new org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections
dup
aload 5
aload 7
invokevirtual org.apache.cassandra.utils.concurrent.Refs.get:(Lorg/apache/cassandra/utils/concurrent/RefCounted;)Lorg/apache/cassandra/utils/concurrent/Ref;
19: aload 7
aload 0
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getPositionsForRanges:(Ljava/util/Collection;)Ljava/util/List;
20: aload 7
aload 0
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.estimatedKeysForRanges:(Ljava/util/Collection;)J
21: lload 9
invokespecial org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections.<init>:(Lorg/apache/cassandra/utils/concurrent/Ref;Ljava/util/List;JJ)V
22: invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 9 end local 7 23: StackMap locals: java.util.Collection java.util.Collection long int org.apache.cassandra.utils.concurrent.Refs java.util.List top java.util.Iterator
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 14
24: aload 6
25: areturn
end local 6 26: StackMap locals: java.util.Collection java.util.Collection long int org.apache.cassandra.utils.concurrent.Refs
StackMap stack: java.lang.Throwable
astore 6
start local 6 27: aload 5
invokevirtual org.apache.cassandra.utils.concurrent.Refs.release:()V
28: aload 6
athrow
end local 6 end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 29 0 ranges Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
0 29 1 stores Ljava/util/Collection<Lorg/apache/cassandra/db/ColumnFamilyStore;>;
0 29 2 overriddenRepairedAt J
0 29 4 isIncremental Z
1 29 5 refs Lorg/apache/cassandra/utils/concurrent/Refs<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
3 11 6 cfStore Lorg/apache/cassandra/db/ColumnFamilyStore;
4 11 8 keyRanges Ljava/util/List<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/db/PartitionPosition;>;>;
6 7 9 range Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;
13 26 6 sections Ljava/util/List<Lorg/apache/cassandra/streaming/StreamSession$SSTableStreamingSections;>;
15 23 7 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
16 23 9 repairedAt J
27 29 6 t Ljava/lang/Throwable;
Exception table:
from to target type
1 25 26 Class java.lang.Throwable
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;Ljava/util/Collection<Lorg/apache/cassandra/db/ColumnFamilyStore;>;JZ)Ljava/util/List<Lorg/apache/cassandra/streaming/StreamSession$SSTableStreamingSections;>;
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
ranges
stores
overriddenRepairedAt
isIncremental final
public synchronized void addTransferFiles(java.util.Collection<org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections>);
descriptor: (Ljava/util/Collection;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=7, locals=7, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.failIfFinished:()V
1: aload 1
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 2
start local 2 2: goto 17
3: StackMap locals: java.util.Iterator
StackMap stack:
aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections
astore 3
start local 3 4: aload 3
getfield org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections.sections:Ljava/util/List;
invokeinterface java.util.List.isEmpty:()Z
ifeq 8
5: aload 3
getfield org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections.ref:Lorg/apache/cassandra/utils/concurrent/Ref;
invokevirtual org.apache.cassandra.utils.concurrent.Ref.release:()V
6: aload 2
invokeinterface java.util.Iterator.remove:()V
7: goto 17
8: StackMap locals: org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections
StackMap stack:
aload 3
getfield org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections.ref:Lorg/apache/cassandra/utils/concurrent/Ref;
invokevirtual org.apache.cassandra.utils.concurrent.Ref.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
getfield org.apache.cassandra.io.sstable.format.SSTableReader.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
astore 4
start local 4 9: aload 0
getfield org.apache.cassandra.streaming.StreamSession.transfers:Ljava/util/concurrent/ConcurrentHashMap;
aload 4
invokevirtual java.util.concurrent.ConcurrentHashMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamTransferTask
astore 5
start local 5 10: aload 5
ifnonnull 15
11: new org.apache.cassandra.streaming.StreamTransferTask
dup
aload 0
aload 4
invokespecial org.apache.cassandra.streaming.StreamTransferTask.<init>:(Lorg/apache/cassandra/streaming/StreamSession;Ljava/util/UUID;)V
astore 6
start local 6 12: aload 0
getfield org.apache.cassandra.streaming.StreamSession.transfers:Ljava/util/concurrent/ConcurrentHashMap;
aload 4
aload 6
invokevirtual java.util.concurrent.ConcurrentHashMap.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamTransferTask
astore 5
13: aload 5
ifnonnull 15
14: aload 6
astore 5
end local 6 15: StackMap locals: java.util.UUID org.apache.cassandra.streaming.StreamTransferTask
StackMap stack:
aload 5
aload 3
getfield org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections.ref:Lorg/apache/cassandra/utils/concurrent/Ref;
aload 3
getfield org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections.estimatedKeys:J
aload 3
getfield org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections.sections:Ljava/util/List;
aload 3
getfield org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections.repairedAt:J
invokevirtual org.apache.cassandra.streaming.StreamTransferTask.addTransferFile:(Lorg/apache/cassandra/utils/concurrent/Ref;JLjava/util/List;J)V
16: aload 2
invokeinterface java.util.Iterator.remove:()V
end local 5 end local 4 end local 3 17: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
18: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 19 1 sstableDetails Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamSession$SSTableStreamingSections;>;
2 19 2 iter Ljava/util/Iterator<Lorg/apache/cassandra/streaming/StreamSession$SSTableStreamingSections;>;
4 17 3 details Lorg/apache/cassandra/streaming/StreamSession$SSTableStreamingSections;
9 17 4 cfId Ljava/util/UUID;
10 17 5 task Lorg/apache/cassandra/streaming/StreamTransferTask;
12 15 6 newTask Lorg/apache/cassandra/streaming/StreamTransferTask;
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamSession$SSTableStreamingSections;>;)V
MethodParameters:
Name Flags
sstableDetails
private synchronized void closeSession(org.apache.cassandra.streaming.StreamSession$State);
descriptor: (Lorg/apache/cassandra/streaming/StreamSession$State;)V
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.isAborted:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_0
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
ifeq 13
1: aload 0
aload 1
invokevirtual org.apache.cassandra.streaming.StreamSession.state:(Lorg/apache/cassandra/streaming/StreamSession$State;)V
2: aload 1
getstatic org.apache.cassandra.streaming.StreamSession$State.FAILED:Lorg/apache/cassandra/streaming/StreamSession$State;
if_acmpne 7
3: aload 0
getfield org.apache.cassandra.streaming.StreamSession.receivers:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
aload 0
getfield org.apache.cassandra.streaming.StreamSession.transfers:Ljava/util/concurrent/ConcurrentHashMap;
invokevirtual java.util.concurrent.ConcurrentHashMap.values:()Ljava/util/Collection;
invokestatic com.google.common.collect.Iterables.concat:(Ljava/lang/Iterable;Ljava/lang/Iterable;)Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 3
goto 6
StackMap locals: org.apache.cassandra.streaming.StreamSession org.apache.cassandra.streaming.StreamSession$State top java.util.Iterator
StackMap stack:
4: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamTask
astore 2
start local 2 5: aload 2
invokevirtual org.apache.cassandra.streaming.StreamTask.abort:()V
end local 2 6: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
7: StackMap locals: org.apache.cassandra.streaming.StreamSession org.apache.cassandra.streaming.StreamSession$State
StackMap stack:
aload 0
getfield org.apache.cassandra.streaming.StreamSession.keepAliveFuture:Ljava/util/concurrent/ScheduledFuture;
ifnull 11
8: getstatic org.apache.cassandra.streaming.StreamSession.logger:Lorg/slf4j/Logger;
ldc "[Stream #{}] Finishing keep-alive task."
aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.planId:()Ljava/util/UUID;
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
9: aload 0
getfield org.apache.cassandra.streaming.StreamSession.keepAliveFuture:Ljava/util/concurrent/ScheduledFuture;
iconst_0
invokeinterface java.util.concurrent.ScheduledFuture.cancel:(Z)Z
pop
10: aload 0
aconst_null
putfield org.apache.cassandra.streaming.StreamSession.keepAliveFuture:Ljava/util/concurrent/ScheduledFuture;
11: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.streaming.StreamSession.handler:Lorg/apache/cassandra/streaming/ConnectionHandler;
invokevirtual org.apache.cassandra.streaming.ConnectionHandler.close:()Lcom/google/common/util/concurrent/ListenableFuture;
pop
12: aload 0
getfield org.apache.cassandra.streaming.StreamSession.streamResult:Lorg/apache/cassandra/streaming/StreamResultFuture;
aload 0
invokevirtual org.apache.cassandra.streaming.StreamResultFuture.handleSessionComplete:(Lorg/apache/cassandra/streaming/StreamSession;)V
13: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 14 1 finalState Lorg/apache/cassandra/streaming/StreamSession$State;
5 6 2 task Lorg/apache/cassandra/streaming/StreamTask;
MethodParameters:
Name Flags
finalState
public void state(org.apache.cassandra.streaming.StreamSession$State);
descriptor: (Lorg/apache/cassandra/streaming/StreamSession$State;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield org.apache.cassandra.streaming.StreamSession.state:Lorg/apache/cassandra/streaming/StreamSession$State;
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 2 1 newState Lorg/apache/cassandra/streaming/StreamSession$State;
MethodParameters:
Name Flags
newState
public org.apache.cassandra.streaming.StreamSession$State state();
descriptor: ()Lorg/apache/cassandra/streaming/StreamSession$State;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.state:Lorg/apache/cassandra/streaming/StreamSession$State;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/streaming/StreamSession;
public boolean isSuccess();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.state:Lorg/apache/cassandra/streaming/StreamSession$State;
getstatic org.apache.cassandra.streaming.StreamSession$State.COMPLETE:Lorg/apache/cassandra/streaming/StreamSession$State;
if_acmpne 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/streaming/StreamSession;
public void messageReceived(org.apache.cassandra.streaming.messages.StreamMessage);
descriptor: (Lorg/apache/cassandra/streaming/messages/StreamMessage;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: invokestatic org.apache.cassandra.streaming.StreamSession.$SWITCH_TABLE$org$apache$cassandra$streaming$messages$StreamMessage$Type:()[I
aload 1
getfield org.apache.cassandra.streaming.messages.StreamMessage.type:Lorg/apache/cassandra/streaming/messages/StreamMessage$Type;
invokevirtual org.apache.cassandra.streaming.messages.StreamMessage$Type.ordinal:()I
iaload
tableswitch { // 1 - 6
1: 1
2: 4
3: 6
4: 12
5: 9
6: 11
default: 12
}
1: StackMap locals:
StackMap stack:
aload 1
checkcast org.apache.cassandra.streaming.messages.PrepareMessage
astore 2
start local 2 2: aload 0
aload 2
getfield org.apache.cassandra.streaming.messages.PrepareMessage.requests:Ljava/util/Collection;
aload 2
getfield org.apache.cassandra.streaming.messages.PrepareMessage.summaries:Ljava/util/Collection;
invokevirtual org.apache.cassandra.streaming.StreamSession.prepare:(Ljava/util/Collection;Ljava/util/Collection;)V
3: goto 12
end local 2 4: StackMap locals:
StackMap stack:
aload 0
aload 1
checkcast org.apache.cassandra.streaming.messages.IncomingFileMessage
invokevirtual org.apache.cassandra.streaming.StreamSession.receive:(Lorg/apache/cassandra/streaming/messages/IncomingFileMessage;)V
5: goto 12
6: StackMap locals:
StackMap stack:
aload 1
checkcast org.apache.cassandra.streaming.messages.ReceivedMessage
astore 3
start local 3 7: aload 0
aload 3
getfield org.apache.cassandra.streaming.messages.ReceivedMessage.cfId:Ljava/util/UUID;
aload 3
getfield org.apache.cassandra.streaming.messages.ReceivedMessage.sequenceNumber:I
invokevirtual org.apache.cassandra.streaming.StreamSession.received:(Ljava/util/UUID;I)V
8: goto 12
end local 3 9: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.complete:()V
10: goto 12
11: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.sessionFailed:()V
12: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 13 1 message Lorg/apache/cassandra/streaming/messages/StreamMessage;
2 4 2 msg Lorg/apache/cassandra/streaming/messages/PrepareMessage;
7 9 3 received Lorg/apache/cassandra/streaming/messages/ReceivedMessage;
MethodParameters:
Name Flags
message
public void onInitializationComplete();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=1
start local 0 0: aload 0
getstatic org.apache.cassandra.streaming.StreamSession$State.PREPARING:Lorg/apache/cassandra/streaming/StreamSession$State;
invokevirtual org.apache.cassandra.streaming.StreamSession.state:(Lorg/apache/cassandra/streaming/StreamSession$State;)V
1: new org.apache.cassandra.streaming.messages.PrepareMessage
dup
invokespecial org.apache.cassandra.streaming.messages.PrepareMessage.<init>:()V
astore 1
start local 1 2: aload 1
getfield org.apache.cassandra.streaming.messages.PrepareMessage.requests:Ljava/util/Collection;
aload 0
getfield org.apache.cassandra.streaming.StreamSession.requests:Ljava/util/Set;
invokeinterface java.util.Collection.addAll:(Ljava/util/Collection;)Z
pop
3: aload 0
getfield org.apache.cassandra.streaming.StreamSession.transfers:Ljava/util/concurrent/ConcurrentHashMap;
invokevirtual java.util.concurrent.ConcurrentHashMap.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 3
goto 6
StackMap locals: org.apache.cassandra.streaming.StreamSession org.apache.cassandra.streaming.messages.PrepareMessage top java.util.Iterator
StackMap stack:
4: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamTransferTask
astore 2
start local 2 5: aload 1
getfield org.apache.cassandra.streaming.messages.PrepareMessage.summaries:Ljava/util/Collection;
aload 2
invokevirtual org.apache.cassandra.streaming.StreamTransferTask.getSummary:()Lorg/apache/cassandra/streaming/StreamSummary;
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
pop
end local 2 6: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
7: aload 0
getfield org.apache.cassandra.streaming.StreamSession.handler:Lorg/apache/cassandra/streaming/ConnectionHandler;
aload 1
invokevirtual org.apache.cassandra.streaming.ConnectionHandler.sendMessage:(Lorg/apache/cassandra/streaming/messages/StreamMessage;)V
8: aload 0
getfield org.apache.cassandra.streaming.StreamSession.requests:Ljava/util/Set;
invokeinterface java.util.Set.isEmpty:()Z
ifeq 10
9: aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.startStreamingFiles:()V
10: StackMap locals: org.apache.cassandra.streaming.StreamSession org.apache.cassandra.streaming.messages.PrepareMessage
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/streaming/StreamSession;
2 11 1 prepare Lorg/apache/cassandra/streaming/messages/PrepareMessage;
5 6 2 task Lorg/apache/cassandra/streaming/StreamTransferTask;
public void onError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual org.apache.cassandra.streaming.StreamSession.logError:(Ljava/lang/Throwable;)V
1: aload 0
getfield org.apache.cassandra.streaming.StreamSession.handler:Lorg/apache/cassandra/streaming/ConnectionHandler;
invokevirtual org.apache.cassandra.streaming.ConnectionHandler.isOutgoingConnected:()Z
ifeq 3
2: aload 0
getfield org.apache.cassandra.streaming.StreamSession.handler:Lorg/apache/cassandra/streaming/ConnectionHandler;
new org.apache.cassandra.streaming.messages.SessionFailedMessage
dup
invokespecial org.apache.cassandra.streaming.messages.SessionFailedMessage.<init>:()V
invokevirtual org.apache.cassandra.streaming.ConnectionHandler.sendMessage:(Lorg/apache/cassandra/streaming/messages/StreamMessage;)V
3: StackMap locals:
StackMap stack:
aload 0
getstatic org.apache.cassandra.streaming.StreamSession$State.FAILED:Lorg/apache/cassandra/streaming/StreamSession$State;
invokevirtual org.apache.cassandra.streaming.StreamSession.closeSession:(Lorg/apache/cassandra/streaming/StreamSession$State;)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 5 1 e Ljava/lang/Throwable;
MethodParameters:
Name Flags
e
private void logError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=2, args_size=2
start local 0 start local 1 0: aload 1
instanceof java.net.SocketTimeoutException
ifeq 16
1: aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.isKeepAliveSupported:()Z
ifeq 12
2: getstatic org.apache.cassandra.streaming.StreamSession.logger:Lorg/slf4j/Logger;
ldc "[Stream #{}] Did not receive response from peer {}{} for {} secs. Is peer down? If not, maybe try increasing streaming_keep_alive_period_in_secs."
iconst_5
anewarray java.lang.Object
dup
iconst_0
3: aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.planId:()Ljava/util/UUID;
aastore
dup
iconst_1
4: aload 0
getfield org.apache.cassandra.streaming.StreamSession.peer:Ljava/net/InetAddress;
invokevirtual java.net.InetAddress.getHostAddress:()Ljava/lang/String;
aastore
dup
iconst_2
5: aload 0
getfield org.apache.cassandra.streaming.StreamSession.peer:Ljava/net/InetAddress;
aload 0
getfield org.apache.cassandra.streaming.StreamSession.connecting:Ljava/net/InetAddress;
invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
ifeq 6
ldc ""
goto 7
StackMap locals: org.apache.cassandra.streaming.StreamSession java.lang.Throwable
StackMap stack: org.slf4j.Logger java.lang.String java.lang.Object[] java.lang.Object[] int
6: new java.lang.StringBuilder
dup
ldc " through "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.apache.cassandra.streaming.StreamSession.connecting:Ljava/net/InetAddress;
invokevirtual java.net.InetAddress.getHostAddress:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
StackMap locals: org.apache.cassandra.streaming.StreamSession java.lang.Throwable
StackMap stack: org.slf4j.Logger java.lang.String java.lang.Object[] java.lang.Object[] int java.lang.String
7: aastore
dup
iconst_3
8: iconst_2
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getStreamingKeepAlivePeriod:()I
imul
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_4
9: aload 1
aastore
10: invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;[Ljava/lang/Object;)V
11: goto 23
12: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.streaming.StreamSession.logger:Lorg/slf4j/Logger;
ldc "[Stream #{}] Streaming socket timed out. This means the session peer stopped responding or is still processing received data. If there is no sign of failure in the other end or a very dense table is being transferred you may want to increase streaming_socket_timeout_in_ms property. Current value is {}ms."
iconst_3
anewarray java.lang.Object
dup
iconst_0
13: aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.planId:()Ljava/util/UUID;
aastore
dup
iconst_1
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getStreamingSocketTimeout:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
aload 1
aastore
14: invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;[Ljava/lang/Object;)V
15: goto 23
16: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.streaming.StreamSession.logger:Lorg/slf4j/Logger;
ldc "[Stream #{}] Streaming error occurred on session with peer {}{}"
iconst_4
anewarray java.lang.Object
dup
iconst_0
aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.planId:()Ljava/util/UUID;
aastore
dup
iconst_1
17: aload 0
getfield org.apache.cassandra.streaming.StreamSession.peer:Ljava/net/InetAddress;
invokevirtual java.net.InetAddress.getHostAddress:()Ljava/lang/String;
aastore
dup
iconst_2
18: aload 0
getfield org.apache.cassandra.streaming.StreamSession.peer:Ljava/net/InetAddress;
aload 0
getfield org.apache.cassandra.streaming.StreamSession.connecting:Ljava/net/InetAddress;
invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
ifeq 19
ldc ""
goto 20
StackMap locals: org.apache.cassandra.streaming.StreamSession java.lang.Throwable
StackMap stack: org.slf4j.Logger java.lang.String java.lang.Object[] java.lang.Object[] int
19: new java.lang.StringBuilder
dup
ldc " through "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.apache.cassandra.streaming.StreamSession.connecting:Ljava/net/InetAddress;
invokevirtual java.net.InetAddress.getHostAddress:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
StackMap locals: org.apache.cassandra.streaming.StreamSession java.lang.Throwable
StackMap stack: org.slf4j.Logger java.lang.String java.lang.Object[] java.lang.Object[] int java.lang.String
20: aastore
dup
iconst_3
21: aload 1
aastore
22: invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;[Ljava/lang/Object;)V
23: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 24 1 e Ljava/lang/Throwable;
MethodParameters:
Name Flags
e
public void prepare(java.util.Collection<org.apache.cassandra.streaming.StreamRequest>, java.util.Collection<org.apache.cassandra.streaming.StreamSummary>);
descriptor: (Ljava/util/Collection;Ljava/util/Collection;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getstatic org.apache.cassandra.streaming.StreamSession$State.PREPARING:Lorg/apache/cassandra/streaming/StreamSession$State;
invokevirtual org.apache.cassandra.streaming.StreamSession.state:(Lorg/apache/cassandra/streaming/StreamSession$State;)V
1: aload 1
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 4
goto 4
StackMap locals: org.apache.cassandra.streaming.StreamSession java.util.Collection java.util.Collection top java.util.Iterator
StackMap stack:
2: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamRequest
astore 3
start local 3 3: aload 0
aload 3
getfield org.apache.cassandra.streaming.StreamRequest.keyspace:Ljava/lang/String;
aload 3
getfield org.apache.cassandra.streaming.StreamRequest.ranges:Ljava/util/Collection;
aload 3
getfield org.apache.cassandra.streaming.StreamRequest.columnFamilies:Ljava/util/Collection;
iconst_1
aload 3
getfield org.apache.cassandra.streaming.StreamRequest.repairedAt:J
invokevirtual org.apache.cassandra.streaming.StreamSession.addTransferRanges:(Ljava/lang/String;Ljava/util/Collection;Ljava/util/Collection;ZJ)V
end local 3 4: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: aload 2
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 4
goto 8
StackMap locals:
StackMap stack:
6: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamSummary
astore 3
start local 3 7: aload 0
aload 3
invokevirtual org.apache.cassandra.streaming.StreamSession.prepareReceiving:(Lorg/apache/cassandra/streaming/StreamSummary;)V
end local 3 8: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
9: aload 1
invokeinterface java.util.Collection.isEmpty:()Z
ifne 16
10: new org.apache.cassandra.streaming.messages.PrepareMessage
dup
invokespecial org.apache.cassandra.streaming.messages.PrepareMessage.<init>:()V
astore 3
start local 3 11: aload 0
getfield org.apache.cassandra.streaming.StreamSession.transfers:Ljava/util/concurrent/ConcurrentHashMap;
invokevirtual java.util.concurrent.ConcurrentHashMap.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 5
goto 14
StackMap locals: org.apache.cassandra.streaming.StreamSession java.util.Collection java.util.Collection org.apache.cassandra.streaming.messages.PrepareMessage top java.util.Iterator
StackMap stack:
12: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamTransferTask
astore 4
start local 4 13: aload 3
getfield org.apache.cassandra.streaming.messages.PrepareMessage.summaries:Ljava/util/Collection;
aload 4
invokevirtual org.apache.cassandra.streaming.StreamTransferTask.getSummary:()Lorg/apache/cassandra/streaming/StreamSummary;
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
pop
end local 4 14: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 12
15: aload 0
getfield org.apache.cassandra.streaming.StreamSession.handler:Lorg/apache/cassandra/streaming/ConnectionHandler;
aload 3
invokevirtual org.apache.cassandra.streaming.ConnectionHandler.sendMessage:(Lorg/apache/cassandra/streaming/messages/StreamMessage;)V
end local 3 16: StackMap locals: org.apache.cassandra.streaming.StreamSession java.util.Collection java.util.Collection
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.maybeCompleted:()Z
ifne 18
17: aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.startStreamingFiles:()V
18: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 19 1 requests Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamRequest;>;
0 19 2 summaries Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamSummary;>;
3 4 3 request Lorg/apache/cassandra/streaming/StreamRequest;
7 8 3 summary Lorg/apache/cassandra/streaming/StreamSummary;
11 16 3 prepare Lorg/apache/cassandra/streaming/messages/PrepareMessage;
13 14 4 task Lorg/apache/cassandra/streaming/StreamTransferTask;
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamRequest;>;Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamSummary;>;)V
MethodParameters:
Name Flags
requests
summaries
public void fileSent(org.apache.cassandra.streaming.messages.FileMessageHeader);
descriptor: (Lorg/apache/cassandra/streaming/messages/FileMessageHeader;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.apache.cassandra.streaming.messages.FileMessageHeader.size:()J
lstore 2
start local 2 1: getstatic org.apache.cassandra.metrics.StreamingMetrics.totalOutgoingBytes:Lcom/codahale/metrics/Counter;
lload 2
invokevirtual com.codahale.metrics.Counter.inc:(J)V
2: aload 0
getfield org.apache.cassandra.streaming.StreamSession.metrics:Lorg/apache/cassandra/metrics/StreamingMetrics;
getfield org.apache.cassandra.metrics.StreamingMetrics.outgoingBytes:Lcom/codahale/metrics/Counter;
lload 2
invokevirtual com.codahale.metrics.Counter.inc:(J)V
3: aload 0
getfield org.apache.cassandra.streaming.StreamSession.transfers:Ljava/util/concurrent/ConcurrentHashMap;
aload 1
getfield org.apache.cassandra.streaming.messages.FileMessageHeader.cfId:Ljava/util/UUID;
invokevirtual java.util.concurrent.ConcurrentHashMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamTransferTask
astore 4
start local 4 4: aload 4
ifnull 6
5: aload 4
aload 1
getfield org.apache.cassandra.streaming.messages.FileMessageHeader.sequenceNumber:I
ldc 12
getstatic java.util.concurrent.TimeUnit.HOURS:Ljava/util/concurrent/TimeUnit;
invokevirtual org.apache.cassandra.streaming.StreamTransferTask.scheduleTimeout:(IJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
pop
6: StackMap locals: long org.apache.cassandra.streaming.StreamTransferTask
StackMap stack:
return
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 7 1 header Lorg/apache/cassandra/streaming/messages/FileMessageHeader;
1 7 2 headerSize J
4 7 4 task Lorg/apache/cassandra/streaming/StreamTransferTask;
MethodParameters:
Name Flags
header
public void receive(org.apache.cassandra.streaming.messages.IncomingFileMessage);
descriptor: (Lorg/apache/cassandra/streaming/messages/IncomingFileMessage;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 1
getfield org.apache.cassandra.streaming.messages.IncomingFileMessage.header:Lorg/apache/cassandra/streaming/messages/FileMessageHeader;
invokevirtual org.apache.cassandra.streaming.messages.FileMessageHeader.size:()J
lstore 2
start local 2 1: getstatic org.apache.cassandra.metrics.StreamingMetrics.totalIncomingBytes:Lcom/codahale/metrics/Counter;
lload 2
invokevirtual com.codahale.metrics.Counter.inc:(J)V
2: aload 0
getfield org.apache.cassandra.streaming.StreamSession.metrics:Lorg/apache/cassandra/metrics/StreamingMetrics;
getfield org.apache.cassandra.metrics.StreamingMetrics.incomingBytes:Lcom/codahale/metrics/Counter;
lload 2
invokevirtual com.codahale.metrics.Counter.inc:(J)V
3: aload 0
getfield org.apache.cassandra.streaming.StreamSession.handler:Lorg/apache/cassandra/streaming/ConnectionHandler;
new org.apache.cassandra.streaming.messages.ReceivedMessage
dup
aload 1
getfield org.apache.cassandra.streaming.messages.IncomingFileMessage.header:Lorg/apache/cassandra/streaming/messages/FileMessageHeader;
getfield org.apache.cassandra.streaming.messages.FileMessageHeader.cfId:Ljava/util/UUID;
aload 1
getfield org.apache.cassandra.streaming.messages.IncomingFileMessage.header:Lorg/apache/cassandra/streaming/messages/FileMessageHeader;
getfield org.apache.cassandra.streaming.messages.FileMessageHeader.sequenceNumber:I
invokespecial org.apache.cassandra.streaming.messages.ReceivedMessage.<init>:(Ljava/util/UUID;I)V
invokevirtual org.apache.cassandra.streaming.ConnectionHandler.sendMessage:(Lorg/apache/cassandra/streaming/messages/StreamMessage;)V
4: aload 0
getfield org.apache.cassandra.streaming.StreamSession.receivers:Ljava/util/Map;
aload 1
getfield org.apache.cassandra.streaming.messages.IncomingFileMessage.header:Lorg/apache/cassandra/streaming/messages/FileMessageHeader;
getfield org.apache.cassandra.streaming.messages.FileMessageHeader.cfId:Ljava/util/UUID;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamReceiveTask
aload 1
getfield org.apache.cassandra.streaming.messages.IncomingFileMessage.sstable:Lorg/apache/cassandra/io/sstable/SSTableMultiWriter;
invokevirtual org.apache.cassandra.streaming.StreamReceiveTask.received:(Lorg/apache/cassandra/io/sstable/SSTableMultiWriter;)V
5: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 6 1 message Lorg/apache/cassandra/streaming/messages/IncomingFileMessage;
1 6 2 headerSize J
MethodParameters:
Name Flags
message
public void progress(java.lang.String, org.apache.cassandra.streaming.ProgressInfo$Direction, long, long);
descriptor: (Ljava/lang/String;Lorg/apache/cassandra/streaming/ProgressInfo$Direction;JJ)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=10, locals=8, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: new org.apache.cassandra.streaming.ProgressInfo
dup
aload 0
getfield org.apache.cassandra.streaming.StreamSession.peer:Ljava/net/InetAddress;
aload 0
getfield org.apache.cassandra.streaming.StreamSession.index:I
aload 1
aload 2
lload 3
lload 5
invokespecial org.apache.cassandra.streaming.ProgressInfo.<init>:(Ljava/net/InetAddress;ILjava/lang/String;Lorg/apache/cassandra/streaming/ProgressInfo$Direction;JJ)V
astore 7
start local 7 1: aload 0
getfield org.apache.cassandra.streaming.StreamSession.streamResult:Lorg/apache/cassandra/streaming/StreamResultFuture;
aload 7
invokevirtual org.apache.cassandra.streaming.StreamResultFuture.handleProgress:(Lorg/apache/cassandra/streaming/ProgressInfo;)V
2: return
end local 7 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 3 1 filename Ljava/lang/String;
0 3 2 direction Lorg/apache/cassandra/streaming/ProgressInfo$Direction;
0 3 3 bytes J
0 3 5 total J
1 3 7 progress Lorg/apache/cassandra/streaming/ProgressInfo;
MethodParameters:
Name Flags
filename
direction
bytes
total
public void received(java.util.UUID, int);
descriptor: (Ljava/util/UUID;I)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
getfield org.apache.cassandra.streaming.StreamSession.transfers:Ljava/util/concurrent/ConcurrentHashMap;
aload 1
invokevirtual java.util.concurrent.ConcurrentHashMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamTransferTask
iload 2
invokevirtual org.apache.cassandra.streaming.StreamTransferTask.complete:(I)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 2 1 cfId Ljava/util/UUID;
0 2 2 sequenceNumber I
MethodParameters:
Name Flags
cfId
sequenceNumber
public synchronized void complete();
descriptor: ()V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.state:Lorg/apache/cassandra/streaming/StreamSession$State;
getstatic org.apache.cassandra.streaming.StreamSession$State.WAIT_COMPLETE:Lorg/apache/cassandra/streaming/StreamSession$State;
if_acmpne 6
1: aload 0
getfield org.apache.cassandra.streaming.StreamSession.completeSent:Z
ifne 4
2: aload 0
getfield org.apache.cassandra.streaming.StreamSession.handler:Lorg/apache/cassandra/streaming/ConnectionHandler;
new org.apache.cassandra.streaming.messages.CompleteMessage
dup
invokespecial org.apache.cassandra.streaming.messages.CompleteMessage.<init>:()V
invokevirtual org.apache.cassandra.streaming.ConnectionHandler.sendMessage:(Lorg/apache/cassandra/streaming/messages/StreamMessage;)V
3: aload 0
iconst_1
putfield org.apache.cassandra.streaming.StreamSession.completeSent:Z
4: StackMap locals:
StackMap stack:
aload 0
getstatic org.apache.cassandra.streaming.StreamSession$State.COMPLETE:Lorg/apache/cassandra/streaming/StreamSession$State;
invokevirtual org.apache.cassandra.streaming.StreamSession.closeSession:(Lorg/apache/cassandra/streaming/StreamSession$State;)V
5: goto 8
6: StackMap locals:
StackMap stack:
aload 0
getstatic org.apache.cassandra.streaming.StreamSession$State.WAIT_COMPLETE:Lorg/apache/cassandra/streaming/StreamSession$State;
invokevirtual org.apache.cassandra.streaming.StreamSession.state:(Lorg/apache/cassandra/streaming/StreamSession$State;)V
7: aload 0
getfield org.apache.cassandra.streaming.StreamSession.handler:Lorg/apache/cassandra/streaming/ConnectionHandler;
invokevirtual org.apache.cassandra.streaming.ConnectionHandler.closeIncoming:()Lcom/google/common/util/concurrent/ListenableFuture;
pop
8: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/streaming/StreamSession;
private synchronized void scheduleKeepAliveTask();
descriptor: ()V
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=8, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.keepAliveFuture:Ljava/util/concurrent/ScheduledFuture;
ifnonnull 4
1: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getStreamingKeepAlivePeriod:()I
istore 1
start local 1 2: getstatic org.apache.cassandra.streaming.StreamSession.logger:Lorg/slf4j/Logger;
ldc "[Stream #{}] Scheduling keep-alive task with {}s period."
aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.planId:()Ljava/util/UUID;
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
3: aload 0
getstatic org.apache.cassandra.streaming.StreamSession.keepAliveExecutor:Lorg/apache/cassandra/concurrent/DebuggableScheduledThreadPoolExecutor;
new org.apache.cassandra.streaming.StreamSession$KeepAliveTask
dup
aload 0
invokespecial org.apache.cassandra.streaming.StreamSession$KeepAliveTask.<init>:(Lorg/apache/cassandra/streaming/StreamSession;)V
lconst_0
iload 1
i2l
getstatic java.util.concurrent.TimeUnit.SECONDS:Ljava/util/concurrent/TimeUnit;
invokevirtual org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor.scheduleAtFixedRate:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
putfield org.apache.cassandra.streaming.StreamSession.keepAliveFuture:Ljava/util/concurrent/ScheduledFuture;
end local 1 4: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/streaming/StreamSession;
2 4 1 keepAlivePeriod I
public synchronized void sessionFailed();
descriptor: ()V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.streaming.StreamSession.logger:Lorg/slf4j/Logger;
ldc "[Stream #{}] Remote peer {} failed stream session."
aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.planId:()Ljava/util/UUID;
aload 0
getfield org.apache.cassandra.streaming.StreamSession.peer:Ljava/net/InetAddress;
invokevirtual java.net.InetAddress.getHostAddress:()Ljava/lang/String;
invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
1: aload 0
getstatic org.apache.cassandra.streaming.StreamSession$State.FAILED:Lorg/apache/cassandra/streaming/StreamSession$State;
invokevirtual org.apache.cassandra.streaming.StreamSession.closeSession:(Lorg/apache/cassandra/streaming/StreamSession$State;)V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/streaming/StreamSession;
public org.apache.cassandra.streaming.SessionInfo getSessionInfo();
descriptor: ()Lorg/apache/cassandra/streaming/SessionInfo;
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=5, args_size=1
start local 0 0: invokestatic com.google.common.collect.Lists.newArrayList:()Ljava/util/ArrayList;
astore 1
start local 1 1: aload 0
getfield org.apache.cassandra.streaming.StreamSession.receivers:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 3
goto 4
StackMap locals: org.apache.cassandra.streaming.StreamSession java.util.List top java.util.Iterator
StackMap stack:
2: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamTask
astore 2
start local 2 3: aload 1
aload 2
invokevirtual org.apache.cassandra.streaming.StreamTask.getSummary:()Lorg/apache/cassandra/streaming/StreamSummary;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 2 4: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: invokestatic com.google.common.collect.Lists.newArrayList:()Ljava/util/ArrayList;
astore 2
start local 2 6: aload 0
getfield org.apache.cassandra.streaming.StreamSession.transfers:Ljava/util/concurrent/ConcurrentHashMap;
invokevirtual java.util.concurrent.ConcurrentHashMap.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 4
goto 9
StackMap locals: org.apache.cassandra.streaming.StreamSession java.util.List java.util.List top java.util.Iterator
StackMap stack:
7: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamTask
astore 3
start local 3 8: aload 2
aload 3
invokevirtual org.apache.cassandra.streaming.StreamTask.getSummary:()Lorg/apache/cassandra/streaming/StreamSummary;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 3 9: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 7
10: new org.apache.cassandra.streaming.SessionInfo
dup
aload 0
getfield org.apache.cassandra.streaming.StreamSession.peer:Ljava/net/InetAddress;
aload 0
getfield org.apache.cassandra.streaming.StreamSession.index:I
aload 0
getfield org.apache.cassandra.streaming.StreamSession.connecting:Ljava/net/InetAddress;
aload 1
aload 2
aload 0
getfield org.apache.cassandra.streaming.StreamSession.state:Lorg/apache/cassandra/streaming/StreamSession$State;
invokespecial org.apache.cassandra.streaming.SessionInfo.<init>:(Ljava/net/InetAddress;ILjava/net/InetAddress;Ljava/util/Collection;Ljava/util/Collection;Lorg/apache/cassandra/streaming/StreamSession$State;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/streaming/StreamSession;
1 11 1 receivingSummaries Ljava/util/List<Lorg/apache/cassandra/streaming/StreamSummary;>;
3 4 2 receiver Lorg/apache/cassandra/streaming/StreamTask;
6 11 2 transferSummaries Ljava/util/List<Lorg/apache/cassandra/streaming/StreamSummary;>;
8 9 3 transfer Lorg/apache/cassandra/streaming/StreamTask;
public synchronized void taskCompleted(org.apache.cassandra.streaming.StreamReceiveTask);
descriptor: (Lorg/apache/cassandra/streaming/StreamReceiveTask;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.receivers:Ljava/util/Map;
aload 1
getfield org.apache.cassandra.streaming.StreamReceiveTask.cfId:Ljava/util/UUID;
invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.maybeCompleted:()Z
pop
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 3 1 completedTask Lorg/apache/cassandra/streaming/StreamReceiveTask;
MethodParameters:
Name Flags
completedTask
public synchronized void taskCompleted(org.apache.cassandra.streaming.StreamTransferTask);
descriptor: (Lorg/apache/cassandra/streaming/StreamTransferTask;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.transfers:Ljava/util/concurrent/ConcurrentHashMap;
aload 1
getfield org.apache.cassandra.streaming.StreamTransferTask.cfId:Ljava/util/UUID;
invokevirtual java.util.concurrent.ConcurrentHashMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.maybeCompleted:()Z
pop
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 3 1 completedTask Lorg/apache/cassandra/streaming/StreamTransferTask;
MethodParameters:
Name Flags
completedTask
public void onJoin(java.net.InetAddress, org.apache.cassandra.gms.EndpointState);
descriptor: (Ljava/net/InetAddress;Lorg/apache/cassandra/gms/EndpointState;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=0, locals=3, args_size=3
start local 0 start local 1 start local 2 0: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 1 1 endpoint Ljava/net/InetAddress;
0 1 2 epState Lorg/apache/cassandra/gms/EndpointState;
MethodParameters:
Name Flags
endpoint
epState
public void beforeChange(java.net.InetAddress, org.apache.cassandra.gms.EndpointState, org.apache.cassandra.gms.ApplicationState, org.apache.cassandra.gms.VersionedValue);
descriptor: (Ljava/net/InetAddress;Lorg/apache/cassandra/gms/EndpointState;Lorg/apache/cassandra/gms/ApplicationState;Lorg/apache/cassandra/gms/VersionedValue;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=0, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 1 1 endpoint Ljava/net/InetAddress;
0 1 2 currentState Lorg/apache/cassandra/gms/EndpointState;
0 1 3 newStateKey Lorg/apache/cassandra/gms/ApplicationState;
0 1 4 newValue Lorg/apache/cassandra/gms/VersionedValue;
MethodParameters:
Name Flags
endpoint
currentState
newStateKey
newValue
public void onChange(java.net.InetAddress, org.apache.cassandra.gms.ApplicationState, org.apache.cassandra.gms.VersionedValue);
descriptor: (Ljava/net/InetAddress;Lorg/apache/cassandra/gms/ApplicationState;Lorg/apache/cassandra/gms/VersionedValue;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=0, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 1 1 endpoint Ljava/net/InetAddress;
0 1 2 state Lorg/apache/cassandra/gms/ApplicationState;
0 1 3 value Lorg/apache/cassandra/gms/VersionedValue;
MethodParameters:
Name Flags
endpoint
state
value
public void onAlive(java.net.InetAddress, org.apache.cassandra.gms.EndpointState);
descriptor: (Ljava/net/InetAddress;Lorg/apache/cassandra/gms/EndpointState;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=0, locals=3, args_size=3
start local 0 start local 1 start local 2 0: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 1 1 endpoint Ljava/net/InetAddress;
0 1 2 state Lorg/apache/cassandra/gms/EndpointState;
MethodParameters:
Name Flags
endpoint
state
public void onDead(java.net.InetAddress, org.apache.cassandra.gms.EndpointState);
descriptor: (Ljava/net/InetAddress;Lorg/apache/cassandra/gms/EndpointState;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=0, locals=3, args_size=3
start local 0 start local 1 start local 2 0: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 1 1 endpoint Ljava/net/InetAddress;
0 1 2 state Lorg/apache/cassandra/gms/EndpointState;
MethodParameters:
Name Flags
endpoint
state
public void onRemove(java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.streaming.StreamSession.logger:Lorg/slf4j/Logger;
ldc "[Stream #{}] Session failed because remote peer {} has left."
aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.planId:()Ljava/util/UUID;
aload 0
getfield org.apache.cassandra.streaming.StreamSession.peer:Ljava/net/InetAddress;
invokevirtual java.net.InetAddress.getHostAddress:()Ljava/lang/String;
invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
1: aload 0
getstatic org.apache.cassandra.streaming.StreamSession$State.FAILED:Lorg/apache/cassandra/streaming/StreamSession$State;
invokevirtual org.apache.cassandra.streaming.StreamSession.closeSession:(Lorg/apache/cassandra/streaming/StreamSession$State;)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 3 1 endpoint Ljava/net/InetAddress;
MethodParameters:
Name Flags
endpoint
public void onRestart(java.net.InetAddress, org.apache.cassandra.gms.EndpointState);
descriptor: (Ljava/net/InetAddress;Lorg/apache/cassandra/gms/EndpointState;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.streaming.StreamSession.logger:Lorg/slf4j/Logger;
ldc "[Stream #{}] Session failed because remote peer {} was restarted."
aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.planId:()Ljava/util/UUID;
aload 0
getfield org.apache.cassandra.streaming.StreamSession.peer:Ljava/net/InetAddress;
invokevirtual java.net.InetAddress.getHostAddress:()Ljava/lang/String;
invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
1: aload 0
getstatic org.apache.cassandra.streaming.StreamSession$State.FAILED:Lorg/apache/cassandra/streaming/StreamSession$State;
invokevirtual org.apache.cassandra.streaming.StreamSession.closeSession:(Lorg/apache/cassandra/streaming/StreamSession$State;)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/streaming/StreamSession;
0 3 1 endpoint Ljava/net/InetAddress;
0 3 2 epState Lorg/apache/cassandra/gms/EndpointState;
MethodParameters:
Name Flags
endpoint
epState
private boolean maybeCompleted();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.receivers:Ljava/util/Map;
invokeinterface java.util.Map.isEmpty:()Z
ifeq 1
aload 0
getfield org.apache.cassandra.streaming.StreamSession.transfers:Ljava/util/concurrent/ConcurrentHashMap;
invokevirtual java.util.concurrent.ConcurrentHashMap.isEmpty:()Z
ifeq 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: istore 1
start local 1 3: iload 1
ifeq 14
4: aload 0
getfield org.apache.cassandra.streaming.StreamSession.state:Lorg/apache/cassandra/streaming/StreamSession$State;
getstatic org.apache.cassandra.streaming.StreamSession$State.WAIT_COMPLETE:Lorg/apache/cassandra/streaming/StreamSession$State;
if_acmpne 10
5: aload 0
getfield org.apache.cassandra.streaming.StreamSession.completeSent:Z
ifne 8
6: aload 0
getfield org.apache.cassandra.streaming.StreamSession.handler:Lorg/apache/cassandra/streaming/ConnectionHandler;
new org.apache.cassandra.streaming.messages.CompleteMessage
dup
invokespecial org.apache.cassandra.streaming.messages.CompleteMessage.<init>:()V
invokevirtual org.apache.cassandra.streaming.ConnectionHandler.sendMessage:(Lorg/apache/cassandra/streaming/messages/StreamMessage;)V
7: aload 0
iconst_1
putfield org.apache.cassandra.streaming.StreamSession.completeSent:Z
8: StackMap locals: int
StackMap stack:
aload 0
getstatic org.apache.cassandra.streaming.StreamSession$State.COMPLETE:Lorg/apache/cassandra/streaming/StreamSession$State;
invokevirtual org.apache.cassandra.streaming.StreamSession.closeSession:(Lorg/apache/cassandra/streaming/StreamSession$State;)V
9: goto 14
10: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.streaming.StreamSession.handler:Lorg/apache/cassandra/streaming/ConnectionHandler;
new org.apache.cassandra.streaming.messages.CompleteMessage
dup
invokespecial org.apache.cassandra.streaming.messages.CompleteMessage.<init>:()V
invokevirtual org.apache.cassandra.streaming.ConnectionHandler.sendMessage:(Lorg/apache/cassandra/streaming/messages/StreamMessage;)V
11: aload 0
iconst_1
putfield org.apache.cassandra.streaming.StreamSession.completeSent:Z
12: aload 0
getstatic org.apache.cassandra.streaming.StreamSession$State.WAIT_COMPLETE:Lorg/apache/cassandra/streaming/StreamSession$State;
invokevirtual org.apache.cassandra.streaming.StreamSession.state:(Lorg/apache/cassandra/streaming/StreamSession$State;)V
13: aload 0
getfield org.apache.cassandra.streaming.StreamSession.handler:Lorg/apache/cassandra/streaming/ConnectionHandler;
invokevirtual org.apache.cassandra.streaming.ConnectionHandler.closeOutgoing:()Lcom/google/common/util/concurrent/ListenableFuture;
pop
14: StackMap locals:
StackMap stack:
iload 1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lorg/apache/cassandra/streaming/StreamSession;
3 15 1 completed Z
private void flushSSTables(java.lang.Iterable<org.apache.cassandra.db.ColumnFamilyStore>);
descriptor: (Ljava/lang/Iterable;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
start local 2 1: aload 1
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 4
goto 4
StackMap locals: org.apache.cassandra.streaming.StreamSession java.lang.Iterable java.util.List top java.util.Iterator
StackMap stack:
2: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 3
start local 3 3: aload 2
aload 3
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.forceFlush:()Lcom/google/common/util/concurrent/ListenableFuture;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 3 4: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: aload 2
invokestatic org.apache.cassandra.utils.FBUtilities.waitOnFutures:(Ljava/lang/Iterable;)Ljava/util/List;
pop
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 7 1 stores Ljava/lang/Iterable<Lorg/apache/cassandra/db/ColumnFamilyStore;>;
1 7 2 flushes Ljava/util/List<Ljava/util/concurrent/Future<*>;>;
3 4 3 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/db/ColumnFamilyStore;>;)V
MethodParameters:
Name Flags
stores
private synchronized void prepareReceiving(org.apache.cassandra.streaming.StreamSummary);
descriptor: (Lorg/apache/cassandra/streaming/StreamSummary;)V
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.streaming.StreamSession.failIfFinished:()V
1: aload 1
getfield org.apache.cassandra.streaming.StreamSummary.files:I
ifle 3
2: aload 0
getfield org.apache.cassandra.streaming.StreamSession.receivers:Ljava/util/Map;
aload 1
getfield org.apache.cassandra.streaming.StreamSummary.cfId:Ljava/util/UUID;
new org.apache.cassandra.streaming.StreamReceiveTask
dup
aload 0
aload 1
getfield org.apache.cassandra.streaming.StreamSummary.cfId:Ljava/util/UUID;
aload 1
getfield org.apache.cassandra.streaming.StreamSummary.files:I
aload 1
getfield org.apache.cassandra.streaming.StreamSummary.totalSize:J
invokespecial org.apache.cassandra.streaming.StreamReceiveTask.<init>:(Lorg/apache/cassandra/streaming/StreamSession;Ljava/util/UUID;IJ)V
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/streaming/StreamSession;
0 4 1 summary Lorg/apache/cassandra/streaming/StreamSummary;
MethodParameters:
Name Flags
summary
private void startStreamingFiles();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=4, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.streaming.StreamSession.streamResult:Lorg/apache/cassandra/streaming/StreamResultFuture;
aload 0
invokevirtual org.apache.cassandra.streaming.StreamResultFuture.handleSessionPrepared:(Lorg/apache/cassandra/streaming/StreamSession;)V
1: aload 0
getstatic org.apache.cassandra.streaming.StreamSession$State.STREAMING:Lorg/apache/cassandra/streaming/StreamSession$State;
invokevirtual org.apache.cassandra.streaming.StreamSession.state:(Lorg/apache/cassandra/streaming/StreamSession$State;)V
2: aload 0
getfield org.apache.cassandra.streaming.StreamSession.transfers:Ljava/util/concurrent/ConcurrentHashMap;
invokevirtual java.util.concurrent.ConcurrentHashMap.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 2
goto 8
StackMap locals: org.apache.cassandra.streaming.StreamSession top java.util.Iterator
StackMap stack:
3: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.streaming.StreamTransferTask
astore 1
start local 1 4: aload 1
invokevirtual org.apache.cassandra.streaming.StreamTransferTask.getFileMessages:()Ljava/util/Collection;
astore 3
start local 3 5: aload 3
invokeinterface java.util.Collection.size:()I
ifle 7
6: aload 0
getfield org.apache.cassandra.streaming.StreamSession.handler:Lorg/apache/cassandra/streaming/ConnectionHandler;
aload 3
invokevirtual org.apache.cassandra.streaming.ConnectionHandler.sendMessages:(Ljava/util/Collection;)V
goto 8
7: StackMap locals: org.apache.cassandra.streaming.StreamSession org.apache.cassandra.streaming.StreamTransferTask java.util.Iterator java.util.Collection
StackMap stack:
aload 0
aload 1
invokevirtual org.apache.cassandra.streaming.StreamSession.taskCompleted:(Lorg/apache/cassandra/streaming/StreamTransferTask;)V
end local 3 end local 1 8: StackMap locals: org.apache.cassandra.streaming.StreamSession top java.util.Iterator
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
9: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/streaming/StreamSession;
4 8 1 task Lorg/apache/cassandra/streaming/StreamTransferTask;
5 8 3 messages Ljava/util/Collection<Lorg/apache/cassandra/streaming/messages/OutgoingFileMessage;>;
public static void shutdownAndWait(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=2
start local 0 start local 2 0: getstatic org.apache.cassandra.streaming.StreamSession.keepAliveExecutor:Lorg/apache/cassandra/concurrent/DebuggableScheduledThreadPoolExecutor;
invokestatic com.google.common.collect.ImmutableList.of:(Ljava/lang/Object;)Lcom/google/common/collect/ImmutableList;
astore 3
start local 3 1: aload 3
invokestatic org.apache.cassandra.utils.ExecutorUtils.shutdownNow:(Ljava/lang/Iterable;)V
2: lload 0
aload 2
aload 3
invokestatic org.apache.cassandra.utils.ExecutorUtils.awaitTermination:(JLjava/util/concurrent/TimeUnit;Ljava/util/Collection;)V
3: return
end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 timeout J
0 4 2 unit Ljava/util/concurrent/TimeUnit;
1 4 3 executors Ljava/util/List<Ljava/util/concurrent/ExecutorService;>;
Exceptions:
throws java.lang.InterruptedException, java.util.concurrent.TimeoutException
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
timeout
unit
static int[] $SWITCH_TABLE$org$apache$cassandra$streaming$messages$StreamMessage$Type();
descriptor: ()[I
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=0
0: getstatic org.apache.cassandra.streaming.StreamSession.$SWITCH_TABLE$org$apache$cassandra$streaming$messages$StreamMessage$Type:[I
dup
ifnull 1
areturn
StackMap locals:
StackMap stack: int[]
1: pop
invokestatic org.apache.cassandra.streaming.messages.StreamMessage$Type.values:()[Lorg/apache/cassandra/streaming/messages/StreamMessage$Type;
arraylength
newarray 10
astore 0
2: aload 0
getstatic org.apache.cassandra.streaming.messages.StreamMessage$Type.COMPLETE:Lorg/apache/cassandra/streaming/messages/StreamMessage$Type;
invokevirtual org.apache.cassandra.streaming.messages.StreamMessage$Type.ordinal:()I
iconst_5
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.messages.StreamMessage$Type.FILE:Lorg/apache/cassandra/streaming/messages/StreamMessage$Type;
invokevirtual org.apache.cassandra.streaming.messages.StreamMessage$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.messages.StreamMessage$Type.KEEP_ALIVE:Lorg/apache/cassandra/streaming/messages/StreamMessage$Type;
invokevirtual org.apache.cassandra.streaming.messages.StreamMessage$Type.ordinal:()I
bipush 7
iastore
9: goto 11
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
10: pop
StackMap locals:
StackMap stack:
11: aload 0
getstatic org.apache.cassandra.streaming.messages.StreamMessage$Type.PREPARE:Lorg/apache/cassandra/streaming/messages/StreamMessage$Type;
invokevirtual org.apache.cassandra.streaming.messages.StreamMessage$Type.ordinal:()I
iconst_1
iastore
12: goto 14
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
13: pop
StackMap locals:
StackMap stack:
14: aload 0
getstatic org.apache.cassandra.streaming.messages.StreamMessage$Type.RECEIVED:Lorg/apache/cassandra/streaming/messages/StreamMessage$Type;
invokevirtual org.apache.cassandra.streaming.messages.StreamMessage$Type.ordinal:()I
iconst_3
iastore
15: goto 17
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
16: pop
StackMap locals:
StackMap stack:
17: aload 0
getstatic org.apache.cassandra.streaming.messages.StreamMessage$Type.RETRY:Lorg/apache/cassandra/streaming/messages/StreamMessage$Type;
invokevirtual org.apache.cassandra.streaming.messages.StreamMessage$Type.ordinal:()I
iconst_4
iastore
18: goto 20
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
19: pop
StackMap locals:
StackMap stack:
20: aload 0
getstatic org.apache.cassandra.streaming.messages.StreamMessage$Type.SESSION_FAILED:Lorg/apache/cassandra/streaming/messages/StreamMessage$Type;
invokevirtual org.apache.cassandra.streaming.messages.StreamMessage$Type.ordinal:()I
bipush 6
iastore
21: goto 23
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
22: pop
StackMap locals:
StackMap stack:
23: aload 0
dup
putstatic org.apache.cassandra.streaming.StreamSession.$SWITCH_TABLE$org$apache$cassandra$streaming$messages$StreamMessage$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
11 12 13 Class java.lang.NoSuchFieldError
14 15 16 Class java.lang.NoSuchFieldError
17 18 19 Class java.lang.NoSuchFieldError
20 21 22 Class java.lang.NoSuchFieldError
private static java.lang.Iterable lambda$0(java.util.List, boolean, org.apache.cassandra.db.lifecycle.View);
descriptor: (Ljava/util/List;ZLorg/apache/cassandra/db/lifecycle/View;)Ljava/lang/Iterable;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=9, args_size=3
start local 2 0: invokestatic com.google.common.collect.Sets.newHashSet:()Ljava/util/HashSet;
astore 3
start local 3 1: aload 2
getstatic org.apache.cassandra.db.lifecycle.SSTableSet.CANONICAL:Lorg/apache/cassandra/db/lifecycle/SSTableSet;
invokevirtual org.apache.cassandra.db.lifecycle.View.select:(Lorg/apache/cassandra/db/lifecycle/SSTableSet;)Ljava/lang/Iterable;
invokestatic org.apache.cassandra.db.lifecycle.SSTableIntervalTree.build:(Ljava/lang/Iterable;)Lorg/apache/cassandra/db/lifecycle/SSTableIntervalTree;
astore 4
start local 4 2: aload 0
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 6
goto 9
StackMap locals: java.util.List int org.apache.cassandra.db.lifecycle.View java.util.Set org.apache.cassandra.db.lifecycle.SSTableIntervalTree top java.util.Iterator
StackMap stack:
3: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.Range
astore 5
start local 5 4: aload 5
getfield org.apache.cassandra.dht.Range.left:Lorg/apache/cassandra/dht/RingPosition;
checkcast org.apache.cassandra.db.PartitionPosition
aload 5
getfield org.apache.cassandra.dht.Range.right:Lorg/apache/cassandra/dht/RingPosition;
checkcast org.apache.cassandra.db.PartitionPosition
aload 4
invokestatic org.apache.cassandra.db.lifecycle.View.sstablesInBounds:(Lorg/apache/cassandra/db/PartitionPosition;Lorg/apache/cassandra/db/PartitionPosition;Lorg/apache/cassandra/db/lifecycle/SSTableIntervalTree;)Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 8
goto 8
StackMap locals: java.util.List int org.apache.cassandra.db.lifecycle.View java.util.Set org.apache.cassandra.db.lifecycle.SSTableIntervalTree org.apache.cassandra.dht.Range java.util.Iterator top java.util.Iterator
StackMap stack:
5: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 7
start local 7 6: iload 1
ifeq 7
aload 7
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
ifne 8
7: StackMap locals: java.util.List int org.apache.cassandra.db.lifecycle.View java.util.Set org.apache.cassandra.db.lifecycle.SSTableIntervalTree org.apache.cassandra.dht.Range java.util.Iterator org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator
StackMap stack:
aload 3
aload 7
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 7 8: StackMap locals: java.util.List int org.apache.cassandra.db.lifecycle.View java.util.Set org.apache.cassandra.db.lifecycle.SSTableIntervalTree org.apache.cassandra.dht.Range java.util.Iterator top java.util.Iterator
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
end local 5 9: StackMap locals: java.util.List int org.apache.cassandra.db.lifecycle.View java.util.Set org.apache.cassandra.db.lifecycle.SSTableIntervalTree top java.util.Iterator
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
10: getstatic org.apache.cassandra.streaming.StreamSession.logger:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
ifeq 12
11: getstatic org.apache.cassandra.streaming.StreamSession.logger:Lorg/slf4j/Logger;
ldc "ViewFilter for {}/{} sstables"
aload 3
invokeinterface java.util.Set.size:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aload 2
getstatic org.apache.cassandra.db.lifecycle.SSTableSet.CANONICAL:Lorg/apache/cassandra/db/lifecycle/SSTableSet;
invokevirtual org.apache.cassandra.db.lifecycle.View.select:(Lorg/apache/cassandra/db/lifecycle/SSTableSet;)Ljava/lang/Iterable;
invokestatic com.google.common.collect.Iterables.size:(Ljava/lang/Iterable;)I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
12: StackMap locals: java.util.List int org.apache.cassandra.db.lifecycle.View java.util.Set org.apache.cassandra.db.lifecycle.SSTableIntervalTree
StackMap stack:
aload 3
areturn
end local 4 end local 3 end local 2 LocalVariableTable:
Start End Slot Name Signature
0 13 2 view Lorg/apache/cassandra/db/lifecycle/View;
1 13 3 sstables Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
2 13 4 intervalTree Lorg/apache/cassandra/db/lifecycle/SSTableIntervalTree;
4 9 5 keyRange Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/db/PartitionPosition;>;
6 8 7 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
}
SourceFile: "StreamSession.java"
NestMembers:
org.apache.cassandra.streaming.StreamSession$KeepAliveTask org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections org.apache.cassandra.streaming.StreamSession$State
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public RefViewFragment = org.apache.cassandra.db.ColumnFamilyStore$RefViewFragment of org.apache.cassandra.db.ColumnFamilyStore
public final Direction = org.apache.cassandra.streaming.ProgressInfo$Direction of org.apache.cassandra.streaming.ProgressInfo
KeepAliveTask = org.apache.cassandra.streaming.StreamSession$KeepAliveTask of org.apache.cassandra.streaming.StreamSession
public SSTableStreamingSections = org.apache.cassandra.streaming.StreamSession$SSTableStreamingSections of org.apache.cassandra.streaming.StreamSession
public final State = org.apache.cassandra.streaming.StreamSession$State of org.apache.cassandra.streaming.StreamSession
public final Type = org.apache.cassandra.streaming.messages.StreamMessage$Type of org.apache.cassandra.streaming.messages.StreamMessage
StreamSession
STREAM_KEEP_ALIVE: CassandraVersion
requests: Set
$assertionsDisabled: boolean
