Refactor disk segments

src/Playground/RecoverFile.cs

@@ -6,6 +6,7 @@
 using Tenray.ZoneTree.Logger;
 using Tenray.ZoneTree.Options;
 using Tenray.ZoneTree.Segments.Disk;
+using Tenray.ZoneTree.Segments.RandomAccess;
 using Tenray.ZoneTree.Serializers;
 using Tenray.ZoneTree.WAL;
 
@@ -38,7 +39,7 @@ public static void Recover1()
             = WriteAheadLogMode.AsyncCompressed;
 
         var stopWatch = new Stopwatch();
-        var disk = new DiskSegment<string, string>(54, options);
+        var disk = DiskSegmentFactory.CreateDiskSegment(54, options);
         disk.InitSparseArray(100);
 
         Console.WriteLine("Elapsed: " + stopWatch.ElapsedMilliseconds);
@@ -57,7 +58,7 @@ public static void Recover2()
             WriteAheadLogProvider = new WriteAheadLogProvider(
                 new ConsoleLogger(), fileStreamProvider, path),
             WriteAheadLogOptions = meta.WriteAheadLogOptions,
-            RandomAccessDeviceManager = deviceManager,            
+            RandomAccessDeviceManager = deviceManager,
             DiskSegmentOptions = new()
             {
                 CompressionBlockSize = meta.DiskSegmentOptions.CompressionBlockSize,

src/ZoneTree/Core/ZoneTree.BottomSegments.Merge.cs

@@ -2,7 +2,9 @@
 using Tenray.ZoneTree.Collections;
 using Tenray.ZoneTree.Exceptions;
 using Tenray.ZoneTree.Options;
+using Tenray.ZoneTree.Segments;
 using Tenray.ZoneTree.Segments.Disk;
+using Tenray.ZoneTree.Segments.MultiPart;
 
 namespace Tenray.ZoneTree.Core;
 

src/ZoneTree/Core/ZoneTree.Iterators.cs

@@ -1,5 +1,6 @@
 using Tenray.ZoneTree.Collections;
-using Tenray.ZoneTree.Segments.Disk;
+using Tenray.ZoneTree.Segments;
+using Tenray.ZoneTree.Segments.NullDisk;
 
 namespace Tenray.ZoneTree.Core;
 

src/ZoneTree/Core/ZoneTree.Merge.cs

@@ -3,6 +3,9 @@
 using Tenray.ZoneTree.Options;
 using Tenray.ZoneTree.Segments;
 using Tenray.ZoneTree.Segments.Disk;
+using Tenray.ZoneTree.Segments.InMemory;
+using Tenray.ZoneTree.Segments.MultiPart;
+using Tenray.ZoneTree.Segments.NullDisk;
 
 namespace Tenray.ZoneTree.Core;
 

src/ZoneTree/Core/ZoneTree.cs

@@ -3,7 +3,8 @@
 using Tenray.ZoneTree.Logger;
 using Tenray.ZoneTree.Options;
 using Tenray.ZoneTree.Segments;
-using Tenray.ZoneTree.Segments.Disk;
+using Tenray.ZoneTree.Segments.InMemory;
+using Tenray.ZoneTree.Segments.NullDisk;
 
 namespace Tenray.ZoneTree.Core;
 

src/ZoneTree/Core/ZoneTreeIterator.cs

@@ -2,7 +2,7 @@
 using Tenray.ZoneTree.Comparers;
 using Tenray.ZoneTree.Exceptions;
 using Tenray.ZoneTree.Options;
-using Tenray.ZoneTree.Segments.Disk;
+using Tenray.ZoneTree.Segments;
 
 namespace Tenray.ZoneTree.Core;
 

src/ZoneTree/Core/ZoneTreeLoader.cs

@@ -3,6 +3,9 @@
 using Tenray.ZoneTree.Options;
 using Tenray.ZoneTree.Segments;
 using Tenray.ZoneTree.Segments.Disk;
+using Tenray.ZoneTree.Segments.InMemory;
+using Tenray.ZoneTree.Segments.MultiPart;
+using Tenray.ZoneTree.Segments.NullDisk;
 
 namespace Tenray.ZoneTree.Core;
 
@@ -183,7 +186,7 @@ void LoadDiskSegment()
             DiskSegment = new MultiPartDiskSegment<TKey, TValue>(segmentId, Options);
             return;
         }
-        DiskSegment = new DiskSegment<TKey, TValue>(segmentId, Options);
+        DiskSegment = DiskSegmentFactory.CreateDiskSegment(segmentId, Options);
     }
 
     void LoadBottomSegments()
@@ -202,7 +205,7 @@ void LoadBottomSegments()
             }
             else
             {
-                var ds = new DiskSegment<TKey, TValue>(segmentId, Options);
+                var ds = DiskSegmentFactory.CreateDiskSegment(segmentId, Options);
                 map.AddOrUpdate(segmentId, ds, (_, _) => ds);
             }
         });

src/ZoneTree/Core/ZoneTreeMaintainer.cs

