1586}, TestConstants.DefaultOrchestratorTestTimeout);

27using TestConstants = Microsoft.AspNetCore.InternalTesting.TestConstants; 68}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 113}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 140var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 143await orchestrator.StartResourceAsync(resourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 144await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 147await orchestrator.StopResourceAsync(resourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 148await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 151var restartResourceTask = orchestrator.StartResourceAsync(resourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 152await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 155await orchestrator.StartResourceAsync(resourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 156await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 158await restartResourceTask.DefaultTimeout(TestConstants.LongTimeoutDuration); 159await startTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 160await app.StopAsync().DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 184var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 185var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 205await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 206var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 214var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 222await orchestrator.StopResourceAsync(notStartedResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 223await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 226await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 227await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 229await startTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 230await app.StopAsync().DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 259var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 260var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 279await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 280var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 287var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 295await orchestrator.StopResourceAsync(notStartedResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 296await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 299await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 300await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 302await startTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 303await app.StopAsync().DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 340notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 341dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 360await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 363var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 370var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 378await orchestrator.StopResourceAsync(runningResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 379await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 385await orchestrator.StartResourceAsync(runningResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 386await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 389await startTask.DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 390await app.StopAsync().DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 451await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 453var appModel = await tcs.Task.DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 491await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 497await Task.WhenAll(clientA.GetStringAsync("/pid"), clientC.GetStringAsync("/pid")).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 545await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 548var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 558await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 603await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 606var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 624await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 718await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 724var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 832await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 858await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 860var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 862await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 890await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 892using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.DefaultOrchestratorTestLongTimeout); 896var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 902await orchestrator.StopResourceAsync(redisContainer.Metadata.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 904redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Exited, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 915await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 933await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 936var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 939await orchestrator.StopResourceAsync(serviceA.Metadata.Name, CancellationToken.None).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 941serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Finished).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 944await orchestrator.StartResourceAsync(serviceA.Metadata.Name, CancellationToken.None).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 946serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running).DefaultTimeout(TestConstants.LongTimeoutDuration); 949await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 975await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 978var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, $"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 981var serviceA = await KubernetesHelper.GetResourceByNameAsync<Executable>(kubernetes, $"{testName}-servicea", suffix!, r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 984var nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1001await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1026await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1037await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1060await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1063var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1073await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1100await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1103var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1109await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1131await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1137r => r.Status?.State == ContainerState.FailedToStart && (r.Status?.Message.Contains("bob") ?? false)).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1143await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1160await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1167$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1173await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1189await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1196$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1203await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1219await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1226$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1232await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1245await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1264await foreach (var resource in s.WatchAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout)) 1278await foreach (var resource in s.WatchAsync<Executable>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout)) 1306var ex = await Assert.ThrowsAsync<InvalidOperationException>(async () => await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout)); 1325var ex = await Assert.ThrowsAsync<InvalidOperationException>(async () => await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout)); 1347await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1351var result = await client.GetStringAsync("pid").DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1363}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1390await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1392using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 1396await app.WaitForTextAsync("Content root path:", resourceName: testProgram.ServiceABuilder.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutDuration); 1459await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1462await app.WaitForTextAsync("Application started.").DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1466await clientA.GetStringAsync("/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1489await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1513await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1516await app.WaitForTextAsync("Application started.").DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1520await clientA.GetStringAsync("/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1547await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1564var ex = await Assert.ThrowsAsync<InvalidOperationException>(async () => await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout)); 1587await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1623await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1625await kubernetesLifecycle.HooksCompleted.DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);

189await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 193await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 216await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 221await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 327await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);

48await app.StopAsync().TimeoutAfter(TestConstants.LongTimeoutTimeSpan); 224var abortTokenSource = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 241await app.StopAsync(abortTokenSource.Token).TimeoutAfter(TestConstants.LongTimeoutTimeSpan); 265var abortTokenSource = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 308var abortTokenSource = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 357await app.StopAsync().TimeoutAfter(TestConstants.LongTimeoutTimeSpan); 423var pendingStart = app.StartAsync().DefaultTimeout(TestConstants.LongTimeoutDuration); 557await app.StopAsync().TimeoutAfter(TestConstants.LongTimeoutTimeSpan); 605await app.StopAsync().TimeoutAfter(TestConstants.LongTimeoutTimeSpan); 651await app.StopAsync().TimeoutAfter(TestConstants.LongTimeoutTimeSpan);

103await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 105await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 109await rns.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 111await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 113await pendingStart.DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 115await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 135}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);

31await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 33var context = await tcs.Task.WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 35await app.StopAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 60await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 62var context = await tcs.Task.WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 64await app.StopAsync().WaitAsync(TestConstants.LongTimeoutTimeSpan); 89await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 91var context = await tcs.Task.WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 93await app.StopAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 120await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 122var context = await tcs.Task.WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 124await app.StopAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan);

35using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 67using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 99using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 137using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 175using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 209using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 247using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 288using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 327using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 363using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 392using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 443using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 470using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 496using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 518using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 539using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 569using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 601using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 633using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 670using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 716using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 788using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 883using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan);

133await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 176await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 235await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 270await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan);

26using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 51using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 70using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration);

32using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration);

40milliseconds = TestConstants.DefaultTimeoutDuration; 55milliseconds = TestConstants.DefaultTimeoutDuration; 70milliseconds = TestConstants.DefaultTimeoutDuration; 85milliseconds = TestConstants.DefaultTimeoutDuration; 100milliseconds = TestConstants.DefaultTimeoutDuration; 115milliseconds = TestConstants.DefaultTimeoutDuration;

29var abortCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 104using var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 107using var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 135using var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 138using var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 168var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 174var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 212var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 215var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 323var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 326var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 357var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 360var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 404var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 407var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 446var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 452var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 468var runningStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 493var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 499var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 515var runningStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 548var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 554var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 571var runningStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 602var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 608var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 623var runningStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 653var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 659var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 706var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 712var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 755var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 761var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 870var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 874var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 884var runningStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration);

188await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 212await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 235await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 274await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 313await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 354await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 403await app.ResourceNotifications.WaitForResourceAsync(service.Resource.Name, KnownResourceStates.Starting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 413await app.ResourceNotifications.WaitForResourceAsync(service.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 414await watchTcs.Task.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 473await app.ResourceNotifications.WaitForResourceAsync(service.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 484await watchTcs.Task.DefaultTimeout(TestConstants.LongTimeoutTimeSpan);

397await watchTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 433await watchTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 482await app.ResourceNotifications.WaitForResourceAsync(servicea.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 484await watchTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 646await app.ResourceNotifications.WaitForResourceAsync(servicea.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 647await app.ResourceNotifications.WaitForResourceAsync(custom.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 649await watchTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 690await rns.WaitForResourceAsync("servicea", KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 691await watchTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan);