make STATE_CLEANUP log details of performed purges

Mainly to monitor how long it takes.
real-logic · Oct 10, 2024 · 7e9a02d · 7e9a02d
1 parent f3fdba8
commit 7e9a02d
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/artio-core/src/main/java/uk/co/real_logic/artio/engine/framer/PruneOperation.java b/artio-core/src/main/java/uk/co/real_logic/artio/engine/framer/PruneOperation.java
@@ -53,6 +53,8 @@ public static class Formatters
         private final CharFormatter filteredRecordingFormatter = new CharFormatter(
             "PruneOperation: filtered recordingId=%s,segmentStartPosition=%s,lowerBoundPrunePosition=%s" +
             ",segmentFileLength=%s,requestedNewStartPosition=%s,startPosition=%s");
+        private final CharFormatter purgedSegmentsFormatter = new CharFormatter(
+            "PruneOperation: purged recordingId=%s,oldStartPosition=%s,newStartPosition=%s,durationNs=%s");
     }
 
     private final Formatters formatters;
@@ -235,7 +237,19 @@ private void prune()
                 }
                 else
                 {
+                    final long start = System.nanoTime();
                     aeronArchive.purgeSegments(recordingId, segmentStartPosition);
+                    if (STATE_CLEANUP_ENABLED)
+                    {
+                        final long durationNs = System.nanoTime() - start;
+                        formatters.purgedSegmentsFormatter
+                            .clear()
+                            .with(recordingId)
+                            .with(stashedStartPosition)
+                            .with(segmentStartPosition)
+                            .with(durationNs);
+                        DebugLogger.log(STATE_CLEANUP, formatters.purgedSegmentsFormatter);
+                    }
                     recordingIdToNewStartPosition.put(recordingId, segmentStartPosition);
                 }
             }