Automatic merge of jdk:master into master

Author: duke

src/jdk.jfr/share/classes/jdk/jfr/internal/consumer/ChunkParser.java

@@ -41,7 +41,7 @@
 import jdk.jfr.internal.MetadataDescriptor;
 import jdk.jfr.internal.Type;
 import jdk.jfr.internal.Utils;
-import jdk.jfr.internal.consumer.filter.CheckPointEvent;
+import jdk.jfr.internal.consumer.filter.CheckpointEvent;
 import jdk.jfr.internal.consumer.filter.ChunkWriter;
 
 /**
@@ -77,7 +77,7 @@ public boolean isOrdered() {
         }
     }
 
-    private enum CheckPointType {
+    private enum CheckpointType {
         // Checkpoint that finishes a flush segment
         FLUSH(1),
         // Checkpoint contains chunk header information in the first pool
@@ -87,7 +87,7 @@ private enum CheckPointType {
         // Checkpoint contains thread related information
         THREAD(8);
         private final int mask;
-        private CheckPointType(int mask) {
+        private CheckpointType(int mask) {
             this.mask = mask;
         }
 
@@ -267,7 +267,7 @@ public RecordedEvent readEvent() throws IOException {
                 // Not accepted by filter
             } else {
                 if (typeId == 1) { // checkpoint event
-                    if (CheckPointType.FLUSH.is(parseCheckpointType())) {
+                    if (CheckpointType.FLUSH.is(parseCheckpointType())) {
                         input.position(pos + size);
                         return FLUSH_MARKER;
                     }
@@ -317,9 +317,9 @@ private void fillConstantPools(long abortCP) throws IOException {
         long delta = -1;
         boolean logTrace = Logger.shouldLog(LogTag.JFR_SYSTEM_PARSER, LogLevel.TRACE);
         while (thisCP != abortCP && delta != 0) {
-            CheckPointEvent cp = null;
+            CheckpointEvent cp = null;
             if (configuration.chunkWriter != null) {
-                cp = configuration.chunkWriter.newCheckPointEvent(thisCP);
+                cp = configuration.chunkWriter.newCheckpointEvent(thisCP);
             }
             input.position(thisCP);
             lastCP = thisCP;

src/jdk.jfr/share/classes/jdk/jfr/internal/consumer/filter/CheckPointEvent.java

@@ -35,36 +35,36 @@
  * <p>
  * All positional values are relative to file start, not the chunk.
  */
