[Java] Write message header before mark file header in the `cluster-m…

…ark.dat` file to be able to use SBE features based on the `actingBlockLength` and `actingVersion`.
aeron-io · Jan 15, 2025 · 3440bf0 · 3440bf0
1 parent 6095ed1
commit 3440bf0
Show file tree

Hide file tree

Showing 7 changed files with 653 additions and 109 deletions.
diff --git a/aeron-cluster/src/main/java/io/aeron/cluster/ClusterBackup.java b/aeron-cluster/src/main/java/io/aeron/cluster/ClusterBackup.java
@@ -2021,11 +2021,7 @@ public String toString()
         private void concludeMarkFile()
         {
             ClusterMarkFile.checkHeaderLength(
-                aeron.context().aeronDirectoryName(),
-                null,
-                null,
-                null,
-                null);
+                aeron.context().aeronDirectoryName(), null, null, null, null);
 
             markFile.encoder()
                 .archiveStreamId(archiveContext.controlRequestStreamId())

diff --git a/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusModule.java b/aeron-cluster/src/main/java/io/aeron/cluster/ConsensusModule.java
@@ -4301,11 +4301,7 @@ private void concludeMarkFile()
             final String aeronDirectory = aeron.context().aeronDirectoryName();
             final String authenticatorClassName = authenticatorSupplier.getClass().getName();
             ClusterMarkFile.checkHeaderLength(
-                aeronDirectory,
-                controlChannel(),
-                ingressChannel,
-                null,
-                authenticatorClassName);
+                aeronDirectory, controlChannel(), ingressChannel, null, authenticatorClassName);
 
             markFile.encoder()
                 .archiveStreamId(archiveContext.controlRequestStreamId())