http://lmax-exchange.github.com/disruptor: Disruptor - Concurrent Programming Framework
  • LMAX Disruptor Development Team 
class com.lmax.disruptor.SequenceGroups
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: com.lmax.disruptor.SequenceGroups
  super_class: java.lang.Object
{
  void <init>();
    descriptor: ()V
    flags: (0x0000) 
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // com.lmax.disruptor.SequenceGroups this
         0: .line 25
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // com.lmax.disruptor.SequenceGroups this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lcom/lmax/disruptor/SequenceGroups;

  static <T> void addSequences(T, java.util.concurrent.atomic.AtomicReferenceFieldUpdater<T, com.lmax.disruptor.Sequence[]>, com.lmax.disruptor.Cursored, com.lmax.disruptor.Sequence[]);
    descriptor: (Ljava/lang/Object;Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Lcom/lmax/disruptor/Cursored;[Lcom/lmax/disruptor/Sequence;)V
    flags: (0x0088) ACC_STATIC, ACC_VARARGS
    Code:
      stack=4, locals=13, args_size=4
        start local 0 // java.lang.Object holder
        start local 1 // java.util.concurrent.atomic.AtomicReferenceFieldUpdater updater
        start local 2 // com.lmax.disruptor.Cursored cursor
        start local 3 // com.lmax.disruptor.Sequence[] sequencesToAdd
         0: .line 39
      StackMap locals:
      StackMap stack:
            aload 1 /* updater */
            aload 0 /* holder */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast com.lmax.disruptor.Sequence[]
            astore 7 /* currentSequences */
        start local 7 // com.lmax.disruptor.Sequence[] currentSequences
         1: .line 40
            aload 7 /* currentSequences */
            aload 7 /* currentSequences */
            arraylength
            aload 3 /* sequencesToAdd */
            arraylength
            iadd
            invokestatic java.util.Arrays.copyOf:([Ljava/lang/Object;I)[Ljava/lang/Object;
            checkcast com.lmax.disruptor.Sequence[]
            astore 6 /* updatedSequences */
        start local 6 // com.lmax.disruptor.Sequence[] updatedSequences
         2: .line 41
            aload 2 /* cursor */
            invokeinterface com.lmax.disruptor.Cursored.getCursor:()J
            lstore 4 /* cursorSequence */
        start local 4 // long cursorSequence
         3: .line 43
            aload 7 /* currentSequences */
            arraylength
            istore 8 /* index */
        start local 8 // int index
         4: .line 44
            aload 3 /* sequencesToAdd */
            dup
            astore 12
            arraylength
            istore 11
            iconst_0
            istore 10
            goto 9
      StackMap locals: java.lang.Object java.util.concurrent.atomic.AtomicReferenceFieldUpdater com.lmax.disruptor.Cursored com.lmax.disruptor.Sequence[] long com.lmax.disruptor.Sequence[] com.lmax.disruptor.Sequence[] int top int int com.lmax.disruptor.Sequence[]
      StackMap stack:
         5: aload 12
            iload 10
            aaload
            astore 9 /* sequence */
        start local 9 // com.lmax.disruptor.Sequence sequence
         6: .line 46
            aload 9 /* sequence */
            lload 4 /* cursorSequence */
            invokevirtual com.lmax.disruptor.Sequence.set:(J)V
         7: .line 47
            aload 6 /* updatedSequences */
            iload 8 /* index */
            iinc 8 /* index */ 1
            aload 9 /* sequence */
            aastore
        end local 9 // com.lmax.disruptor.Sequence sequence
         8: .line 44
            iinc 10 1
      StackMap locals:
      StackMap stack:
         9: iload 10
            iload 11
            if_icmplt 5
        end local 8 // int index
        10: .line 50
            aload 1 /* updater */
            aload 0 /* holder */
            aload 7 /* currentSequences */
            aload 6 /* updatedSequences */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
            ifeq 0
        11: .line 52
            aload 2 /* cursor */
            invokeinterface com.lmax.disruptor.Cursored.getCursor:()J
            lstore 4 /* cursorSequence */
        12: .line 53
            aload 3 /* sequencesToAdd */
            dup
            astore 11
            arraylength
            istore 10
            iconst_0
            istore 9
            goto 16
      StackMap locals: java.lang.Object java.util.concurrent.atomic.AtomicReferenceFieldUpdater com.lmax.disruptor.Cursored com.lmax.disruptor.Sequence[] long com.lmax.disruptor.Sequence[] com.lmax.disruptor.Sequence[] top int int com.lmax.disruptor.Sequence[]
      StackMap stack:
        13: aload 11
            iload 9
            aaload
            astore 8 /* sequence */
        start local 8 // com.lmax.disruptor.Sequence sequence
        14: .line 55
            aload 8 /* sequence */
            lload 4 /* cursorSequence */
            invokevirtual com.lmax.disruptor.Sequence.set:(J)V
        end local 8 // com.lmax.disruptor.Sequence sequence
        15: .line 53
            iinc 9 1
      StackMap locals:
      StackMap stack:
        16: iload 9
            iload 10
            if_icmplt 13
        17: .line 57
            return
        end local 7 // com.lmax.disruptor.Sequence[] currentSequences
        end local 6 // com.lmax.disruptor.Sequence[] updatedSequences
        end local 4 // long cursorSequence
        end local 3 // com.lmax.disruptor.Sequence[] sequencesToAdd
        end local 2 // com.lmax.disruptor.Cursored cursor
        end local 1 // java.util.concurrent.atomic.AtomicReferenceFieldUpdater updater
        end local 0 // java.lang.Object holder
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   18     0            holder  TT;
            0   18     1           updater  Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<TT;[Lcom/lmax/disruptor/Sequence;>;
            0   18     2            cursor  Lcom/lmax/disruptor/Cursored;
            0   18     3    sequencesToAdd  [Lcom/lmax/disruptor/Sequence;
            3   18     4    cursorSequence  J
            2   18     6  updatedSequences  [Lcom/lmax/disruptor/Sequence;
            1   18     7  currentSequences  [Lcom/lmax/disruptor/Sequence;
            4   10     8             index  I
            6    8     9          sequence  Lcom/lmax/disruptor/Sequence;
           14   15     8          sequence  Lcom/lmax/disruptor/Sequence;
    Signature: <T:Ljava/lang/Object;>(TT;Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<TT;[Lcom/lmax/disruptor/Sequence;>;Lcom/lmax/disruptor/Cursored;[Lcom/lmax/disruptor/Sequence;)V
    MethodParameters:
                Name  Flags
      holder          final
      updater         final
      cursor          final
      sequencesToAdd  final

  static <T> boolean removeSequence(T, java.util.concurrent.atomic.AtomicReferenceFieldUpdater<T, com.lmax.disruptor.Sequence[]>, com.lmax.disruptor.Sequence);
    descriptor: (Ljava/lang/Object;Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;Lcom/lmax/disruptor/Sequence;)Z
    flags: (0x0008) ACC_STATIC
    Code:
      stack=4, locals=10, args_size=3
        start local 0 // java.lang.Object holder
        start local 1 // java.util.concurrent.atomic.AtomicReferenceFieldUpdater sequenceUpdater
        start local 2 // com.lmax.disruptor.Sequence sequence
         0: .line 70
      StackMap locals:
      StackMap stack:
            aload 1 /* sequenceUpdater */
            aload 0 /* holder */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast com.lmax.disruptor.Sequence[]
            astore 4 /* oldSequences */
        start local 4 // com.lmax.disruptor.Sequence[] oldSequences
         1: .line 72
            aload 4 /* oldSequences */
            aload 2 /* sequence */
            invokestatic com.lmax.disruptor.SequenceGroups.countMatching:([Ljava/lang/Object;Ljava/lang/Object;)I
            istore 3 /* numToRemove */
        start local 3 // int numToRemove
         2: .line 74
            iload 3 /* numToRemove */
            ifne 4
         3: .line 76
            goto 15
         4: .line 79
      StackMap locals: int com.lmax.disruptor.Sequence[]
      StackMap stack:
            aload 4 /* oldSequences */
            arraylength
            istore 6 /* oldSize */
        start local 6 // int oldSize
         5: .line 80
            iload 6 /* oldSize */
            iload 3 /* numToRemove */
            isub
            anewarray com.lmax.disruptor.Sequence
            astore 5 /* newSequences */
        start local 5 // com.lmax.disruptor.Sequence[] newSequences
         6: .line 82
            iconst_0
            istore 7 /* i */
        start local 7 // int i
         7: iconst_0
            istore 8 /* pos */
        start local 8 // int pos
         8: goto 13
         9: .line 84
      StackMap locals: java.lang.Object java.util.concurrent.atomic.AtomicReferenceFieldUpdater com.lmax.disruptor.Sequence int com.lmax.disruptor.Sequence[] com.lmax.disruptor.Sequence[] int int int
      StackMap stack:
            aload 4 /* oldSequences */
            iload 7 /* i */
            aaload
            astore 9 /* testSequence */
        start local 9 // com.lmax.disruptor.Sequence testSequence
        10: .line 85
            aload 2 /* sequence */
            aload 9 /* testSequence */
            if_acmpeq 12
        11: .line 87
            aload 5 /* newSequences */
            iload 8 /* pos */
            iinc 8 /* pos */ 1
            aload 9 /* testSequence */
            aastore
        end local 9 // com.lmax.disruptor.Sequence testSequence
        12: .line 82
      StackMap locals:
      StackMap stack:
            iinc 7 /* i */ 1
      StackMap locals:
      StackMap stack:
        13: iload 7 /* i */
            iload 6 /* oldSize */
            if_icmplt 9
        end local 8 // int pos
        end local 7 // int i
        end local 6 // int oldSize
        14: .line 91
            aload 1 /* sequenceUpdater */
            aload 0 /* holder */
            aload 4 /* oldSequences */
            aload 5 /* newSequences */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
            ifeq 0
        end local 5 // com.lmax.disruptor.Sequence[] newSequences
        15: .line 93
      StackMap locals: java.lang.Object java.util.concurrent.atomic.AtomicReferenceFieldUpdater com.lmax.disruptor.Sequence int com.lmax.disruptor.Sequence[]
      StackMap stack:
            iload 3 /* numToRemove */
            ifeq 16
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
        16: iconst_0
            ireturn
        end local 4 // com.lmax.disruptor.Sequence[] oldSequences
        end local 3 // int numToRemove
        end local 2 // com.lmax.disruptor.Sequence sequence
        end local 1 // java.util.concurrent.atomic.AtomicReferenceFieldUpdater sequenceUpdater
        end local 0 // java.lang.Object holder
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   17     0           holder  TT;
            0   17     1  sequenceUpdater  Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<TT;[Lcom/lmax/disruptor/Sequence;>;
            0   17     2         sequence  Lcom/lmax/disruptor/Sequence;
            2   17     3      numToRemove  I
            1   17     4     oldSequences  [Lcom/lmax/disruptor/Sequence;
            6   15     5     newSequences  [Lcom/lmax/disruptor/Sequence;
            5   14     6          oldSize  I
            7   14     7                i  I
            8   14     8              pos  I
           10   12     9     testSequence  Lcom/lmax/disruptor/Sequence;
    Signature: <T:Ljava/lang/Object;>(TT;Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater<TT;[Lcom/lmax/disruptor/Sequence;>;Lcom/lmax/disruptor/Sequence;)Z
    MethodParameters:
                 Name  Flags
      holder           final
      sequenceUpdater  final
      sequence         final

  private static <T> int countMatching(T[], );
    descriptor: ([Ljava/lang/Object;Ljava/lang/Object;)I
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=2, locals=7, args_size=2
        start local 0 // java.lang.Object[] values
        start local 1 // java.lang.Object toMatch
         0: .line 98
            iconst_0
            istore 2 /* numToRemove */
        start local 2 // int numToRemove
         1: .line 99
            aload 0 /* values */
            dup
            astore 6
            arraylength
            istore 5
            iconst_0
            istore 4
            goto 6
      StackMap locals: java.lang.Object[] java.lang.Object int top int int java.lang.Object[]
      StackMap stack:
         2: aload 6
            iload 4
            aaload
            astore 3 /* value */
        start local 3 // java.lang.Object value
         3: .line 101
            aload 3 /* value */
            aload 1 /* toMatch */
            if_acmpne 5
         4: .line 103
            iinc 2 /* numToRemove */ 1
        end local 3 // java.lang.Object value
         5: .line 99
      StackMap locals:
      StackMap stack:
            iinc 4 1
      StackMap locals:
      StackMap stack:
         6: iload 4
            iload 5
            if_icmplt 2
         7: .line 106
            iload 2 /* numToRemove */
            ireturn
        end local 2 // int numToRemove
        end local 1 // java.lang.Object toMatch
        end local 0 // java.lang.Object[] values
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    8     0       values  [Ljava/lang/Object;
            0    8     1      toMatch  TT;
            1    8     2  numToRemove  I
            3    5     3        value  TT;
    Signature: <T:Ljava/lang/Object;>([TT;TT;)I
    MethodParameters:
         Name  Flags
      values   
      toMatch  final
}
SourceFile: "SequenceGroups.java"