Prevents indexing of WAL files

dotnet · Feb 14, 2024 · b288ab1 · b288ab1
1 parent 5b65018
commit b288ab1
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 14 deletions.
diff --git a/src/cluster/DotNext.Net.Cluster/Net/Cluster/Consensus/Raft/PersistentState.Internal.cs b/src/cluster/DotNext.Net.Cluster/Net/Cluster/Consensus/Raft/PersistentState.Internal.cs
@@ -218,17 +218,9 @@ public void Format(Span<byte> output)
         }
     }
 
-    private sealed class VersionedFileReader : FileReader
+    private sealed class VersionedFileReader(SafeFileHandle handle, long fileOffset, int bufferSize, MemoryAllocator<byte> allocator, ulong version) : FileReader(handle, fileOffset, bufferSize, allocator)
     {
-        private long version;
-
-        internal VersionedFileReader(SafeFileHandle handle, long fileOffset, int bufferSize, MemoryAllocator<byte> allocator, long version)
-            : base(handle, fileOffset, bufferSize, allocator)
-        {
-            this.version = version;
-        }
-
-        internal void VerifyVersion(long expected)
+        internal void VerifyVersion(ulong expected)
         {
             if (version != expected)
                 Reset();
@@ -251,7 +243,7 @@ internal abstract class ConcurrentStorageAccess : Disposable
         private VersionedFileReader?[] readers;
 
         // This field is used to control 'freshness' of the read buffers
-        private long version; // volatile
+        private ulong version; // volatile
 
         private protected ConcurrentStorageAccess(string fileName, int fileOffset, int bufferSize, MemoryAllocator<byte> allocator, int readersCount, WriteMode writeMode, long initialSize)
         {
@@ -273,14 +265,18 @@ private protected ConcurrentStorageAccess(string fileName, int fileOffset, int b
 
             Handle = File.OpenHandle(fileName, fileMode, FileAccess.ReadWrite, FileShare.Read, options, initialSize);
 
+            if (fileMode is FileMode.CreateNew)
+            {
+                File.SetAttributes(Handle, FileAttributes.NotContentIndexed);
+            }
+
             this.fileOffset = fileOffset;
             writer = new(Handle, fileOffset, bufferSize, allocator);
             readers = new VersionedFileReader[readersCount];
             this.allocator = allocator;
             FileName = fileName;
-            version = long.MinValue;
 
-            if (readersCount is 1)
+            if (readers.Length is 1)
                 readers[0] = new(Handle, fileOffset, bufferSize, allocator, version);
 
             autoFlush = writeMode is WriteMode.AutoFlush;

diff --git a/src/cluster/DotNext.Net.Cluster/Net/Cluster/Consensus/Raft/PersistentState.NodeState.cs b/src/cluster/DotNext.Net.Cluster/Net/Cluster/Consensus/Raft/PersistentState.NodeState.cs
@@ -7,7 +7,6 @@
 namespace DotNext.Net.Cluster.Consensus.Raft;
 
 using Buffers;
-using Threading;
 using BoxedClusterMemberId = Runtime.BoxedValue<ClusterMemberId>;
 using IntegrityException = IO.Log.IntegrityException;
 
@@ -68,9 +67,19 @@ private NodeState(string fileName, MemoryAllocator<byte> allocator, bool integri
             {
                 handle = File.OpenHandle(fileName, FileMode.CreateNew, FileAccess.Write, FileShare.None, FileOptions.WriteThrough, Capacity);
                 buffer.Span.Clear();
+
+                FileAttributes attributes;
                 if (integrityCheck)
+                {
+                    attributes = FileAttributes.NotContentIndexed | FileAttributes.IntegrityStream;
                     WriteInt64LittleEndian(Checksum, Hash(Data));
+                }
+                else
+                {
+                    attributes = FileAttributes.NotContentIndexed;
+                }
 
+                File.SetAttributes(handle, attributes);
                 RandomAccess.Write(handle, buffer.Span, 0L);
             }