< 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 >