final class org.apache.lucene.index.BufferedUpdatesStream implements org.apache.lucene.util.Accountable
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: org.apache.lucene.index.BufferedUpdatesStream
super_class: java.lang.Object
{
private final java.util.Set<org.apache.lucene.index.FrozenBufferedUpdates> updates;
descriptor: Ljava/util/Set;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Set<Lorg/apache/lucene/index/FrozenBufferedUpdates;>;
private long nextGen;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private final org.apache.lucene.index.BufferedUpdatesStream$FinishedSegments finishedSegments;
descriptor: Lorg/apache/lucene/index/BufferedUpdatesStream$FinishedSegments;
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 final java.util.concurrent.atomic.AtomicLong bytesUsed;
descriptor: Ljava/util/concurrent/atomic/AtomicLong;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.AtomicInteger numTerms;
descriptor: Ljava/util/concurrent/atomic/AtomicInteger;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
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/BufferedUpdatesStream;
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.BufferedUpdatesStream.$assertionsDisabled:Z
return
LocalVariableTable:
Start End Slot Name Signature
void <init>(org.apache.lucene.util.InfoStream);
descriptor: (Lorg/apache/lucene/util/InfoStream;)V
flags: (0x0000)
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
putfield org.apache.lucene.index.BufferedUpdatesStream.updates:Ljava/util/Set;
2: aload 0
lconst_1
putfield org.apache.lucene.index.BufferedUpdatesStream.nextGen:J
3: aload 0
new java.util.concurrent.atomic.AtomicLong
dup
invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
putfield org.apache.lucene.index.BufferedUpdatesStream.bytesUsed:Ljava/util/concurrent/atomic/AtomicLong;
4: aload 0
new java.util.concurrent.atomic.AtomicInteger
dup
invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
putfield org.apache.lucene.index.BufferedUpdatesStream.numTerms:Ljava/util/concurrent/atomic/AtomicInteger;
5: aload 0
aload 1
putfield org.apache.lucene.index.BufferedUpdatesStream.infoStream:Lorg/apache/lucene/util/InfoStream;
6: aload 0
new org.apache.lucene.index.BufferedUpdatesStream$FinishedSegments
dup
aload 1
invokespecial org.apache.lucene.index.BufferedUpdatesStream$FinishedSegments.<init>:(Lorg/apache/lucene/util/InfoStream;)V
putfield org.apache.lucene.index.BufferedUpdatesStream.finishedSegments:Lorg/apache/lucene/index/BufferedUpdatesStream$FinishedSegments;
7: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
0 8 1 infoStream Lorg/apache/lucene/util/InfoStream;
MethodParameters:
Name Flags
infoStream
synchronized long push(org.apache.lucene.index.FrozenBufferedUpdates);
descriptor: (Lorg/apache/lucene/index/FrozenBufferedUpdates;)J
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=11, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 0
dup
getfield org.apache.lucene.index.BufferedUpdatesStream.nextGen:J
dup2_x1
lconst_1
ladd
putfield org.apache.lucene.index.BufferedUpdatesStream.nextGen:J
invokevirtual org.apache.lucene.index.FrozenBufferedUpdates.setDelGen:(J)V
1: getstatic org.apache.lucene.index.BufferedUpdatesStream.$assertionsDisabled:Z
ifne 2
aload 1
invokevirtual org.apache.lucene.index.FrozenBufferedUpdates.any:()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.BufferedUpdatesStream.$assertionsDisabled:Z
ifne 3
aload 0
invokevirtual org.apache.lucene.index.BufferedUpdatesStream.checkDeleteStats:()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.BufferedUpdatesStream.updates:Ljava/util/Set;
aload 1
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
4: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.numTerms:Ljava/util/concurrent/atomic/AtomicInteger;
aload 1
getfield org.apache.lucene.index.FrozenBufferedUpdates.numTermDeletes:I
invokevirtual java.util.concurrent.atomic.AtomicInteger.addAndGet:(I)I
pop
5: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.bytesUsed:Ljava/util/concurrent/atomic/AtomicLong;
aload 1
getfield org.apache.lucene.index.FrozenBufferedUpdates.bytesUsed:I
i2l
invokevirtual java.util.concurrent.atomic.AtomicLong.addAndGet:(J)J
pop2
6: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "BD"
invokevirtual org.apache.lucene.util.InfoStream.isEnabled:(Ljava/lang/String;)Z
ifeq 8
7: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "BD"
getstatic java.util.Locale.ROOT:Ljava/util/Locale;
ldc "push new packet (%s), packetCount=%d, bytesUsed=%.3f MB"
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
dup
iconst_1
aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.updates:Ljava/util/Set;
invokeinterface java.util.Set.size:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.bytesUsed:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
l2d
ldc 1024.0
ddiv
ldc 1024.0
ddiv
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
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
8: StackMap locals:
StackMap stack:
getstatic org.apache.lucene.index.BufferedUpdatesStream.$assertionsDisabled:Z
ifne 9
aload 0
invokevirtual org.apache.lucene.index.BufferedUpdatesStream.checkDeleteStats:()Z
ifne 9
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
9: StackMap locals:
StackMap stack:
aload 1
invokevirtual org.apache.lucene.index.FrozenBufferedUpdates.delGen:()J
lreturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
0 10 1 packet Lorg/apache/lucene/index/FrozenBufferedUpdates;
MethodParameters:
Name Flags
packet
synchronized int getPendingUpdatesCount();
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.BufferedUpdatesStream.updates:Ljava/util/Set;
invokeinterface java.util.Set.size:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
synchronized void clear();
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.BufferedUpdatesStream.updates:Ljava/util/Set;
invokeinterface java.util.Set.clear:()V
1: aload 0
lconst_1
putfield org.apache.lucene.index.BufferedUpdatesStream.nextGen:J
2: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.finishedSegments:Lorg/apache/lucene/index/BufferedUpdatesStream$FinishedSegments;
invokevirtual org.apache.lucene.index.BufferedUpdatesStream$FinishedSegments.clear:()V
3: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.numTerms:Ljava/util/concurrent/atomic/AtomicInteger;
iconst_0
invokevirtual java.util.concurrent.atomic.AtomicInteger.set:(I)V
4: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.bytesUsed:Ljava/util/concurrent/atomic/AtomicLong;
lconst_0
invokevirtual java.util.concurrent.atomic.AtomicLong.set:(J)V
5: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
boolean any();
descriptor: ()Z
flags: (0x0000)
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.bytesUsed:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
lconst_0
lcmp
ifeq 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
int numTerms();
descriptor: ()I
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.numTerms:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
public long ramBytesUsed();
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.BufferedUpdatesStream.bytesUsed:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
void waitApplyAll(org.apache.lucene.index.IndexWriter);
descriptor: (Lorg/apache/lucene/index/IndexWriter;)V
flags: (0x0000)
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: getstatic org.apache.lucene.index.BufferedUpdatesStream.$assertionsDisabled:Z
ifne 1
aload 1
invokestatic java.lang.Thread.holdsLock:(Ljava/lang/Object;)Z
ifeq 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
dup
astore 3
monitorenter
2: new java.util.HashSet
dup
aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.updates:Ljava/util/Set;
invokespecial java.util.HashSet.<init>:(Ljava/util/Collection;)V
astore 2
start local 2 3: aload 3
monitorexit
4: goto 7
end local 2 StackMap locals: org.apache.lucene.index.BufferedUpdatesStream org.apache.lucene.index.IndexWriter top org.apache.lucene.index.BufferedUpdatesStream
StackMap stack: java.lang.Throwable
5: aload 3
monitorexit
6: athrow
start local 2 7: StackMap locals: org.apache.lucene.index.BufferedUpdatesStream org.apache.lucene.index.IndexWriter java.util.Set
StackMap stack:
aload 0
aload 2
aload 1
invokevirtual org.apache.lucene.index.BufferedUpdatesStream.waitApply:(Ljava/util/Set;Lorg/apache/lucene/index/IndexWriter;)V
8: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
0 9 1 writer Lorg/apache/lucene/index/IndexWriter;
3 5 2 waitFor Ljava/util/Set<Lorg/apache/lucene/index/FrozenBufferedUpdates;>;
7 9 2 waitFor Ljava/util/Set<Lorg/apache/lucene/index/FrozenBufferedUpdates;>;
Exception table:
from to target type
2 4 5 any
5 6 5 any
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
writer
boolean stillRunning(long);
descriptor: (J)Z
flags: (0x0000)
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.finishedSegments:Lorg/apache/lucene/index/BufferedUpdatesStream$FinishedSegments;
lload 1
invokevirtual org.apache.lucene.index.BufferedUpdatesStream$FinishedSegments.stillRunning:(J)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
0 1 1 delGen J
MethodParameters:
Name Flags
delGen
void finishedSegment(long);
descriptor: (J)V
flags: (0x0000)
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.finishedSegments:Lorg/apache/lucene/index/BufferedUpdatesStream$FinishedSegments;
lload 1
invokevirtual org.apache.lucene.index.BufferedUpdatesStream$FinishedSegments.finishedSegment:(J)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
0 2 1 delGen J
MethodParameters:
Name Flags
delGen
synchronized void finished(org.apache.lucene.index.FrozenBufferedUpdates);
descriptor: (Lorg/apache/lucene/index/FrozenBufferedUpdates;)V
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: getstatic org.apache.lucene.index.BufferedUpdatesStream.$assertionsDisabled:Z
ifne 1
aload 1
getfield org.apache.lucene.index.FrozenBufferedUpdates.applied:Ljava/util/concurrent/CountDownLatch;
invokevirtual java.util.concurrent.CountDownLatch.getCount:()J
lconst_1
lcmp
ifeq 1
new java.lang.AssertionError
dup
new java.lang.StringBuilder
dup
ldc "packet="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
1: StackMap locals:
StackMap stack:
aload 1
getfield org.apache.lucene.index.FrozenBufferedUpdates.applied:Ljava/util/concurrent/CountDownLatch;
invokevirtual java.util.concurrent.CountDownLatch.countDown:()V
2: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.updates:Ljava/util/Set;
aload 1
invokeinterface java.util.Set.remove:(Ljava/lang/Object;)Z
pop
3: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.numTerms:Ljava/util/concurrent/atomic/AtomicInteger;
aload 1
getfield org.apache.lucene.index.FrozenBufferedUpdates.numTermDeletes:I
ineg
invokevirtual java.util.concurrent.atomic.AtomicInteger.addAndGet:(I)I
pop
4: getstatic org.apache.lucene.index.BufferedUpdatesStream.$assertionsDisabled:Z
ifne 5
aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.numTerms:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
ifge 5
new java.lang.AssertionError
dup
new java.lang.StringBuilder
dup
ldc "numTerms="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.numTerms:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc " packet="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
5: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.bytesUsed:Ljava/util/concurrent/atomic/AtomicLong;
aload 1
getfield org.apache.lucene.index.FrozenBufferedUpdates.bytesUsed:I
ineg
i2l
invokevirtual java.util.concurrent.atomic.AtomicLong.addAndGet:(J)J
pop2
6: aload 0
aload 1
invokevirtual org.apache.lucene.index.FrozenBufferedUpdates.delGen:()J
invokevirtual org.apache.lucene.index.BufferedUpdatesStream.finishedSegment:(J)V
7: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
0 8 1 packet Lorg/apache/lucene/index/FrozenBufferedUpdates;
MethodParameters:
Name Flags
packet
long getCompletedDelGen();
descriptor: ()J
flags: (0x0000)
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.finishedSegments:Lorg/apache/lucene/index/BufferedUpdatesStream$FinishedSegments;
invokevirtual org.apache.lucene.index.BufferedUpdatesStream$FinishedSegments.getCompletedDelGen:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
void waitApplyForMerge(java.util.List<org.apache.lucene.index.SegmentCommitInfo>, org.apache.lucene.index.IndexWriter);
descriptor: (Ljava/util/List;Lorg/apache/lucene/index/IndexWriter;)V
flags: (0x0000)
Code:
stack=5, locals=9, args_size=3
start local 0 start local 1 start local 2 0: ldc -9223372036854775808
lstore 3
start local 3 1: aload 1
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 6
goto 4
StackMap locals: org.apache.lucene.index.BufferedUpdatesStream java.util.List org.apache.lucene.index.IndexWriter long top java.util.Iterator
StackMap stack:
2: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.lucene.index.SegmentCommitInfo
astore 5
start local 5 3: lload 3
aload 5
invokevirtual org.apache.lucene.index.SegmentCommitInfo.getBufferedDeletesGen:()J
invokestatic java.lang.Math.max:(JJ)J
lstore 3
end local 5 4: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 5
start local 5 6: aload 0
dup
astore 6
monitorenter
7: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.updates:Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 8
goto 11
StackMap locals: org.apache.lucene.index.BufferedUpdatesStream java.util.List org.apache.lucene.index.IndexWriter long java.util.Set org.apache.lucene.index.BufferedUpdatesStream top java.util.Iterator
StackMap stack:
8: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.lucene.index.FrozenBufferedUpdates
astore 7
start local 7 9: aload 7
invokevirtual org.apache.lucene.index.FrozenBufferedUpdates.delGen:()J
lload 3
lcmp
ifgt 11
10: aload 5
aload 7
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 7 11: StackMap locals:
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 8
12: aload 6
monitorexit
13: goto 16
StackMap locals: org.apache.lucene.index.BufferedUpdatesStream java.util.List org.apache.lucene.index.IndexWriter long java.util.Set org.apache.lucene.index.BufferedUpdatesStream
StackMap stack: java.lang.Throwable
14: aload 6
monitorexit
15: athrow
16: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "BD"
invokevirtual org.apache.lucene.util.InfoStream.isEnabled:(Ljava/lang/String;)Z
ifeq 18
17: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "BD"
new java.lang.StringBuilder
dup
ldc "waitApplyForMerge: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 5
invokeinterface java.util.Set.size:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc " packets, "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokeinterface java.util.List.size:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc " merging segments"
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
18: StackMap locals:
StackMap stack:
aload 0
aload 5
aload 2
invokevirtual org.apache.lucene.index.BufferedUpdatesStream.waitApply:(Ljava/util/Set;Lorg/apache/lucene/index/IndexWriter;)V
19: return
end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
0 20 1 mergeInfos Ljava/util/List<Lorg/apache/lucene/index/SegmentCommitInfo;>;
0 20 2 writer Lorg/apache/lucene/index/IndexWriter;
1 20 3 maxDelGen J
3 4 5 info Lorg/apache/lucene/index/SegmentCommitInfo;
6 20 5 waitFor Ljava/util/Set<Lorg/apache/lucene/index/FrozenBufferedUpdates;>;
9 11 7 packet Lorg/apache/lucene/index/FrozenBufferedUpdates;
Exception table:
from to target type
7 13 14 any
14 15 14 any
Exceptions:
throws java.io.IOException
Signature: (Ljava/util/List<Lorg/apache/lucene/index/SegmentCommitInfo;>;Lorg/apache/lucene/index/IndexWriter;)V
MethodParameters:
Name Flags
mergeInfos
writer
private void waitApply(java.util.Set<org.apache.lucene.index.FrozenBufferedUpdates>, org.apache.lucene.index.IndexWriter);
descriptor: (Ljava/util/Set;Lorg/apache/lucene/index/IndexWriter;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=11, locals=11, args_size=3
start local 0 start local 1 start local 2 0: invokestatic java.lang.System.nanoTime:()J
lstore 3
start local 3 1: aload 1
invokeinterface java.util.Set.size:()I
istore 5
start local 5 2: aload 1
invokeinterface java.util.Set.isEmpty:()Z
ifeq 6
3: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "BD"
invokevirtual org.apache.lucene.util.InfoStream.isEnabled:(Ljava/lang/String;)Z
ifeq 5
4: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "BD"
ldc "waitApply: no deletes to apply"
invokevirtual org.apache.lucene.util.InfoStream.message:(Ljava/lang/String;Ljava/lang/String;)V
5: StackMap locals: long int
StackMap stack:
return
6: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "BD"
invokevirtual org.apache.lucene.util.InfoStream.isEnabled:(Ljava/lang/String;)Z
ifeq 8
7: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "BD"
new java.lang.StringBuilder
dup
ldc "waitApply: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokeinterface java.util.Set.size:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc " packets: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)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
8: StackMap locals:
StackMap stack:
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 6
start local 6 9: lconst_0
lstore 7
start local 7 10: aload 1
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 10
goto 15
StackMap locals: org.apache.lucene.index.BufferedUpdatesStream java.util.Set org.apache.lucene.index.IndexWriter long int java.util.ArrayList long top java.util.Iterator
StackMap stack:
11: aload 10
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.lucene.index.FrozenBufferedUpdates
astore 9
start local 9 12: aload 2
aload 9
invokevirtual org.apache.lucene.index.IndexWriter.tryApply:(Lorg/apache/lucene/index/FrozenBufferedUpdates;)Z
ifne 14
13: aload 6
aload 9
invokevirtual java.util.ArrayList.add:(Ljava/lang/Object;)Z
pop
14: StackMap locals: org.apache.lucene.index.BufferedUpdatesStream java.util.Set org.apache.lucene.index.IndexWriter long int java.util.ArrayList long org.apache.lucene.index.FrozenBufferedUpdates java.util.Iterator
StackMap stack:
lload 7
aload 9
getfield org.apache.lucene.index.FrozenBufferedUpdates.totalDelCount:J
ladd
lstore 7
end local 9 15: StackMap locals: org.apache.lucene.index.BufferedUpdatesStream java.util.Set org.apache.lucene.index.IndexWriter long int java.util.ArrayList long top java.util.Iterator
StackMap stack:
aload 10
invokeinterface java.util.Iterator.hasNext:()Z
ifne 11
16: aload 6
invokevirtual java.util.ArrayList.iterator:()Ljava/util/Iterator;
astore 10
goto 19
StackMap locals:
StackMap stack:
17: aload 10
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.lucene.index.FrozenBufferedUpdates
astore 9
start local 9 18: aload 2
aload 9
invokevirtual org.apache.lucene.index.IndexWriter.forceApply:(Lorg/apache/lucene/index/FrozenBufferedUpdates;)V
end local 9 19: StackMap locals:
StackMap stack:
aload 10
invokeinterface java.util.Iterator.hasNext:()Z
ifne 17
20: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "BD"
invokevirtual org.apache.lucene.util.InfoStream.isEnabled:(Ljava/lang/String;)Z
ifeq 29
21: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.infoStream:Lorg/apache/lucene/util/InfoStream;
ldc "BD"
22: getstatic java.util.Locale.ROOT:Ljava/util/Locale;
ldc "waitApply: done %d packets; totalDelCount=%d; totBytesUsed=%d; took %.2f msec"
iconst_4
anewarray java.lang.Object
dup
iconst_0
23: iload 5
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
24: lload 7
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_2
25: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.bytesUsed:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_3
26: invokestatic java.lang.System.nanoTime:()J
lload 3
lsub
l2d
ldc 1000000.0
ddiv
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
27: invokestatic java.lang.String.format:(Ljava/util/Locale;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
28: invokevirtual org.apache.lucene.util.InfoStream.message:(Ljava/lang/String;Ljava/lang/String;)V
29: StackMap locals: org.apache.lucene.index.BufferedUpdatesStream java.util.Set org.apache.lucene.index.IndexWriter long int java.util.ArrayList long
StackMap stack:
return
end local 7 end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 30 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
0 30 1 waitFor Ljava/util/Set<Lorg/apache/lucene/index/FrozenBufferedUpdates;>;
0 30 2 writer Lorg/apache/lucene/index/IndexWriter;
1 30 3 startNS J
2 30 5 packetCount I
9 30 6 pendingPackets Ljava/util/ArrayList<Lorg/apache/lucene/index/FrozenBufferedUpdates;>;
10 30 7 totalDelCount J
12 15 9 packet Lorg/apache/lucene/index/FrozenBufferedUpdates;
18 19 9 packet Lorg/apache/lucene/index/FrozenBufferedUpdates;
Exceptions:
throws java.io.IOException
Signature: (Ljava/util/Set<Lorg/apache/lucene/index/FrozenBufferedUpdates;>;Lorg/apache/lucene/index/IndexWriter;)V
MethodParameters:
Name Flags
waitFor
writer
synchronized long getNextGen();
descriptor: ()J
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=7, locals=1, args_size=1
start local 0 0: aload 0
dup
getfield org.apache.lucene.index.BufferedUpdatesStream.nextGen:J
dup2_x1
lconst_1
ladd
putfield org.apache.lucene.index.BufferedUpdatesStream.nextGen:J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
private boolean checkDeleteStats();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=6, args_size=1
start local 0 0: iconst_0
istore 1
start local 1 1: lconst_0
lstore 2
start local 2 2: aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.updates:Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 6
StackMap locals: org.apache.lucene.index.BufferedUpdatesStream int long top java.util.Iterator
StackMap stack:
3: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.lucene.index.FrozenBufferedUpdates
astore 4
start local 4 4: iload 1
aload 4
getfield org.apache.lucene.index.FrozenBufferedUpdates.numTermDeletes:I
iadd
istore 1
5: lload 2
aload 4
getfield org.apache.lucene.index.FrozenBufferedUpdates.bytesUsed:I
i2l
ladd
lstore 2
end local 4 6: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
7: getstatic org.apache.lucene.index.BufferedUpdatesStream.$assertionsDisabled:Z
ifne 8
iload 1
aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.numTerms:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
if_icmpeq 8
new java.lang.AssertionError
dup
new java.lang.StringBuilder
dup
ldc "numTerms2="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 1
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc " vs "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.numTerms:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()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
8: StackMap locals: org.apache.lucene.index.BufferedUpdatesStream int long
StackMap stack:
getstatic org.apache.lucene.index.BufferedUpdatesStream.$assertionsDisabled:Z
ifne 9
lload 2
aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.bytesUsed:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
lcmp
ifeq 9
new java.lang.AssertionError
dup
new java.lang.StringBuilder
dup
ldc "bytesUsed2="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
lload 2
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc " vs "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.lucene.index.BufferedUpdatesStream.bytesUsed:Ljava/util/concurrent/atomic/AtomicLong;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
9: StackMap locals:
StackMap stack:
iconst_1
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/lucene/index/BufferedUpdatesStream;
1 10 1 numTerms2 I
2 10 2 bytesUsed2 J
4 6 4 packet Lorg/apache/lucene/index/FrozenBufferedUpdates;
}
SourceFile: "BufferedUpdatesStream.java"
NestMembers:
org.apache.lucene.index.BufferedUpdatesStream$ApplyDeletesResult org.apache.lucene.index.BufferedUpdatesStream$FinishedSegments org.apache.lucene.index.BufferedUpdatesStream$SegmentState
InnerClasses:
ApplyDeletesResult = org.apache.lucene.index.BufferedUpdatesStream$ApplyDeletesResult of org.apache.lucene.index.BufferedUpdatesStream
private FinishedSegments = org.apache.lucene.index.BufferedUpdatesStream$FinishedSegments of org.apache.lucene.index.BufferedUpdatesStream
final SegmentState = org.apache.lucene.index.BufferedUpdatesStream$SegmentState of org.apache.lucene.index.BufferedUpdatesStream