-public final class CheckPointEvent {
+public final class CheckpointEvent {
     private final ChunkWriter chunkWriter;
-    private final LinkedHashMap<Long, CheckPointPool> pools = new LinkedHashMap<>();
+    private final LinkedHashMap<Long, CheckpointPool> pools = new LinkedHashMap<>();
     private final long startPosition;
 
-    public CheckPointEvent(ChunkWriter chunkWriter, long startPosition) {
+    public CheckpointEvent(ChunkWriter chunkWriter, long startPosition) {
         this.chunkWriter = chunkWriter;
         this.startPosition = startPosition;
     }
 
     public PoolEntry addEntry(Type type, long id, long startPosition, long endPosition, Object references) {
         long typeId = type.getId();
         PoolEntry pe = new PoolEntry(startPosition, endPosition, type, id, references);
-        var cpp = pools.computeIfAbsent(typeId, k -> new CheckPointPool(typeId));
+        var cpp = pools.computeIfAbsent(typeId, k -> new CheckpointPool(typeId));
         cpp.add(pe);
         chunkWriter.getPool(type).add(id, pe);
         return pe;
     }
 
     public long touchedPools() {
         int count = 0;
-        for (CheckPointPool cpp : pools.values()) {
+        for (CheckpointPool cpp : pools.values()) {
             if (cpp.isTouched()) {
                 count++;
             }
         }
         return count;
     }
 
-    public Collection<CheckPointPool> getPools() {
+    public Collection<CheckpointPool> getPools() {
         return pools.values();
     }
 
@@ -74,7 +74,7 @@ public long getStartPosition() {
 
     public String toString() {
         StringBuilder sb = new StringBuilder();
-        for (CheckPointPool p : pools.values()) {
+        for (CheckpointPool p : pools.values()) {
             for (var e : p.getEntries()) {
                 if (e.isTouched()) {
                     sb.append(e.getType().getName() + " " + e.getId() + "\n");

src/jdk.jfr/share/classes/jdk/jfr/internal/consumer/filter/CheckPointPool.java

@@ -29,11 +29,11 @@
 /**
  * Represents a constant pool in a checkpoint, both entries and type id
  */
-final class CheckPointPool {
+final class CheckpointPool {
     private final List<PoolEntry> entries = new ArrayList<>();
     private final long typeId;
 
-    public CheckPointPool(long typeId) {
+    public CheckpointPool(long typeId) {
         this.typeId = typeId;
     }
 

src/jdk.jfr/share/classes/jdk/jfr/internal/consumer/filter/ChunkWriter.java

@@ -51,15 +51,15 @@
  */
 public final class ChunkWriter implements Closeable {
     private LongMap<Constants> pools = new LongMap<>();
-    private final Deque<CheckPointEvent> checkPoints = new ArrayDeque<>();
+    private final Deque<CheckpointEvent> checkpoints = new ArrayDeque<>();
     private final Path destination;
     private final RecordingInput input;
     private final RecordingOutput output;
     private final Predicate<RecordedEvent> filter;
 
     private long chunkStartPosition;
     private boolean chunkComplete;
-    private long lastCheckPoint;
+    private long lastCheckpoint;
 
     public ChunkWriter(Path source, Path destination, Predicate<RecordedEvent> filter) throws IOException {
         this.destination = destination;
@@ -78,9 +78,9 @@ Constants getPool(Type type) {
         return pool;
     }
 
-    public CheckPointEvent newCheckPointEvent(long startPosition) {
-        CheckPointEvent event = new CheckPointEvent(this, startPosition);
-        checkPoints.add(event);
+    public CheckpointEvent newCheckpointEvent(long startPosition) {
+        CheckpointEvent event = new CheckpointEvent(this, startPosition);
+        checkpoints.add(event);
         return event;
     }
 
@@ -120,16 +120,16 @@ public void writeEvent(long startPosition, long endPosition) throws IOException
 
     // Write check point events before a position
     private void writeCheckpointEvents(long before) throws IOException {
-        CheckPointEvent cp = checkPoints.peek();
+        CheckpointEvent cp = checkpoints.peek();
         while (cp != null && cp.getStartPosition() < before) {
-            checkPoints.poll();
+            checkpoints.poll();
             long delta = 0;
-            if (lastCheckPoint != 0) {
-                delta = lastCheckPoint - output.position();
+            if (lastCheckpoint != 0) {
+                delta = lastCheckpoint - output.position();
             }
-            lastCheckPoint = output.position();
+            lastCheckpoint = output.position();
             write(cp, delta);
-            cp = checkPoints.peek();
+            cp = checkpoints.peek();
         }
     }
 
@@ -174,10 +174,10 @@ public void endChunk(ChunkHeader header) throws IOException {
         writeCheckpointEvents(Long.MAX_VALUE);
         long metadata = output.position();
         writeMetadataEvent(header);
-        updateHeader(output.position(), lastCheckPoint, metadata);
+        updateHeader(output.position(), lastCheckpoint, metadata);
         pools = new LongMap<>();
         chunkComplete = true;
-        lastCheckPoint = 0;
+        lastCheckpoint = 0;
     }
 
     private void writeMetadataEvent(ChunkHeader header) throws IOException {
@@ -190,7 +190,7 @@ private void writeMetadataEvent(ChunkHeader header) throws IOException {
         }
     }
 
-    private void write(CheckPointEvent event, long delta) throws IOException {
+    private void write(CheckpointEvent event, long delta) throws IOException {
         input.position(event.getStartPosition());
         long startPosition = output.position();
 
@@ -205,7 +205,7 @@ private void write(CheckPointEvent event, long delta) throws IOException {
 
         // Write even if touched pools are zero, checkpoint works as sync point
         output.writeLong(event.touchedPools()); // Pool count
-        for (CheckPointPool pool : event.getPools()) {
+        for (CheckpointPool pool : event.getPools()) {
             if (pool.isTouched()) {
                 output.writeLong(pool.getTypeId());
                 output.writeLong(pool.getTouchedCount());

src/jdk.jfr/share/classes/jdk/jfr/internal/tool/Summary.java

@@ -100,7 +100,7 @@ private void printInformation(Path p) throws IOException {
             }
             HashMap<Long, Statistics> stats = new HashMap<>();
             stats.put(0L, new Statistics(eventPrefix + "Metadata"));
-            stats.put(1L, new Statistics(eventPrefix + "CheckPoint"));
+            stats.put(1L, new Statistics(eventPrefix + "Checkpoint"));
             int minWidth = 0;
             while (true) {
                 long chunkEnd = ch.getEnd();

src/jdk.management.jfr/share/classes/jdk/management/jfr/DiskRepository.java

@@ -179,7 +179,7 @@ public synchronized void write(byte[] bytes) throws IOException {
                 bufferIndex = 0;
                 break;
             case CHECKPOINT_EVENT_HEADER_BYTE_ARRAY_CONTENT:
-                processCheckPointHeader();
+                processCheckpointHeader();
                 break;
             case CHECKPOINT_EVENT_FLUSH_TYPE:
                 processFlush();
@@ -286,10 +286,10 @@ private void processInitialHeader() throws IOException {
         }
     }
 
-    private void processCheckPointHeader() throws IOException {
+    private void processCheckpointHeader() throws IOException {
         buffer.put(bufferIndex, nextByte(true));
         if (bufferIndex == HEADER_SIZE) {
-            writeCheckPointHeader();
+            writeCheckpointHeader();
             state = State.EVENT_PAYLOAD;
             bufferIndex = 0;
         }
@@ -321,7 +321,7 @@ private void completePrevious(DiskChunk previous) throws IOException {
         }
     }
 
-    private void writeCheckPointHeader() throws IOException {
+    private void writeCheckpointHeader() throws IOException {
         Objects.requireNonNull(raf);
         byte state = buffer.get(HEADER_FILE_STATE_POSITION);
         boolean complete = state == COMPLETE_STATE;