public class jdk.jfr.internal.consumer.EventDirectoryStream extends jdk.jfr.internal.consumer.AbstractEventStream
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: jdk.jfr.internal.consumer.EventDirectoryStream
super_class: jdk.jfr.internal.consumer.AbstractEventStream
{
private static final java.util.Comparator<? super jdk.jfr.consumer.RecordedEvent> EVENT_COMPARATOR;
descriptor: Ljava/util/Comparator;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Ljava/util/Comparator<-Ljdk/jfr/consumer/RecordedEvent;>;
private final jdk.jfr.internal.consumer.RepositoryFiles repositoryFiles;
descriptor: Ljdk/jfr/internal/consumer/RepositoryFiles;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final jdk.jfr.internal.PlatformRecording recording;
descriptor: Ljdk/jfr/internal/PlatformRecording;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final jdk.jfr.internal.consumer.FileAccess fileAccess;
descriptor: Ljdk/jfr/internal/consumer/FileAccess;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private jdk.jfr.internal.consumer.ChunkParser currentParser;
descriptor: Ljdk/jfr/internal/consumer/ChunkParser;
flags: (0x0002) ACC_PRIVATE
private long currentChunkStartNanos;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private jdk.jfr.consumer.RecordedEvent[] sortedCache;
descriptor: [Ljdk/jfr/consumer/RecordedEvent;
flags: (0x0002) ACC_PRIVATE
private int threadExclusionLevel;
descriptor: I
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: invokestatic jdk.jfr.internal.consumer.JdkJfrConsumer.instance:()Ljdk/jfr/internal/consumer/JdkJfrConsumer;
invokevirtual jdk.jfr.internal.consumer.JdkJfrConsumer.eventComparator:()Ljava/util/Comparator;
putstatic jdk.jfr.internal.consumer.EventDirectoryStream.EVENT_COMPARATOR:Ljava/util/Comparator;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(java.security.AccessControlContext, java.nio.file.Path, jdk.jfr.internal.consumer.FileAccess, jdk.jfr.internal.PlatformRecording);
descriptor: (Ljava/security/AccessControlContext;Ljava/nio/file/Path;Ljdk/jfr/internal/consumer/FileAccess;Ljdk/jfr/internal/PlatformRecording;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 4
invokespecial jdk.jfr.internal.consumer.AbstractEventStream.<init>:(Ljava/security/AccessControlContext;Ljdk/jfr/internal/PlatformRecording;)V
1: aload 0
iconst_0
putfield jdk.jfr.internal.consumer.EventDirectoryStream.threadExclusionLevel:I
2: aload 0
aload 3
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast jdk.jfr.internal.consumer.FileAccess
putfield jdk.jfr.internal.consumer.EventDirectoryStream.fileAccess:Ljdk/jfr/internal/consumer/FileAccess;
3: aload 0
aload 4
putfield jdk.jfr.internal.consumer.EventDirectoryStream.recording:Ljdk/jfr/internal/PlatformRecording;
4: aload 0
new jdk.jfr.internal.consumer.RepositoryFiles
dup
aload 3
aload 2
invokespecial jdk.jfr.internal.consumer.RepositoryFiles.<init>:(Ljdk/jfr/internal/consumer/FileAccess;Ljava/nio/file/Path;)V
putfield jdk.jfr.internal.consumer.EventDirectoryStream.repositoryFiles:Ljdk/jfr/internal/consumer/RepositoryFiles;
5: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Ljdk/jfr/internal/consumer/EventDirectoryStream;
0 6 1 acc Ljava/security/AccessControlContext;
0 6 2 p Ljava/nio/file/Path;
0 6 3 fileAccess Ljdk/jfr/internal/consumer/FileAccess;
0 6 4 recording Ljdk/jfr/internal/PlatformRecording;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
acc
p
fileAccess
recording
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_1
invokevirtual jdk.jfr.internal.consumer.EventDirectoryStream.setClosed:(Z)V
1: aload 0
invokevirtual jdk.jfr.internal.consumer.EventDirectoryStream.dispatcher:()Ljdk/jfr/internal/consumer/Dispatcher;
invokevirtual jdk.jfr.internal.consumer.Dispatcher.runCloseActions:()V
2: aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.repositoryFiles:Ljdk/jfr/internal/consumer/RepositoryFiles;
invokevirtual jdk.jfr.internal.consumer.RepositoryFiles.close:()V
3: aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
ifnull 5
4: aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
invokevirtual jdk.jfr.internal.consumer.ChunkParser.close:()V
5: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Ljdk/jfr/internal/consumer/EventDirectoryStream;
public void start();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokestatic java.time.Instant.now:()Ljava/time/Instant;
invokestatic jdk.jfr.internal.Utils.timeToNanos:(Ljava/time/Instant;)J
invokevirtual jdk.jfr.internal.consumer.EventDirectoryStream.start:(J)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Ljdk/jfr/internal/consumer/EventDirectoryStream;
public void startAsync();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokestatic java.time.Instant.now:()Ljava/time/Instant;
invokestatic jdk.jfr.internal.Utils.timeToNanos:(Ljava/time/Instant;)J
invokevirtual jdk.jfr.internal.consumer.EventDirectoryStream.startAsync:(J)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Ljdk/jfr/internal/consumer/EventDirectoryStream;
protected void process();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=4, args_size=1
start local 0 0: invokestatic jdk.jfr.internal.JVM.getJVM:()Ljdk/jfr/internal/JVM;
astore 1
start local 1 1: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
astore 2
start local 2 2: aload 1
aload 2
invokevirtual jdk.jfr.internal.JVM.isExcluded:(Ljava/lang/Thread;)Z
ifeq 5
3: aload 0
dup
getfield jdk.jfr.internal.consumer.EventDirectoryStream.threadExclusionLevel:I
iconst_1
iadd
putfield jdk.jfr.internal.consumer.EventDirectoryStream.threadExclusionLevel:I
4: goto 6
5: StackMap locals: jdk.jfr.internal.JVM java.lang.Thread
StackMap stack:
aload 1
aload 2
invokevirtual jdk.jfr.internal.JVM.exclude:(Ljava/lang/Thread;)V
6: StackMap locals:
StackMap stack:
aload 0
invokevirtual jdk.jfr.internal.consumer.EventDirectoryStream.processRecursionSafe:()V
7: goto 14
StackMap locals:
StackMap stack: java.lang.Throwable
8: astore 3
9: aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.threadExclusionLevel:I
ifle 12
10: aload 0
dup
getfield jdk.jfr.internal.consumer.EventDirectoryStream.threadExclusionLevel:I
iconst_1
isub
putfield jdk.jfr.internal.consumer.EventDirectoryStream.threadExclusionLevel:I
11: goto 13
12: StackMap locals: java.lang.Throwable
StackMap stack:
aload 1
aload 2
invokevirtual jdk.jfr.internal.JVM.include:(Ljava/lang/Thread;)V
13: StackMap locals:
StackMap stack:
aload 3
athrow
14: StackMap locals:
StackMap stack:
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.threadExclusionLevel:I
ifle 17
15: aload 0
dup
getfield jdk.jfr.internal.consumer.EventDirectoryStream.threadExclusionLevel:I
iconst_1
isub
putfield jdk.jfr.internal.consumer.EventDirectoryStream.threadExclusionLevel:I
16: goto 18
17: StackMap locals:
StackMap stack:
aload 1
aload 2
invokevirtual jdk.jfr.internal.JVM.include:(Ljava/lang/Thread;)V
18: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Ljdk/jfr/internal/consumer/EventDirectoryStream;
1 19 1 jvm Ljdk/jfr/internal/JVM;
2 19 2 t Ljava/lang/Thread;
Exception table:
from to target type
2 8 8 any
Exceptions:
throws java.io.IOException
protected void processRecursionSafe();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=5, locals=16, args_size=1
start local 0 0: aconst_null
astore 1
start local 1 1: aload 0
invokevirtual jdk.jfr.internal.consumer.EventDirectoryStream.dispatcher:()Ljdk/jfr/internal/consumer/Dispatcher;
astore 2
start local 2 2: aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.recording:Ljdk/jfr/internal/PlatformRecording;
ifnonnull 3
aload 2
getfield jdk.jfr.internal.consumer.Dispatcher.startTime:Ljava/time/Instant;
ifnonnull 3
iconst_0
goto 4
StackMap locals: jdk.jfr.internal.consumer.Dispatcher jdk.jfr.internal.consumer.Dispatcher
StackMap stack:
3: iconst_1
StackMap locals:
StackMap stack: int
4: istore 4
start local 4 5: iload 4
ifeq 8
6: aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.repositoryFiles:Ljdk/jfr/internal/consumer/RepositoryFiles;
aload 2
getfield jdk.jfr.internal.consumer.Dispatcher.startNanos:J
invokevirtual jdk.jfr.internal.consumer.RepositoryFiles.firstPath:(J)Ljava/nio/file/Path;
astore 3
start local 3 7: goto 9
end local 3 8: StackMap locals: jdk.jfr.internal.consumer.EventDirectoryStream jdk.jfr.internal.consumer.Dispatcher jdk.jfr.internal.consumer.Dispatcher top int
StackMap stack:
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.repositoryFiles:Ljdk/jfr/internal/consumer/RepositoryFiles;
invokevirtual jdk.jfr.internal.consumer.RepositoryFiles.lastPath:()Ljava/nio/file/Path;
astore 3
start local 3 9: StackMap locals: jdk.jfr.internal.consumer.EventDirectoryStream jdk.jfr.internal.consumer.Dispatcher jdk.jfr.internal.consumer.Dispatcher java.nio.file.Path int
StackMap stack:
aload 3
ifnonnull 11
10: return
11: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.repositoryFiles:Ljdk/jfr/internal/consumer/RepositoryFiles;
aload 3
invokevirtual jdk.jfr.internal.consumer.RepositoryFiles.getTimestamp:(Ljava/nio/file/Path;)J
putfield jdk.jfr.internal.consumer.EventDirectoryStream.currentChunkStartNanos:J
12: aconst_null
astore 5
aconst_null
astore 6
13: new jdk.jfr.internal.consumer.RecordingInput
dup
aload 3
invokeinterface java.nio.file.Path.toFile:()Ljava/io/File;
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.fileAccess:Ljdk/jfr/internal/consumer/FileAccess;
invokespecial jdk.jfr.internal.consumer.RecordingInput.<init>:(Ljava/io/File;Ljdk/jfr/internal/consumer/FileAccess;)V
astore 7
start local 7 14: aload 0
new jdk.jfr.internal.consumer.ChunkParser
dup
aload 7
aload 2
getfield jdk.jfr.internal.consumer.Dispatcher.parserConfiguration:Ljdk/jfr/internal/consumer/ChunkParser$ParserConfiguration;
invokespecial jdk.jfr.internal.consumer.ChunkParser.<init>:(Ljdk/jfr/internal/consumer/RecordingInput;Ljdk/jfr/internal/consumer/ChunkParser$ParserConfiguration;)V
putfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
15: aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
invokevirtual jdk.jfr.internal.consumer.ChunkParser.getStartNanos:()J
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
invokevirtual jdk.jfr.internal.consumer.ChunkParser.getChunkDuration:()J
ladd
lstore 8
start local 8 16: iload 4
ifeq 17
aload 2
getfield jdk.jfr.internal.consumer.Dispatcher.startNanos:J
goto 18
StackMap locals: jdk.jfr.internal.consumer.EventDirectoryStream jdk.jfr.internal.consumer.Dispatcher jdk.jfr.internal.consumer.Dispatcher java.nio.file.Path int java.lang.Throwable java.lang.Throwable jdk.jfr.internal.consumer.RecordingInput long
StackMap stack:
17: lload 8
StackMap locals:
StackMap stack: long
18: lstore 10
start local 10 19: aload 2
getfield jdk.jfr.internal.consumer.Dispatcher.endTime:Ljava/time/Instant;
ifnull 20
aload 2
getfield jdk.jfr.internal.consumer.Dispatcher.endNanos:J
goto 21
StackMap locals: long
StackMap stack:
20: ldc 9223372036854775807
StackMap locals:
StackMap stack: long
21: lstore 12
start local 12 22: goto 59
23: StackMap locals: long
StackMap stack:
aload 0
invokevirtual jdk.jfr.internal.consumer.EventDirectoryStream.dispatcher:()Ljdk/jfr/internal/consumer/Dispatcher;
astore 2
24: aload 2
aload 1
if_acmpeq 31
25: aload 2
getfield jdk.jfr.internal.consumer.Dispatcher.parserConfiguration:Ljdk/jfr/internal/consumer/ChunkParser$ParserConfiguration;
astore 14
start local 14 26: aload 14
lload 10
putfield jdk.jfr.internal.consumer.ChunkParser$ParserConfiguration.filterStart:J
27: aload 14
lload 12
putfield jdk.jfr.internal.consumer.ChunkParser$ParserConfiguration.filterEnd:J
28: aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
aload 14
iconst_1
invokevirtual jdk.jfr.internal.consumer.ChunkParser.updateConfiguration:(Ljdk/jfr/internal/consumer/ChunkParser$ParserConfiguration;Z)V
29: aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
aload 0
invokevirtual jdk.jfr.internal.consumer.EventDirectoryStream.getFlushOperation:()Ljava/lang/Runnable;
invokevirtual jdk.jfr.internal.consumer.ChunkParser.setFlushOperation:(Ljava/lang/Runnable;)V
30: aload 2
astore 1
end local 14 31: StackMap locals:
StackMap stack:
aload 2
getfield jdk.jfr.internal.consumer.Dispatcher.parserConfiguration:Ljdk/jfr/internal/consumer/ChunkParser$ParserConfiguration;
invokevirtual jdk.jfr.internal.consumer.ChunkParser$ParserConfiguration.isOrdered:()Z
ifeq 34
32: aload 0
aload 2
invokevirtual jdk.jfr.internal.consumer.EventDirectoryStream.processOrdered:(Ljdk/jfr/internal/consumer/Dispatcher;)V
33: goto 35
34: StackMap locals:
StackMap stack:
aload 0
aload 2
invokevirtual jdk.jfr.internal.consumer.EventDirectoryStream.processUnordered:(Ljdk/jfr/internal/consumer/Dispatcher;)Z
pop
35: StackMap locals:
StackMap stack:
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
invokevirtual jdk.jfr.internal.consumer.ChunkParser.getStartNanos:()J
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
invokevirtual jdk.jfr.internal.consumer.ChunkParser.getChunkDuration:()J
ladd
lload 12
lcmp
ifle 39
36: aload 0
invokevirtual jdk.jfr.internal.consumer.EventDirectoryStream.close:()V
37: aload 7
ifnull 38
aload 7
invokevirtual jdk.jfr.internal.consumer.RecordingInput.close:()V
38: StackMap locals:
StackMap stack:
return
39: StackMap locals:
StackMap stack:
aload 0
invokevirtual jdk.jfr.internal.consumer.EventDirectoryStream.isClosed:()Z
ifne 40
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
invokevirtual jdk.jfr.internal.consumer.ChunkParser.isChunkFinished:()Z
ifeq 23
40: StackMap locals:
StackMap stack:
aload 0
invokevirtual jdk.jfr.internal.consumer.EventDirectoryStream.isLastChunk:()Z
ifeq 43
41: aload 7
ifnull 42
aload 7
invokevirtual jdk.jfr.internal.consumer.RecordingInput.close:()V
42: StackMap locals:
StackMap stack:
return
43: StackMap locals:
StackMap stack:
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.repositoryFiles:Ljdk/jfr/internal/consumer/RepositoryFiles;
invokevirtual jdk.jfr.internal.consumer.RepositoryFiles.hasFixedPath:()Z
ifeq 46
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
invokevirtual jdk.jfr.internal.consumer.ChunkParser.isFinalChunk:()Z
ifeq 46
44: aload 7
ifnull 45
aload 7
invokevirtual jdk.jfr.internal.consumer.RecordingInput.close:()V
45: StackMap locals:
StackMap stack:
return
46: StackMap locals:
StackMap stack:
aload 0
invokevirtual jdk.jfr.internal.consumer.EventDirectoryStream.isClosed:()Z
ifeq 49
47: aload 7
ifnull 48
aload 7
invokevirtual jdk.jfr.internal.consumer.RecordingInput.close:()V
48: StackMap locals:
StackMap stack:
return
49: StackMap locals:
StackMap stack:
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
invokevirtual jdk.jfr.internal.consumer.ChunkParser.getChunkDuration:()J
lstore 14
start local 14 50: lload 14
lconst_0
lcmp
ifne 52
51: lload 14
lconst_1
ladd
lstore 14
52: StackMap locals: long
StackMap stack:
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.repositoryFiles:Ljdk/jfr/internal/consumer/RepositoryFiles;
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentChunkStartNanos:J
lload 14
ladd
invokevirtual jdk.jfr.internal.consumer.RepositoryFiles.nextPath:(J)Ljava/nio/file/Path;
astore 3
53: aload 3
ifnonnull 56
54: aload 7
ifnull 55
aload 7
invokevirtual jdk.jfr.internal.consumer.RecordingInput.close:()V
55: StackMap locals:
StackMap stack:
return
56: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.repositoryFiles:Ljdk/jfr/internal/consumer/RepositoryFiles;
aload 3
invokevirtual jdk.jfr.internal.consumer.RepositoryFiles.getTimestamp:(Ljava/nio/file/Path;)J
putfield jdk.jfr.internal.consumer.EventDirectoryStream.currentChunkStartNanos:J
57: aload 7
aload 3
invokevirtual jdk.jfr.internal.consumer.RecordingInput.setFile:(Ljava/nio/file/Path;)V
58: aload 0
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
invokevirtual jdk.jfr.internal.consumer.ChunkParser.newChunkParser:()Ljdk/jfr/internal/consumer/ChunkParser;
putfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
end local 14 59: StackMap locals:
StackMap stack:
aload 0
invokevirtual jdk.jfr.internal.consumer.EventDirectoryStream.isClosed:()Z
ifeq 39
end local 12 end local 10 end local 8 60: aload 7
ifnull 66
aload 7
invokevirtual jdk.jfr.internal.consumer.RecordingInput.close:()V
goto 66
StackMap locals: jdk.jfr.internal.consumer.EventDirectoryStream jdk.jfr.internal.consumer.Dispatcher jdk.jfr.internal.consumer.Dispatcher java.nio.file.Path int java.lang.Throwable java.lang.Throwable jdk.jfr.internal.consumer.RecordingInput
StackMap stack: java.lang.Throwable
61: astore 5
aload 7
ifnull 62
aload 7
invokevirtual jdk.jfr.internal.consumer.RecordingInput.close:()V
end local 7 StackMap locals:
StackMap stack:
62: aload 5
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
63: astore 6
aload 5
ifnonnull 64
aload 6
astore 5
goto 65
StackMap locals:
StackMap stack:
64: aload 5
aload 6
if_acmpeq 65
aload 5
aload 6
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
65: aload 5
athrow
66: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 67 0 this Ljdk/jfr/internal/consumer/EventDirectoryStream;
1 67 1 lastDisp Ljdk/jfr/internal/consumer/Dispatcher;
2 67 2 disp Ljdk/jfr/internal/consumer/Dispatcher;
7 8 3 path Ljava/nio/file/Path;
9 67 3 path Ljava/nio/file/Path;
5 67 4 validStartTime Z
14 62 7 input Ljdk/jfr/internal/consumer/RecordingInput;
16 60 8 segmentStart J
19 60 10 filterStart J
22 60 12 filterEnd J
26 31 14 pc Ljdk/jfr/internal/consumer/ChunkParser$ParserConfiguration;
50 59 14 durationNanos J
Exception table:
from to target type
14 37 61 any
39 41 61 any
43 44 61 any
46 47 61 any
49 54 61 any
56 60 61 any
13 38 63 any
39 42 63 any
43 45 63 any
46 48 63 any
49 55 63 any
56 63 63 any
Exceptions:
throws java.io.IOException
private boolean isLastChunk();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.recording:Ljdk/jfr/internal/PlatformRecording;
ifnonnull 2
1: iconst_0
ireturn
2: StackMap locals:
StackMap stack:
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.recording:Ljdk/jfr/internal/PlatformRecording;
invokevirtual jdk.jfr.internal.PlatformRecording.getFinalChunkStartNanos:()J
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
invokevirtual jdk.jfr.internal.consumer.ChunkParser.getStartNanos:()J
lcmp
iflt 3
iconst_1
ireturn
StackMap locals:
StackMap stack:
3: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Ljdk/jfr/internal/consumer/EventDirectoryStream;
private void processOrdered(jdk.jfr.internal.consumer.Dispatcher);
descriptor: (Ljdk/jfr/internal/consumer/Dispatcher;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.sortedCache:[Ljdk/jfr/consumer/RecordedEvent;
ifnonnull 2
1: aload 0
ldc 100000
anewarray jdk.jfr.consumer.RecordedEvent
putfield jdk.jfr.internal.consumer.EventDirectoryStream.sortedCache:[Ljdk/jfr/consumer/RecordedEvent;
2: StackMap locals:
StackMap stack:
iconst_0
istore 2
start local 2 3: StackMap locals: int
StackMap stack:
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
invokevirtual jdk.jfr.internal.consumer.ChunkParser.readStreamingEvent:()Ljdk/jfr/consumer/RecordedEvent;
astore 3
start local 3 4: aload 3
ifnonnull 6
5: goto 10
6: StackMap locals: jdk.jfr.consumer.RecordedEvent
StackMap stack:
iload 2
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.sortedCache:[Ljdk/jfr/consumer/RecordedEvent;
arraylength
if_icmpne 8
7: aload 0
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.sortedCache:[Ljdk/jfr/consumer/RecordedEvent;
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.sortedCache:[Ljdk/jfr/consumer/RecordedEvent;
arraylength
iconst_2
imul
invokestatic java.util.Arrays.copyOf:([Ljava/lang/Object;I)[Ljava/lang/Object;
checkcast jdk.jfr.consumer.RecordedEvent[]
putfield jdk.jfr.internal.consumer.EventDirectoryStream.sortedCache:[Ljdk/jfr/consumer/RecordedEvent;
8: StackMap locals:
StackMap stack:
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.sortedCache:[Ljdk/jfr/consumer/RecordedEvent;
iload 2
iinc 2 1
aload 3
aastore
end local 3 9: goto 3
10: StackMap locals:
StackMap stack:
iload 2
ifne 12
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
invokevirtual jdk.jfr.internal.consumer.ChunkParser.isChunkFinished:()Z
ifeq 12
11: return
12: StackMap locals:
StackMap stack:
iload 2
iconst_1
if_icmple 14
13: aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.sortedCache:[Ljdk/jfr/consumer/RecordedEvent;
iconst_0
iload 2
getstatic jdk.jfr.internal.consumer.EventDirectoryStream.EVENT_COMPARATOR:Ljava/util/Comparator;
invokestatic java.util.Arrays.sort:([Ljava/lang/Object;IILjava/util/Comparator;)V
14: StackMap locals:
StackMap stack:
iconst_0
istore 3
start local 3 15: goto 18
16: StackMap locals: int
StackMap stack:
aload 1
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.sortedCache:[Ljdk/jfr/consumer/RecordedEvent;
iload 3
aaload
invokevirtual jdk.jfr.internal.consumer.Dispatcher.dispatch:(Ljdk/jfr/consumer/RecordedEvent;)V
17: iinc 3 1
StackMap locals:
StackMap stack:
18: iload 3
iload 2
if_icmplt 16
end local 3 19: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Ljdk/jfr/internal/consumer/EventDirectoryStream;
0 20 1 c Ljdk/jfr/internal/consumer/Dispatcher;
3 20 2 index I
4 9 3 e Ljdk/jfr/consumer/RecordedEvent;
15 19 3 i I
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
c
private boolean processUnordered(jdk.jfr.internal.consumer.Dispatcher);
descriptor: (Ljdk/jfr/internal/consumer/Dispatcher;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: StackMap locals:
StackMap stack:
aload 0
getfield jdk.jfr.internal.consumer.EventDirectoryStream.currentParser:Ljdk/jfr/internal/consumer/ChunkParser;
invokevirtual jdk.jfr.internal.consumer.ChunkParser.readStreamingEvent:()Ljdk/jfr/consumer/RecordedEvent;
astore 2
start local 2 1: aload 2
ifnonnull 3
2: iconst_1
ireturn
3: StackMap locals: jdk.jfr.consumer.RecordedEvent
StackMap stack:
aload 1
aload 2
invokevirtual jdk.jfr.internal.consumer.Dispatcher.dispatch:(Ljdk/jfr/consumer/RecordedEvent;)V
end local 2 4: goto 0
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Ljdk/jfr/internal/consumer/EventDirectoryStream;
0 5 1 c Ljdk/jfr/internal/consumer/Dispatcher;
1 4 2 e Ljdk/jfr/consumer/RecordedEvent;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
c
}
SourceFile: "EventDirectoryStream.java"
InnerClasses:
final ParserConfiguration = jdk.jfr.internal.consumer.ChunkParser$ParserConfiguration of jdk.jfr.internal.consumer.ChunkParser