(ignite-extensions) branch master updated: IGNITE-20697 Store crash recovery data to checkpoint recovery files (#300)

[alexpl]

This is an automated email from the ASF dual-hosted git repository.

alexpl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git


The following commit(s) were added to refs/heads/master by this push:
     new bfe7df92 IGNITE-20697 Store crash recovery data to checkpoint recovery 
files (#300)
bfe7df92 is described below

commit bfe7df922eb25919c182c64443423f3c0c533a03
Author: Aleksey Plekhanov <plehanov.a...@gmail.com>
AuthorDate: Sun Feb 9 22:31:40 2025 +0300

    IGNITE-20697 Store crash recovery data to checkpoint recovery files (#300)
---
 .../handlers/IgnitePerformanceStatisticsHandler.java               | 3 ++-
 .../internal/performancestatistics/handlers/PrintHandler.java      | 7 +++++--
 .../performancestatistics/PerformanceStatisticsPrinterTest.java    | 4 ++--
 3 files changed, 9 insertions(+), 5 deletions(-)

diff --git 
a/modules/performance-statistics-ext/src/main/java/org/apache/ignite/internal/performancestatistics/handlers/IgnitePerformanceStatisticsHandler.java
 
b/modules/performance-statistics-ext/src/main/java/org/apache/ignite/internal/performancestatistics/handlers/IgnitePerformanceStatisticsHandler.java
index 7cfeddf2..3da8e12e 100644
--- 
a/modules/performance-statistics-ext/src/main/java/org/apache/ignite/internal/performancestatistics/handlers/IgnitePerformanceStatisticsHandler.java
+++ 
b/modules/performance-statistics-ext/src/main/java/org/apache/ignite/internal/performancestatistics/handlers/IgnitePerformanceStatisticsHandler.java
@@ -81,7 +81,8 @@ public interface IgnitePerformanceStatisticsHandler extends 
PerformanceStatistic
     @Override default void checkpoint(UUID nodeId, long beforeLockDuration, 
long lockWaitDuration,
         long listenersExecDuration, long markDuration, long lockHoldDuration, 
long pagesWriteDuration,
         long fsyncDuration, long walCpRecordFsyncDuration, long 
writeCpEntryDuration, long splitAndSortCpPagesDuration,
-        long totalDuration, long cpStartTime, int pagesSize, int 
dataPagesWritten, int cowPagesWritten) {
+        long recoveryDataWriteDuration, long totalDuration, long cpStartTime, 
int pagesSize, int dataPagesWritten,
+        int cowPagesWritten) {
         // No-op.
     }
 
diff --git 
a/modules/performance-statistics-ext/src/main/java/org/apache/ignite/internal/performancestatistics/handlers/PrintHandler.java
 
b/modules/performance-statistics-ext/src/main/java/org/apache/ignite/internal/performancestatistics/handlers/PrintHandler.java
index c0086530..5e5e1aed 100644
--- 
a/modules/performance-statistics-ext/src/main/java/org/apache/ignite/internal/performancestatistics/handlers/PrintHandler.java
+++ 
b/modules/performance-statistics-ext/src/main/java/org/apache/ignite/internal/performancestatistics/handlers/PrintHandler.java
@@ -279,8 +279,9 @@ public class PrintHandler implements 
PerformanceStatisticsHandler {
     /** {@inheritDoc} */
     @Override public void checkpoint(UUID nodeId, long beforeLockDuration, 
long lockWaitDuration, long listenersExecDuration,
         long markDuration, long lockHoldDuration, long pagesWriteDuration, 
long fsyncDuration,
-        long walCpRecordFsyncDuration, long writeCpEntryDuration, long 
splitAndSortCpPagesDuration, long totalDuration,
-        long cpStartTime, int pagesSize, int dataPagesWritten, int 
cowPagesWritten) {
+        long walCpRecordFsyncDuration, long writeCpEntryDuration, long 
splitAndSortCpPagesDuration,
+        long recoveryDataWriteDuration, long totalDuration, long cpStartTime, 
int pagesSize, int dataPagesWritten,
+        int cowPagesWritten) {
         if (skip(CHECKPOINT, cpStartTime))
             return;
 
@@ -307,6 +308,8 @@ public class PrintHandler implements 
PerformanceStatisticsHandler {
         ps.print(writeCpEntryDuration);
         ps.print(",\"splitAndSortCpPagesDuration\":");
         ps.print(splitAndSortCpPagesDuration);
+        ps.print(",\"recoveryDataWriteDuration\":");
+        ps.print(recoveryDataWriteDuration);
         ps.print(",\"totalDuration\":");
         ps.print(totalDuration);
         ps.print(",\"startTime\":");
diff --git 
a/modules/performance-statistics-ext/src/test/java/org/apache/ignite/internal/performancestatistics/PerformanceStatisticsPrinterTest.java
 
b/modules/performance-statistics-ext/src/test/java/org/apache/ignite/internal/performancestatistics/PerformanceStatisticsPrinterTest.java
index 33809bbc..8aa5a545 100644
--- 
a/modules/performance-statistics-ext/src/test/java/org/apache/ignite/internal/performancestatistics/PerformanceStatisticsPrinterTest.java
+++ 
b/modules/performance-statistics-ext/src/test/java/org/apache/ignite/internal/performancestatistics/PerformanceStatisticsPrinterTest.java
@@ -96,7 +96,7 @@ public class PerformanceStatisticsPrinterTest {
             writer.queryRows(GridCacheQueryType.SQL_FIELDS, NODE_ID, 0, 
"action", 0);
             writer.task(new IgniteUuid(NODE_ID, 0), "task", 0, 0, 0);
             writer.job(new IgniteUuid(NODE_ID, 0), 0, 0, 0, true);
-            writer.checkpoint(0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
+            writer.checkpoint(0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
             writer.pagesWriteThrottle(0, 0);
         });
 
@@ -148,7 +148,7 @@ public class PerformanceStatisticsPrinterTest {
                 writer.query(GridCacheQueryType.SQL_FIELDS, "query", 0, 
startTime, 0, true);
                 writer.task(new IgniteUuid(NODE_ID, 0), "", startTime, 0, 0);
                 writer.job(new IgniteUuid(NODE_ID, 0), 0, startTime, 0, true);
-                writer.checkpoint(0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, startTime, 
0, 0, 0);
+                writer.checkpoint(0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 
startTime, 0, 0, 0);
                 writer.pagesWriteThrottle(startTime, 0);
             }
         });