Wait for the task to be running.

Fixes #75 Fixes #76
FubarDevelopment · Aug 16, 2019 · a37e729 · a37e729
1 parent f4fc7ba
commit a37e729
Showing 1 changed file with 34 additions and 6 deletions.
diff --git a/src/FubarDev.FtpServer/Networking/PausableFtpService.cs b/src/FubarDev.FtpServer/Networking/PausableFtpService.cs
@@ -55,17 +55,31 @@ protected PausableFtpService(
         protected bool IsPauseRequested => _jobPaused.IsCancellationRequested;
 
         /// <inheritdoc />
-        public Task StartAsync(CancellationToken cancellationToken)
+        public async Task StartAsync(CancellationToken cancellationToken)
         {
             if (Status != FtpServiceStatus.ReadyToRun)
             {
                 throw new InvalidOperationException($"Status must be {FtpServiceStatus.ReadyToRun}, but was {Status}.");
             }
 
-            _jobPaused = new CancellationTokenSource();
-            _task = RunAsync(new Progress<FtpServiceStatus>(status => Status = status));
-
-            return Task.CompletedTask;
+            using (var semaphore = new SemaphoreSlim(0, 1))
+            {
+                _jobPaused = new CancellationTokenSource();
+                _task = RunAsync(
+                    new Progress<FtpServiceStatus>(
+                        status =>
+                        {
+                            Status = status;
+
+                            if (status == FtpServiceStatus.Running)
+                            {
+                                // ReSharper disable once AccessToDisposedClosure
+                                semaphore.Release();
+                            }
+                        }));
+
+                await semaphore.WaitAsync(cancellationToken);
+            }
         }
 
         /// <inheritdoc />
@@ -140,7 +154,21 @@ public async Task ContinueAsync(CancellationToken cancellationToken)
             await OnContinueRequestingAsync(cancellationToken)
                .ConfigureAwait(false);
 
-            _task = RunAsync(new Progress<FtpServiceStatus>(status => Status = status));
+            using (var semaphore = new SemaphoreSlim(0, 1))
+            {
+                _task = RunAsync(new Progress<FtpServiceStatus>(status =>
+                {
+                    Status = status;
+
+                    if (status == FtpServiceStatus.Running)
+                    {
+                        // ReSharper disable once AccessToDisposedClosure
+                        semaphore.Release();
+                    }
+                }));
+
+                await semaphore.WaitAsync(cancellationToken);
+            }
         }
 
         [NotNull]