NonPersistentDiskQueueSegment: default read buffer size corrected

ikopylov · Apr 28, 2017 · 10f21e7 · 10f21e7
1 parent 850e170
commit 10f21e7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/Qoollo.Turbo/Queues/DiskQueueComponents/NonPersistentDiskQueueSegment.cs b/src/Qoollo.Turbo/Queues/DiskQueueComponents/NonPersistentDiskQueueSegment.cs
@@ -234,7 +234,7 @@ public NonPersistentDiskQueueSegment(long segmentNumber, string fileName, IDiskQ
                 }
 
 
-                _maxReadBufferSize = readBufferSize >= 0 ? readBufferSize : DefaultReadBufferSize;
+                _maxReadBufferSize = readBufferSize >= 0 ? readBufferSize : Math.Max(_writeBufferSize / 2, DefaultReadBufferSize);
                 if (_maxReadBufferSize > 0)
                     _readBuffer = new ConcurrentQueue<T>();