add comment for sanity check

microsoft · Nov 18, 2024 · b004fc8 · b004fc8
1 parent fb098b6
commit b004fc8
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/libs/cluster/Server/Replication/ReplicaOps/ReplicationReplicaAofSync.cs b/libs/cluster/Server/Replication/ReplicaOps/ReplicationReplicaAofSync.cs
@@ -67,6 +67,10 @@ public unsafe void ProcessPrimaryStream(byte* record, int recordLength, long pre
 
                 var tail = storeWrapper.appendOnlyFile.TailAddress;
                 var nextPageBeginAddress = ((tail >> pageSizeBits) + 1) << pageSizeBits;
+                // Check to ensure:
+                // 1. if record fits in current page tailAddress of this local node (replica) should be equal to the incoming currentAddress (address of chunk send from primary node)
+                // 2. if record does not fit in current page start address of the next page matches incoming currentAddress (address of chunk send from primary node)
+                // otherwise fail and break the connection
                 if ((tail + recordLength <= nextPageBeginAddress && tail != currentAddress) ||
                     (tail + recordLength > nextPageBeginAddress && nextPageBeginAddress != currentAddress))
                 {