Fixing break after merge.

microsoft · Sep 18, 2019 · ce31917 · ce31917
1 parent 4ef03bb
commit ce31917
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 23 deletions.
diff --git a/cs/src/core/Epochs/LightEpoch.cs b/cs/src/core/Epochs/LightEpoch.cs
@@ -227,28 +227,6 @@ public void Resume()
             ProtectAndDrain();
         }
 
-        /// <summary>
-        /// Thread suspends its epoch entry
-        /// </summary>
-        public void Suspend()
-        {
-            int entry = threadEntryIndex.Value;
-            (*(tableAligned + entry)).localCurrentEpoch = int.MaxValue;
-        }
-
-        /// <summary>
-        /// Thread resumes its epoch entry
-        /// </summary>
-        public void Resume()
-        {
-            if (!threadEntryIndex.IsInitializedForThread || threadEntryIndex.Value == kInvalidIndex)
-            {
-                Acquire();
-            }
-        }
-
-        internal FastThreadLocal<int> ThreadEntry => threadEntryIndex;
-
         /// <summary>
         /// Increment global current epoch
         /// </summary>

diff --git a/cs/src/core/Index/FasterLog/FasterLog.cs b/cs/src/core/Index/FasterLog/FasterLog.cs
@@ -120,7 +120,7 @@ public unsafe long Append(List<byte[]> entries)
         public long Flush(bool spinWait = false)
         {
             epoch.Resume();
-            allocator.ShiftReadOnlyToTail(out long tailAddress);
+            allocator.ShiftReadOnlyToTail(out long tailAddress, out SemaphoreSlim _);
             epoch.Suspend();
             if (spinWait)
             {