Simplified DiskWriterQueue with blocking concurrency

litedb-org · Jan 25, 2024 · 13ab9ef · 13ab9ef
1 parent 33f85d5
commit 13ab9ef
Showing 1 changed file with 14 additions and 1 deletion.
diff --git a/LiteDB/Engine/Disk/DiskWriterQueue.cs b/LiteDB/Engine/Disk/DiskWriterQueue.cs
@@ -72,7 +72,8 @@ private void ExecuteQueue()
                 }
                 else
                 {
-                    _stream.FlushToDisk();
+                    TryFlushStream();
+
                     lock (_queueSync)
                     {
                         if (_queue.Count > 0) continue;
@@ -85,6 +86,18 @@ private void ExecuteQueue()
             }
         }
 
+        private void TryFlushStream()
+        {
+            try
+            {
+                _stream.FlushToDisk();
+            }
+            catch (IOException)
+            {
+                // Disk is probably full. This may be unrecoverable problem but until we have enough space in the buffer we may be ok.
+            }
+        }
+
         private void WritePageToStream(PageBuffer page)
         {
             if (page == null) return;