Fix watchdog re-creation of TransportInfrastructure and cancellation improvements

src/ServiceControl.Audit/Auditing/AuditIngestion.cs

@@ -76,18 +76,18 @@ async Task EnsureStarted(CancellationToken cancellationToken)
                 await startStopSemaphore.WaitAsync(cancellationToken);
                 logger.Debug("Ensure started. Start/stop semaphore acquired");
 
-                var canIngest = unitOfWorkFactory.CanIngestMore();
-
-                logger.DebugFormat("Ensure started {0}", canIngest);
-
-                if (canIngest)
-                {
-                    await SetUpAndStartInfrastructure(cancellationToken);
-                }
-                else
+                if (!unitOfWorkFactory.CanIngestMore())
                 {
+                    logger.Warn("Ensure started. Storage unable to ingest more. Ingestion will be paused");
+
                     await StopAndTeardownInfrastructure(cancellationToken);
+
+                    return;
                 }
+
+                logger.Debug("Ensure started. Storage able to ingest. Ingestion will be started");
+
+                await SetUpAndStartInfrastructure(cancellationToken);
             }
             catch (Exception e)
             {