FlowState property rename

Author: stidsborg

Core/Cleipnir.ResilientFunctions/CoreRuntime/FlowState.cs

@@ -14,7 +14,7 @@ public class FlowState
     public StoredId Id { get; }
     public QueueManager QueueManager { get; }
     public int Threads { get; private set; }
-    public int SuspendedThreads { get; private set; }
+    public int WaitingThreads { get; private set; }
     public FlowTimeouts Timeouts { get; }
     public AsyncSignal InterruptSignal { get; } = new();
     public bool Suspended { get; private set; }
@@ -24,13 +24,13 @@ public FlowState(
         StoredId id,
         QueueManager queueManager,
         int threads,
-        int suspendedThreads,
+        int waitingThreads,
         FlowTimeouts timeouts)
     {
         Id = id;
         QueueManager = queueManager;
         Threads = threads;
-        SuspendedThreads = suspendedThreads;
+        WaitingThreads = waitingThreads;
         Timeouts = timeouts;
         SuspendedTask = _suspendedTcs.Task;
     }
@@ -50,7 +50,7 @@ public void ThreadCompleted()
     public void ThreadSuspended()
     {
         lock (_lock)
-            SuspendedThreads++;
+            WaitingThreads++;
     }
 
     public bool ResumeThread()
@@ -59,7 +59,7 @@ public bool ResumeThread()
             if (Suspended)
                 return false;
             else
-                SuspendedThreads--;
+                WaitingThreads--;
 
         return true;
     }
@@ -71,7 +71,7 @@ public void Interrupt()
             if (Suspended)
                 return;
 
-            SuspendedThreads = 0;
+            WaitingThreads = 0;
         }
 
         InterruptSignal.Fire();
@@ -80,8 +80,12 @@ public void Interrupt()
     public bool Suspend()
     {
         lock (_lock)
-            return Threads == SuspendedThreads && (Suspended = true);
+            if (Threads == WaitingThreads)
+                Suspended = true;
+            else
+                return false;
+        
+        _suspendedTcs.TrySetResult();
+        return true;
     }
-
-    public void NotifySuspension() => _suspendedTcs.TrySetResult();
 }

Core/Cleipnir.ResilientFunctions/CoreRuntime/FlowsManager.cs

@@ -47,7 +47,7 @@ private async Task TimeoutCheckLoop()
     public FlowState AddFlow(StoredId id, QueueManager queueManager, FlowTimeouts timeouts)
     {
         lock (_lock)
-            return _dict[id] = new FlowState(id, queueManager, threads: 1, suspendedThreads: 0, timeouts);
+            return _dict[id] = new FlowState(id, queueManager, threads: 1, waitingThreads: 0, timeouts);
     }
 
     public void RemoveFlow(StoredId id)