Added tailing iterator WaitAsync to wait for iteration to proceed.

microsoft · Oct 4, 2019 · 944504b · 944504b
1 parent b06d112
commit 944504b
Showing 1 changed file with 17 additions and 0 deletions.
diff --git a/cs/src/core/Index/FasterLog/FasterLogIterator.cs b/cs/src/core/Index/FasterLog/FasterLogIterator.cs
@@ -5,6 +5,7 @@
 using System.Threading;
 using System.Diagnostics;
 using System.Runtime.CompilerServices;
+using System.Threading.Tasks;
 
 namespace FASTER.core
 {
@@ -79,6 +80,22 @@ internal unsafe FasterLogScanIterator(FasterLog fasterLog, BlittableAllocator<Em
 
         }
 
+        /// <summary>
+        /// Wait for iteration to be ready to continue
+        /// </summary>
+        /// <returns></returns>
+        public async void WaitAsync()
+        {
+            while (true)
+            {
+                var commitTask = fasterLog.CommitTask;
+                if (nextAddress >= fasterLog.CommittedUntilAddress)
+                    await commitTask;
+                else
+                    break;
+            }
+        }
+
         /// <summary>
         /// Get next record in iterator
         /// </summary>