Categories:
Audio (13)
Biotech (29)
Bytecode (36)
Database (77)
Framework (7)
Game (7)
General (507)
Graphics (53)
I/O (35)
IDE (2)
JAR Tools (101)
JavaBeans (21)
JDBC (121)
JDK (426)
JSP (20)
Logging (108)
Mail (58)
Messaging (8)
Network (84)
PDF (97)
Report (7)
Scripting (84)
Security (32)
Server (121)
Servlet (26)
SOAP (24)
Testing (54)
Web (15)
XML (309)
Collections:
Other Resources:
JDK 17 jdk.jfr.jmod - JFR Module
JDK 17 jdk.jfr.jmod is the JMOD file for JDK 17 JFR module.
JDK 17 JFR module compiled class files are stored in \fyicenter\jdk-17.0.5\jmods\jdk.jfr.jmod.
JDK 17 JFR module compiled class files are also linked and stored in the \fyicenter\jdk-17.0.5\lib\modules JImage file.
JDK 17 JFR module source code files are stored in \fyicenter\jdk-17.0.5\lib\src.zip\jdk.jfr.
You can click and view the content of each source code file in the list below.
✍: FYIcenter
⏎ jdk/jfr/internal/consumer/EventFileStream.java
/* * Copyright (c) 2019, 2021, Oracle and/or its affiliates. All rights reserved. * ORACLE PROPRIETARY/CONFIDENTIAL. Use is subject to license terms. * * * * * * * * * * * * * * * * * * * * */ package jdk.jfr.internal.consumer; import java.io.IOException; import java.nio.file.Path; import java.security.AccessControlContext; import java.util.Arrays; import java.util.Collections; import java.util.Comparator; import java.util.Objects; import jdk.jfr.consumer.RecordedEvent; /** * Implementation of an event stream that operates against a recording file. * */ public final class EventFileStream extends AbstractEventStream { private static final Comparator<? super RecordedEvent> EVENT_COMPARATOR = JdkJfrConsumer.instance().eventComparator(); private final RecordingInput input; private ChunkParser currentParser; private RecordedEvent[] cacheSorted; public EventFileStream(@SuppressWarnings("removal") AccessControlContext acc, Path path) throws IOException { super(acc, null, Collections.emptyList()); Objects.requireNonNull(path); this.input = new RecordingInput(path.toFile(), FileAccess.UNPRIVILEGED); this.input.setStreamed(); } @Override public void start() { start(0); } @Override public void startAsync() { startAsync(0); } @Override public void close() { setClosed(true); dispatcher().runCloseActions(); try { input.close(); } catch (IOException e) { // ignore } } @Override protected void process() throws IOException { Dispatcher disp = dispatcher(); long start = 0; long end = Long.MAX_VALUE; if (disp.startTime != null) { start = disp.startNanos; } if (disp.endTime != null) { end = disp.endNanos; } currentParser = new ChunkParser(input, disp.parserConfiguration); while (!isClosed()) { onMetadata(currentParser); if (currentParser.getStartNanos() > end) { close(); return; } disp = dispatcher(); disp.parserConfiguration.filterStart = start; disp.parserConfiguration.filterEnd = end; currentParser.updateConfiguration(disp.parserConfiguration, true); if (disp.parserConfiguration.isOrdered()) { processOrdered(disp); } else { processUnordered(disp); } currentParser.resetCache(); if (isClosed() || currentParser.isLastChunk()) { return; } currentParser = currentParser.nextChunkParser(); } } private void processOrdered(Dispatcher c) throws IOException { if (cacheSorted == null) { cacheSorted = new RecordedEvent[10_000]; } RecordedEvent event; int index = 0; while (!currentParser.isChunkFinished()) { while ((event = currentParser.readStreamingEvent()) != null) { if (index == cacheSorted.length) { RecordedEvent[] tmp = cacheSorted; cacheSorted = new RecordedEvent[2 * tmp.length]; System.arraycopy(tmp, 0, cacheSorted, 0, tmp.length); } cacheSorted[index++] = event; } dispatchOrdered(c, index); index = 0; } } private void dispatchOrdered(Dispatcher c, int index) { onMetadata(currentParser); Arrays.sort(cacheSorted, 0, index, EVENT_COMPARATOR); for (int i = 0; i < index; i++) { c.dispatch(cacheSorted[i]); } onFlush(); } private void processUnordered(Dispatcher c) throws IOException { onMetadata(currentParser); while (!isClosed()) { RecordedEvent event = currentParser.readStreamingEvent(); if (event == null) { onFlush(); if (currentParser.isChunkFinished()) { return; } continue; } onMetadata(currentParser); c.dispatch(event); } } }
⏎ jdk/jfr/internal/consumer/EventFileStream.java
Or download all of them as a single archive file:
File name: jdk.jfr-17.0.5-src.zip File size: 363343 bytes Release date: 2022-09-13 Download
⇒ JDK 17 jdk.jlink.jmod - JLink Tool
2023-04-17, 8886👍, 0💬
Popular Posts:
The Web Services Description Language for Java Toolkit (WSDL4J), Release 1.6.2, allows the creation,...
What is the sax\Writer.java provided in the Apache Xerces package? I have Apache Xerces 2.11.0 insta...
kernel.jar is a component in iText Java library to provide low-level functionalities. iText Java lib...
How to read XML document with XML Schema validation from socket connections with the socket\DelayedI...
iText is an ideal library for developers looking to enhance web- and other applications with dynamic...