< prev index next >
core/org.openjdk.jmc.flightrecorder/src/main/java/org/openjdk/jmc/flightrecorder/internal/FlightRecordingLoader.java
Print this page
*** 66,76 ****
private static final Logger LOGGER = Logger.getLogger(FlightRecordingLoader.class.getName());
private static final String SINGLE_THREADED_PARSER_PROPERTY_KEY = "org.openjdk.jmc.flightrecorder.parser.singlethreaded"; //$NON-NLS-1$
private static final int MIN_MEMORY_PER_THREAD = 300 * 1024 * 1024; // Unless the chunks are very big, 300MB of available memory per parallel chunk load should be plenty
private static final short VERSION_0 = 0; // JDK7 & JDK8
! private static final short VERSION_1 = 1; // JDK9
private static final byte[] FLIGHT_RECORDER_MAGIC = {'F', 'L', 'R', '\0'};
public static EventArray[] loadStream(InputStream stream, boolean hideExperimentals, boolean ignoreTruncatedChunk)
throws CouldNotLoadRecordingException, IOException {
return loadStream(stream, ParserExtensionRegistry.getParserExtensions(), hideExperimentals,
--- 66,77 ----
private static final Logger LOGGER = Logger.getLogger(FlightRecordingLoader.class.getName());
private static final String SINGLE_THREADED_PARSER_PROPERTY_KEY = "org.openjdk.jmc.flightrecorder.parser.singlethreaded"; //$NON-NLS-1$
private static final int MIN_MEMORY_PER_THREAD = 300 * 1024 * 1024; // Unless the chunks are very big, 300MB of available memory per parallel chunk load should be plenty
private static final short VERSION_0 = 0; // JDK7 & JDK8
! private static final short VERSION_1 = 1; // JDK9 & JDK10
! private static final short VERSION_2 = 2; // JDK11
private static final byte[] FLIGHT_RECORDER_MAGIC = {'F', 'L', 'R', '\0'};
public static EventArray[] loadStream(InputStream stream, boolean hideExperimentals, boolean ignoreTruncatedChunk)
throws CouldNotLoadRecordingException, IOException {
return loadStream(stream, ParserExtensionRegistry.getParserExtensions(), hideExperimentals,
*** 175,184 ****
--- 176,186 ----
throws CouldNotLoadRecordingException, IOException {
switch (nextChunk.getMajorVersion()) {
case VERSION_0:
return ChunkLoaderV0.getInfo(nextChunk, nextChunkPos);
case VERSION_1:
+ case VERSION_2:
return ChunkLoaderV1.getInfo(nextChunk, nextChunkPos);
default:
throw new VersionNotSupportedException();
}
}
*** 294,303 ****
--- 296,306 ----
if (chunk != null) {
switch (chunk.getMajorVersion()) {
case VERSION_0:
return ChunkLoaderV0.create(chunk, context);
case VERSION_1:
+ case VERSION_2:
return ChunkLoaderV1.create(chunk, context);
default:
throw new VersionNotSupportedException();
}
}
< prev index next >