RavenDB-21802 Should_Delete_All_Documents_Without_Timeout fix

aviv86 · Dec 20, 2023 · 3fb0c92 · 3fb0c92
1 parent 15fc5e8
commit 3fb0c92
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/src/Raven.Client/Documents/BulkInsert/BulkInsertOperation.cs b/src/Raven.Client/Documents/BulkInsert/BulkInsertOperation.cs
@@ -317,14 +317,14 @@ private static void HandleHeartbeat(object state)
 
         private async Task SendHeartBeatAsync()
         {
-            try
-            {
-                if (DateTime.UtcNow.Ticks - _lastWriteToStream.Ticks < _heartbeatCheckInterval.Ticks)
-                    return;
+            if (DateTime.UtcNow.Ticks - _lastWriteToStream.Ticks < _heartbeatCheckInterval.Ticks)
+                return;
 
-                if (_streamLock.Wait(0) == false)
-                    return; // if locked we are already writing
+            if (_streamLock.Wait(0) == false)
+                return; // if locked we are already writing
 
+            try
+            {
                 await ExecuteBeforeStore().ConfigureAwait(false);
                 EndPreviousCommandIfNeeded();
                 _options.ForTestingPurposes?.OnSendHeartBeat_DoBulkStore?.Invoke();