public final class org.apache.cassandra.streaming.SessionInfo implements java.io.Serializable
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: org.apache.cassandra.streaming.SessionInfo
  super_class: java.lang.Object
{
  public final java.net.InetAddress peer;
    descriptor: Ljava/net/InetAddress;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  public final int sessionIndex;
    descriptor: I
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  public final java.net.InetAddress connecting;
    descriptor: Ljava/net/InetAddress;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  public final java.util.Collection<org.apache.cassandra.streaming.StreamSummary> receivingSummaries;
    descriptor: Ljava/util/Collection;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Signature: Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamSummary;>;

  public final java.util.Collection<org.apache.cassandra.streaming.StreamSummary> sendingSummaries;
    descriptor: Ljava/util/Collection;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Signature: Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamSummary;>;

  public final org.apache.cassandra.streaming.StreamSession$State state;
    descriptor: Lorg/apache/cassandra/streaming/StreamSession$State;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  private final java.util.Map<java.lang.String, org.apache.cassandra.streaming.ProgressInfo> receivingFiles;
    descriptor: Ljava/util/Map;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Map<Ljava/lang/String;Lorg/apache/cassandra/streaming/ProgressInfo;>;

  private final java.util.Map<java.lang.String, org.apache.cassandra.streaming.ProgressInfo> sendingFiles;
    descriptor: Ljava/util/Map;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Map<Ljava/lang/String;Lorg/apache/cassandra/streaming/ProgressInfo;>;

  static final boolean $assertionsDisabled;
    descriptor: Z
    flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 33
            ldc Lorg/apache/cassandra/streaming/SessionInfo;
            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.SessionInfo.$assertionsDisabled:Z
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(java.net.InetAddress, int, java.net.InetAddress, java.util.Collection<org.apache.cassandra.streaming.StreamSummary>, java.util.Collection<org.apache.cassandra.streaming.StreamSummary>, org.apache.cassandra.streaming.StreamSession$State);
    descriptor: (Ljava/net/InetAddress;ILjava/net/InetAddress;Ljava/util/Collection;Ljava/util/Collection;Lorg/apache/cassandra/streaming/StreamSession$State;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=7, args_size=7
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
        start local 1 // java.net.InetAddress peer
        start local 2 // int sessionIndex
        start local 3 // java.net.InetAddress connecting
        start local 4 // java.util.Collection receivingSummaries
        start local 5 // java.util.Collection sendingSummaries
        start local 6 // org.apache.cassandra.streaming.StreamSession$State state
         0: .line 48
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 55
            aload 0 /* this */
            aload 1 /* peer */
            putfield org.apache.cassandra.streaming.SessionInfo.peer:Ljava/net/InetAddress;
         2: .line 56
            aload 0 /* this */
            iload 2 /* sessionIndex */
            putfield org.apache.cassandra.streaming.SessionInfo.sessionIndex:I
         3: .line 57
            aload 0 /* this */
            aload 3 /* connecting */
            putfield org.apache.cassandra.streaming.SessionInfo.connecting:Ljava/net/InetAddress;
         4: .line 58
            aload 0 /* this */
            aload 4 /* receivingSummaries */
            invokestatic com.google.common.collect.ImmutableSet.copyOf:(Ljava/util/Collection;)Lcom/google/common/collect/ImmutableSet;
            putfield org.apache.cassandra.streaming.SessionInfo.receivingSummaries:Ljava/util/Collection;
         5: .line 59
            aload 0 /* this */
            aload 5 /* sendingSummaries */
            invokestatic com.google.common.collect.ImmutableSet.copyOf:(Ljava/util/Collection;)Lcom/google/common/collect/ImmutableSet;
            putfield org.apache.cassandra.streaming.SessionInfo.sendingSummaries:Ljava/util/Collection;
         6: .line 60
            aload 0 /* this */
            new java.util.concurrent.ConcurrentHashMap
            dup
            invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
            putfield org.apache.cassandra.streaming.SessionInfo.receivingFiles:Ljava/util/Map;
         7: .line 61
            aload 0 /* this */
            new java.util.concurrent.ConcurrentHashMap
            dup
            invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
            putfield org.apache.cassandra.streaming.SessionInfo.sendingFiles:Ljava/util/Map;
         8: .line 62
            aload 0 /* this */
            aload 6 /* state */
            putfield org.apache.cassandra.streaming.SessionInfo.state:Lorg/apache/cassandra/streaming/StreamSession$State;
         9: .line 63
            return
        end local 6 // org.apache.cassandra.streaming.StreamSession$State state
        end local 5 // java.util.Collection sendingSummaries
        end local 4 // java.util.Collection receivingSummaries
        end local 3 // java.net.InetAddress connecting
        end local 2 // int sessionIndex
        end local 1 // java.net.InetAddress peer
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   10     0                this  Lorg/apache/cassandra/streaming/SessionInfo;
            0   10     1                peer  Ljava/net/InetAddress;
            0   10     2        sessionIndex  I
            0   10     3          connecting  Ljava/net/InetAddress;
            0   10     4  receivingSummaries  Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamSummary;>;
            0   10     5    sendingSummaries  Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamSummary;>;
            0   10     6               state  Lorg/apache/cassandra/streaming/StreamSession$State;
    Signature: (Ljava/net/InetAddress;ILjava/net/InetAddress;Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamSummary;>;Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamSummary;>;Lorg/apache/cassandra/streaming/StreamSession$State;)V
    MethodParameters:
                    Name  Flags
      peer                
      sessionIndex        
      connecting          
      receivingSummaries  
      sendingSummaries    
      state               

  public boolean isFailed();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
         0: .line 67
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.SessionInfo.state:Lorg/apache/cassandra/streaming/StreamSession$State;
            getstatic org.apache.cassandra.streaming.StreamSession$State.FAILED:Lorg/apache/cassandra/streaming/StreamSession$State;
            if_acmpne 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/streaming/SessionInfo;

  public void updateProgress(org.apache.cassandra.streaming.ProgressInfo);
    descriptor: (Lorg/apache/cassandra/streaming/ProgressInfo;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
        start local 1 // org.apache.cassandra.streaming.ProgressInfo newProgress
         0: .line 77
            getstatic org.apache.cassandra.streaming.SessionInfo.$assertionsDisabled:Z
            ifne 1
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.SessionInfo.peer:Ljava/net/InetAddress;
            aload 1 /* newProgress */
            getfield org.apache.cassandra.streaming.ProgressInfo.peer:Ljava/net/InetAddress;
            invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
            ifne 1
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         1: .line 79
      StackMap locals:
      StackMap stack:
            aload 1 /* newProgress */
            getfield org.apache.cassandra.streaming.ProgressInfo.direction:Lorg/apache/cassandra/streaming/ProgressInfo$Direction;
            getstatic org.apache.cassandra.streaming.ProgressInfo$Direction.IN:Lorg/apache/cassandra/streaming/ProgressInfo$Direction;
            if_acmpne 3
         2: .line 80
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.SessionInfo.receivingFiles:Ljava/util/Map;
            goto 4
      StackMap locals:
      StackMap stack:
         3: aload 0 /* this */
            getfield org.apache.cassandra.streaming.SessionInfo.sendingFiles:Ljava/util/Map;
         4: .line 79
      StackMap locals:
      StackMap stack: java.util.Map
            astore 2 /* currentFiles */
        start local 2 // java.util.Map currentFiles
         5: .line 81
            aload 2 /* currentFiles */
            aload 1 /* newProgress */
            getfield org.apache.cassandra.streaming.ProgressInfo.fileName:Ljava/lang/String;
            aload 1 /* newProgress */
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         6: .line 82
            return
        end local 2 // java.util.Map currentFiles
        end local 1 // org.apache.cassandra.streaming.ProgressInfo newProgress
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    7     0          this  Lorg/apache/cassandra/streaming/SessionInfo;
            0    7     1   newProgress  Lorg/apache/cassandra/streaming/ProgressInfo;
            5    7     2  currentFiles  Ljava/util/Map<Ljava/lang/String;Lorg/apache/cassandra/streaming/ProgressInfo;>;
    MethodParameters:
             Name  Flags
      newProgress  

  public java.util.Collection<org.apache.cassandra.streaming.ProgressInfo> getReceivingFiles();
    descriptor: ()Ljava/util/Collection;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
         0: .line 86
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.SessionInfo.receivingFiles:Ljava/util/Map;
            invokeinterface java.util.Map.values:()Ljava/util/Collection;
            areturn
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/streaming/SessionInfo;
    Signature: ()Ljava/util/Collection<Lorg/apache/cassandra/streaming/ProgressInfo;>;

  public java.util.Collection<org.apache.cassandra.streaming.ProgressInfo> getSendingFiles();
    descriptor: ()Ljava/util/Collection;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
         0: .line 91
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.SessionInfo.sendingFiles:Ljava/util/Map;
            invokeinterface java.util.Map.values:()Ljava/util/Collection;
            areturn
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/streaming/SessionInfo;
    Signature: ()Ljava/util/Collection<Lorg/apache/cassandra/streaming/ProgressInfo;>;

  public long getTotalFilesReceived();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
         0: .line 99
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.SessionInfo.receivingFiles:Ljava/util/Map;
            invokeinterface java.util.Map.values:()Ljava/util/Collection;
            invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalFilesCompleted:(Ljava/util/Collection;)J
            lreturn
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/streaming/SessionInfo;

  public long getTotalFilesSent();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
         0: .line 107
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.SessionInfo.sendingFiles:Ljava/util/Map;
            invokeinterface java.util.Map.values:()Ljava/util/Collection;
            invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalFilesCompleted:(Ljava/util/Collection;)J
            lreturn
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/streaming/SessionInfo;

  public long getTotalSizeReceived();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
         0: .line 115
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.SessionInfo.receivingFiles:Ljava/util/Map;
            invokeinterface java.util.Map.values:()Ljava/util/Collection;
            invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalSizeInProgress:(Ljava/util/Collection;)J
            lreturn
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/streaming/SessionInfo;

  public long getTotalSizeSent();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
         0: .line 123
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.SessionInfo.sendingFiles:Ljava/util/Map;
            invokeinterface java.util.Map.values:()Ljava/util/Collection;
            invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalSizeInProgress:(Ljava/util/Collection;)J
            lreturn
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/streaming/SessionInfo;

  public long getTotalFilesToReceive();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
         0: .line 131
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.SessionInfo.receivingSummaries:Ljava/util/Collection;
            invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalFiles:(Ljava/util/Collection;)J
            lreturn
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/streaming/SessionInfo;

  public long getTotalFilesToSend();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
         0: .line 139
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.SessionInfo.sendingSummaries:Ljava/util/Collection;
            invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalFiles:(Ljava/util/Collection;)J
            lreturn
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/streaming/SessionInfo;

  public long getTotalSizeToReceive();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
         0: .line 147
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.SessionInfo.receivingSummaries:Ljava/util/Collection;
            invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalSizes:(Ljava/util/Collection;)J
            lreturn
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/streaming/SessionInfo;

  public long getTotalSizeToSend();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
         0: .line 155
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.SessionInfo.sendingSummaries:Ljava/util/Collection;
            invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalSizes:(Ljava/util/Collection;)J
            lreturn
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/streaming/SessionInfo;

  private long getTotalSizeInProgress(java.util.Collection<org.apache.cassandra.streaming.ProgressInfo>);
    descriptor: (Ljava/util/Collection;)J
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=6, args_size=2
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
        start local 1 // java.util.Collection files
         0: .line 160
            lconst_0
            lstore 2 /* total */
        start local 2 // long total
         1: .line 161
            aload 1 /* files */
            invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
            astore 5
            goto 4
      StackMap locals: org.apache.cassandra.streaming.SessionInfo java.util.Collection long top java.util.Iterator
      StackMap stack:
         2: aload 5
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.streaming.ProgressInfo
            astore 4 /* file */
        start local 4 // org.apache.cassandra.streaming.ProgressInfo file
         3: .line 162
            lload 2 /* total */
            aload 4 /* file */
            getfield org.apache.cassandra.streaming.ProgressInfo.currentBytes:J
            ladd
            lstore 2 /* total */
        end local 4 // org.apache.cassandra.streaming.ProgressInfo file
         4: .line 161
      StackMap locals:
      StackMap stack:
            aload 5
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         5: .line 163
            lload 2 /* total */
            lreturn
        end local 2 // long total
        end local 1 // java.util.Collection files
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    6     0   this  Lorg/apache/cassandra/streaming/SessionInfo;
            0    6     1  files  Ljava/util/Collection<Lorg/apache/cassandra/streaming/ProgressInfo;>;
            1    6     2  total  J
            3    4     4   file  Lorg/apache/cassandra/streaming/ProgressInfo;
    Signature: (Ljava/util/Collection<Lorg/apache/cassandra/streaming/ProgressInfo;>;)J
    MethodParameters:
       Name  Flags
      files  

  private long getTotalFiles(java.util.Collection<org.apache.cassandra.streaming.StreamSummary>);
    descriptor: (Ljava/util/Collection;)J
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=6, args_size=2
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
        start local 1 // java.util.Collection summaries
         0: .line 168
            lconst_0
            lstore 2 /* total */
        start local 2 // long total
         1: .line 169
            aload 1 /* summaries */
            invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
            astore 5
            goto 4
      StackMap locals: org.apache.cassandra.streaming.SessionInfo java.util.Collection long top java.util.Iterator
      StackMap stack:
         2: aload 5
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.streaming.StreamSummary
            astore 4 /* summary */
        start local 4 // org.apache.cassandra.streaming.StreamSummary summary
         3: .line 170
            lload 2 /* total */
            aload 4 /* summary */
            getfield org.apache.cassandra.streaming.StreamSummary.files:I
            i2l
            ladd
            lstore 2 /* total */
        end local 4 // org.apache.cassandra.streaming.StreamSummary summary
         4: .line 169
      StackMap locals:
      StackMap stack:
            aload 5
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         5: .line 171
            lload 2 /* total */
            lreturn
        end local 2 // long total
        end local 1 // java.util.Collection summaries
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    6     0       this  Lorg/apache/cassandra/streaming/SessionInfo;
            0    6     1  summaries  Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamSummary;>;
            1    6     2      total  J
            3    4     4    summary  Lorg/apache/cassandra/streaming/StreamSummary;
    Signature: (Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamSummary;>;)J
    MethodParameters:
           Name  Flags
      summaries  

  private long getTotalSizes(java.util.Collection<org.apache.cassandra.streaming.StreamSummary>);
    descriptor: (Ljava/util/Collection;)J
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=6, args_size=2
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
        start local 1 // java.util.Collection summaries
         0: .line 176
            lconst_0
            lstore 2 /* total */
        start local 2 // long total
         1: .line 177
            aload 1 /* summaries */
            invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
            astore 5
            goto 4
      StackMap locals: org.apache.cassandra.streaming.SessionInfo java.util.Collection long top java.util.Iterator
      StackMap stack:
         2: aload 5
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.streaming.StreamSummary
            astore 4 /* summary */
        start local 4 // org.apache.cassandra.streaming.StreamSummary summary
         3: .line 178
            lload 2 /* total */
            aload 4 /* summary */
            getfield org.apache.cassandra.streaming.StreamSummary.totalSize:J
            ladd
            lstore 2 /* total */
        end local 4 // org.apache.cassandra.streaming.StreamSummary summary
         4: .line 177
      StackMap locals:
      StackMap stack:
            aload 5
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         5: .line 179
            lload 2 /* total */
            lreturn
        end local 2 // long total
        end local 1 // java.util.Collection summaries
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    6     0       this  Lorg/apache/cassandra/streaming/SessionInfo;
            0    6     1  summaries  Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamSummary;>;
            1    6     2      total  J
            3    4     4    summary  Lorg/apache/cassandra/streaming/StreamSummary;
    Signature: (Ljava/util/Collection<Lorg/apache/cassandra/streaming/StreamSummary;>;)J
    MethodParameters:
           Name  Flags
      summaries  

  private long getTotalFilesCompleted(java.util.Collection<org.apache.cassandra.streaming.ProgressInfo>);
    descriptor: (Ljava/util/Collection;)J
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // org.apache.cassandra.streaming.SessionInfo this
        start local 1 // java.util.Collection files
         0: .line 184
            aload 1 /* files */
            new org.apache.cassandra.streaming.SessionInfo$1
            dup
            aload 0 /* this */
            invokespecial org.apache.cassandra.streaming.SessionInfo$1.<init>:(Lorg/apache/cassandra/streaming/SessionInfo;)V
            invokestatic com.google.common.collect.Iterables.filter:(Ljava/lang/Iterable;Lcom/google/common/base/Predicate;)Ljava/lang/Iterable;
            astore 2 /* completed */
        start local 2 // java.lang.Iterable completed
         1: .line 191
            aload 2 /* completed */
            invokestatic com.google.common.collect.Iterables.size:(Ljava/lang/Iterable;)I
            i2l
            lreturn
        end local 2 // java.lang.Iterable completed
        end local 1 // java.util.Collection files
        end local 0 // org.apache.cassandra.streaming.SessionInfo this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lorg/apache/cassandra/streaming/SessionInfo;
            0    2     1      files  Ljava/util/Collection<Lorg/apache/cassandra/streaming/ProgressInfo;>;
            1    2     2  completed  Ljava/lang/Iterable<Lorg/apache/cassandra/streaming/ProgressInfo;>;
    Signature: (Ljava/util/Collection<Lorg/apache/cassandra/streaming/ProgressInfo;>;)J
    MethodParameters:
       Name  Flags
      files  
}
SourceFile: "SessionInfo.java"
NestMembers:
  org.apache.cassandra.streaming.SessionInfo$1
InnerClasses:
  public final Direction = org.apache.cassandra.streaming.ProgressInfo$Direction of org.apache.cassandra.streaming.ProgressInfo
  org.apache.cassandra.streaming.SessionInfo$1
  public final State = org.apache.cassandra.streaming.StreamSession$State of org.apache.cassandra.streaming.StreamSession