public final class com.lmax.disruptor.RingBuffer<E> extends com.lmax.disruptor.RingBufferFields<E> implements com.lmax.disruptor.Cursored, com.lmax.disruptor.EventSequencer<E>, com.lmax.disruptor.EventSink<E>
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: com.lmax.disruptor.RingBuffer
super_class: com.lmax.disruptor.RingBufferFields
{
public static final long INITIAL_CURSOR_VALUE;
descriptor: J
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: -1
protected long p1;
descriptor: J
flags: (0x0004) ACC_PROTECTED
protected long p2;
descriptor: J
flags: (0x0004) ACC_PROTECTED
protected long p3;
descriptor: J
flags: (0x0004) ACC_PROTECTED
protected long p4;
descriptor: J
flags: (0x0004) ACC_PROTECTED
protected long p5;
descriptor: J
flags: (0x0004) ACC_PROTECTED
protected long p6;
descriptor: J
flags: (0x0004) ACC_PROTECTED
protected long p7;
descriptor: J
flags: (0x0004) ACC_PROTECTED
private static volatile int[] $SWITCH_TABLE$com$lmax$disruptor$dsl$ProducerType;
descriptor: [I
flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC
void <init>(com.lmax.disruptor.EventFactory<E>, com.lmax.disruptor.Sequencer);
descriptor: (Lcom/lmax/disruptor/EventFactory;Lcom/lmax/disruptor/Sequencer;)V
flags: (0x0000)
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokespecial com.lmax.disruptor.RingBufferFields.<init>:(Lcom/lmax/disruptor/EventFactory;Lcom/lmax/disruptor/Sequencer;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 2 1 eventFactory Lcom/lmax/disruptor/EventFactory<TE;>;
0 2 2 sequencer Lcom/lmax/disruptor/Sequencer;
Signature: (Lcom/lmax/disruptor/EventFactory<TE;>;Lcom/lmax/disruptor/Sequencer;)V
MethodParameters:
Name Flags
eventFactory
sequencer
public static <E> com.lmax.disruptor.RingBuffer<E> createMultiProducer(com.lmax.disruptor.EventFactory<E>, int, com.lmax.disruptor.WaitStrategy);
descriptor: (Lcom/lmax/disruptor/EventFactory;ILcom/lmax/disruptor/WaitStrategy;)Lcom/lmax/disruptor/RingBuffer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: new com.lmax.disruptor.MultiProducerSequencer
dup
iload 1
aload 2
invokespecial com.lmax.disruptor.MultiProducerSequencer.<init>:(ILcom/lmax/disruptor/WaitStrategy;)V
astore 3
start local 3 1: new com.lmax.disruptor.RingBuffer
dup
aload 0
aload 3
invokespecial com.lmax.disruptor.RingBuffer.<init>:(Lcom/lmax/disruptor/EventFactory;Lcom/lmax/disruptor/Sequencer;)V
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 factory Lcom/lmax/disruptor/EventFactory<TE;>;
0 2 1 bufferSize I
0 2 2 waitStrategy Lcom/lmax/disruptor/WaitStrategy;
1 2 3 sequencer Lcom/lmax/disruptor/MultiProducerSequencer;
Signature: <E:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventFactory<TE;>;ILcom/lmax/disruptor/WaitStrategy;)Lcom/lmax/disruptor/RingBuffer<TE;>;
MethodParameters:
Name Flags
factory
bufferSize
waitStrategy
public static <E> com.lmax.disruptor.RingBuffer<E> createMultiProducer(com.lmax.disruptor.EventFactory<E>, int);
descriptor: (Lcom/lmax/disruptor/EventFactory;I)Lcom/lmax/disruptor/RingBuffer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
new com.lmax.disruptor.BlockingWaitStrategy
dup
invokespecial com.lmax.disruptor.BlockingWaitStrategy.<init>:()V
invokestatic com.lmax.disruptor.RingBuffer.createMultiProducer:(Lcom/lmax/disruptor/EventFactory;ILcom/lmax/disruptor/WaitStrategy;)Lcom/lmax/disruptor/RingBuffer;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 factory Lcom/lmax/disruptor/EventFactory<TE;>;
0 1 1 bufferSize I
Signature: <E:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventFactory<TE;>;I)Lcom/lmax/disruptor/RingBuffer<TE;>;
MethodParameters:
Name Flags
factory
bufferSize
public static <E> com.lmax.disruptor.RingBuffer<E> createSingleProducer(com.lmax.disruptor.EventFactory<E>, int, com.lmax.disruptor.WaitStrategy);
descriptor: (Lcom/lmax/disruptor/EventFactory;ILcom/lmax/disruptor/WaitStrategy;)Lcom/lmax/disruptor/RingBuffer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: new com.lmax.disruptor.SingleProducerSequencer
dup
iload 1
aload 2
invokespecial com.lmax.disruptor.SingleProducerSequencer.<init>:(ILcom/lmax/disruptor/WaitStrategy;)V
astore 3
start local 3 1: new com.lmax.disruptor.RingBuffer
dup
aload 0
aload 3
invokespecial com.lmax.disruptor.RingBuffer.<init>:(Lcom/lmax/disruptor/EventFactory;Lcom/lmax/disruptor/Sequencer;)V
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 factory Lcom/lmax/disruptor/EventFactory<TE;>;
0 2 1 bufferSize I
0 2 2 waitStrategy Lcom/lmax/disruptor/WaitStrategy;
1 2 3 sequencer Lcom/lmax/disruptor/SingleProducerSequencer;
Signature: <E:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventFactory<TE;>;ILcom/lmax/disruptor/WaitStrategy;)Lcom/lmax/disruptor/RingBuffer<TE;>;
MethodParameters:
Name Flags
factory
bufferSize
waitStrategy
public static <E> com.lmax.disruptor.RingBuffer<E> createSingleProducer(com.lmax.disruptor.EventFactory<E>, int);
descriptor: (Lcom/lmax/disruptor/EventFactory;I)Lcom/lmax/disruptor/RingBuffer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
new com.lmax.disruptor.BlockingWaitStrategy
dup
invokespecial com.lmax.disruptor.BlockingWaitStrategy.<init>:()V
invokestatic com.lmax.disruptor.RingBuffer.createSingleProducer:(Lcom/lmax/disruptor/EventFactory;ILcom/lmax/disruptor/WaitStrategy;)Lcom/lmax/disruptor/RingBuffer;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 factory Lcom/lmax/disruptor/EventFactory<TE;>;
0 1 1 bufferSize I
Signature: <E:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventFactory<TE;>;I)Lcom/lmax/disruptor/RingBuffer<TE;>;
MethodParameters:
Name Flags
factory
bufferSize
public static <E> com.lmax.disruptor.RingBuffer<E> create(com.lmax.disruptor.dsl.ProducerType, com.lmax.disruptor.EventFactory<E>, int, com.lmax.disruptor.WaitStrategy);
descriptor: (Lcom/lmax/disruptor/dsl/ProducerType;Lcom/lmax/disruptor/EventFactory;ILcom/lmax/disruptor/WaitStrategy;)Lcom/lmax/disruptor/RingBuffer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: invokestatic com.lmax.disruptor.RingBuffer.$SWITCH_TABLE$com$lmax$disruptor$dsl$ProducerType:()[I
aload 0
invokevirtual com.lmax.disruptor.dsl.ProducerType.ordinal:()I
iaload
tableswitch { // 1 - 2
1: 1
2: 2
default: 3
}
1: StackMap locals:
StackMap stack:
aload 1
iload 2
aload 3
invokestatic com.lmax.disruptor.RingBuffer.createSingleProducer:(Lcom/lmax/disruptor/EventFactory;ILcom/lmax/disruptor/WaitStrategy;)Lcom/lmax/disruptor/RingBuffer;
areturn
2: StackMap locals:
StackMap stack:
aload 1
iload 2
aload 3
invokestatic com.lmax.disruptor.RingBuffer.createMultiProducer:(Lcom/lmax/disruptor/EventFactory;ILcom/lmax/disruptor/WaitStrategy;)Lcom/lmax/disruptor/RingBuffer;
areturn
3: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
aload 0
invokevirtual com.lmax.disruptor.dsl.ProducerType.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 producerType Lcom/lmax/disruptor/dsl/ProducerType;
0 4 1 factory Lcom/lmax/disruptor/EventFactory<TE;>;
0 4 2 bufferSize I
0 4 3 waitStrategy Lcom/lmax/disruptor/WaitStrategy;
Signature: <E:Ljava/lang/Object;>(Lcom/lmax/disruptor/dsl/ProducerType;Lcom/lmax/disruptor/EventFactory<TE;>;ILcom/lmax/disruptor/WaitStrategy;)Lcom/lmax/disruptor/RingBuffer<TE;>;
MethodParameters:
Name Flags
producerType
factory
bufferSize
waitStrategy
public E get();
descriptor: (J)Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
lload 1
invokevirtual com.lmax.disruptor.RingBuffer.elementAt:(J)Ljava/lang/Object;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 1 1 sequence J
Signature: (J)TE;
MethodParameters:
Name Flags
sequence
public long next();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokeinterface com.lmax.disruptor.Sequencer.next:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
public long next(int);
descriptor: (I)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
iload 1
invokeinterface com.lmax.disruptor.Sequencer.next:(I)J
lreturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 1 1 n I
MethodParameters:
Name Flags
n
public long tryNext();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokeinterface com.lmax.disruptor.Sequencer.tryNext:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
Exceptions:
throws com.lmax.disruptor.InsufficientCapacityException
public long tryNext(int);
descriptor: (I)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
iload 1
invokeinterface com.lmax.disruptor.Sequencer.tryNext:(I)J
lreturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 1 1 n I
Exceptions:
throws com.lmax.disruptor.InsufficientCapacityException
MethodParameters:
Name Flags
n
public void resetTo(long);
descriptor: (J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 1
invokeinterface com.lmax.disruptor.Sequencer.claim:(J)V
1: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 1
invokeinterface com.lmax.disruptor.Sequencer.publish:(J)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 3 1 sequence J
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
sequence
public E claimAndGetPreallocated();
descriptor: (J)Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 1
invokeinterface com.lmax.disruptor.Sequencer.claim:(J)V
1: aload 0
lload 1
invokevirtual com.lmax.disruptor.RingBuffer.get:(J)Ljava/lang/Object;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 2 1 sequence J
Signature: (J)TE;
MethodParameters:
Name Flags
sequence
public boolean isPublished(long);
descriptor: (J)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 1
invokeinterface com.lmax.disruptor.Sequencer.isAvailable:(J)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 1 1 sequence J
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
sequence
public void addGatingSequences(com.lmax.disruptor.Sequence[]);
descriptor: ([Lcom/lmax/disruptor/Sequence;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
aload 1
invokeinterface com.lmax.disruptor.Sequencer.addGatingSequences:([Lcom/lmax/disruptor/Sequence;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 2 1 gatingSequences [Lcom/lmax/disruptor/Sequence;
MethodParameters:
Name Flags
gatingSequences
public long getMinimumGatingSequence();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokeinterface com.lmax.disruptor.Sequencer.getMinimumSequence:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
public boolean removeGatingSequence(com.lmax.disruptor.Sequence);
descriptor: (Lcom/lmax/disruptor/Sequence;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
aload 1
invokeinterface com.lmax.disruptor.Sequencer.removeGatingSequence:(Lcom/lmax/disruptor/Sequence;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 1 1 sequence Lcom/lmax/disruptor/Sequence;
MethodParameters:
Name Flags
sequence
public com.lmax.disruptor.SequenceBarrier newBarrier(com.lmax.disruptor.Sequence[]);
descriptor: ([Lcom/lmax/disruptor/Sequence;)Lcom/lmax/disruptor/SequenceBarrier;
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
aload 1
invokeinterface com.lmax.disruptor.Sequencer.newBarrier:([Lcom/lmax/disruptor/Sequence;)Lcom/lmax/disruptor/SequenceBarrier;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 1 1 sequencesToTrack [Lcom/lmax/disruptor/Sequence;
MethodParameters:
Name Flags
sequencesToTrack
public com.lmax.disruptor.EventPoller<E> newPoller(com.lmax.disruptor.Sequence[]);
descriptor: ([Lcom/lmax/disruptor/Sequence;)Lcom/lmax/disruptor/EventPoller;
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
aload 0
aload 1
invokeinterface com.lmax.disruptor.Sequencer.newPoller:(Lcom/lmax/disruptor/DataProvider;[Lcom/lmax/disruptor/Sequence;)Lcom/lmax/disruptor/EventPoller;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 1 1 gatingSequences [Lcom/lmax/disruptor/Sequence;
Signature: ([Lcom/lmax/disruptor/Sequence;)Lcom/lmax/disruptor/EventPoller<TE;>;
MethodParameters:
Name Flags
gatingSequences
public long getCursor();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokeinterface com.lmax.disruptor.Sequencer.getCursor:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
public int getBufferSize();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.lmax.disruptor.RingBuffer.bufferSize:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
public boolean hasAvailableCapacity(int);
descriptor: (I)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
iload 1
invokeinterface com.lmax.disruptor.Sequencer.hasAvailableCapacity:(I)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 1 1 requiredCapacity I
MethodParameters:
Name Flags
requiredCapacity
public void publishEvent(com.lmax.disruptor.EventTranslator<E>);
descriptor: (Lcom/lmax/disruptor/EventTranslator;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokeinterface com.lmax.disruptor.Sequencer.next:()J
lstore 2
start local 2 1: aload 0
aload 1
lload 2
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublish:(Lcom/lmax/disruptor/EventTranslator;J)V
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 3 1 translator Lcom/lmax/disruptor/EventTranslator<TE;>;
1 3 2 sequence J
Signature: (Lcom/lmax/disruptor/EventTranslator<TE;>;)V
MethodParameters:
Name Flags
translator
public boolean tryPublishEvent(com.lmax.disruptor.EventTranslator<E>);
descriptor: (Lcom/lmax/disruptor/EventTranslator;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokeinterface com.lmax.disruptor.Sequencer.tryNext:()J
lstore 2
start local 2 1: aload 0
aload 1
lload 2
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublish:(Lcom/lmax/disruptor/EventTranslator;J)V
2: iconst_1
ireturn
end local 2 3: StackMap locals:
StackMap stack: com.lmax.disruptor.InsufficientCapacityException
pop
4: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 5 1 translator Lcom/lmax/disruptor/EventTranslator<TE;>;
1 3 2 sequence J
Exception table:
from to target type
0 2 3 Class com.lmax.disruptor.InsufficientCapacityException
Signature: (Lcom/lmax/disruptor/EventTranslator<TE;>;)Z
MethodParameters:
Name Flags
translator
public <A> void publishEvent(com.lmax.disruptor.EventTranslatorOneArg<E, A>, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorOneArg;Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokeinterface com.lmax.disruptor.Sequencer.next:()J
lstore 3
start local 3 1: aload 0
aload 1
lload 3
aload 2
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublish:(Lcom/lmax/disruptor/EventTranslatorOneArg;JLjava/lang/Object;)V
2: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 3 1 translator Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;
0 3 2 arg0 TA;
1 3 3 sequence J
Signature: <A:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;TA;)V
MethodParameters:
Name Flags
translator
arg0
public <A> boolean tryPublishEvent(com.lmax.disruptor.EventTranslatorOneArg<E, A>, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorOneArg;Ljava/lang/Object;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokeinterface com.lmax.disruptor.Sequencer.tryNext:()J
lstore 3
start local 3 1: aload 0
aload 1
lload 3
aload 2
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublish:(Lcom/lmax/disruptor/EventTranslatorOneArg;JLjava/lang/Object;)V
2: iconst_1
ireturn
end local 3 3: StackMap locals:
StackMap stack: com.lmax.disruptor.InsufficientCapacityException
pop
4: iconst_0
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 5 1 translator Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;
0 5 2 arg0 TA;
1 3 3 sequence J
Exception table:
from to target type
0 2 3 Class com.lmax.disruptor.InsufficientCapacityException
Signature: <A:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;TA;)Z
MethodParameters:
Name Flags
translator
arg0
public <A, B> void publishEvent(com.lmax.disruptor.EventTranslatorTwoArg<E, A, B>, A, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorTwoArg;Ljava/lang/Object;Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokeinterface com.lmax.disruptor.Sequencer.next:()J
lstore 4
start local 4 1: aload 0
aload 1
lload 4
aload 2
aload 3
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublish:(Lcom/lmax/disruptor/EventTranslatorTwoArg;JLjava/lang/Object;Ljava/lang/Object;)V
2: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 3 1 translator Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;
0 3 2 arg0 TA;
0 3 3 arg1 TB;
1 3 4 sequence J
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;TA;TB;)V
MethodParameters:
Name Flags
translator
arg0
arg1
public <A, B> boolean tryPublishEvent(com.lmax.disruptor.EventTranslatorTwoArg<E, A, B>, A, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorTwoArg;Ljava/lang/Object;Ljava/lang/Object;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokeinterface com.lmax.disruptor.Sequencer.tryNext:()J
lstore 4
start local 4 1: aload 0
aload 1
lload 4
aload 2
aload 3
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublish:(Lcom/lmax/disruptor/EventTranslatorTwoArg;JLjava/lang/Object;Ljava/lang/Object;)V
2: iconst_1
ireturn
end local 4 3: StackMap locals:
StackMap stack: com.lmax.disruptor.InsufficientCapacityException
pop
4: iconst_0
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 5 1 translator Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;
0 5 2 arg0 TA;
0 5 3 arg1 TB;
1 3 4 sequence J
Exception table:
from to target type
0 2 3 Class com.lmax.disruptor.InsufficientCapacityException
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;TA;TB;)Z
MethodParameters:
Name Flags
translator
arg0
arg1
public <A, B, C> void publishEvent(com.lmax.disruptor.EventTranslatorThreeArg<E, A, B, C>, A, B, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorThreeArg;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=7, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokeinterface com.lmax.disruptor.Sequencer.next:()J
lstore 5
start local 5 1: aload 0
aload 1
lload 5
aload 2
aload 3
aload 4
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublish:(Lcom/lmax/disruptor/EventTranslatorThreeArg;JLjava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)V
2: return
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 3 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 3 1 translator Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;
0 3 2 arg0 TA;
0 3 3 arg1 TB;
0 3 4 arg2 TC;
1 3 5 sequence J
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;C:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;TA;TB;TC;)V
MethodParameters:
Name Flags
translator
arg0
arg1
arg2
public <A, B, C> boolean tryPublishEvent(com.lmax.disruptor.EventTranslatorThreeArg<E, A, B, C>, A, B, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorThreeArg;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=7, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokeinterface com.lmax.disruptor.Sequencer.tryNext:()J
lstore 5
start local 5 1: aload 0
aload 1
lload 5
aload 2
aload 3
aload 4
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublish:(Lcom/lmax/disruptor/EventTranslatorThreeArg;JLjava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)V
2: iconst_1
ireturn
end local 5 3: StackMap locals:
StackMap stack: com.lmax.disruptor.InsufficientCapacityException
pop
4: iconst_0
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 5 1 translator Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;
0 5 2 arg0 TA;
0 5 3 arg1 TB;
0 5 4 arg2 TC;
1 3 5 sequence J
Exception table:
from to target type
0 2 3 Class com.lmax.disruptor.InsufficientCapacityException
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;C:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;TA;TB;TC;)Z
MethodParameters:
Name Flags
translator
arg0
arg1
arg2
public void publishEvent(com.lmax.disruptor.EventTranslatorVararg<E>, []);
descriptor: (Lcom/lmax/disruptor/EventTranslatorVararg;[Ljava/lang/Object;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokeinterface com.lmax.disruptor.Sequencer.next:()J
lstore 3
start local 3 1: aload 0
aload 1
lload 3
aload 2
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublish:(Lcom/lmax/disruptor/EventTranslatorVararg;J[Ljava/lang/Object;)V
2: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 3 1 translator Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;
0 3 2 args [Ljava/lang/Object;
1 3 3 sequence J
Signature: (Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;[Ljava/lang/Object;)V
MethodParameters:
Name Flags
translator
args
public boolean tryPublishEvent(com.lmax.disruptor.EventTranslatorVararg<E>, []);
descriptor: (Lcom/lmax/disruptor/EventTranslatorVararg;[Ljava/lang/Object;)Z
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokeinterface com.lmax.disruptor.Sequencer.tryNext:()J
lstore 3
start local 3 1: aload 0
aload 1
lload 3
aload 2
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublish:(Lcom/lmax/disruptor/EventTranslatorVararg;J[Ljava/lang/Object;)V
2: iconst_1
ireturn
end local 3 3: StackMap locals:
StackMap stack: com.lmax.disruptor.InsufficientCapacityException
pop
4: iconst_0
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 5 1 translator Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;
0 5 2 args [Ljava/lang/Object;
1 3 3 sequence J
Exception table:
from to target type
0 2 3 Class com.lmax.disruptor.InsufficientCapacityException
Signature: (Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;[Ljava/lang/Object;)Z
MethodParameters:
Name Flags
translator
args
public void publishEvents(com.lmax.disruptor.EventTranslator<E>[]);
descriptor: ([Lcom/lmax/disruptor/EventTranslator;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
iconst_0
aload 1
arraylength
invokevirtual com.lmax.disruptor.RingBuffer.publishEvents:([Lcom/lmax/disruptor/EventTranslator;II)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 2 1 translators [Lcom/lmax/disruptor/EventTranslator;
Signature: ([Lcom/lmax/disruptor/EventTranslator<TE;>;)V
MethodParameters:
Name Flags
translators
public void publishEvents(com.lmax.disruptor.EventTranslator<E>[], int, );
descriptor: ([Lcom/lmax/disruptor/EventTranslator;II)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
iload 2
iload 3
invokevirtual com.lmax.disruptor.RingBuffer.checkBounds:([Lcom/lmax/disruptor/EventTranslator;II)V
1: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
iload 3
invokeinterface com.lmax.disruptor.Sequencer.next:(I)J
lstore 4
start local 4 2: aload 0
aload 1
iload 2
iload 3
lload 4
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublishBatch:([Lcom/lmax/disruptor/EventTranslator;IIJ)V
3: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 4 1 translators [Lcom/lmax/disruptor/EventTranslator;
0 4 2 batchStartsAt I
0 4 3 batchSize I
2 4 4 finalSequence J
Signature: ([Lcom/lmax/disruptor/EventTranslator<TE;>;II)V
MethodParameters:
Name Flags
translators
batchStartsAt
batchSize
public boolean tryPublishEvents(com.lmax.disruptor.EventTranslator<E>[]);
descriptor: ([Lcom/lmax/disruptor/EventTranslator;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
iconst_0
aload 1
arraylength
invokevirtual com.lmax.disruptor.RingBuffer.tryPublishEvents:([Lcom/lmax/disruptor/EventTranslator;II)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 1 1 translators [Lcom/lmax/disruptor/EventTranslator;
Signature: ([Lcom/lmax/disruptor/EventTranslator<TE;>;)Z
MethodParameters:
Name Flags
translators
public boolean tryPublishEvents(com.lmax.disruptor.EventTranslator<E>[], int, );
descriptor: ([Lcom/lmax/disruptor/EventTranslator;II)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
iload 2
iload 3
invokevirtual com.lmax.disruptor.RingBuffer.checkBounds:([Lcom/lmax/disruptor/EventTranslator;II)V
1: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
iload 3
invokeinterface com.lmax.disruptor.Sequencer.tryNext:(I)J
lstore 4
start local 4 2: aload 0
aload 1
iload 2
iload 3
lload 4
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublishBatch:([Lcom/lmax/disruptor/EventTranslator;IIJ)V
3: iconst_1
ireturn
end local 4 4: StackMap locals:
StackMap stack: com.lmax.disruptor.InsufficientCapacityException
pop
5: iconst_0
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 6 1 translators [Lcom/lmax/disruptor/EventTranslator;
0 6 2 batchStartsAt I
0 6 3 batchSize I
2 4 4 finalSequence J
Exception table:
from to target type
1 3 4 Class com.lmax.disruptor.InsufficientCapacityException
Signature: ([Lcom/lmax/disruptor/EventTranslator<TE;>;II)Z
MethodParameters:
Name Flags
translators
batchStartsAt
batchSize
public <A> void publishEvents(com.lmax.disruptor.EventTranslatorOneArg<E, A>, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorOneArg;[Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
iconst_0
aload 2
arraylength
aload 2
invokevirtual com.lmax.disruptor.RingBuffer.publishEvents:(Lcom/lmax/disruptor/EventTranslatorOneArg;II[Ljava/lang/Object;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 2 1 translator Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;
0 2 2 arg0 [Ljava/lang/Object;
Signature: <A:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;[TA;)V
MethodParameters:
Name Flags
translator
arg0
public <A> void publishEvents(com.lmax.disruptor.EventTranslatorOneArg<E, A>, int, int, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorOneArg;II[Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=7, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 4
iload 2
iload 3
invokevirtual com.lmax.disruptor.RingBuffer.checkBounds:([Ljava/lang/Object;II)V
1: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
iload 3
invokeinterface com.lmax.disruptor.Sequencer.next:(I)J
lstore 5
start local 5 2: aload 0
aload 1
aload 4
iload 2
iload 3
lload 5
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublishBatch:(Lcom/lmax/disruptor/EventTranslatorOneArg;[Ljava/lang/Object;IIJ)V
3: return
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 4 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 4 1 translator Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;
0 4 2 batchStartsAt I
0 4 3 batchSize I
0 4 4 arg0 [Ljava/lang/Object;
2 4 5 finalSequence J
Signature: <A:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;II[TA;)V
MethodParameters:
Name Flags
translator
batchStartsAt
batchSize
arg0
public <A> boolean tryPublishEvents(com.lmax.disruptor.EventTranslatorOneArg<E, A>, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorOneArg;[Ljava/lang/Object;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
iconst_0
aload 2
arraylength
aload 2
invokevirtual com.lmax.disruptor.RingBuffer.tryPublishEvents:(Lcom/lmax/disruptor/EventTranslatorOneArg;II[Ljava/lang/Object;)Z
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 1 1 translator Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;
0 1 2 arg0 [Ljava/lang/Object;
Signature: <A:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;[TA;)Z
MethodParameters:
Name Flags
translator
arg0
public <A> boolean tryPublishEvents(com.lmax.disruptor.EventTranslatorOneArg<E, A>, int, int, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorOneArg;II[Ljava/lang/Object;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=7, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 4
iload 2
iload 3
invokevirtual com.lmax.disruptor.RingBuffer.checkBounds:([Ljava/lang/Object;II)V
1: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
iload 3
invokeinterface com.lmax.disruptor.Sequencer.tryNext:(I)J
lstore 5
start local 5 2: aload 0
aload 1
aload 4
iload 2
iload 3
lload 5
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublishBatch:(Lcom/lmax/disruptor/EventTranslatorOneArg;[Ljava/lang/Object;IIJ)V
3: iconst_1
ireturn
end local 5 4: StackMap locals:
StackMap stack: com.lmax.disruptor.InsufficientCapacityException
pop
5: iconst_0
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 6 1 translator Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;
0 6 2 batchStartsAt I
0 6 3 batchSize I
0 6 4 arg0 [Ljava/lang/Object;
2 4 5 finalSequence J
Exception table:
from to target type
1 3 4 Class com.lmax.disruptor.InsufficientCapacityException
Signature: <A:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;II[TA;)Z
MethodParameters:
Name Flags
translator
batchStartsAt
batchSize
arg0
public <A, B> void publishEvents(com.lmax.disruptor.EventTranslatorTwoArg<E, A, B>, A[], );
descriptor: (Lcom/lmax/disruptor/EventTranslatorTwoArg;[Ljava/lang/Object;[Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
iconst_0
aload 2
arraylength
aload 2
aload 3
invokevirtual com.lmax.disruptor.RingBuffer.publishEvents:(Lcom/lmax/disruptor/EventTranslatorTwoArg;II[Ljava/lang/Object;[Ljava/lang/Object;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 2 1 translator Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;
0 2 2 arg0 [Ljava/lang/Object;
0 2 3 arg1 [Ljava/lang/Object;
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;[TA;[TB;)V
MethodParameters:
Name Flags
translator
arg0
arg1
public <A, B> void publishEvents(com.lmax.disruptor.EventTranslatorTwoArg<E, A, B>, int, int, A[], );
descriptor: (Lcom/lmax/disruptor/EventTranslatorTwoArg;II[Ljava/lang/Object;[Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=8, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
aload 4
aload 5
iload 2
iload 3
invokevirtual com.lmax.disruptor.RingBuffer.checkBounds:([Ljava/lang/Object;[Ljava/lang/Object;II)V
1: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
iload 3
invokeinterface com.lmax.disruptor.Sequencer.next:(I)J
lstore 6
start local 6 2: aload 0
aload 1
aload 4
aload 5
iload 2
iload 3
lload 6
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublishBatch:(Lcom/lmax/disruptor/EventTranslatorTwoArg;[Ljava/lang/Object;[Ljava/lang/Object;IIJ)V
3: 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 4 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 4 1 translator Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;
0 4 2 batchStartsAt I
0 4 3 batchSize I
0 4 4 arg0 [Ljava/lang/Object;
0 4 5 arg1 [Ljava/lang/Object;
2 4 6 finalSequence J
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;II[TA;[TB;)V
MethodParameters:
Name Flags
translator
batchStartsAt
batchSize
arg0
arg1
public <A, B> boolean tryPublishEvents(com.lmax.disruptor.EventTranslatorTwoArg<E, A, B>, A[], );
descriptor: (Lcom/lmax/disruptor/EventTranslatorTwoArg;[Ljava/lang/Object;[Ljava/lang/Object;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
iconst_0
aload 2
arraylength
aload 2
aload 3
invokevirtual com.lmax.disruptor.RingBuffer.tryPublishEvents:(Lcom/lmax/disruptor/EventTranslatorTwoArg;II[Ljava/lang/Object;[Ljava/lang/Object;)Z
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 1 1 translator Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;
0 1 2 arg0 [Ljava/lang/Object;
0 1 3 arg1 [Ljava/lang/Object;
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;[TA;[TB;)Z
MethodParameters:
Name Flags
translator
arg0
arg1
public <A, B> boolean tryPublishEvents(com.lmax.disruptor.EventTranslatorTwoArg<E, A, B>, int, int, A[], );
descriptor: (Lcom/lmax/disruptor/EventTranslatorTwoArg;II[Ljava/lang/Object;[Ljava/lang/Object;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=8, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
aload 4
aload 5
iload 2
iload 3
invokevirtual com.lmax.disruptor.RingBuffer.checkBounds:([Ljava/lang/Object;[Ljava/lang/Object;II)V
1: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
iload 3
invokeinterface com.lmax.disruptor.Sequencer.tryNext:(I)J
lstore 6
start local 6 2: aload 0
aload 1
aload 4
aload 5
iload 2
iload 3
lload 6
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublishBatch:(Lcom/lmax/disruptor/EventTranslatorTwoArg;[Ljava/lang/Object;[Ljava/lang/Object;IIJ)V
3: iconst_1
ireturn
end local 6 4: StackMap locals:
StackMap stack: com.lmax.disruptor.InsufficientCapacityException
pop
5: iconst_0
ireturn
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 6 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 6 1 translator Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;
0 6 2 batchStartsAt I
0 6 3 batchSize I
0 6 4 arg0 [Ljava/lang/Object;
0 6 5 arg1 [Ljava/lang/Object;
2 4 6 finalSequence J
Exception table:
from to target type
1 3 4 Class com.lmax.disruptor.InsufficientCapacityException
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;II[TA;[TB;)Z
MethodParameters:
Name Flags
translator
batchStartsAt
batchSize
arg0
arg1
public <A, B, C> void publishEvents(com.lmax.disruptor.EventTranslatorThreeArg<E, A, B, C>, A[], B[], );
descriptor: (Lcom/lmax/disruptor/EventTranslatorThreeArg;[Ljava/lang/Object;[Ljava/lang/Object;[Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
iconst_0
aload 2
arraylength
aload 2
aload 3
aload 4
invokevirtual com.lmax.disruptor.RingBuffer.publishEvents:(Lcom/lmax/disruptor/EventTranslatorThreeArg;II[Ljava/lang/Object;[Ljava/lang/Object;[Ljava/lang/Object;)V
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 Lcom/lmax/disruptor/RingBuffer<TE;>;
0 2 1 translator Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;
0 2 2 arg0 [Ljava/lang/Object;
0 2 3 arg1 [Ljava/lang/Object;
0 2 4 arg2 [Ljava/lang/Object;
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;C:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;[TA;[TB;[TC;)V
MethodParameters:
Name Flags
translator
arg0
arg1
arg2
public <A, B, C> void publishEvents(com.lmax.disruptor.EventTranslatorThreeArg<E, A, B, C>, int, int, A[], B[], );
descriptor: (Lcom/lmax/disruptor/EventTranslatorThreeArg;II[Ljava/lang/Object;[Ljava/lang/Object;[Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=9, locals=9, 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
aload 4
aload 5
aload 6
iload 2
iload 3
invokevirtual com.lmax.disruptor.RingBuffer.checkBounds:([Ljava/lang/Object;[Ljava/lang/Object;[Ljava/lang/Object;II)V
1: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
iload 3
invokeinterface com.lmax.disruptor.Sequencer.next:(I)J
lstore 7
start local 7 2: aload 0
aload 1
aload 4
aload 5
aload 6
iload 2
iload 3
lload 7
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublishBatch:(Lcom/lmax/disruptor/EventTranslatorThreeArg;[Ljava/lang/Object;[Ljava/lang/Object;[Ljava/lang/Object;IIJ)V
3: return
end local 7 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 4 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 4 1 translator Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;
0 4 2 batchStartsAt I
0 4 3 batchSize I
0 4 4 arg0 [Ljava/lang/Object;
0 4 5 arg1 [Ljava/lang/Object;
0 4 6 arg2 [Ljava/lang/Object;
2 4 7 finalSequence J
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;C:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;II[TA;[TB;[TC;)V
MethodParameters:
Name Flags
translator
batchStartsAt
batchSize
arg0
arg1
arg2
public <A, B, C> boolean tryPublishEvents(com.lmax.disruptor.EventTranslatorThreeArg<E, A, B, C>, A[], B[], );
descriptor: (Lcom/lmax/disruptor/EventTranslatorThreeArg;[Ljava/lang/Object;[Ljava/lang/Object;[Ljava/lang/Object;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
iconst_0
aload 2
arraylength
aload 2
aload 3
aload 4
invokevirtual com.lmax.disruptor.RingBuffer.tryPublishEvents:(Lcom/lmax/disruptor/EventTranslatorThreeArg;II[Ljava/lang/Object;[Ljava/lang/Object;[Ljava/lang/Object;)Z
ireturn
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 Lcom/lmax/disruptor/RingBuffer<TE;>;
0 1 1 translator Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;
0 1 2 arg0 [Ljava/lang/Object;
0 1 3 arg1 [Ljava/lang/Object;
0 1 4 arg2 [Ljava/lang/Object;
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;C:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;[TA;[TB;[TC;)Z
MethodParameters:
Name Flags
translator
arg0
arg1
arg2
public <A, B, C> boolean tryPublishEvents(com.lmax.disruptor.EventTranslatorThreeArg<E, A, B, C>, int, int, A[], B[], );
descriptor: (Lcom/lmax/disruptor/EventTranslatorThreeArg;II[Ljava/lang/Object;[Ljava/lang/Object;[Ljava/lang/Object;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=9, locals=9, 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
aload 4
aload 5
aload 6
iload 2
iload 3
invokevirtual com.lmax.disruptor.RingBuffer.checkBounds:([Ljava/lang/Object;[Ljava/lang/Object;[Ljava/lang/Object;II)V
1: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
iload 3
invokeinterface com.lmax.disruptor.Sequencer.tryNext:(I)J
lstore 7
start local 7 2: aload 0
aload 1
aload 4
aload 5
aload 6
iload 2
iload 3
lload 7
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublishBatch:(Lcom/lmax/disruptor/EventTranslatorThreeArg;[Ljava/lang/Object;[Ljava/lang/Object;[Ljava/lang/Object;IIJ)V
3: iconst_1
ireturn
end local 7 4: StackMap locals:
StackMap stack: com.lmax.disruptor.InsufficientCapacityException
pop
5: iconst_0
ireturn
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 6 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 6 1 translator Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;
0 6 2 batchStartsAt I
0 6 3 batchSize I
0 6 4 arg0 [Ljava/lang/Object;
0 6 5 arg1 [Ljava/lang/Object;
0 6 6 arg2 [Ljava/lang/Object;
2 4 7 finalSequence J
Exception table:
from to target type
1 3 4 Class com.lmax.disruptor.InsufficientCapacityException
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;C:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;II[TA;[TB;[TC;)Z
MethodParameters:
Name Flags
translator
batchStartsAt
batchSize
arg0
arg1
arg2
public void publishEvents(com.lmax.disruptor.EventTranslatorVararg<E>, [][]);
descriptor: (Lcom/lmax/disruptor/EventTranslatorVararg;[[Ljava/lang/Object;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
iconst_0
aload 2
arraylength
aload 2
invokevirtual com.lmax.disruptor.RingBuffer.publishEvents:(Lcom/lmax/disruptor/EventTranslatorVararg;II[[Ljava/lang/Object;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 2 1 translator Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;
0 2 2 args [[Ljava/lang/Object;
Signature: (Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;[[Ljava/lang/Object;)V
MethodParameters:
Name Flags
translator
args
public void publishEvents(com.lmax.disruptor.EventTranslatorVararg<E>, int, int, [][]);
descriptor: (Lcom/lmax/disruptor/EventTranslatorVararg;II[[Ljava/lang/Object;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=7, locals=7, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
iload 2
iload 3
aload 4
invokevirtual com.lmax.disruptor.RingBuffer.checkBounds:(II[[Ljava/lang/Object;)V
1: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
iload 3
invokeinterface com.lmax.disruptor.Sequencer.next:(I)J
lstore 5
start local 5 2: aload 0
aload 1
iload 2
iload 3
lload 5
aload 4
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublishBatch:(Lcom/lmax/disruptor/EventTranslatorVararg;IIJ[[Ljava/lang/Object;)V
3: return
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 4 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 4 1 translator Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;
0 4 2 batchStartsAt I
0 4 3 batchSize I
0 4 4 args [[Ljava/lang/Object;
2 4 5 finalSequence J
Signature: (Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;II[[Ljava/lang/Object;)V
MethodParameters:
Name Flags
translator
batchStartsAt
batchSize
args
public boolean tryPublishEvents(com.lmax.disruptor.EventTranslatorVararg<E>, [][]);
descriptor: (Lcom/lmax/disruptor/EventTranslatorVararg;[[Ljava/lang/Object;)Z
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
iconst_0
aload 2
arraylength
aload 2
invokevirtual com.lmax.disruptor.RingBuffer.tryPublishEvents:(Lcom/lmax/disruptor/EventTranslatorVararg;II[[Ljava/lang/Object;)Z
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 1 1 translator Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;
0 1 2 args [[Ljava/lang/Object;
Signature: (Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;[[Ljava/lang/Object;)Z
MethodParameters:
Name Flags
translator
args
public boolean tryPublishEvents(com.lmax.disruptor.EventTranslatorVararg<E>, int, int, [][]);
descriptor: (Lcom/lmax/disruptor/EventTranslatorVararg;II[[Ljava/lang/Object;)Z
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=7, locals=7, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 4
iload 2
iload 3
invokevirtual com.lmax.disruptor.RingBuffer.checkBounds:([Ljava/lang/Object;II)V
1: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
iload 3
invokeinterface com.lmax.disruptor.Sequencer.tryNext:(I)J
lstore 5
start local 5 2: aload 0
aload 1
iload 2
iload 3
lload 5
aload 4
invokevirtual com.lmax.disruptor.RingBuffer.translateAndPublishBatch:(Lcom/lmax/disruptor/EventTranslatorVararg;IIJ[[Ljava/lang/Object;)V
3: iconst_1
ireturn
end local 5 4: StackMap locals:
StackMap stack: com.lmax.disruptor.InsufficientCapacityException
pop
5: iconst_0
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 6 1 translator Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;
0 6 2 batchStartsAt I
0 6 3 batchSize I
0 6 4 args [[Ljava/lang/Object;
2 4 5 finalSequence J
Exception table:
from to target type
1 3 4 Class com.lmax.disruptor.InsufficientCapacityException
Signature: (Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;II[[Ljava/lang/Object;)Z
MethodParameters:
Name Flags
translator
batchStartsAt
batchSize
args
public void publish(long);
descriptor: (J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 1
invokeinterface com.lmax.disruptor.Sequencer.publish:(J)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 2 1 sequence J
MethodParameters:
Name Flags
sequence
public void publish(long, long);
descriptor: (JJ)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 3 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 1
lload 3
invokeinterface com.lmax.disruptor.Sequencer.publish:(JJ)V
1: return
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 2 1 lo J
0 2 3 hi J
MethodParameters:
Name Flags
lo
hi
public long remainingCapacity();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokeinterface com.lmax.disruptor.Sequencer.remainingCapacity:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
private void checkBounds(com.lmax.disruptor.EventTranslator<E>[], int, );
descriptor: ([Lcom/lmax/disruptor/EventTranslator;II)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
iload 2
iload 3
invokevirtual com.lmax.disruptor.RingBuffer.checkBatchSizing:(II)V
1: aload 0
aload 1
iload 2
iload 3
invokevirtual com.lmax.disruptor.RingBuffer.batchOverRuns:([Ljava/lang/Object;II)V
2: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 3 1 translators [Lcom/lmax/disruptor/EventTranslator;
0 3 2 batchStartsAt I
0 3 3 batchSize I
Signature: ([Lcom/lmax/disruptor/EventTranslator<TE;>;II)V
MethodParameters:
Name Flags
translators final
batchStartsAt final
batchSize final
private void checkBatchSizing(int, int);
descriptor: (II)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: iload 1
iflt 1
iload 2
ifge 2
1: StackMap locals:
StackMap stack:
new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "Both batchStartsAt and batchSize must be positive but got: batchStartsAt "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 1
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc " and batchSize "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
iload 2
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
iload 2
aload 0
getfield com.lmax.disruptor.RingBuffer.bufferSize:I
if_icmple 4
3: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "The ring buffer cannot accommodate "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 2
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc " it only has space for "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield com.lmax.disruptor.RingBuffer.bufferSize:I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc " entities."
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 5 1 batchStartsAt I
0 5 2 batchSize I
MethodParameters:
Name Flags
batchStartsAt
batchSize
private <A> void checkBounds(A[], int, );
descriptor: ([Ljava/lang/Object;II)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
iload 2
iload 3
invokevirtual com.lmax.disruptor.RingBuffer.checkBatchSizing:(II)V
1: aload 0
aload 1
iload 2
iload 3
invokevirtual com.lmax.disruptor.RingBuffer.batchOverRuns:([Ljava/lang/Object;II)V
2: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 3 1 arg0 [Ljava/lang/Object;
0 3 2 batchStartsAt I
0 3 3 batchSize I
Signature: <A:Ljava/lang/Object;>([TA;II)V
MethodParameters:
Name Flags
arg0 final
batchStartsAt final
batchSize final
private <A, B> void checkBounds(A[], B[], int, );
descriptor: ([Ljava/lang/Object;[Ljava/lang/Object;II)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
iload 3
iload 4
invokevirtual com.lmax.disruptor.RingBuffer.checkBatchSizing:(II)V
1: aload 0
aload 1
iload 3
iload 4
invokevirtual com.lmax.disruptor.RingBuffer.batchOverRuns:([Ljava/lang/Object;II)V
2: aload 0
aload 2
iload 3
iload 4
invokevirtual com.lmax.disruptor.RingBuffer.batchOverRuns:([Ljava/lang/Object;II)V
3: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 4 1 arg0 [Ljava/lang/Object;
0 4 2 arg1 [Ljava/lang/Object;
0 4 3 batchStartsAt I
0 4 4 batchSize I
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;>([TA;[TB;II)V
MethodParameters:
Name Flags
arg0 final
arg1 final
batchStartsAt final
batchSize final
private <A, B, C> void checkBounds(A[], B[], C[], int, );
descriptor: ([Ljava/lang/Object;[Ljava/lang/Object;[Ljava/lang/Object;II)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
iload 4
iload 5
invokevirtual com.lmax.disruptor.RingBuffer.checkBatchSizing:(II)V
1: aload 0
aload 1
iload 4
iload 5
invokevirtual com.lmax.disruptor.RingBuffer.batchOverRuns:([Ljava/lang/Object;II)V
2: aload 0
aload 2
iload 4
iload 5
invokevirtual com.lmax.disruptor.RingBuffer.batchOverRuns:([Ljava/lang/Object;II)V
3: aload 0
aload 3
iload 4
iload 5
invokevirtual com.lmax.disruptor.RingBuffer.batchOverRuns:([Ljava/lang/Object;II)V
4: return
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 5 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 5 1 arg0 [Ljava/lang/Object;
0 5 2 arg1 [Ljava/lang/Object;
0 5 3 arg2 [Ljava/lang/Object;
0 5 4 batchStartsAt I
0 5 5 batchSize I
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;C:Ljava/lang/Object;>([TA;[TB;[TC;II)V
MethodParameters:
Name Flags
arg0 final
arg1 final
arg2 final
batchStartsAt final
batchSize final
private void checkBounds(int, int, java.lang.Object[][]);
descriptor: (II[[Ljava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
iload 1
iload 2
invokevirtual com.lmax.disruptor.RingBuffer.checkBatchSizing:(II)V
1: aload 0
aload 3
iload 1
iload 2
invokevirtual com.lmax.disruptor.RingBuffer.batchOverRuns:([Ljava/lang/Object;II)V
2: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 3 1 batchStartsAt I
0 3 2 batchSize I
0 3 3 args [[Ljava/lang/Object;
MethodParameters:
Name Flags
batchStartsAt final
batchSize final
args final
private <A> void batchOverRuns(A[], int, );
descriptor: ([Ljava/lang/Object;II)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: iload 2
iload 3
iadd
aload 1
arraylength
if_icmple 7
1: new java.lang.IllegalArgumentException
dup
2: new java.lang.StringBuilder
dup
ldc "A batchSize of: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 3
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
3: ldc " with batchStatsAt of: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
iload 2
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
4: ldc " will overrun the available number of arguments: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
arraylength
iload 2
isub
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
5: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
6: invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
7: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 8 1 arg0 [Ljava/lang/Object;
0 8 2 batchStartsAt I
0 8 3 batchSize I
Signature: <A:Ljava/lang/Object;>([TA;II)V
MethodParameters:
Name Flags
arg0 final
batchStartsAt final
batchSize final
private void translateAndPublish(com.lmax.disruptor.EventTranslator<E>, );
descriptor: (Lcom/lmax/disruptor/EventTranslator;J)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 1
aload 0
lload 2
invokevirtual com.lmax.disruptor.RingBuffer.get:(J)Ljava/lang/Object;
lload 2
invokeinterface com.lmax.disruptor.EventTranslator.translateTo:(Ljava/lang/Object;J)V
1: goto 5
2: StackMap locals:
StackMap stack: java.lang.Throwable
astore 4
3: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 2
invokeinterface com.lmax.disruptor.Sequencer.publish:(J)V
4: aload 4
athrow
5: StackMap locals:
StackMap stack:
aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 2
invokeinterface com.lmax.disruptor.Sequencer.publish:(J)V
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 7 1 translator Lcom/lmax/disruptor/EventTranslator<TE;>;
0 7 2 sequence J
Exception table:
from to target type
0 2 2 any
Signature: (Lcom/lmax/disruptor/EventTranslator<TE;>;J)V
MethodParameters:
Name Flags
translator
sequence
private <A> void translateAndPublish(com.lmax.disruptor.EventTranslatorOneArg<E, A>, long, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorOneArg;JLjava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 1
aload 0
lload 2
invokevirtual com.lmax.disruptor.RingBuffer.get:(J)Ljava/lang/Object;
lload 2
aload 4
invokeinterface com.lmax.disruptor.EventTranslatorOneArg.translateTo:(Ljava/lang/Object;JLjava/lang/Object;)V
1: goto 5
2: StackMap locals:
StackMap stack: java.lang.Throwable
astore 5
3: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 2
invokeinterface com.lmax.disruptor.Sequencer.publish:(J)V
4: aload 5
athrow
5: StackMap locals:
StackMap stack:
aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 2
invokeinterface com.lmax.disruptor.Sequencer.publish:(J)V
6: return
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 7 1 translator Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;
0 7 2 sequence J
0 7 4 arg0 TA;
Exception table:
from to target type
0 2 2 any
Signature: <A:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;JTA;)V
MethodParameters:
Name Flags
translator
sequence
arg0
private <A, B> void translateAndPublish(com.lmax.disruptor.EventTranslatorTwoArg<E, A, B>, long, A, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorTwoArg;JLjava/lang/Object;Ljava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=7, args_size=5
start local 0 start local 1 start local 2 start local 4 start local 5 0: aload 1
aload 0
lload 2
invokevirtual com.lmax.disruptor.RingBuffer.get:(J)Ljava/lang/Object;
lload 2
aload 4
aload 5
invokeinterface com.lmax.disruptor.EventTranslatorTwoArg.translateTo:(Ljava/lang/Object;JLjava/lang/Object;Ljava/lang/Object;)V
1: goto 5
2: StackMap locals:
StackMap stack: java.lang.Throwable
astore 6
3: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 2
invokeinterface com.lmax.disruptor.Sequencer.publish:(J)V
4: aload 6
athrow
5: StackMap locals:
StackMap stack:
aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 2
invokeinterface com.lmax.disruptor.Sequencer.publish:(J)V
6: return
end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 7 1 translator Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;
0 7 2 sequence J
0 7 4 arg0 TA;
0 7 5 arg1 TB;
Exception table:
from to target type
0 2 2 any
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;JTA;TB;)V
MethodParameters:
Name Flags
translator
sequence
arg0
arg1
private <A, B, C> void translateAndPublish(com.lmax.disruptor.EventTranslatorThreeArg<E, A, B, C>, long, A, B, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorThreeArg;JLjava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=8, args_size=6
start local 0 start local 1 start local 2 start local 4 start local 5 start local 6 0: aload 1
aload 0
lload 2
invokevirtual com.lmax.disruptor.RingBuffer.get:(J)Ljava/lang/Object;
lload 2
aload 4
aload 5
aload 6
invokeinterface com.lmax.disruptor.EventTranslatorThreeArg.translateTo:(Ljava/lang/Object;JLjava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)V
1: goto 5
2: StackMap locals:
StackMap stack: java.lang.Throwable
astore 7
3: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 2
invokeinterface com.lmax.disruptor.Sequencer.publish:(J)V
4: aload 7
athrow
5: StackMap locals:
StackMap stack:
aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 2
invokeinterface com.lmax.disruptor.Sequencer.publish:(J)V
6: return
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 7 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 7 1 translator Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;
0 7 2 sequence J
0 7 4 arg0 TA;
0 7 5 arg1 TB;
0 7 6 arg2 TC;
Exception table:
from to target type
0 2 2 any
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;C:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;JTA;TB;TC;)V
MethodParameters:
Name Flags
translator
sequence
arg0
arg1
arg2
private void translateAndPublish(com.lmax.disruptor.EventTranslatorVararg<E>, long, []);
descriptor: (Lcom/lmax/disruptor/EventTranslatorVararg;J[Ljava/lang/Object;)V
flags: (0x0082) ACC_PRIVATE, ACC_VARARGS
Code:
stack=5, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 1
aload 0
lload 2
invokevirtual com.lmax.disruptor.RingBuffer.get:(J)Ljava/lang/Object;
lload 2
aload 4
invokeinterface com.lmax.disruptor.EventTranslatorVararg.translateTo:(Ljava/lang/Object;J[Ljava/lang/Object;)V
1: goto 5
2: StackMap locals:
StackMap stack: java.lang.Throwable
astore 5
3: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 2
invokeinterface com.lmax.disruptor.Sequencer.publish:(J)V
4: aload 5
athrow
5: StackMap locals:
StackMap stack:
aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 2
invokeinterface com.lmax.disruptor.Sequencer.publish:(J)V
6: return
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 7 1 translator Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;
0 7 2 sequence J
0 7 4 args [Ljava/lang/Object;
Exception table:
from to target type
0 2 2 any
Signature: (Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;J[Ljava/lang/Object;)V
MethodParameters:
Name Flags
translator
sequence
args
private void translateAndPublishBatch(com.lmax.disruptor.EventTranslator<E>[], int, int, );
descriptor: ([Lcom/lmax/disruptor/EventTranslator;IIJ)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=14, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: lload 4
iload 3
iconst_1
isub
i2l
lsub
lstore 6
start local 6 1: lload 6
lstore 8
start local 8 2: iload 2
iload 3
iadd
istore 10
start local 10 3: iload 2
istore 11
start local 11 4: goto 8
5: StackMap locals: com.lmax.disruptor.RingBuffer com.lmax.disruptor.EventTranslator[] int int long long long int int
StackMap stack:
aload 1
iload 11
aaload
astore 12
start local 12 6: aload 12
aload 0
lload 8
invokevirtual com.lmax.disruptor.RingBuffer.get:(J)Ljava/lang/Object;
lload 8
dup2
lconst_1
ladd
lstore 8
invokeinterface com.lmax.disruptor.EventTranslator.translateTo:(Ljava/lang/Object;J)V
end local 12 7: iinc 11 1
StackMap locals:
StackMap stack:
8: iload 11
iload 10
if_icmplt 5
end local 11 end local 10 end local 8 9: goto 13
10: StackMap locals: com.lmax.disruptor.RingBuffer com.lmax.disruptor.EventTranslator[] int int long long
StackMap stack: java.lang.Throwable
astore 13
11: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 6
lload 4
invokeinterface com.lmax.disruptor.Sequencer.publish:(JJ)V
12: aload 13
athrow
13: StackMap locals:
StackMap stack:
aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 6
lload 4
invokeinterface com.lmax.disruptor.Sequencer.publish:(JJ)V
14: return
end local 6 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 15 1 translators [Lcom/lmax/disruptor/EventTranslator;
0 15 2 batchStartsAt I
0 15 3 batchSize I
0 15 4 finalSequence J
1 15 6 initialSequence J
2 9 8 sequence J
3 9 10 batchEndsAt I
4 9 11 i I
6 7 12 translator Lcom/lmax/disruptor/EventTranslator<TE;>;
Exception table:
from to target type
1 10 10 any
Signature: ([Lcom/lmax/disruptor/EventTranslator<TE;>;IIJ)V
MethodParameters:
Name Flags
translators final
batchStartsAt
batchSize final
finalSequence final
private <A> void translateAndPublishBatch(com.lmax.disruptor.EventTranslatorOneArg<E, A>, A[], int, int, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorOneArg;[Ljava/lang/Object;IIJ)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=14, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: lload 5
iload 4
iconst_1
isub
i2l
lsub
lstore 7
start local 7 1: lload 7
lstore 9
start local 9 2: iload 3
iload 4
iadd
istore 11
start local 11 3: iload 3
istore 12
start local 12 4: goto 7
5: StackMap locals: com.lmax.disruptor.RingBuffer com.lmax.disruptor.EventTranslatorOneArg java.lang.Object[] int int long long long int int
StackMap stack:
aload 1
aload 0
lload 9
invokevirtual com.lmax.disruptor.RingBuffer.get:(J)Ljava/lang/Object;
lload 9
dup2
lconst_1
ladd
lstore 9
aload 2
iload 12
aaload
invokeinterface com.lmax.disruptor.EventTranslatorOneArg.translateTo:(Ljava/lang/Object;JLjava/lang/Object;)V
6: iinc 12 1
StackMap locals:
StackMap stack:
7: iload 12
iload 11
if_icmplt 5
end local 12 end local 11 end local 9 8: goto 12
9: StackMap locals: com.lmax.disruptor.RingBuffer com.lmax.disruptor.EventTranslatorOneArg java.lang.Object[] int int long long
StackMap stack: java.lang.Throwable
astore 13
10: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 7
lload 5
invokeinterface com.lmax.disruptor.Sequencer.publish:(JJ)V
11: aload 13
athrow
12: StackMap locals:
StackMap stack:
aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 7
lload 5
invokeinterface com.lmax.disruptor.Sequencer.publish:(JJ)V
13: return
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 14 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 14 1 translator Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;
0 14 2 arg0 [Ljava/lang/Object;
0 14 3 batchStartsAt I
0 14 4 batchSize I
0 14 5 finalSequence J
1 14 7 initialSequence J
2 8 9 sequence J
3 8 11 batchEndsAt I
4 8 12 i I
Exception table:
from to target type
1 9 9 any
Signature: <A:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorOneArg<TE;TA;>;[TA;IIJ)V
MethodParameters:
Name Flags
translator final
arg0 final
batchStartsAt
batchSize final
finalSequence final
private <A, B> void translateAndPublishBatch(com.lmax.disruptor.EventTranslatorTwoArg<E, A, B>, A[], B[], int, int, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorTwoArg;[Ljava/lang/Object;[Ljava/lang/Object;IIJ)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=15, 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: lload 6
iload 5
iconst_1
isub
i2l
lsub
lstore 8
start local 8 1: lload 8
lstore 10
start local 10 2: iload 4
iload 5
iadd
istore 12
start local 12 3: iload 4
istore 13
start local 13 4: goto 7
5: StackMap locals: com.lmax.disruptor.RingBuffer com.lmax.disruptor.EventTranslatorTwoArg java.lang.Object[] java.lang.Object[] int int long long long int int
StackMap stack:
aload 1
aload 0
lload 10
invokevirtual com.lmax.disruptor.RingBuffer.get:(J)Ljava/lang/Object;
lload 10
dup2
lconst_1
ladd
lstore 10
aload 2
iload 13
aaload
aload 3
iload 13
aaload
invokeinterface com.lmax.disruptor.EventTranslatorTwoArg.translateTo:(Ljava/lang/Object;JLjava/lang/Object;Ljava/lang/Object;)V
6: iinc 13 1
StackMap locals:
StackMap stack:
7: iload 13
iload 12
if_icmplt 5
end local 13 end local 12 end local 10 8: goto 12
9: StackMap locals: com.lmax.disruptor.RingBuffer com.lmax.disruptor.EventTranslatorTwoArg java.lang.Object[] java.lang.Object[] int int long long
StackMap stack: java.lang.Throwable
astore 14
10: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 8
lload 6
invokeinterface com.lmax.disruptor.Sequencer.publish:(JJ)V
11: aload 14
athrow
12: StackMap locals:
StackMap stack:
aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 8
lload 6
invokeinterface com.lmax.disruptor.Sequencer.publish:(JJ)V
13: return
end local 8 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 14 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 14 1 translator Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;
0 14 2 arg0 [Ljava/lang/Object;
0 14 3 arg1 [Ljava/lang/Object;
0 14 4 batchStartsAt I
0 14 5 batchSize I
0 14 6 finalSequence J
1 14 8 initialSequence J
2 8 10 sequence J
3 8 12 batchEndsAt I
4 8 13 i I
Exception table:
from to target type
1 9 9 any
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorTwoArg<TE;TA;TB;>;[TA;[TB;IIJ)V
MethodParameters:
Name Flags
translator final
arg0 final
arg1 final
batchStartsAt
batchSize
finalSequence final
private <A, B, C> void translateAndPublishBatch(com.lmax.disruptor.EventTranslatorThreeArg<E, A, B, C>, A[], B[], C[], int, int, );
descriptor: (Lcom/lmax/disruptor/EventTranslatorThreeArg;[Ljava/lang/Object;[Ljava/lang/Object;[Ljava/lang/Object;IIJ)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=16, args_size=8
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 0: lload 7
iload 6
iconst_1
isub
i2l
lsub
lstore 9
start local 9 1: lload 9
lstore 11
start local 11 2: iload 5
iload 6
iadd
istore 13
start local 13 3: iload 5
istore 14
start local 14 4: goto 7
5: StackMap locals: com.lmax.disruptor.RingBuffer com.lmax.disruptor.EventTranslatorThreeArg java.lang.Object[] java.lang.Object[] java.lang.Object[] int int long long long int int
StackMap stack:
aload 1
aload 0
lload 11
invokevirtual com.lmax.disruptor.RingBuffer.get:(J)Ljava/lang/Object;
lload 11
dup2
lconst_1
ladd
lstore 11
aload 2
iload 14
aaload
aload 3
iload 14
aaload
aload 4
iload 14
aaload
invokeinterface com.lmax.disruptor.EventTranslatorThreeArg.translateTo:(Ljava/lang/Object;JLjava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)V
6: iinc 14 1
StackMap locals:
StackMap stack:
7: iload 14
iload 13
if_icmplt 5
end local 14 end local 13 end local 11 8: goto 12
9: StackMap locals: com.lmax.disruptor.RingBuffer com.lmax.disruptor.EventTranslatorThreeArg java.lang.Object[] java.lang.Object[] java.lang.Object[] int int long long
StackMap stack: java.lang.Throwable
astore 15
10: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 9
lload 7
invokeinterface com.lmax.disruptor.Sequencer.publish:(JJ)V
11: aload 15
athrow
12: StackMap locals:
StackMap stack:
aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 9
lload 7
invokeinterface com.lmax.disruptor.Sequencer.publish:(JJ)V
13: return
end local 9 end local 7 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 14 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 14 1 translator Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;
0 14 2 arg0 [Ljava/lang/Object;
0 14 3 arg1 [Ljava/lang/Object;
0 14 4 arg2 [Ljava/lang/Object;
0 14 5 batchStartsAt I
0 14 6 batchSize I
0 14 7 finalSequence J
1 14 9 initialSequence J
2 8 11 sequence J
3 8 13 batchEndsAt I
4 8 14 i I
Exception table:
from to target type
1 9 9 any
Signature: <A:Ljava/lang/Object;B:Ljava/lang/Object;C:Ljava/lang/Object;>(Lcom/lmax/disruptor/EventTranslatorThreeArg<TE;TA;TB;TC;>;[TA;[TB;[TC;IIJ)V
MethodParameters:
Name Flags
translator final
arg0 final
arg1 final
arg2 final
batchStartsAt
batchSize final
finalSequence final
private void translateAndPublishBatch(com.lmax.disruptor.EventTranslatorVararg<E>, int, int, long, [][]);
descriptor: (Lcom/lmax/disruptor/EventTranslatorVararg;IIJ[[Ljava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=14, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 6 0: lload 4
iload 3
iconst_1
isub
i2l
lsub
lstore 7
start local 7 1: lload 7
lstore 9
start local 9 2: iload 2
iload 3
iadd
istore 11
start local 11 3: iload 2
istore 12
start local 12 4: goto 7
5: StackMap locals: com.lmax.disruptor.RingBuffer com.lmax.disruptor.EventTranslatorVararg int int long java.lang.Object[][] long long int int
StackMap stack:
aload 1
aload 0
lload 9
invokevirtual com.lmax.disruptor.RingBuffer.get:(J)Ljava/lang/Object;
lload 9
dup2
lconst_1
ladd
lstore 9
aload 6
iload 12
aaload
invokeinterface com.lmax.disruptor.EventTranslatorVararg.translateTo:(Ljava/lang/Object;J[Ljava/lang/Object;)V
6: iinc 12 1
StackMap locals:
StackMap stack:
7: iload 12
iload 11
if_icmplt 5
end local 12 end local 11 end local 9 8: goto 12
9: StackMap locals: com.lmax.disruptor.RingBuffer com.lmax.disruptor.EventTranslatorVararg int int long java.lang.Object[][] long
StackMap stack: java.lang.Throwable
astore 13
10: aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 7
lload 4
invokeinterface com.lmax.disruptor.Sequencer.publish:(JJ)V
11: aload 13
athrow
12: StackMap locals:
StackMap stack:
aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
lload 7
lload 4
invokeinterface com.lmax.disruptor.Sequencer.publish:(JJ)V
13: return
end local 7 end local 6 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
0 14 1 translator Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;
0 14 2 batchStartsAt I
0 14 3 batchSize I
0 14 4 finalSequence J
0 14 6 args [[Ljava/lang/Object;
1 14 7 initialSequence J
2 8 9 sequence J
3 8 11 batchEndsAt I
4 8 12 i I
Exception table:
from to target type
1 9 9 any
Signature: (Lcom/lmax/disruptor/EventTranslatorVararg<TE;>;IIJ[[Ljava/lang/Object;)V
MethodParameters:
Name Flags
translator final
batchStartsAt
batchSize final
finalSequence final
args final
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.StringBuilder
dup
ldc "RingBuffer{bufferSize="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
1: aload 0
getfield com.lmax.disruptor.RingBuffer.bufferSize:I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
2: ldc ", sequencer="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield com.lmax.disruptor.RingBuffer.sequencer:Lcom/lmax/disruptor/Sequencer;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
3: ldc "}"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
4: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/lmax/disruptor/RingBuffer<TE;>;
static int[] $SWITCH_TABLE$com$lmax$disruptor$dsl$ProducerType();
descriptor: ()[I
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=0
0: getstatic com.lmax.disruptor.RingBuffer.$SWITCH_TABLE$com$lmax$disruptor$dsl$ProducerType:[I
dup
ifnull 1
areturn
StackMap locals:
StackMap stack: int[]
1: pop
invokestatic com.lmax.disruptor.dsl.ProducerType.values:()[Lcom/lmax/disruptor/dsl/ProducerType;
arraylength
newarray 10
astore 0
2: aload 0
getstatic com.lmax.disruptor.dsl.ProducerType.MULTI:Lcom/lmax/disruptor/dsl/ProducerType;
invokevirtual com.lmax.disruptor.dsl.ProducerType.ordinal:()I
iconst_2
iastore
3: goto 5
StackMap locals: int[]
StackMap stack: java.lang.NoSuchFieldError
4: pop
StackMap locals:
StackMap stack:
5: aload 0
getstatic com.lmax.disruptor.dsl.ProducerType.SINGLE:Lcom/lmax/disruptor/dsl/ProducerType;
invokevirtual com.lmax.disruptor.dsl.ProducerType.ordinal:()I
iconst_1
iastore
6: goto 8
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
7: pop
StackMap locals:
StackMap stack:
8: aload 0
dup
putstatic com.lmax.disruptor.RingBuffer.$SWITCH_TABLE$com$lmax$disruptor$dsl$ProducerType:[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
}
Signature: <E:Ljava/lang/Object;>Lcom/lmax/disruptor/RingBufferFields<TE;>;Lcom/lmax/disruptor/Cursored;Lcom/lmax/disruptor/EventSequencer<TE;>;Lcom/lmax/disruptor/EventSink<TE;>;
SourceFile: "RingBuffer.java"
RingBuffer
p1: long
$SWITCH_TABLE$com$lmax$disruptor$dsl$ProducerType: int[]
$SWITCH_TABLE$com$lmax$disruptor$dsl$ProducerType(): int[]