test tsavorite format

PaulusParssinen · Apr 20, 2024 · d2abe02 · d2abe02
1 parent 0c2a6aa
commit d2abe02
Showing 1 changed file with 9 additions and 4 deletions.
diff --git a/libs/storage/Tsavorite/cs/src/core/Device/AsyncPool.cs b/libs/storage/Tsavorite/cs/src/core/Device/AsyncPool.cs
@@ -8,16 +8,19 @@
 
 namespace Tsavorite.core
 {
+
+
+
     /// <summary>
     /// Asynchronous pool of fixed pre-filled capacity
     /// Supports sync get (TryGet) for fast path
     /// </summary>
     /// <typeparam name="T"></typeparam>
-    public class AsyncPool<T> : IDisposable where T : IDisposable
+    public class AsyncPool<T> : IDisposable where T : IDisposable        
     {
         readonly int size;
         readonly Func<T> creator;
-        readonly SemaphoreSlim handleAvailable;
+           readonly SemaphoreSlim handleAvailable;
         readonly ConcurrentQueue<T> itemQueue;
 
         bool disposed = false;
@@ -45,12 +48,14 @@ public T Get(CancellationToken token = default)
         {
             for (; ; )
             {
-                if (disposed)
+                if (     disposed)
                     throw new TsavoriteException("Getting handle in disposed device");
 
                 if (GetOrAdd(itemQueue, out T item))
                     return item;
 
+
+
                 handleAvailable.Wait(token);
             }
         }
@@ -83,7 +88,7 @@ public bool TryGet(out T item)
         {
             if (disposed)
             {
-                item = default;
+                   item = default;
                 return false;
             }
             return GetOrAdd(itemQueue, out item);