@@ -1,6 +1,6 @@
 using System.Collections.Concurrent;
 using Tenray.ZoneTree.Logger;
-using Tenray.ZoneTree.Segments.Disk;
+using Tenray.ZoneTree.Segments;
 
 namespace Tenray.ZoneTree.Core;
 

src/ZoneTree/Core/ZoneTreeMetaWAL.cs

@@ -3,7 +3,7 @@
 using System.Text.Json;
 using Tenray.ZoneTree.Exceptions;
 using Tenray.ZoneTree.Options;
-using Tenray.ZoneTree.Segments.Disk;
+using Tenray.ZoneTree.Segments.RandomAccess;
 using Tenray.ZoneTree.Serializers;
 
 namespace Tenray.ZoneTree.Core;

src/ZoneTree/GlobalSuppressions.cs

@@ -24,6 +24,22 @@
     Scope = "namespaceanddescendants",
     Target = "Tenray.ZoneTree.Comparers")]
 
+[assembly: SuppressMessage(
+    "\tUsage",
+    "CA2213: Disposable fields should be disposed",
+    Justification = "False warning: Device is disposed on ReleaseResources method.",
+    Scope = "namespaceanddescendants",
+    Target = "Tenray.ZoneTree.Segments.DiskSegmentVariations")]
+
+[assembly: SuppressMessage(
+    "\tUsage",
+    "CA2213: Disposable fields should be disposed",
+    Justification = "False warning: Device is disposed on ReleaseResources method.",
+    Scope = "member",
+    Target = "Tenray.ZoneTree.Segments.Disk.DiskSegment.DataDevice")]
+
+#pragma warning disable CA2213 // False warning: Device is disposed on ReleaseResources.
+
 [assembly: SuppressMessage(
     "Naming",
     "CA1711: Identifiers should not have incorrect suffix",

src/ZoneTree/Options/ZoneTreeOptions.cs

@@ -1,10 +1,10 @@
 using Tenray.ZoneTree.Exceptions;
-using Tenray.ZoneTree.Segments.Disk;
 using Tenray.ZoneTree.WAL;
 using Tenray.ZoneTree.Collections.BTree.Lock;
 using Tenray.ZoneTree.Logger;
 using Tenray.ZoneTree.Serializers;
 using Tenray.ZoneTree.Comparers;
+using Tenray.ZoneTree.Segments.RandomAccess;
 
 namespace Tenray.ZoneTree.Options;
 

src/ZoneTree/Segments/Disk/CircularBlockCache.cs → src/ZoneTree/Segments/Block/CircularBlockCache.cs

@@ -1,7 +1,7 @@
 using System.Collections.Concurrent;
 using Tenray.ZoneTree.Logger;
 
-namespace Tenray.ZoneTree.Segments.Disk;
+namespace Tenray.ZoneTree.Segments.Block;
 
 public sealed class CircularBlockCache
 {
@@ -123,7 +123,7 @@ public bool TryGetBlock(int blockIndex, out DecompressedBlock block)
 
     public void Clear()
     {
-        Array.Fill(Table, null); 
+        Array.Fill(Table, null);
         LastReplacementTicks.Clear();
     }
 

src/ZoneTree/Segments/Disk/DecompressedBlock.cs → src/ZoneTree/Segments/Block/DecompressedBlock.cs

@@ -1,7 +1,7 @@
 using Tenray.ZoneTree.Compression;
 using Tenray.ZoneTree.Options;
 
-namespace Tenray.ZoneTree.Segments.Disk;
+namespace Tenray.ZoneTree.Segments.Block;
 
 public sealed class DecompressedBlock
 {
@@ -20,13 +20,14 @@ public int Length
     }
 
     volatile byte[] Bytes;
-    
+
     public bool IsFull => Length == Bytes.Length;
 
     long _lastAccessTicks;
 
-    public long LastAccessTicks {
-        get => Volatile.Read(ref _lastAccessTicks); 
+    public long LastAccessTicks
+    {
+        get => Volatile.Read(ref _lastAccessTicks);
         set => Volatile.Write(ref _lastAccessTicks, value);
     }
 

src/ZoneTree/Segments/Disk/LRUBlockCache.cs → src/ZoneTree/Segments/Block/LRUBlockCache.cs

@@ -1,4 +1,6 @@
-namespace Tenray.ZoneTree.Segments.Disk;
+#if DEBUG
+
+namespace Tenray.ZoneTree.Segments.Block;
 
 /// <summary>
 /// Thread-safe LRU Block Cache.
@@ -14,7 +16,7 @@ public sealed class LRUBlockCache
         LinkedListNode<DecompressedBlock>> Cache;
 
     readonly LinkedList<DecompressedBlock> List;
-    
+
     volatile int _count;
     public int Count { get => _count; private set => _count = value; }
 
@@ -99,4 +101,6 @@ public DecompressedBlock[] ToArray()
             return List.ToArray();
         }
     }
-}
+}
+
+#endif