final class org.apache.lucene.index.DocumentsWriterFlushControl implements org.apache.lucene.util.Accountable, java.io.Closeable
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: org.apache.lucene.index.DocumentsWriterFlushControl
super_class: java.lang.Object
{
private final long hardMaxBytesPerDWPT;
descriptor: J
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private long activeBytes;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private volatile long flushBytes;
descriptor: J
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile int numPending;
descriptor: I
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private int numDocsSinceStalled;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private final java.util.concurrent.atomic.AtomicBoolean flushDeletes;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private boolean fullFlush;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean fullFlushMarkDone;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private final java.util.Queue<org.apache.lucene.index.DocumentsWriterPerThread> flushQueue;
descriptor: Ljava/util/Queue;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Queue<Lorg/apache/lucene/index/DocumentsWriterPerThread;>;
private final java.util.Queue<org.apache.lucene.index.DocumentsWriterPerThread> blockedFlushes;
descriptor: Ljava/util/Queue;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Queue<Lorg/apache/lucene/index/DocumentsWriterPerThread;>;
private final java.util.List<org.apache.lucene.index.DocumentsWriterPerThread> flushingWriters;
descriptor: Ljava/util/List;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/List<Lorg/apache/lucene/index/DocumentsWriterPerThread;>;
private double maxConfiguredRamBuffer;
descriptor: D
flags: (0x0002) ACC_PRIVATE
private long peakActiveBytes;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private long peakFlushBytes;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private long peakNetBytes;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private long peakDelta;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private boolean flushByRAMWasDisabled;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
final org.apache.lucene.index.DocumentsWriterStallControl stallControl;
descriptor: Lorg/apache/lucene/index/DocumentsWriterStallControl;
flags: (0x0010) ACC_FINAL
private final org.apache.lucene.index.DocumentsWriterPerThreadPool perThreadPool;
descriptor: Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.lucene.index.FlushPolicy flushPolicy;
descriptor: Lorg/apache/lucene/index/FlushPolicy;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private boolean closed;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private final org.apache.lucene.index.DocumentsWriter documentsWriter;
descriptor: Lorg/apache/lucene/index/DocumentsWriter;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.lucene.index.LiveIndexWriterConfig config;
descriptor: Lorg/apache/lucene/index/LiveIndexWriterConfig;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.lucene.util.InfoStream infoStream;
descriptor: Lorg/apache/lucene/util/InfoStream;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private long stallStartNS;
descriptor: J
flags: (0x0002) ACC_PRIVATE
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/apache/lucene/index/DocumentsWriterFlushControl;
invokevirtual java.lang.Class.desiredAssertionStatus:()Z
ifne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: putstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
return
LocalVariableTable:
Start End Slot Name Signature
void <init>(org.apache.lucene.index.DocumentsWriter, org.apache.lucene.index.LiveIndexWriterConfig);
descriptor: (Lorg/apache/lucene/index/DocumentsWriter;Lorg/apache/lucene/index/LiveIndexWriterConfig;)V
flags: (0x0000)
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
lconst_0
putfield org.apache.lucene.index.DocumentsWriterFlushControl.activeBytes:J
2: aload 0
lconst_0
putfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
3: aload 0
iconst_0
putfield org.apache.lucene.index.DocumentsWriterFlushControl.numPending:I
4: aload 0
iconst_0
putfield org.apache.lucene.index.DocumentsWriterFlushControl.numDocsSinceStalled:I
5: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
iconst_0
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
putfield org.apache.lucene.index.DocumentsWriterFlushControl.flushDeletes:Ljava/util/concurrent/atomic/AtomicBoolean;
6: aload 0
iconst_0
putfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
7: aload 0
iconst_0
putfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlushMarkDone:Z
8: aload 0
new java.util.LinkedList
dup
invokespecial java.util.LinkedList.<init>:()V
putfield org.apache.lucene.index.DocumentsWriterFlushControl.flushQueue:Ljava/util/Queue;
9: aload 0
new java.util.LinkedList
dup
invokespecial java.util.LinkedList.<init>:()V
putfield org.apache.lucene.index.DocumentsWriterFlushControl.blockedFlushes:Ljava/util/Queue;
10: aload 0
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
putfield org.apache.lucene.index.DocumentsWriterFlushControl.flushingWriters:Ljava/util/List;
11: aload 0
dconst_0
putfield org.apache.lucene.index.DocumentsWriterFlushControl.maxConfiguredRamBuffer:D
12: aload 0
lconst_0
putfield org.apache.lucene.index.DocumentsWriterFlushControl.peakActiveBytes:J
13: aload 0
lconst_0
putfield org.apache.lucene.index.DocumentsWriterFlushControl.peakFlushBytes:J
14: aload 0
lconst_0
putfield org.apache.lucene.index.DocumentsWriterFlushControl.peakNetBytes:J
15: aload 0
lconst_0
putfield org.apache.lucene.index.DocumentsWriterFlushControl.peakDelta:J
16: aload 0
new org.apache.lucene.index.DocumentsWriterStallControl
dup
invokespecial org.apache.lucene.index.DocumentsWriterStallControl.<init>:()V
putfield org.apache.lucene.index.DocumentsWriterFlushControl.stallControl:Lorg/apache/lucene/index/DocumentsWriterStallControl;
17: aload 0
iconst_0
putfield org.apache.lucene.index.DocumentsWriterFlushControl.closed:Z
18: aload 0
aload 2
invokevirtual org.apache.lucene.index.LiveIndexWriterConfig.getInfoStream:()Lorg/apache/lucene/util/InfoStream;
putfield org.apache.lucene.index.DocumentsWriterFlushControl.infoStream:Lorg/apache/lucene/util/InfoStream;
19: aload 0
aload 1
getfield org.apache.lucene.index.DocumentsWriter.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
putfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
20: aload 0
aload 2
invokevirtual org.apache.lucene.index.LiveIndexWriterConfig.getFlushPolicy:()Lorg/apache/lucene/index/FlushPolicy;
putfield org.apache.lucene.index.DocumentsWriterFlushControl.flushPolicy:Lorg/apache/lucene/index/FlushPolicy;
21: aload 0
aload 2
putfield org.apache.lucene.index.DocumentsWriterFlushControl.config:Lorg/apache/lucene/index/LiveIndexWriterConfig;
22: aload 0
aload 2
invokevirtual org.apache.lucene.index.LiveIndexWriterConfig.getRAMPerThreadHardLimitMB:()I
sipush 1024
imul
sipush 1024
imul
i2l
putfield org.apache.lucene.index.DocumentsWriterFlushControl.hardMaxBytesPerDWPT:J
23: aload 0
aload 1
putfield org.apache.lucene.index.DocumentsWriterFlushControl.documentsWriter:Lorg/apache/lucene/index/DocumentsWriter;
24: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 25 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
0 25 1 documentsWriter Lorg/apache/lucene/index/DocumentsWriter;
0 25 2 config Lorg/apache/lucene/index/LiveIndexWriterConfig;
MethodParameters:
Name Flags
documentsWriter
config
public synchronized long activeBytes();
descriptor: ()J
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.activeBytes:J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
long getFlushingBytes();
descriptor: ()J
flags: (0x0000)
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
synchronized long netBytes();
descriptor: ()J
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.activeBytes:J
ladd
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
private long stallLimitBytes();
descriptor: ()J
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=3, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.config:Lorg/apache/lucene/index/LiveIndexWriterConfig;
invokevirtual org.apache.lucene.index.LiveIndexWriterConfig.getRAMBufferSizeMB:()D
dstore 1
start local 1 1: dload 1
ldc -1.0
dcmpl
ifeq 2
ldc 2.0
dload 1
ldc 1024.0
dmul
ldc 1024.0
dmul
dmul
d2l
goto 3
StackMap locals: double
StackMap stack:
2: ldc 9223372036854775807
StackMap locals:
StackMap stack: long
3: lreturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
1 4 1 maxRamMB D
private boolean assertMemory();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=9, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.config:Lorg/apache/lucene/index/LiveIndexWriterConfig;
invokevirtual org.apache.lucene.index.LiveIndexWriterConfig.getRAMBufferSizeMB:()D
dstore 1
start local 1 1: dload 1
ldc -1.0
dcmpl
ifeq 13
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushByRAMWasDisabled:Z
ifne 13
2: aload 0
dload 1
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.maxConfiguredRamBuffer:D
invokestatic java.lang.Math.max:(DD)D
putfield org.apache.lucene.index.DocumentsWriterFlushControl.maxConfiguredRamBuffer:D
3: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.activeBytes:J
ladd
lstore 3
start local 3 4: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.maxConfiguredRamBuffer:D
ldc 1024.0
dmul
ldc 1024.0
dmul
d2l
lstore 5
start local 5 5: ldc 2
lload 5
lmul
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.numPending:I
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.numFlushingDWPT:()I
iadd
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.numBlockedFlushes:()I
iadd
i2l
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.peakDelta:J
lmul
ladd
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.numDocsSinceStalled:I
i2l
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.peakDelta:J
lmul
ladd
lstore 7
start local 7 6: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.peakDelta:J
lload 5
iconst_1
lshr
lcmp
ifge 14
7: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 14
lload 3
lload 7
lcmp
ifle 14
new java.lang.AssertionError
dup
new java.lang.StringBuilder
dup
ldc "actual mem: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
lload 3
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc " byte, expected mem: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
lload 7
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
8: ldc " byte, flush mem: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc ", active mem: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.activeBytes:J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
9: ldc ", pending DWPT: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.numPending:I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ", flushing DWPT: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
10: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.numFlushingDWPT:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ", blocked DWPT: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.numBlockedFlushes:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
11: ldc ", peakDelta mem: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.peakDelta:J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc " bytes, ramBufferBytes="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
lload 5
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
12: ldc ", maxConfiguredRamBuffer="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.maxConfiguredRamBuffer:D
invokevirtual java.lang.StringBuilder.append:(D)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
end local 7 end local 5 end local 3 13: StackMap locals: double
StackMap stack:
aload 0
iconst_1
putfield org.apache.lucene.index.DocumentsWriterFlushControl.flushByRAMWasDisabled:Z
14: StackMap locals:
StackMap stack:
iconst_1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
1 15 1 maxRamMB D
4 13 3 ram J
5 13 5 ramBufferBytes J
6 13 7 expected J
private synchronized void commitPerThreadBytes(org.apache.lucene.index.DocumentsWriterPerThread);
descriptor: (Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.commitLastBytesUsed:()J
lstore 2
start local 2 1: aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isFlushPending:()Z
ifeq 4
2: aload 0
dup
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
lload 2
ladd
putfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
3: goto 5
4: StackMap locals: long
StackMap stack:
aload 0
dup
getfield org.apache.lucene.index.DocumentsWriterFlushControl.activeBytes:J
lload 2
ladd
putfield org.apache.lucene.index.DocumentsWriterFlushControl.activeBytes:J
5: StackMap locals:
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 6
aload 0
lload 2
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updatePeaks:(J)Z
ifne 6
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
6: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
0 7 1 perThread Lorg/apache/lucene/index/DocumentsWriterPerThread;
1 7 2 delta J
MethodParameters:
Name Flags
perThread
private boolean updatePeaks(long);
descriptor: (J)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.peakActiveBytes:J
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.activeBytes:J
invokestatic java.lang.Math.max:(JJ)J
putfield org.apache.lucene.index.DocumentsWriterFlushControl.peakActiveBytes:J
1: aload 0
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.peakFlushBytes:J
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
invokestatic java.lang.Math.max:(JJ)J
putfield org.apache.lucene.index.DocumentsWriterFlushControl.peakFlushBytes:J
2: aload 0
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.peakNetBytes:J
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.netBytes:()J
invokestatic java.lang.Math.max:(JJ)J
putfield org.apache.lucene.index.DocumentsWriterFlushControl.peakNetBytes:J
3: aload 0
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.peakDelta:J
lload 1
invokestatic java.lang.Math.max:(JJ)J
putfield org.apache.lucene.index.DocumentsWriterFlushControl.peakDelta:J
4: iconst_1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
0 5 1 delta J
MethodParameters:
Name Flags
delta
synchronized org.apache.lucene.index.DocumentsWriterPerThread doAfterDocument(org.apache.lucene.index.DocumentsWriterPerThread, boolean);
descriptor: (Lorg/apache/lucene/index/DocumentsWriterPerThread;Z)Lorg/apache/lucene/index/DocumentsWriterPerThread;
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=4, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.commitPerThreadBytes:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
1: aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isFlushPending:()Z
ifne 8
2: iload 2
ifeq 5
3: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushPolicy:Lorg/apache/lucene/index/FlushPolicy;
aload 0
aload 1
invokevirtual org.apache.lucene.index.FlushPolicy.onUpdate:(Lorg/apache/lucene/index/DocumentsWriterFlushControl;Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
4: goto 6
5: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushPolicy:Lorg/apache/lucene/index/FlushPolicy;
aload 0
aload 1
invokevirtual org.apache.lucene.index.FlushPolicy.onInsert:(Lorg/apache/lucene/index/DocumentsWriterFlushControl;Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
6: StackMap locals:
StackMap stack:
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isFlushPending:()Z
ifne 8
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.ramBytesUsed:()J
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.hardMaxBytesPerDWPT:J
lcmp
ifle 8
7: aload 0
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.setFlushPending:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
8: StackMap locals:
StackMap stack:
aload 0
aload 1
iconst_0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.checkout:(Lorg/apache/lucene/index/DocumentsWriterPerThread;Z)Lorg/apache/lucene/index/DocumentsWriterPerThread;
astore 4
9: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
istore 5
start local 5 10: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 12
aload 0
iload 5
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.assertNumDocsSinceStalled:(Z)Z
ifeq 11
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.assertMemory:()Z
ifne 12
StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread int top org.apache.lucene.index.DocumentsWriterPerThread int
StackMap stack:
11: new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
end local 5 12: StackMap locals:
StackMap stack:
aload 4
areturn
13: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread int
StackMap stack: java.lang.Throwable
astore 3
14: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
istore 5
start local 5 15: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 17
aload 0
iload 5
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.assertNumDocsSinceStalled:(Z)Z
ifeq 16
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.assertMemory:()Z
ifne 17
StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread int java.lang.Throwable top int
StackMap stack:
16: new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
end local 5 17: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread int java.lang.Throwable
StackMap stack:
aload 3
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
0 18 1 perThread Lorg/apache/lucene/index/DocumentsWriterPerThread;
0 18 2 isUpdate Z
10 12 5 stalled Z
15 17 5 stalled Z
Exception table:
from to target type
0 9 13 any
MethodParameters:
Name Flags
perThread
isUpdate
private org.apache.lucene.index.DocumentsWriterPerThread checkout(org.apache.lucene.index.DocumentsWriterPerThread, boolean);
descriptor: (Lorg/apache/lucene/index/DocumentsWriterPerThread;Z)Lorg/apache/lucene/index/DocumentsWriterPerThread;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 1
aload 0
invokestatic java.lang.Thread.holdsLock:(Ljava/lang/Object;)Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
ifeq 5
2: aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isFlushPending:()Z
ifeq 10
3: aload 0
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.checkoutAndBlock:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
4: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.nextPendingFlush:()Lorg/apache/lucene/index/DocumentsWriterPerThread;
areturn
5: StackMap locals:
StackMap stack:
iload 2
ifeq 8
6: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 7
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isFlushPending:()Z
ifeq 7
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
7: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.setFlushPending:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
8: StackMap locals:
StackMap stack:
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isFlushPending:()Z
ifeq 10
9: aload 0
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.checkOutForFlush:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)Lorg/apache/lucene/index/DocumentsWriterPerThread;
areturn
10: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
0 11 1 perThread Lorg/apache/lucene/index/DocumentsWriterPerThread;
0 11 2 markPending Z
MethodParameters:
Name Flags
perThread
markPending
private boolean assertNumDocsSinceStalled(boolean);
descriptor: (Z)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: iload 1
ifeq 3
1: aload 0
dup
getfield org.apache.lucene.index.DocumentsWriterFlushControl.numDocsSinceStalled:I
iconst_1
iadd
putfield org.apache.lucene.index.DocumentsWriterFlushControl.numDocsSinceStalled:I
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
iconst_0
putfield org.apache.lucene.index.DocumentsWriterFlushControl.numDocsSinceStalled:I
4: StackMap locals:
StackMap stack:
iconst_1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
0 5 1 stalled Z
MethodParameters:
Name Flags
stalled
synchronized void doAfterFlush(org.apache.lucene.index.DocumentsWriterPerThread);
descriptor: (Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 1
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushingWriters:Ljava/util/List;
aload 1
invokeinterface java.util.List.contains:(Ljava/lang/Object;)Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushingWriters:Ljava/util/List;
aload 1
invokeinterface java.util.List.remove:(Ljava/lang/Object;)Z
pop
2: aload 0
dup
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.getLastCommittedBytesUsed:()J
lsub
putfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
3: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 12
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.assertMemory:()Z
ifne 12
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
4: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
5: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
pop
6: goto 10
StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread java.lang.Throwable
StackMap stack: java.lang.Throwable
7: astore 3
8: aload 0
invokevirtual java.lang.Object.notifyAll:()V
9: aload 3
athrow
10: StackMap locals:
StackMap stack:
aload 0
invokevirtual java.lang.Object.notifyAll:()V
11: aload 2
athrow
12: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
pop
13: goto 17
StackMap locals:
StackMap stack: java.lang.Throwable
14: astore 3
15: aload 0
invokevirtual java.lang.Object.notifyAll:()V
16: aload 3
athrow
17: StackMap locals:
StackMap stack:
aload 0
invokevirtual java.lang.Object.notifyAll:()V
18: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
0 19 1 dwpt Lorg/apache/lucene/index/DocumentsWriterPerThread;
Exception table:
from to target type
1 4 4 any
5 7 7 any
12 14 14 any
MethodParameters:
Name Flags
dwpt
private boolean updateStallState();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=11, locals=4, args_size=1
start local 0 0: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 1
aload 0
invokestatic java.lang.Thread.holdsLock:(Ljava/lang/Object;)Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.stallLimitBytes:()J
lstore 1
start local 1 2: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.activeBytes:J
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
ladd
lload 1
lcmp
ifle 6
3: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.activeBytes:J
lload 1
lcmp
ifge 6
4: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.closed:Z
ifne 6
5: iconst_1
goto 7
StackMap locals: long
StackMap stack:
6: iconst_0
StackMap locals:
StackMap stack: int
7: istore 3
start local 3 8: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "DWFC"
invokevirtual org.apache.lucene.util.InfoStream.isEnabled:(Ljava/lang/String;)Z
ifeq 19
9: iload 3
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.stallControl:Lorg/apache/lucene/index/DocumentsWriterStallControl;
invokevirtual org.apache.lucene.index.DocumentsWriterStallControl.anyStalledThreads:()Z
if_icmpeq 19
10: iload 3
ifeq 16
11: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "DW"
getstatic java.util.Locale.ROOT:Ljava/util/Locale;
ldc "now stalling flushes: netBytes: %.1f MB flushBytes: %.1f MB fullFlush: %b"
iconst_3
anewarray java.lang.Object
dup
iconst_0
12: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.netBytes:()J
l2d
ldc 1024.0
ddiv
ldc 1024.0
ddiv
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
dup
iconst_1
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.getFlushingBytes:()J
l2d
ldc 1024.0
ddiv
ldc 1024.0
ddiv
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
dup
iconst_2
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
aastore
13: invokestatic java.lang.String.format:(Ljava/util/Locale;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokevirtual org.apache.lucene.util.InfoStream.message:(Ljava/lang/String;Ljava/lang/String;)V
14: aload 0
invokestatic java.lang.System.nanoTime:()J
putfield org.apache.lucene.index.DocumentsWriterFlushControl.stallStartNS:J
15: goto 19
16: StackMap locals: int
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "DW"
getstatic java.util.Locale.ROOT:Ljava/util/Locale;
ldc "done stalling flushes for %.1f msec: netBytes: %.1f MB flushBytes: %.1f MB fullFlush: %b"
iconst_4
anewarray java.lang.Object
dup
iconst_0
17: invokestatic java.lang.System.nanoTime:()J
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.stallStartNS:J
lsub
l2d
ldc 1000000.0
ddiv
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
dup
iconst_1
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.netBytes:()J
l2d
ldc 1024.0
ddiv
ldc 1024.0
ddiv
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
dup
iconst_2
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.getFlushingBytes:()J
l2d
ldc 1024.0
ddiv
ldc 1024.0
ddiv
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
dup
iconst_3
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
aastore
18: invokestatic java.lang.String.format:(Ljava/util/Locale;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokevirtual org.apache.lucene.util.InfoStream.message:(Ljava/lang/String;Ljava/lang/String;)V
19: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.stallControl:Lorg/apache/lucene/index/DocumentsWriterStallControl;
iload 3
invokevirtual org.apache.lucene.index.DocumentsWriterStallControl.updateStalled:(Z)V
20: iload 3
ireturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
2 21 1 limit J
8 21 3 stall Z
public synchronized void waitForFlush();
descriptor: ()V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=2, args_size=1
start local 0 0: goto 5
1: StackMap locals:
StackMap stack:
aload 0
invokevirtual java.lang.Object.wait:()V
2: goto 5
StackMap locals:
StackMap stack: java.lang.InterruptedException
3: astore 1
start local 1 4: new org.apache.lucene.util.ThreadInterruptedException
dup
aload 1
invokespecial org.apache.lucene.util.ThreadInterruptedException.<init>:(Ljava/lang/InterruptedException;)V
athrow
end local 1 5: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushingWriters:Ljava/util/List;
invokeinterface java.util.List.size:()I
ifne 1
6: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
4 5 1 e Ljava/lang/InterruptedException;
Exception table:
from to target type
1 2 3 Class java.lang.InterruptedException
public synchronized void setFlushPending(org.apache.lucene.index.DocumentsWriterPerThread);
descriptor: (Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 1
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isFlushPending:()Z
ifeq 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.getNumDocsInRAM:()I
ifle 8
2: aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.setFlushPending:()V
3: aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.getLastCommittedBytesUsed:()J
lstore 2
start local 2 4: aload 0
dup
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
lload 2
ladd
putfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
5: aload 0
dup
getfield org.apache.lucene.index.DocumentsWriterFlushControl.activeBytes:J
lload 2
lsub
putfield org.apache.lucene.index.DocumentsWriterFlushControl.activeBytes:J
6: aload 0
dup
getfield org.apache.lucene.index.DocumentsWriterFlushControl.numPending:I
iconst_1
iadd
putfield org.apache.lucene.index.DocumentsWriterFlushControl.numPending:I
7: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 8
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.assertMemory:()Z
ifne 8
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
end local 2 8: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
0 9 1 perThread Lorg/apache/lucene/index/DocumentsWriterPerThread;
4 8 2 bytes J
MethodParameters:
Name Flags
perThread
synchronized void doOnAbort(org.apache.lucene.index.DocumentsWriterPerThread);
descriptor: (Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 1
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.isRegistered:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 2
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isHeldByCurrentThread:()Z
ifne 2
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isFlushPending:()Z
ifeq 5
3: aload 0
dup
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.getLastCommittedBytesUsed:()J
lsub
putfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
4: goto 6
5: StackMap locals:
StackMap stack:
aload 0
dup
getfield org.apache.lucene.index.DocumentsWriterFlushControl.activeBytes:J
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.getLastCommittedBytesUsed:()J
lsub
putfield org.apache.lucene.index.DocumentsWriterFlushControl.activeBytes:J
6: StackMap locals:
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 12
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.assertMemory:()Z
ifne 12
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
7: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
8: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
pop
9: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.checkout:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)Z
istore 3
start local 3 10: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 11
iload 3
ifne 11
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
end local 3 11: StackMap locals: java.lang.Throwable
StackMap stack:
aload 2
athrow
12: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
pop
13: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.checkout:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)Z
istore 3
start local 3 14: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 15
iload 3
ifne 15
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
end local 3 15: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
0 16 1 perThread Lorg/apache/lucene/index/DocumentsWriterPerThread;
10 11 3 checkedOut Z
14 15 3 checkedOut Z
Exception table:
from to target type
0 7 7 any
MethodParameters:
Name Flags
perThread
private void checkoutAndBlock(org.apache.lucene.index.DocumentsWriterPerThread);
descriptor: (Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 1
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.isRegistered:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 2
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isHeldByCurrentThread:()Z
ifne 2
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 3
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isFlushPending:()Z
ifne 3
new java.lang.AssertionError
dup
ldc "can not block non-pending threadstate"
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
3: StackMap locals:
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 4
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
ifne 4
new java.lang.AssertionError
dup
ldc "can not block if fullFlush == false"
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
4: StackMap locals:
StackMap stack:
aload 0
dup
getfield org.apache.lucene.index.DocumentsWriterFlushControl.numPending:I
iconst_1
isub
putfield org.apache.lucene.index.DocumentsWriterFlushControl.numPending:I
5: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.blockedFlushes:Ljava/util/Queue;
aload 1
invokeinterface java.util.Queue.add:(Ljava/lang/Object;)Z
pop
6: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.checkout:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)Z
istore 2
start local 2 7: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 8
iload 2
ifne 8
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
8: StackMap locals: int
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
0 9 1 perThread Lorg/apache/lucene/index/DocumentsWriterPerThread;
7 9 2 checkedOut Z
MethodParameters:
Name Flags
perThread
private synchronized org.apache.lucene.index.DocumentsWriterPerThread checkOutForFlush(org.apache.lucene.index.DocumentsWriterPerThread);
descriptor: (Lorg/apache/lucene/index/DocumentsWriterPerThread;)Lorg/apache/lucene/index/DocumentsWriterPerThread;
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 1
aload 0
invokestatic java.lang.Thread.holdsLock:(Ljava/lang/Object;)Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 2
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isFlushPending:()Z
ifne 2
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 3
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isHeldByCurrentThread:()Z
ifne 3
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
3: StackMap locals:
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 4
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.isRegistered:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)Z
ifne 4
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
4: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.addFlushingDWPT:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
5: aload 0
dup
getfield org.apache.lucene.index.DocumentsWriterFlushControl.numPending:I
iconst_1
isub
putfield org.apache.lucene.index.DocumentsWriterFlushControl.numPending:I
6: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.checkout:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)Z
istore 2
start local 2 7: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 8
iload 2
ifne 8
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
8: StackMap locals: int
StackMap stack:
aload 1
astore 4
9: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
pop
10: aload 4
areturn
end local 2 11: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread
StackMap stack: java.lang.Throwable
astore 3
12: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
pop
13: aload 3
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
0 14 1 perThread Lorg/apache/lucene/index/DocumentsWriterPerThread;
7 11 2 checkedOut Z
Exception table:
from to target type
4 9 11 any
MethodParameters:
Name Flags
perThread
private void addFlushingDWPT(org.apache.lucene.index.DocumentsWriterPerThread);
descriptor: (Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 1
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushingWriters:Ljava/util/List;
aload 1
invokeinterface java.util.List.contains:(Ljava/lang/Object;)Z
ifeq 1
new java.lang.AssertionError
dup
ldc "DWPT is already flushing"
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushingWriters:Ljava/util/List;
aload 1
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
0 3 1 perThread Lorg/apache/lucene/index/DocumentsWriterPerThread;
MethodParameters:
Name Flags
perThread
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 "DocumentsWriterFlushControl [activeBytes="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.activeBytes:J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
1: ldc ", flushBytes="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushBytes:J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc "]"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
2: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
org.apache.lucene.index.DocumentsWriterPerThread nextPendingFlush();
descriptor: ()Lorg/apache/lucene/index/DocumentsWriterPerThread;
flags: (0x0000)
Code:
stack=2, locals=7, args_size=1
start local 0 0: aload 0
dup
astore 3
monitorenter
1: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushQueue:Ljava/util/Queue;
invokeinterface java.util.Queue.poll:()Ljava/lang/Object;
checkcast org.apache.lucene.index.DocumentsWriterPerThread
dup
astore 4
start local 4 2: ifnull 6
3: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
pop
4: aload 4
aload 3
monitorexit
5: areturn
6: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl top top org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
istore 2
start local 2 7: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.numPending:I
istore 1
end local 4 start local 1 8: aload 3
monitorexit
9: goto 12
end local 2 end local 1 StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl top top org.apache.lucene.index.DocumentsWriterFlushControl
StackMap stack: java.lang.Throwable
10: aload 3
monitorexit
11: athrow
start local 1 start local 2 12: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl int int
StackMap stack:
iload 1
ifle 26
iload 2
ifne 26
13: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.iterator:()Ljava/util/Iterator;
astore 4
goto 25
StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl int int top java.util.Iterator
StackMap stack:
14: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.lucene.index.DocumentsWriterPerThread
astore 3
start local 3 15: aload 3
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isFlushPending:()Z
ifeq 25
16: aload 3
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.tryLock:()Z
ifeq 25
17: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
aload 3
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.isRegistered:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)Z
ifeq 24
18: aload 0
aload 3
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.checkOutForFlush:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)Lorg/apache/lucene/index/DocumentsWriterPerThread;
astore 6
19: aload 3
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.unlock:()V
20: aload 6
areturn
21: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl int int org.apache.lucene.index.DocumentsWriterPerThread java.util.Iterator
StackMap stack: java.lang.Throwable
astore 5
22: aload 3
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.unlock:()V
23: aload 5
athrow
24: StackMap locals:
StackMap stack:
aload 3
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.unlock:()V
end local 3 25: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl int int top java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 14
26: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl int int
StackMap stack:
aconst_null
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 27 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
8 10 1 numPending I
12 27 1 numPending I
7 10 2 fullFlush Z
12 27 2 fullFlush Z
2 8 4 poll Lorg/apache/lucene/index/DocumentsWriterPerThread;
15 25 3 next Lorg/apache/lucene/index/DocumentsWriterPerThread;
Exception table:
from to target type
1 5 10 any
6 9 10 any
10 11 10 any
17 19 21 any
public synchronized void close();
descriptor: ()V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_1
putfield org.apache.lucene.index.DocumentsWriterFlushControl.closed:Z
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
public java.util.Iterator<org.apache.lucene.index.DocumentsWriterPerThread> allActiveWriters();
descriptor: ()Ljava/util/Iterator;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.iterator:()Ljava/util/Iterator;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
Signature: ()Ljava/util/Iterator<Lorg/apache/lucene/index/DocumentsWriterPerThread;>;
synchronized void doOnDelete();
descriptor: ()V
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushPolicy:Lorg/apache/lucene/index/FlushPolicy;
aload 0
aconst_null
invokevirtual org.apache.lucene.index.FlushPolicy.onDelete:(Lorg/apache/lucene/index/DocumentsWriterFlushControl;Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
public long getDeleteBytesUsed();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.documentsWriter:Lorg/apache/lucene/index/DocumentsWriter;
getfield org.apache.lucene.index.DocumentsWriter.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
invokevirtual org.apache.lucene.index.DocumentsWriterDeleteQueue.ramBytesUsed:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
public long ramBytesUsed();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.getDeleteBytesUsed:()J
aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.netBytes:()J
ladd
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
synchronized int numFlushingDWPT();
descriptor: ()I
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushingWriters:Ljava/util/List;
invokeinterface java.util.List.size:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
public boolean getAndResetApplyAllDeletes();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushDeletes:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_0
invokevirtual java.util.concurrent.atomic.AtomicBoolean.getAndSet:(Z)Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
public void setApplyAllDeletes();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushDeletes:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
org.apache.lucene.index.DocumentsWriterPerThread obtainAndLock();
descriptor: ()Lorg/apache/lucene/index/DocumentsWriterPerThread;
flags: (0x0000)
Code:
stack=5, locals=3, args_size=1
start local 0 0: goto 13
1: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.getAndLock:()Lorg/apache/lucene/index/DocumentsWriterPerThread;
astore 1
start local 1 2: aload 1
getfield org.apache.lucene.index.DocumentsWriterPerThread.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.documentsWriter:Lorg/apache/lucene/index/DocumentsWriter;
getfield org.apache.lucene.index.DocumentsWriter.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
if_acmpne 4
3: aload 1
areturn
4: StackMap locals: org.apache.lucene.index.DocumentsWriterPerThread
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 12
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
ifeq 5
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlushMarkDone:Z
ifeq 12
StackMap locals:
StackMap stack:
5: new java.lang.AssertionError
dup
6: new java.lang.StringBuilder
dup
ldc "found a stale DWPT but full flush mark phase is already done fullFlush: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
7: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
ldc " markDone: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlushMarkDone:Z
invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
8: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
9: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
10: aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.unlock:()V
11: aload 2
athrow
12: StackMap locals:
StackMap stack:
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.unlock:()V
end local 1 13: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.closed:Z
ifeq 1
14: new org.apache.lucene.store.AlreadyClosedException
dup
ldc "flush control is closed"
invokespecial org.apache.lucene.store.AlreadyClosedException.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
2 13 1 perThread Lorg/apache/lucene/index/DocumentsWriterPerThread;
Exception table:
from to target type
4 9 9 any
long markForFullFlush();
descriptor: ()J
flags: (0x0000)
Code:
stack=5, locals=10, args_size=1
start local 0 0: aload 0
dup
astore 4
monitorenter
1: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 2
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
ifeq 2
new java.lang.AssertionError
dup
ldc "called DWFC#markForFullFlush() while full flush is still running"
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
2: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl top top top org.apache.lucene.index.DocumentsWriterFlushControl
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 3
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlushMarkDone:Z
ifeq 3
new java.lang.AssertionError
dup
ldc "full flush collection marker is still set to true"
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
3: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
4: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.documentsWriter:Lorg/apache/lucene/index/DocumentsWriter;
getfield org.apache.lucene.index.DocumentsWriter.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
astore 1
start local 1 5: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.lockNewWriters:()V
6: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.documentsWriter:Lorg/apache/lucene/index/DocumentsWriter;
getfield org.apache.lucene.index.DocumentsWriter.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.size:()I
invokevirtual org.apache.lucene.index.DocumentsWriterDeleteQueue.advanceQueue:(I)Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
astore 5
start local 5 7: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.documentsWriter:Lorg/apache/lucene/index/DocumentsWriter;
getfield org.apache.lucene.index.DocumentsWriter.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
invokevirtual org.apache.lucene.index.DocumentsWriterDeleteQueue.getMaxSeqNo:()J
lstore 2
start local 2 8: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.documentsWriter:Lorg/apache/lucene/index/DocumentsWriter;
aload 5
invokevirtual org.apache.lucene.index.DocumentsWriter.resetDeleteQueue:(Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;)V
end local 5 9: goto 13
end local 2 StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterDeleteQueue top top org.apache.lucene.index.DocumentsWriterFlushControl
StackMap stack: java.lang.Throwable
10: astore 6
11: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.unlockNewWriters:()V
12: aload 6
athrow
start local 2 13: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterDeleteQueue long org.apache.lucene.index.DocumentsWriterFlushControl
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.unlockNewWriters:()V
14: aload 4
monitorexit
15: goto 18
end local 2 end local 1 StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl top top top org.apache.lucene.index.DocumentsWriterFlushControl
StackMap stack: java.lang.Throwable
16: aload 4
monitorexit
17: athrow
start local 1 start local 2 18: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterDeleteQueue long
StackMap stack:
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 4
start local 4 19: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
aload 1
invokedynamic test(Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;)Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
org/apache/lucene/index/DocumentsWriterFlushControl.lambda$0(Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;Lorg/apache/lucene/index/DocumentsWriterPerThread;)Z (6)
(Lorg/apache/lucene/index/DocumentsWriterPerThread;)Z
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.filterAndLock:(Ljava/util/function/Predicate;)Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 6
goto 48
StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterDeleteQueue long java.util.List top java.util.Iterator
StackMap stack:
20: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.lucene.index.DocumentsWriterPerThread
astore 5
start local 5 21: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 29
aload 5
getfield org.apache.lucene.index.DocumentsWriterPerThread.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
aload 1
if_acmpeq 29
22: aload 5
getfield org.apache.lucene.index.DocumentsWriterPerThread.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.documentsWriter:Lorg/apache/lucene/index/DocumentsWriter;
getfield org.apache.lucene.index.DocumentsWriter.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
if_acmpeq 29
new java.lang.AssertionError
dup
new java.lang.StringBuilder
dup
ldc " flushingQueue: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
23: aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
24: ldc " currentqueue: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
25: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.documentsWriter:Lorg/apache/lucene/index/DocumentsWriter;
getfield org.apache.lucene.index.DocumentsWriter.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
26: ldc " perThread queue: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
27: aload 5
getfield org.apache.lucene.index.DocumentsWriterPerThread.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
28: ldc " numDocsInRam: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 5
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.getNumDocsInRAM:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
29: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterDeleteQueue long java.util.List org.apache.lucene.index.DocumentsWriterPerThread java.util.Iterator
StackMap stack:
aload 5
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.getNumDocsInRAM:()I
ifle 42
30: aload 0
dup
astore 8
monitorenter
31: aload 5
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isFlushPending:()Z
ifne 33
32: aload 0
aload 5
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.setFlushPending:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
33: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterDeleteQueue long java.util.List org.apache.lucene.index.DocumentsWriterPerThread java.util.Iterator top org.apache.lucene.index.DocumentsWriterFlushControl
StackMap stack:
aload 0
aload 5
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.checkOutForFlush:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)Lorg/apache/lucene/index/DocumentsWriterPerThread;
astore 7
start local 7 34: aload 8
monitorexit
35: goto 38
end local 7 StackMap locals:
StackMap stack: java.lang.Throwable
36: aload 8
monitorexit
37: athrow
start local 7 38: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterDeleteQueue long java.util.List org.apache.lucene.index.DocumentsWriterPerThread java.util.Iterator org.apache.lucene.index.DocumentsWriterPerThread
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 39
aload 7
ifnonnull 39
new java.lang.AssertionError
dup
ldc "DWPT must never be null here since we hold the lock and it holds documents"
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
39: StackMap locals:
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 40
aload 5
aload 7
if_acmpeq 40
new java.lang.AssertionError
dup
ldc "flushControl returned different DWPT"
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
40: StackMap locals:
StackMap stack:
aload 4
aload 7
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 7 41: goto 47
42: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
aload 5
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.checkout:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)Z
istore 7
start local 7 43: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 47
iload 7
ifne 47
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
end local 7 44: StackMap locals:
StackMap stack: java.lang.Throwable
astore 9
45: aload 5
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.unlock:()V
46: aload 9
athrow
47: StackMap locals:
StackMap stack:
aload 5
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.unlock:()V
end local 5 48: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterDeleteQueue long java.util.List top java.util.Iterator
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 20
49: aload 0
dup
astore 5
monitorenter
50: aload 0
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.pruneBlockedQueue:(Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;)V
51: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 52
aload 0
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.documentsWriter:Lorg/apache/lucene/index/DocumentsWriter;
getfield org.apache.lucene.index.DocumentsWriter.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.assertBlockedFlushes:(Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;)Z
ifne 52
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
52: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterDeleteQueue long java.util.List org.apache.lucene.index.DocumentsWriterFlushControl
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushQueue:Ljava/util/Queue;
aload 4
invokeinterface java.util.Queue.addAll:(Ljava/util/Collection;)Z
pop
53: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
pop
54: aload 0
iconst_1
putfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlushMarkDone:Z
55: aload 5
monitorexit
56: goto 59
StackMap locals:
StackMap stack: java.lang.Throwable
57: aload 5
monitorexit
58: athrow
59: StackMap locals:
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 60
aload 0
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.documentsWriter:Lorg/apache/lucene/index/DocumentsWriter;
getfield org.apache.lucene.index.DocumentsWriter.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.assertActiveDeleteQueue:(Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;)Z
ifne 60
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
60: StackMap locals:
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 61
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterDeleteQueue.getLastSequenceNumber:()J
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterDeleteQueue.getMaxSeqNo:()J
lcmp
ifle 61
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
61: StackMap locals:
StackMap stack:
lload 2
lreturn
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 62 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
5 16 1 flushingQueue Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
18 62 1 flushingQueue Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
8 10 2 seqNo J
13 16 2 seqNo J
18 62 2 seqNo J
7 9 5 newQueue Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
19 62 4 fullFlushBuffer Ljava/util/List<Lorg/apache/lucene/index/DocumentsWriterPerThread;>;
21 48 5 next Lorg/apache/lucene/index/DocumentsWriterPerThread;
34 36 7 flushingDWPT Lorg/apache/lucene/index/DocumentsWriterPerThread;
38 41 7 flushingDWPT Lorg/apache/lucene/index/DocumentsWriterPerThread;
43 44 7 checkout Z
Exception table:
from to target type
6 10 10 any
1 15 16 any
16 17 16 any
31 35 36 any
36 37 36 any
21 44 44 any
50 56 57 any
57 58 57 any
private boolean assertActiveDeleteQueue(org.apache.lucene.index.DocumentsWriterDeleteQueue);
descriptor: (Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.iterator:()Ljava/util/Iterator;
astore 3
goto 3
StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterDeleteQueue top java.util.Iterator
StackMap stack:
1: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.lucene.index.DocumentsWriterPerThread
astore 2
start local 2 2: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 3
aload 2
getfield org.apache.lucene.index.DocumentsWriterPerThread.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
aload 1
if_acmpeq 3
new java.lang.AssertionError
dup
new java.lang.StringBuilder
dup
ldc "numDocs: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.getNumDocsInRAM:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
end local 2 3: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
4: iconst_1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
0 5 1 queue Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
2 3 2 next Lorg/apache/lucene/index/DocumentsWriterPerThread;
MethodParameters:
Name Flags
queue
private void pruneBlockedQueue(org.apache.lucene.index.DocumentsWriterDeleteQueue);
descriptor: (Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 1
aload 0
invokestatic java.lang.Thread.holdsLock:(Ljava/lang/Object;)Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.blockedFlushes:Ljava/util/Queue;
invokeinterface java.util.Queue.iterator:()Ljava/util/Iterator;
astore 2
start local 2 2: goto 8
3: StackMap locals: java.util.Iterator
StackMap stack:
aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.lucene.index.DocumentsWriterPerThread
astore 3
start local 3 4: aload 3
getfield org.apache.lucene.index.DocumentsWriterPerThread.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
aload 1
if_acmpne 8
5: aload 2
invokeinterface java.util.Iterator.remove:()V
6: aload 0
aload 3
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.addFlushingDWPT:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
7: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushQueue:Ljava/util/Queue;
aload 3
invokeinterface java.util.Queue.add:(Ljava/lang/Object;)Z
pop
end local 3 8: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
9: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
0 10 1 flushingQueue Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
2 10 2 iterator Ljava/util/Iterator<Lorg/apache/lucene/index/DocumentsWriterPerThread;>;
4 8 3 blockedFlush Lorg/apache/lucene/index/DocumentsWriterPerThread;
MethodParameters:
Name Flags
flushingQueue final
synchronized void finishFullFlush();
descriptor: ()V
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=4, locals=2, args_size=1
start local 0 0: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 1
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 2
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushQueue:Ljava/util/Queue;
invokeinterface java.util.Queue.isEmpty:()Z
ifne 2
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 3
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushingWriters:Ljava/util/List;
invokeinterface java.util.List.isEmpty:()Z
ifne 3
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
3: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.blockedFlushes:Ljava/util/Queue;
invokeinterface java.util.Queue.isEmpty:()Z
ifne 11
4: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 5
aload 0
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.documentsWriter:Lorg/apache/lucene/index/DocumentsWriter;
getfield org.apache.lucene.index.DocumentsWriter.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.assertBlockedFlushes:(Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;)Z
ifne 5
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
5: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.documentsWriter:Lorg/apache/lucene/index/DocumentsWriter;
getfield org.apache.lucene.index.DocumentsWriter.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.pruneBlockedQueue:(Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;)V
6: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 11
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.blockedFlushes:Ljava/util/Queue;
invokeinterface java.util.Queue.isEmpty:()Z
ifne 11
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
7: StackMap locals:
StackMap stack: java.lang.Throwable
astore 1
8: aload 0
aload 0
iconst_0
dup_x1
putfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
putfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlushMarkDone:Z
9: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
pop
10: aload 1
athrow
11: StackMap locals:
StackMap stack:
aload 0
aload 0
iconst_0
dup_x1
putfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
putfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlushMarkDone:Z
12: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
pop
13: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
Exception table:
from to target type
3 7 7 any
boolean assertBlockedFlushes(org.apache.lucene.index.DocumentsWriterDeleteQueue);
descriptor: (Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;)Z
flags: (0x0000)
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.blockedFlushes:Ljava/util/Queue;
invokeinterface java.util.Queue.iterator:()Ljava/util/Iterator;
astore 3
goto 3
StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterDeleteQueue top java.util.Iterator
StackMap stack:
1: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.lucene.index.DocumentsWriterPerThread
astore 2
start local 2 2: getstatic org.apache.lucene.index.DocumentsWriterFlushControl.$assertionsDisabled:Z
ifne 3
aload 2
getfield org.apache.lucene.index.DocumentsWriterPerThread.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
aload 1
if_acmpeq 3
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
end local 2 3: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
4: iconst_1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
0 5 1 flushingQueue Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
2 3 2 blockedFlush Lorg/apache/lucene/index/DocumentsWriterPerThread;
MethodParameters:
Name Flags
flushingQueue
synchronized void abortFullFlushes();
descriptor: ()V
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.abortPendingFlushes:()V
1: goto 5
StackMap locals:
StackMap stack: java.lang.Throwable
2: astore 1
3: aload 0
aload 0
iconst_0
dup_x1
putfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
putfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlushMarkDone:Z
4: aload 1
athrow
5: StackMap locals:
StackMap stack:
aload 0
aload 0
iconst_0
dup_x1
putfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
putfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlushMarkDone:Z
6: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
Exception table:
from to target type
0 2 2 any
synchronized void abortPendingFlushes();
descriptor: ()V
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=2, locals=5, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushQueue:Ljava/util/Queue;
invokeinterface java.util.Queue.iterator:()Ljava/util/Iterator;
astore 2
goto 11
StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl top java.util.Iterator
StackMap stack:
1: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.lucene.index.DocumentsWriterPerThread
astore 1
start local 1 2: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.documentsWriter:Lorg/apache/lucene/index/DocumentsWriter;
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.getNumDocsInRAM:()I
invokevirtual org.apache.lucene.index.DocumentsWriter.subtractFlushedNumDocs:(I)V
3: aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.abort:()V
4: goto 10
StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread java.util.Iterator
StackMap stack: java.lang.Exception
5: pop
6: aload 0
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.doAfterFlush:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
goto 11
7: StackMap locals:
StackMap stack: java.lang.Throwable
astore 3
8: aload 0
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.doAfterFlush:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
9: aload 3
athrow
10: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.doAfterFlush:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
end local 1 11: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl top java.util.Iterator
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
12: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.blockedFlushes:Ljava/util/Queue;
invokeinterface java.util.Queue.iterator:()Ljava/util/Iterator;
astore 2
goto 24
StackMap locals:
StackMap stack:
13: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.lucene.index.DocumentsWriterPerThread
astore 1
start local 1 14: aload 0
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.addFlushingDWPT:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
15: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.documentsWriter:Lorg/apache/lucene/index/DocumentsWriter;
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.getNumDocsInRAM:()I
invokevirtual org.apache.lucene.index.DocumentsWriter.subtractFlushedNumDocs:(I)V
16: aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.abort:()V
17: goto 23
StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread java.util.Iterator
StackMap stack: java.lang.Exception
18: pop
19: aload 0
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.doAfterFlush:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
goto 24
20: StackMap locals:
StackMap stack: java.lang.Throwable
astore 3
21: aload 0
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.doAfterFlush:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
22: aload 3
athrow
23: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.doAfterFlush:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)V
end local 1 24: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl top java.util.Iterator
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 13
25: goto 31
StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl
StackMap stack: java.lang.Throwable
26: astore 4
27: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushQueue:Ljava/util/Queue;
invokeinterface java.util.Queue.clear:()V
28: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.blockedFlushes:Ljava/util/Queue;
invokeinterface java.util.Queue.clear:()V
29: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
pop
30: aload 4
athrow
31: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushQueue:Ljava/util/Queue;
invokeinterface java.util.Queue.clear:()V
32: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.blockedFlushes:Ljava/util/Queue;
invokeinterface java.util.Queue.clear:()V
33: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
pop
34: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 35 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
2 11 1 dwpt Lorg/apache/lucene/index/DocumentsWriterPerThread;
14 24 1 blockedFlush Lorg/apache/lucene/index/DocumentsWriterPerThread;
Exception table:
from to target type
2 4 5 Class java.lang.Exception
2 6 7 any
14 17 18 Class java.lang.Exception
14 19 20 any
0 26 26 any
synchronized boolean isFullFlush();
descriptor: ()Z
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.fullFlush:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
synchronized int numQueuedFlushes();
descriptor: ()I
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.flushQueue:Ljava/util/Queue;
invokeinterface java.util.Queue.size:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
synchronized int numBlockedFlushes();
descriptor: ()I
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.blockedFlushes:Ljava/util/Queue;
invokeinterface java.util.Queue.size:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
void waitIfStalled();
descriptor: ()V
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.stallControl:Lorg/apache/lucene/index/DocumentsWriterStallControl;
invokevirtual org.apache.lucene.index.DocumentsWriterStallControl.waitIfStalled:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
boolean anyStalledThreads();
descriptor: ()Z
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.stallControl:Lorg/apache/lucene/index/DocumentsWriterStallControl;
invokevirtual org.apache.lucene.index.DocumentsWriterStallControl.anyStalledThreads:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
public org.apache.lucene.util.InfoStream getInfoStream();
descriptor: ()Lorg/apache/lucene/util/InfoStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.infoStream:Lorg/apache/lucene/util/InfoStream;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
synchronized org.apache.lucene.index.DocumentsWriterPerThread findLargestNonPendingWriter();
descriptor: ()Lorg/apache/lucene/index/DocumentsWriterPerThread;
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=5, locals=9, args_size=1
start local 0 0: aconst_null
astore 1
start local 1 1: lconst_0
lstore 2
start local 2 2: iconst_0
istore 4
start local 4 3: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.iterator:()Ljava/util/Iterator;
astore 6
goto 13
StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread long int top java.util.Iterator
StackMap stack:
4: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.lucene.index.DocumentsWriterPerThread
astore 5
start local 5 5: aload 5
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isFlushPending:()Z
ifne 13
aload 5
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.getNumDocsInRAM:()I
ifle 13
6: aload 5
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.getLastCommittedBytesUsed:()J
lstore 7
start local 7 7: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "FP"
invokevirtual org.apache.lucene.util.InfoStream.isEnabled:(Ljava/lang/String;)Z
ifeq 9
8: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "FP"
new java.lang.StringBuilder
dup
ldc "thread state has "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
lload 7
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc " bytes; docInRAM="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 5
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.getNumDocsInRAM:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual org.apache.lucene.util.InfoStream.message:(Ljava/lang/String;Ljava/lang/String;)V
9: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread long int org.apache.lucene.index.DocumentsWriterPerThread java.util.Iterator long
StackMap stack:
iinc 4 1
10: lload 7
lload 2
lcmp
ifle 13
11: lload 7
lstore 2
12: aload 5
astore 1
end local 7 end local 5 13: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread long int top java.util.Iterator
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
14: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "FP"
invokevirtual org.apache.lucene.util.InfoStream.isEnabled:(Ljava/lang/String;)Z
ifeq 16
15: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "FP"
new java.lang.StringBuilder
dup
iload 4
invokestatic java.lang.String.valueOf:(I)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc " in-use non-flushing threads states"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual org.apache.lucene.util.InfoStream.message:(Ljava/lang/String;Ljava/lang/String;)V
16: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread long int
StackMap stack:
aload 1
areturn
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
1 17 1 maxRamUsingWriter Lorg/apache/lucene/index/DocumentsWriterPerThread;
2 17 2 maxRamSoFar J
3 17 4 count I
5 13 5 next Lorg/apache/lucene/index/DocumentsWriterPerThread;
7 13 7 nextRam J
final org.apache.lucene.index.DocumentsWriterPerThread checkoutLargestNonPendingWriter();
descriptor: ()Lorg/apache/lucene/index/DocumentsWriterPerThread;
flags: (0x0010) ACC_FINAL
Code:
stack=3, locals=6, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.findLargestNonPendingWriter:()Lorg/apache/lucene/index/DocumentsWriterPerThread;
astore 1
start local 1 1: aload 1
ifnull 20
2: aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.lock:()V
3: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.perThreadPool:Lorg/apache/lucene/index/DocumentsWriterPerThreadPool;
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThreadPool.isRegistered:(Lorg/apache/lucene/index/DocumentsWriterPerThread;)Z
ifeq 19
4: aload 0
dup
astore 2
monitorenter
5: aload 0
aload 1
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.isFlushPending:()Z
ifeq 6
iconst_0
goto 7
StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread org.apache.lucene.index.DocumentsWriterFlushControl
StackMap stack: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread
6: iconst_1
StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread org.apache.lucene.index.DocumentsWriterFlushControl
StackMap stack: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread int
7: invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.checkout:(Lorg/apache/lucene/index/DocumentsWriterPerThread;Z)Lorg/apache/lucene/index/DocumentsWriterPerThread;
astore 4
8: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
pop
aload 2
monitorexit
9: aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.unlock:()V
10: aload 4
areturn
11: StackMap locals:
StackMap stack: java.lang.Throwable
astore 3
12: aload 0
invokevirtual org.apache.lucene.index.DocumentsWriterFlushControl.updateStallState:()Z
pop
13: aload 3
athrow
14: StackMap locals:
StackMap stack: java.lang.Throwable
aload 2
monitorexit
15: athrow
16: StackMap locals: org.apache.lucene.index.DocumentsWriterFlushControl org.apache.lucene.index.DocumentsWriterPerThread
StackMap stack: java.lang.Throwable
astore 5
17: aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.unlock:()V
18: aload 5
athrow
19: StackMap locals:
StackMap stack:
aload 1
invokevirtual org.apache.lucene.index.DocumentsWriterPerThread.unlock:()V
20: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
1 21 1 largestNonPendingWriter Lorg/apache/lucene/index/DocumentsWriterPerThread;
Exception table:
from to target type
5 8 11 any
5 9 14 any
11 15 14 any
3 9 16 any
11 16 16 any
long getPeakActiveBytes();
descriptor: ()J
flags: (0x0000)
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.peakActiveBytes:J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
long getPeakNetBytes();
descriptor: ()J
flags: (0x0000)
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.DocumentsWriterFlushControl.peakNetBytes:J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/DocumentsWriterFlushControl;
private static boolean lambda$0(org.apache.lucene.index.DocumentsWriterDeleteQueue, org.apache.lucene.index.DocumentsWriterPerThread);
descriptor: (Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;Lorg/apache/lucene/index/DocumentsWriterPerThread;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
getfield org.apache.lucene.index.DocumentsWriterPerThread.deleteQueue:Lorg/apache/lucene/index/DocumentsWriterDeleteQueue;
aload 0
if_acmpne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: ireturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 3 1 dwpt Lorg/apache/lucene/index/DocumentsWriterPerThread;
}
SourceFile: "DocumentsWriterFlushControl.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
DocumentsWriterFlushControl
hardMaxBytesPerDWPT: long
activeBytes(): long