670 references to DefaultTimeout
Aspire.Hosting.Tests (670)
AddConnectionStringTests.cs (1)
31var connectionStringManifest = await ManifestUtils.GetManifest(connectionStringResource).DefaultTimeout();
AddParameterTests.cs (13)
131() => parameter.Resource.GetValueAsync(CancellationToken.None).AsTask()).DefaultTimeout(); 223await Assert.ThrowsAsync<MissingParameterValueException>(() => parameter.GetValueAsync(CancellationToken.None).AsTask()).DefaultTimeout(); 237await Assert.ThrowsAsync<MissingParameterValueException>(() => parameter.GetValueAsync(CancellationToken.None).AsTask()).DefaultTimeout(); 250var thrown = await Assert.ThrowsAsync<InvalidOperationException>(() => parameter.GetValueAsync(CancellationToken.None).AsTask()).DefaultTimeout(); 267var thrown = await Assert.ThrowsAsync<InvalidOperationException>(() => parameter.SetValueAsync("value")).DefaultTimeout(); 292: parameter.SetValueAsync("replacement", cts.Token)).DefaultTimeout(); 307var aggregate = await Assert.ThrowsAsync<AggregateException>(() => parameter.SetValueAsync("value")).DefaultTimeout(); 383var paramManifest = await ManifestUtils.GetManifest(appModel.Resources.OfType<ParameterResource>().Single(r => r.Name == "pass")).DefaultTimeout(); 411() => ManifestUtils.GetManifest(parameter)).DefaultTimeout(); 455var paramManifest = await ManifestUtils.GetManifest(appModel.Resources.OfType<ParameterResource>().Single(r => r.Name == "pass")).DefaultTimeout(); 547var paramManifest = await ManifestUtils.GetManifest(appModel.Resources.OfType<ParameterResource>().Single(r => r.Name == "pass")).DefaultTimeout(); 604var paramManifest = await ManifestUtils.GetManifest(appModel.Resources.OfType<ParameterResource>().Single(r => r.Name == "val")).DefaultTimeout(); 632var connectionStringManifest = await ManifestUtils.GetManifest(connectionStringResource).DefaultTimeout();
ApplicationModel\EndpointHostHelpersTests.cs (2)
232.DefaultTimeout(); 260.DefaultTimeout();
AtsInteractionExportsTests.cs (2)
27}).DefaultTimeout(); 54}).DefaultTimeout();
Backchannel\AppHostRpcTargetTests.cs (2)
31() => target.GetDashboardUrlsAsync(TestContext.Current.CancellationToken).DefaultTimeout()); 45var result = await target.GetDashboardUrlsAsync(TestContext.Current.CancellationToken).DefaultTimeout();
Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (49)
43var result = await target.GetAppHostInfoAsync().DefaultTimeout(); 111var ready = await waitTask.DefaultTimeout(); 149var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 253var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 363var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 409var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 460var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 510var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 573var firstResult = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 594var secondResult = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 648var firstResult = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 668var secondResult = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 720var firstResult = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 739var secondResult = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 789var firstResult = await firstConnection.GetResourceSnapshotsAsync().DefaultTimeout(); 815var secondResult = await secondConnection.GetResourceSnapshotsAsync().DefaultTimeout(); 881var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 938var result = await firstConnection.GetResourceSnapshotsAsync().DefaultTimeout(); 974_ = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 987.DefaultTimeout()); 1026await target.GetResourceSnapshotsAsync(cts.Token).DefaultTimeout(); 1044.DefaultTimeout(); 1092var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 1148var before = await ReadSnapshotAsync(enumerator, s => s.Name == "myresource" && HasEnvironmentVariable(s, "PHASE", "before")).DefaultTimeout(); 1164var after = await ReadSnapshotAsync(enumerator, s => s.Name == "myresource" && HasEnvironmentVariable(s, "PHASE", "after")).DefaultTimeout(); 1206var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 1279}).DefaultTimeout(); 1316var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 1364}).DefaultTimeout(); 1409var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 1445var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 1485var response = await waitTask.DefaultTimeout(); 1524var response = await waitTask.DefaultTimeout(); 1625}).DefaultTimeout(); 2223var result = await target.GetDashboardUrlsAsync().DefaultTimeout(); 2344}).DefaultTimeout(); 2397}).DefaultTimeout(); 2455}).DefaultTimeout(); 2526}).DefaultTimeout(); 2601}).DefaultTimeout(); 2651}).DefaultTimeout(); 2710}).DefaultTimeout(); 2738}).DefaultTimeout(); 2765}).DefaultTimeout(); 2789var result = await target.GetDashboardUrlsAsync().DefaultTimeout(); 2815}).DefaultTimeout(); 2848}).DefaultTimeout(); 2881var result = await target.GetAppHostInformationAsync().DefaultTimeout(); 2918var result = await target.GetAppHostInfoAsync().DefaultTimeout();
Backchannel\AuxiliaryBackchannelTests.cs (12)
47var connectedEvent = await connectedEventReceived.Task.DefaultTimeout(); 140var bytesRead = await stream.ReadAsync(new byte[1]).AsTask().DefaultTimeout(); 177).DefaultTimeout(); 212).DefaultTimeout(); 262var results = await Task.WhenAll(tasks).DefaultTimeout(); 297).DefaultTimeout(); 379).DefaultTimeout(); 420).DefaultTimeout(); 505).DefaultTimeout(); 546).DefaultTimeout(); 589).DefaultTimeout(); 632).DefaultTimeout();
Backchannel\GetTerminalInfoAsyncTests.cs (9)
33new GetTerminalInfoRequest { ResourceName = "nope" }).DefaultTimeout(); 50new GetTerminalInfoRequest { ResourceName = "plain" }).DefaultTimeout(); 114}).DefaultTimeout(); 122}).DefaultTimeout(); 180}).DefaultTimeout(); 242}).DefaultTimeout(); 270var result = await target.GetCapabilitiesAsync().DefaultTimeout(); 286() => target.ListTerminalsAsync(new ListTerminalsRequest())).DefaultTimeout(); 308var result = await target.ListTerminalsAsync(new ListTerminalsRequest()).DefaultTimeout();
BuildOnlyContainerValidationTests.cs (2)
28() => ExecutePipelineAsync(app)).DefaultTimeout(); 49() => ExecutePipelineAsync(app)).DefaultTimeout();
ComputeEnvironmentValidationTests.cs (1)
25() => app.ExecuteBeforeStartHooksAsync(default)).DefaultTimeout();
ContainerTunnelTests.cs (6)
65await app.ResourceNotifications.WaitForResourceHealthyAsync(yarp.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 68var response = await clientA.GetAsync("/servicea/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 70var body = await response.Content.ReadAsStringAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 108await app.ResourceNotifications.WaitForResourceHealthyAsync(yarp.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 111var response = await clientA.GetAsync("/servicea/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 113var body = await response.Content.ReadAsStringAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
Dashboard\DashboardEventHandlersTests.cs (1)
292.DefaultTimeout();
Dashboard\DashboardResourceTests.cs (2)
778var log = await testLogger.FirstLogTask.DefaultTimeout(); 806var manifest = await ManifestUtils.GetManifestOrNull(dashboard).DefaultTimeout();
Dashboard\DashboardServiceDataTerminalTests.cs (6)
39var snapshot = await data.WaitForResourceAsync(resource.Name, r => r.Properties.Any(p => p.Name == "resource.trait.Owner")).DefaultTimeout(); 54var snapshot = await data.WaitForResourceAsync(resource.Name, _ => true).DefaultTimeout(); 69var snapshot = await data.WaitForResourceAsync(resource.Name, r => HasTerminalProperty(r, "terminal.enabled")).DefaultTimeout(); 109var snapshot = await data.WaitForResourceAsync("myapp-ccc", r => HasTerminalProperty(r, "terminal.enabled")).DefaultTimeout(); 132var snapshot = await data.WaitForResourceAsync(resource.Name, r => HasTerminalProperty(r, "terminal.enabled")).DefaultTimeout(); 157var snapshot = await data.WaitForResourceAsync("myapp-unknown", r => HasTerminalProperty(r, "terminal.enabled")).DefaultTimeout();
Dashboard\DashboardServiceTests.cs (36)
74var update1 = await writer.ReadNextAsync().DefaultTimeout(); 79var update2 = await writer.ReadNextAsync().DefaultTimeout(); 87var update3 = await writer.ReadNextAsync().DefaultTimeout(); 127var exceedLimitUpdate = await writer.ReadNextAsync().DefaultTimeout(); 131var longLinesUpdate1 = await writer.ReadNextAsync().DefaultTimeout(); 136var longLinesUpdate2 = await writer.ReadNextAsync().DefaultTimeout(); 219}).DefaultTimeout(); 233var readUpdateTask = writer.ReadNextAsync().DefaultTimeout(); 234var completedTask = await Task.WhenAny(task, readUpdateTask).DefaultTimeout(); 502var update = await writer.ReadNextAsync().DefaultTimeout(); 519Assert.Equal(result, (await resultTask.DefaultTimeout()).Data); 529Assert.True((await resultTask.DefaultTimeout()).Canceled); 575var update = await writer.ReadNextAsync().DefaultTimeout(); 612var update = await writer.ReadNextAsync().DefaultTimeout(); 646var update = await writer.ReadNextAsync().DefaultTimeout(); 665var promptResult = await prompt.DefaultTimeout(); 668var complete = await writer.ReadNextAsync().DefaultTimeout(); 712Assert.True((await prompt.DefaultTimeout()).Canceled); 775var update = await writer.ReadNextAsync().DefaultTimeout(); 789var result = await resultTask.DefaultTimeout(); 832await Assert.ThrowsAnyAsync<Exception>(() => task).DefaultTimeout(); 875await Assert.ThrowsAnyAsync<Exception>(() => task).DefaultTimeout(); 1475var initial = await responses.ReadNextAsync().DefaultTimeout(); 1479var recovery = WatchTerminalsUpdate.Parser.ParseFrom((await responses.ReadNextAsync().DefaultTimeout()).ToByteArray()); 1498var change = await responses.ReadNextAsync().DefaultTimeout(); 1576var status = await responses.ReadNextAsync().DefaultTimeout(); 1597new CloseTerminalRequest { TerminalId = "unknown" }, TestServerCallContext.Create()).DefaultTimeout(); 1628new CloseTerminalRequest { TerminalId = terminal.Id }, TestServerCallContext.Create())).DefaultTimeout(); 1657new CloseTerminalRequest { TerminalId = terminal.Id }, TestServerCallContext.Create())).DefaultTimeout(); 1688var response = await service.CloseTerminal(request, TestServerCallContext.Create()).DefaultTimeout(); 1693Assert.NotNull(await service.CloseTerminal(request, TestServerCallContext.Create()).DefaultTimeout()); 1732var exception = await Assert.ThrowsAnyAsync<OperationCanceledException>(() => close).DefaultTimeout(); 1762await run.DefaultTimeout(); 1814var exception = await Assert.ThrowsAnyAsync<OperationCanceledException>(() => close).DefaultTimeout(); 1837var log = await logs.Reader.ReadAsync().AsTask().DefaultTimeout(); 1873var log = await logs.Reader.ReadAsync().AsTask().DefaultTimeout();
Dashboard\ResourcePublisherTests.cs (1)
67var change = Assert.Single(await tcs.Task.DefaultTimeout());
Dcp\DcpExecutorTests.cs (15)
260await endpointEventsProcessed.Reader.ReadAsync().AsTask().DefaultTimeout(); 269await endpointEventsProcessed.Reader.ReadAsync().AsTask().DefaultTimeout(); 369var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => executor.RunApplicationAsync()).DefaultTimeout(); 2326Assert.Equal(1, await terminalLogCountAtNotification.Task.DefaultTimeout()); 2577var followStdErrPipe = await followStdErrPipeChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 3065var change = await changes.Reader.ReadAsync().AsTask().DefaultTimeout(); 3107var change = await changes.Reader.ReadAsync().AsTask().DefaultTimeout(); 4515var allocatedPort = await allocatedPortChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4516var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4564var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4646var resolvedUrl = await resolvedUrlChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4688var resolvedUrl = await resolvedUrlChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4867var failedContext = await tcs.Task.DefaultTimeout(); 9697var allocatedEndpoint = await endpoint.AllAllocatedEndpoints.Single(x => x.NetworkID == network).Snapshot.GetValueAsync().DefaultTimeout(); 10620await Assert.ThrowsAnyAsync<OperationCanceledException>(() => startTask).DefaultTimeout();
Dcp\KubernetesServiceTests.cs (48)
144}).DefaultTimeout(); 155await Assert.ThrowsAnyAsync<OperationCanceledException>(() => moveNext).DefaultTimeout(); 168await moveNext.DefaultTimeout(); 224}).DefaultTimeout(); 234Assert.True(await moveNext.DefaultTimeout()); 269await moveNext.DefaultTimeout(); 312}).DefaultTimeout(); 320.DefaultTimeout(TestConstants.LongTimeoutDuration); 324await Assert.ThrowsAnyAsync<OperationCanceledException>(() => moveNext).DefaultTimeout(); 332await moveNext.DefaultTimeout(); 377}).DefaultTimeout(); 385Assert.True(await moveNext.DefaultTimeout()); 392Assert.True(await moveNext.DefaultTimeout()); 402await Assert.ThrowsAnyAsync<OperationCanceledException>(() => moveNext).DefaultTimeout(); 421context.RequestAborted)).DefaultTimeout(); 428var error = await Assert.ThrowsAsync<KubernetesException>(() => moveNext).DefaultTimeout(); 437await Assert.ThrowsAnyAsync<OperationCanceledException>(() => moveNext).DefaultTimeout(); 475}).DefaultTimeout(); 484Assert.True(await moveNext.DefaultTimeout()); 494await Assert.ThrowsAnyAsync<OperationCanceledException>(() => moveNext).DefaultTimeout(); 523context.Response.WriteAsync(line + (appendNewline ? "\n" : string.Empty), context.RequestAborted)).DefaultTimeout(); 530await Assert.ThrowsAnyAsync<JsonException>(() => moveNext).DefaultTimeout(); 537await Assert.ThrowsAnyAsync<OperationCanceledException>(() => moveNext).DefaultTimeout(); 575}).DefaultTimeout(); 625}).DefaultTimeout(); 666}).DefaultTimeout(); 673Assert.True(await moveNext.DefaultTimeout()); 682await Assert.ThrowsAnyAsync<OperationCanceledException>(() => moveNext).DefaultTimeout(); 720}).DefaultTimeout(); 729Assert.True(await moveNext.DefaultTimeout()); 741await moveNext.DefaultTimeout(); 795}).DefaultTimeout(); 844}).DefaultTimeout(); 850var error = await Assert.ThrowsAsync<HttpOperationException>(WatchAsync).DefaultTimeout(); 855var error = await Assert.ThrowsAsync<KubernetesException>(WatchAsync).DefaultTimeout(); 886return TestDcpApiServer.StartAsync(certificateFixture.Certificate, cancellationToken, successfulRequestNumber, requestHandler).DefaultTimeout(); 1497var exception = await Assert.ThrowsAsync<TimeoutRejectedException>(() => createTask).DefaultTimeout(); 1539var exception = await Assert.ThrowsAsync<TimeoutRejectedException>(() => createTask).DefaultTimeout(); 1591Assert.Empty(await service.ListAsync<Container>(cancellationToken: cts.Token).DefaultTimeout()); 1593var result = await service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token).DefaultTimeout(); 1679var exception = await Assert.ThrowsAsync<TimeoutRejectedException>(() => createTask).DefaultTimeout(); 1770var result = await listTask.DefaultTimeout(); 1796var result = await listTask.DefaultTimeout(); 1875await Assert.ThrowsAsync<TimeoutRejectedException>(() => listTask).DefaultTimeout(); 1928var result = await createTask.DefaultTimeout(); 2173await Assert.ThrowsAnyAsync<OperationCanceledException>(() => watchTask).DefaultTimeout(); 2203await using var stream = await service.GetLogStreamAsync(Container.Create("frontend", "test-image"), "stdout", cts.Token).DefaultTimeout(); 2272var result = await listTask.DefaultTimeout();
Dcp\ProcessUtilTests.cs (8)
33using var process = await processStarted.Task.DefaultTimeout(TestConstants.LongTimeoutDuration); 46var result = await pendingProcessResult.DefaultTimeout(TestConstants.LongTimeoutDuration); 59var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => pendingProcessResult).DefaultTimeout(TestConstants.LongTimeoutDuration); 82var processResult = await pendingProcessResult.DefaultTimeout(TestConstants.LongTimeoutDuration); 108var result = await pendingProcessResult.DefaultTimeout(TestConstants.LongTimeoutDuration); 132var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => pendingProcessResult).DefaultTimeout(TestConstants.LongTimeoutDuration); 168var result = await pendingProcessResult.DefaultTimeout(TestConstants.LongTimeoutDuration); 200var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => pendingProcessResult).DefaultTimeout(TestConstants.LongTimeoutDuration);
DistributedApplicationTests.cs (48)
81}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 126}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 155}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 212: app.RunAsync()).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 460await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 513}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 533}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 554}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 842await Task.WhenAll(clientA.GetStringAsync("/pid"), clientC.GetStringAsync("/pid")).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 855var pidText = await clientB.GetStringAsync(url).DefaultTimeout(); 892var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 949var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 993var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1068var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1203r => r.Spec.Env != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1243r => r.Spec.Env != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1284var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1292redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Exited, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1324var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1331serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Finished, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1336serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.LongTimeoutDuration); 1366var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, $"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1369var serviceA = await KubernetesHelper.GetResourceByNameAsync<Executable>(kubernetes, $"{testName}-servicea", suffix!, r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1372var nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1447var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1484var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1579r => r.Status?.State == ContainerState.FailedToStart && (r.Status?.Message.Contains("bob") ?? false)).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1608$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1636$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1665$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1671var containerVolume = Assert.Single(await s.ListAsync<ContainerVolume>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout)); 1768var allocatedEndpoint = await allocatedEndpointSnapshot.Snapshot.GetValueAsync().DefaultTimeout(); 1793var result = await client.GetStringAsync("pid").DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1805}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1867var value = await client.GetStringAsync($"{httpsEndpoint}urls", token).DefaultTimeout(); 1912await clientA.GetStringAsync("/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1915var exeList = await s.ListAsync<Executable>().DefaultTimeout(); 1924var list = await s.ListAsync<Container>().DefaultTimeout(); 1937.DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1988await clientA.GetStringAsync("/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1992var serviceList = await s.ListAsync<Service>().DefaultTimeout(); 1995var exeList = await s.ListAsync<Executable>().DefaultTimeout(); 2004var list = await s.ListAsync<Container>().DefaultTimeout(); 2017.DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 2081var networks = await s.ListAsync<ContainerNetwork>().DefaultTimeout(); 2123.DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 2132.DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 2308.DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
DotnetProgramPublishingTests.cs (4)
272() => ExecuteBuildPipelineAsync(app, WellKnownPipelineSteps.Build)).DefaultTimeout(); 345() => ExecuteBuildPipelineAsync(app, "build-program")).DefaultTimeout(); 390var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 416manager.BuildImageAsync(resource.Resource, TestContext.Current.CancellationToken)).DefaultTimeout();
ExecutableResourceTests.cs (1)
68var manifest = await ManifestUtils.GetManifest(exe2.Resource).DefaultTimeout();
ExternalServiceTests.cs (4)
344).DefaultTimeout(); 371).DefaultTimeout(); 398).DefaultTimeout(); 472CancellationToken.None).DefaultTimeout();
Health\FriendlyHealthCheckErrorMessagesTests.cs (4)
39cts.Token).DefaultTimeout(); 79cts.Token).DefaultTimeout(); 118CancellationToken.None).DefaultTimeout(); 154CancellationToken.None).DefaultTimeout();
Health\ResourceHealthCheckServiceTests.cs (26)
29await using var app = await builder.BuildAsync().DefaultTimeout(); 38var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 46var healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 69await using var app = await builder.BuildAsync().DefaultTimeout(); 78var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 86var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 93await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 112await using var app = await builder.BuildAsync().DefaultTimeout(); 121var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 130e => e.Snapshot.State?.Text == KnownResourceStates.Running && e.Snapshot.HealthReports.Single().Status == HealthStatus.Unhealthy).DefaultTimeout(); 157await using var app = await builder.BuildAsync().DefaultTimeout(); 168await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 192await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 233await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, abortTokenSource.Token).DefaultTimeout(); 354var @event = await blockAssert.Task.DefaultTimeout(); 449await Task.WhenAll([resourceReadyEventFired.Task]).DefaultTimeout(); 551var parentReadyEvent = await parentReady.Task.DefaultTimeout(); 554var childReadyEvent = await childReady.Task.DefaultTimeout(); 578await using var app = await builder.BuildAsync().DefaultTimeout(); 587var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 596var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 603var healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 624await using var app = await builder.BuildAsync().DefaultTimeout(); 633var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 641var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 649var unhealthyEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.HealthStatus == HealthStatus.Unhealthy).DefaultTimeout();
HealthCheckTests.cs (2)
143await rns.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 168}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
InteractionServiceTests.cs (26)
37var result = await resultTask.DefaultTimeout(); 62var result = await resultTask.DefaultTimeout(); 101var result1 = await resultTask1.DefaultTimeout(); 109var result2 = await resultTask2.DefaultTimeout(); 115var result3 = await resultTask3.DefaultTimeout(); 148Assert.True((await resultTask1.DefaultTimeout()).Data); 152Assert.Equivalent(result1, await completedInteraction1.CompletionTcs.Task.DefaultTimeout()); 156Assert.False((await resultTask2.DefaultTimeout()).Data); 160Assert.Equivalent(result2, await completedInteraction2.CompletionTcs.Task.DefaultTimeout()); 171() => interactionService.PromptConfirmationAsync("Are you sure?", "Confirmation")).DefaultTimeout(); 173() => interactionService.PromptNotificationAsync("Are you sure?", "Confirmation")).DefaultTimeout(); 175() => interactionService.PromptMessageBoxAsync("Are you sure?", "Confirmation")).DefaultTimeout(); 177() => interactionService.PromptProgressAsync("Please wait", new ProgressInteractionOptions { Title = "Working..." })).DefaultTimeout(); 202() => interactionService.PromptMessageBoxAsync("Title", "Message")).DefaultTimeout(); 241() => interactionService.PromptMessageBoxAsync("Title", "Message")).DefaultTimeout(); 264() => app.ExecuteBeforeStartHooksAsync(default)).DefaultTimeout(); 560var result = await resultTask.DefaultTimeout(); 978var result = await resultTask.DefaultTimeout(); 1160var result = await resultTask.DefaultTimeout(); 1247}).DefaultTimeout(); 1280var result = await resultTask.DefaultTimeout(); 1316var result = await resultTask.DefaultTimeout(); 1350var result = await resultTask.DefaultTimeout(); 1370var result = await resultTask.DefaultTimeout(); 1391var result = await resultTask.DefaultTimeout(); 1410await resultTask.DefaultTimeout();
KestrelConfigTests.cs (4)
177var manifest = await ManifestUtils.GetManifest(resource).DefaultTimeout(); 219var manifest = await ManifestUtils.GetManifest(resource).DefaultTimeout(); 288var manifest = await ManifestUtils.GetManifest(resource).DefaultTimeout(); 308var manifest = await ManifestUtils.GetManifest(resource).DefaultTimeout();
Lifecycle\TerminalHostFailureDiagnosticServiceTests.cs (5)
40var logs = await ReadLogsAsync(loggers, host, expected: 2).DefaultTimeout(); 80var logs = await ReadLogsAsync(loggers, host, expected: 2).DefaultTimeout(); 114var current = await ReadCurrentSnapshotAsync(notifications, host).DefaultTimeout(); 154var logs = await ReadLogsAsync(loggers, host, expected: 1).DefaultTimeout(); 191await ReadLogsAsync(loggers, host, expected: 2).DefaultTimeout();
ManifestGenerationTests.cs (5)
102var redisManifest = await ManifestUtils.GetManifest(redis.Resource).DefaultTimeout(); 547var manifest = await ManifestUtils.GetManifest(param.Resource).DefaultTimeout(); 573var destManifest = await ManifestUtils.GetManifest(destContainer.Resource).DefaultTimeout(); 616var destManifest = await ManifestUtils.GetManifest(destContainer.Resource).DefaultTimeout(); 667var destManifest = await ManifestUtils.GetManifest(destContainer.Resource).DefaultTimeout();
Orchestrator\ApplicationOrchestratorTests.cs (6)
739TestContext.Current.CancellationToken).DefaultTimeout(); 797TestContext.Current.CancellationToken).DefaultTimeout(); 848TestContext.Current.CancellationToken).DefaultTimeout(); 902TestContext.Current.CancellationToken).DefaultTimeout(); 910TestContext.Current.CancellationToken).DefaultTimeout(); 1097TestContext.Current.CancellationToken).DefaultTimeout();
Orchestrator\ParameterProcessorTests.cs (52)
46Assert.Equal(param.Value, await param.WaitForValueTcs.Task.DefaultTimeout()); 72Assert.Equal(param.Value, await param.WaitForValueTcs.Task.DefaultTimeout()); 140Assert.Null(await parameter.WaitForValueTcs.Task.DefaultTimeout()); 333Assert.Equal("value1", await param1.WaitForValueTcs.Task.DefaultTimeout()); 334Assert.Equal("value2", await param2.WaitForValueTcs.Task.DefaultTimeout()); 335Assert.Equal("secretValue", await secretParam.WaitForValueTcs.Task.DefaultTimeout()); 391await parameterProcessor.SetParameterCoreAsync(parameterWithMissingValue, CreateSetParameterArguments("resolvedValue"), CancellationToken.None).DefaultTimeout(); 503var logs = await logsTask.DefaultTimeout(); 527var logs = await logsTask.DefaultTimeout(); 570var logs = await logsTask.DefaultTimeout(); 773Assert.Equal("explicitValue", await explicitParameterResource.WaitForValueTcs.Task.DefaultTimeout()); 774Assert.Equal("referencedValue", await referencedParameterResource.WaitForValueTcs.Task.DefaultTimeout()); 815Assert.Equal("explicitValue", await explicitParameterResource.WaitForValueTcs.Task.DefaultTimeout()); 841Assert.Equal("envValue", await parameterResource.WaitForValueTcs.Task.DefaultTimeout()); 863Assert.Equal("testValue", await parameterResource.WaitForValueTcs.Task.DefaultTimeout()); 885Assert.Equal("testValue", await parameterResource.WaitForValueTcs.Task.DefaultTimeout()); 1135var section = await deploymentStateManager.AcquireSectionAsync(parameter.ConfigurationKey).DefaultTimeout(); 1206var section = await deploymentStateManager.AcquireSectionAsync(parameter.ConfigurationKey).DefaultTimeout(); 1259var result = await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("newValue"), CancellationToken.None).DefaultTimeout(); 1276var result = await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments(value: null), CancellationToken.None).DefaultTimeout(); 1295var result = await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("resolvedValue"), CancellationToken.None).DefaultTimeout(); 1444await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("firstValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1449await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("secondValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1516var result = await parameterProcessor.SetParameterCoreAsync(secretParam, CreateSetParameterArguments("replacement-secret"), CancellationToken.None).DefaultTimeout(); 1576await Assert.ThrowsAnyAsync<OperationCanceledException>(() => parameter.SetValueAsync("canceled-notification-secret", cts.Token)).DefaultTimeout(); 1825Assert.Equal("existingValue", await parameterWithGenerateDefault.WaitForValueTcs.Task.DefaultTimeout()); 1962await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1965var result = await parameterProcessor.DeleteParameterCoreAsync(parameter, CreateDeleteParameterArguments(deleteFromUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1969var section = await capturingStateManager.AcquireSectionAsync($"Parameters:{parameter.Name}").DefaultTimeout(); 1981await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1983var result = await parameterProcessor.DeleteParameterCoreAsync(parameter, new InteractionInputCollection([]), CancellationToken.None).DefaultTimeout(); 1998await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 2000var result = await parameterProcessor.DeleteParameterCoreAsync(parameter, CreateDeleteParameterArguments(deleteFromUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 2019await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 2020await parameterProcessor.DeleteParameterCoreAsync(parameter, CreateDeleteParameterArguments(), CancellationToken.None).DefaultTimeout(); 2022var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2027var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2046await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue"), CancellationToken.None).DefaultTimeout(); 2048var result = await parameterProcessor.DeleteParameterCoreAsync(parameter, CreateDeleteParameterArguments(), CancellationToken.None).DefaultTimeout(); 2124await Assert.ThrowsAsync<MissingParameterValueException>(() => parameter.GetValueAsync(CancellationToken.None).AsTask()).DefaultTimeout(); 2188await Assert.ThrowsAsync<MissingParameterValueException>(() => parameter.GetValueAsync(CancellationToken.None).AsTask()).DefaultTimeout(); 2224var section = await stateManager.AcquireSectionAsync(configurationKey).DefaultTimeout(); 2285var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2342Assert.Null(await waitingValue.DefaultTimeout()); 2369() => parameter.GetValueAsync(CancellationToken.None).AsTask()).DefaultTimeout(); 2419await Assert.ThrowsAsync<MissingParameterValueException>(() => parameter.GetValueAsync(CancellationToken.None).AsTask()).DefaultTimeout(); 2455await Assert.ThrowsAsync<MissingParameterValueException>(() => parameter.GetValueAsync(CancellationToken.None).AsTask()).DefaultTimeout(); 2460var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2464var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2530var section = await capturingStateManager.AcquireSectionAsync($"Parameters:{parameter.Name}").DefaultTimeout(); 2533var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2537var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout();
Pipelines\DistributedApplicationPipelineTests.cs (29)
369var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 384var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 414var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 435var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 582var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 603var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 664var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 686var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 721var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 765var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 797await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 828await Assert.ThrowsAnyAsync<Exception>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 859await Assert.ThrowsAnyAsync<Exception>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 898await Assert.ThrowsAnyAsync<Exception>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 921var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 946var exception = await Assert.ThrowsAsync<ProcessFailedException>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 1295await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 1858var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => pipeline.ExecuteAsync(context)).DefaultTimeout(); 2270var steps = await pipeline.ResolveStepsAsync(context).DefaultTimeout(); 2323() => pipeline.ExecuteStepSequentiallyAsync("step", CreateDeployingContext(app))).DefaultTimeout(); 2342var first = await pipeline.ResolveStepsAsync(context).DefaultTimeout(); 2343var second = await pipeline.ResolveStepsAsync(context).DefaultTimeout(); 2365() => pipeline.ResolveStepsAsync(CreateDeployingContext(app))).DefaultTimeout(); 2392() => pipeline.ResolveStepsAsync(CreateDeployingContext(app))).DefaultTimeout(); 2412var steps = await pipeline.ResolveStepsAsync(context).DefaultTimeout(); 2433var steps = await pipeline.ResolveStepsAsync(context).DefaultTimeout(); 2454await pipeline.ResolveStepsAsync(context).DefaultTimeout(); 2564await cloned.ResolveStepsAsync(context).DefaultTimeout(); 2574var resolved = await pipeline.ResolveStepsAsync(context).DefaultTimeout();
ProjectResourceTests.cs (4)
37var projectDetails = await PrepareProjectWithTrailingCommasInLaunchSettingsAsync(workspace.WorkspaceRoot.FullName).DefaultTimeout(); 81var projectDetails = await PrepareProjectWithMalformedLaunchSettingsAsync(workspace.WorkspaceRoot.FullName).DefaultTimeout(); 607var manifest = await ManifestUtils.GetManifest(resource).DefaultTimeout(); 655var manifest = await ManifestUtils.GetManifest(resource).DefaultTimeout();
PublishAsConnectionStringTests.cs (1)
24var manifest = await ManifestUtils.GetManifest(redis.Resource).DefaultTimeout();
PublishAsDockerfileTests.cs (5)
29var manifest = await ManifestUtils.GetManifest(frontend.Resource, manifestDirectory: path).DefaultTimeout(); 75var manifest = await ManifestUtils.GetManifest(frontend.Resource, manifestDirectory: path).DefaultTimeout(); 124var manifest = await ManifestUtils.GetManifest(frontend.Resource, manifestDirectory: path).DefaultTimeout(); 173var manifest = await ManifestUtils.GetManifest(frontend.Resource, manifestDirectory: path).DefaultTimeout(); 235var manifest = await ManifestUtils.GetManifest(project.Resource, manifestDirectory: path).DefaultTimeout();
Publishing\ContainerRuntimeReadinessTests.cs (9)
38.EnsureRunningAsync(runtime, TestContext.Current.CancellationToken)).DefaultTimeout(); 57var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 87var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 90var exception = await Assert.ThrowsAsync<DistributedApplicationException>(() => check).DefaultTimeout(); 114readiness.EnsureRunningAsync(runtime, TestContext.Current.CancellationToken)).DefaultTimeout(); 131var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 136await Assert.ThrowsAnyAsync<OperationCanceledException>(() => second).DefaultTimeout(); 164var interaction = await interactions.Interactions.Reader.ReadAsync(TestContext.Current.CancellationToken).AsTask().DefaultTimeout(); 169var exception = await Assert.ThrowsAsync<DistributedApplicationException>(() => check).DefaultTimeout();
Publishing\DockerContainerRuntimeTests.cs (1)
145await Assert.ThrowsAnyAsync<OperationCanceledException>(() => buildTask).DefaultTimeout();
Publishing\DotnetProgramArchiveTests.cs (2)
185() => BuildAsync(app, resource.Resource, false, cancellation.Token)).DefaultTimeout(); 227() => BuildAsync(app, resource.Resource, false, cancellation.Token)).DefaultTimeout();
Publishing\PipelineActivityReporterTests.cs (5)
582var promptResult = await promptTask.DefaultTimeout(); 611var promptResult = await promptTask.DefaultTimeout(); 640var promptResult = await promptTask.DefaultTimeout(); 671var result = await promptTask.DefaultTimeout(); 744var notificationResult = await notificationTask.DefaultTimeout();
Publishing\ResourceContainerImageManagerTests.cs (2)
1253var result = await pendingResult.WaitAsync(TestContext.Current.CancellationToken).DefaultTimeout(); 1317var result = await pendingResult.WaitAsync(TestContext.Current.CancellationToken).DefaultTimeout();
ResourceCommandServiceTests.cs (13)
642CancellationToken.None).DefaultTimeout(); 1038CancellationToken.None).DefaultTimeout(); 1128CancellationToken.None).DefaultTimeout(); 1203CancellationToken.None).DefaultTimeout(); 1250CancellationToken.None).DefaultTimeout(); 1297CancellationToken.None).DefaultTimeout(); 1394var result = await resultTask.DefaultTimeout(); 1472CancellationToken.None).DefaultTimeout(); 1527CancellationToken.None).DefaultTimeout(); 1561CancellationToken.None).DefaultTimeout(); 1595CancellationToken.None).DefaultTimeout(); 1887var result = await resultTask.DefaultTimeout(); 1937var result = await resultTask.DefaultTimeout();
ResourceLoggerServiceTests.cs (15)
36var allLogs = await logsLoop.DefaultTimeout(); 49allLogs = await logsLoop.DefaultTimeout(); 80var allLogs = await logsLoop.DefaultTimeout(); 91allLogs = await logsLoop.DefaultTimeout(); 117var allLogs = await logsLoop.DefaultTimeout(); 130allLogs = await logsLoop.DefaultTimeout(); 144allLogs = await logsLoop.DefaultTimeout(); 169var allLogs = await logsLoop.DefaultTimeout(); 178allLogs = await logsLoop.DefaultTimeout(); 188allLogs = await logsLoop.DefaultTimeout(); 207allLogs = await logsLoop.DefaultTimeout(); 241var allLogs = await logsLoop.DefaultTimeout(); 701var allLogs = await watchTask.DefaultTimeout(); 732var allLogs = await watchTask.DefaultTimeout(); 780var allSubscribers = await watchTask.DefaultTimeout();
ResourceNotificationTests.cs (36)
89var resourceEvent = await watchTask.DefaultTimeout(); 126var values = await enumerableTask.DefaultTimeout(); 206var values = await enumerableTask.DefaultTimeout(); 294Assert.Equal("SomeOtherState", await waitTask.DefaultTimeout()); 332var reachedState = await waitTask.DefaultTimeout(); 358var reachedState = await waitTask.DefaultTimeout(); 395}).DefaultTimeout(); 421cts.Token).DefaultTimeout(); 434cts.Token).DefaultTimeout(); 469cts.Token).DefaultTimeout(); 487cts.Token).DefaultTimeout(); 525cts.Token).DefaultTimeout(); 539cts.Token).DefaultTimeout(); 578cts.Token).DefaultTimeout(); 658cts.Token).DefaultTimeout(); 729cts.Token).DefaultTimeout(); 768cts.Token).DefaultTimeout(); 801cts.Token).DefaultTimeout(); 814cts.Token).DefaultTimeout(); 878}).DefaultTimeout(); 905TestContext.Current.CancellationToken).DefaultTimeout(); 912}).DefaultTimeout(); 931}).DefaultTimeout(); 948}).DefaultTimeout(); 1117var values = await enumerableTask.DefaultTimeout(); 1162var value = await enumerableTask.DefaultTimeout(); 1198var value = await enumerableTask.DefaultTimeout(); 1340var resourceEvent = await waitTask.DefaultTimeout(); 1379var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => waitTask.DefaultTimeout()); 1409var resourceEvent = await waitTask.DefaultTimeout(); 1437var resourceEvent = await notificationService.WaitForResourceHealthyAsync(resource.Name, waitBehavior).DefaultTimeout(); 1470Assert.Equal(KnownResourceStates.Running, (await waitTask.DefaultTimeout()).Snapshot.State?.Text); 1525var exception = await Assert.ThrowsAsync<OperationCanceledException>(() => waitTask).DefaultTimeout(); 1548var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => waitTask).DefaultTimeout(); 1591Assert.True((await waitTask.DefaultTimeout()).Snapshot.ResourceReadyEvent?.EventTask.IsCompletedSuccessfully); 1610Assert.True((await waitTask.DefaultTimeout()).Snapshot.ResourceReadyEvent?.EventTask.IsCompletedSuccessfully);
Terminals\Hex1bAspireTerminalTests.cs (3)
74var exception = await Assert.ThrowsAnyAsync<OperationCanceledException>(() => operation).DefaultTimeout(); 119() => terminal.SendKeyAsync(AspireTerminalKey.Enter, cts.Token)).DefaultTimeout(); 519await run.DefaultTimeout();
Terminals\InteractionServiceTerminalTests.cs (16)
123var result = await prompt.DefaultTimeout(); 142() => terminals.AttachAsync(terminal.Id, Stream.Null, _ => Task.CompletedTask, CancellationToken.None)).DefaultTimeout(); 146Assert.True((await prompt.DefaultTimeout()).Canceled); 172var result = await prompt.DefaultTimeout(); 213Assert.True((await prompt.DefaultTimeout()).Canceled); 264Assert.True((await prompt.DefaultTimeout()).Canceled); 290Assert.True(await firstUpdate.DefaultTimeout()); 297Assert.Same(failure, await Assert.ThrowsAsync<InvalidOperationException>(() => prompt).DefaultTimeout()); 302Assert.True((await prompt.DefaultTimeout()).Data); 320Assert.True((await prompt.DefaultTimeout()).Canceled); 322Assert.True(await updates.MoveNextAsync().AsTask().DefaultTimeout()); 331Assert.True(await updates.MoveNextAsync().AsTask().DefaultTimeout()); 335await second.DefaultTimeout(); 379Assert.Equal(cancel, (await prompt.DefaultTimeout()).Canceled); 412Assert.True((await prompt.DefaultTimeout()).Canceled); 429var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => prompt).DefaultTimeout();
Terminals\ResourceAspireTerminalTests.cs (6)
63() => terminal.WaitForTextAsync("text-the-workload-never-writes", TimeSpan.FromSeconds(1))).DefaultTimeout(); 75await Assert.ThrowsAnyAsync<Exception>(() => terminal.SendTextAsync("hello")).DefaultTimeout(); 96await Assert.ThrowsAnyAsync<Exception>(() => terminal.SendTextAsync("not-delivered")).DefaultTimeout(); 136using var peer = await listener.AcceptAsync().DefaultTimeout(); 140await Assert.ThrowsAnyAsync<OperationCanceledException>(() => canceledCall).DefaultTimeout(); 144await Assert.ThrowsAnyAsync<OperationCanceledException>(() => otherCall).DefaultTimeout();
Terminals\ResourceTerminalCatalogTests.cs (1)
217await Assert.ThrowsAnyAsync<OperationCanceledException>(() => automation).DefaultTimeout();
Terminals\TerminalClientStreamTests.cs (3)
29await Assert.ThrowsAnyAsync<OperationCanceledException>(() => read).DefaultTimeout(); 40await Assert.ThrowsAnyAsync<OperationCanceledException>(() => write).DefaultTimeout(); 49Assert.Equal(1, await peer.ReadAsync(buffer).AsTask().DefaultTimeout());
Terminals\TerminalServiceTests.cs (23)
70Assert.True(await updates.MoveNextAsync().AsTask().DefaultTimeout()); 357() => service.AttachAsync("does-not-exist", stream, _ => Task.CompletedTask, CancellationToken.None)).DefaultTimeout(); 385Assert.True(await changes.MoveNextAsync().AsTask().DefaultTimeout()); 403Assert.True(await changes.MoveNextAsync().AsTask().DefaultTimeout()); 430Assert.True(await updates.MoveNextAsync().AsTask().DefaultTimeout()); 438Assert.True(await updates.MoveNextAsync().AsTask().DefaultTimeout()); 466Assert.True(await updates.MoveNextAsync().AsTask().DefaultTimeout()); 484Assert.True(await updates.MoveNextAsync().AsTask().DefaultTimeout()); 505Assert.True(await updates.MoveNextAsync().AsTask().DefaultTimeout()); 524Assert.True(await fastUpdates.MoveNextAsync().AsTask().DefaultTimeout()); 531Assert.True(await slowUpdates.MoveNextAsync().AsTask().DefaultTimeout()); 549await Assert.ThrowsAnyAsync<OperationCanceledException>(() => updates.MoveNextAsync().AsTask()).DefaultTimeout(); 562Assert.False(await next.DefaultTimeout()); 644Assert.True(await changes.MoveNextAsync().AsTask().DefaultTimeout()); 724Assert.Same(expected, await Assert.ThrowsAsync<IOException>(() => disposal).DefaultTimeout()); 726Assert.Same(expected, await Assert.ThrowsAsync<IOException>(() => terminal.DisposeAsync().AsTask()).DefaultTimeout()); 754Assert.True(await changes.MoveNextAsync().AsTask().DefaultTimeout()); 761Assert.False(await changes.MoveNextAsync().AsTask().DefaultTimeout()); 818await Assert.ThrowsAnyAsync<OperationCanceledException>(() => stop).DefaultTimeout(); 869Assert.Equal(descriptor.Id, (await create.DefaultTimeout()).Id); 885await create.DefaultTimeout(); 906Assert.False(await changes.MoveNextAsync().AsTask().DefaultTimeout()); 968Assert.False(await changes.MoveNextAsync().AsTask().DefaultTimeout());
Utils\SignalingFakeTimeProviderTests.cs (1)
51var exception = await Assert.ThrowsAsync<TimeoutRejectedException>(() => executionTask).DefaultTimeout();
Utils\TestAppHostTerminalViewer.cs (3)
52var completed = await Task.WhenAny(viewer._connected.Task, viewer._run, viewer._attachment).DefaultTimeout(); 72var connection = await _connected.Task.DefaultTimeout(); 77.Build().ApplyAsync(_client, _clientCts.Token).DefaultTimeout();
WithEndpointTests.cs (11)
275var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 303var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 330var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 357var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 384var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 411var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 438var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 469var manifest = await ManifestUtils.GetManifest(project.Resource).DefaultTimeout(); 537var manifest = await ManifestUtils.GetManifest(project.Resource).DefaultTimeout(); 562var manifests = await ManifestUtils.GetManifests([container0.Resource, container1.Resource]).DefaultTimeout(); 606var manifest = await ManifestUtils.GetManifest(project.Resource).DefaultTimeout();
WithEnvironmentTests.cs (1)
331)).DefaultTimeout();
WithHttpCommandTests.cs (20)
145var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").DefaultTimeout(); 387var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand", arguments).DefaultTimeout(); 457var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").DefaultTimeout(); 482var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand", cts.Token).DefaultTimeout(); 514var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").DefaultTimeout(); 549var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").DefaultTimeout(); 636var result = await app.ResourceCommands.ExecuteCommandAsync(serviceB.Resource, "mycommand").DefaultTimeout(); 680var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").DefaultTimeout(); 724var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").DefaultTimeout(); 788var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand", arguments).DefaultTimeout(); 817var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").DefaultTimeout(); 843var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").DefaultTimeout(); 870var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").DefaultTimeout(); 898var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").DefaultTimeout(); 925var result = await app.ResourceCommands.ExecuteCommandAsync(service.Resource, "mycommand").DefaultTimeout(); 957e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 971e.Snapshot.Commands.First(c => c.Name == "mycommand").State == ResourceCommandState.Enabled).DefaultTimeout(); 1014e.Snapshot.Commands.First(c => c.Name == "mycommand").State == ResourceCommandState.Hidden).DefaultTimeout(); 1028e => e.Snapshot.Commands.First(c => c.Name == "mycommand").State == ResourceCommandState.Enabled).DefaultTimeout(); 1070e.Snapshot.Commands.FirstOrDefault(c => c.Name == commandName)?.State == ResourceCommandState.Enabled).DefaultTimeout();
WithProcessCommandTests.cs (42)
124var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "export-command").DefaultTimeout(); 190var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "options-callback-command", arguments).DefaultTimeout(); 269var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "factory-command", arguments).DefaultTimeout(); 313var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "factory-accepted-exit-code").DefaultTimeout(); 334var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "null-process-spec").DefaultTimeout(); 384var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "echo-argument", arguments).DefaultTimeout(); 450}).DefaultTimeout(); 488var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "async-factory").DefaultTimeout(); 522var firstResult = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "repeat").DefaultTimeout(); 523var secondResult = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "repeat").DefaultTimeout(); 566var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "many-lines").DefaultTimeout(); 599var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "display-immediately").DefaultTimeout(); 623var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "no-output").DefaultTimeout(); 645var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "fail-no-output").DefaultTimeout(); 673var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "accepted-exit-code").DefaultTimeout(); 711var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "failure-display-immediately").DefaultTimeout(); 735var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "log-output").DefaultTimeout(); 742var logs = await ConsoleLoggingTestHelpers.WatchForLogsAsync(loggerService, 4, resource.Resource).DefaultTimeout(); 791var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "custom-result").DefaultTimeout(); 833var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "ordered-output").DefaultTimeout(); 862var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "fail").DefaultTimeout(); 898var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "argument-fidelity").DefaultTimeout(); 922var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "stdin").DefaultTimeout(); 945var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "path-executable").DefaultTimeout(); 969var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "working-directory").DefaultTimeout(); 997var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "environment").DefaultTimeout(); 1023var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "invalid-environment-name").DefaultTimeout(); 1049var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "null-environment-value").DefaultTimeout(); 1087var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "export-options").DefaultTimeout(); 1125var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "export-accepted-exit-code").DefaultTimeout(); 1150var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "export-default-options").DefaultTimeout(); 1213var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, $"invalid-export-{i}").DefaultTimeout(); 1260var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "default-success-exit-codes").DefaultTimeout(); 1284var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "environment-inheritance").DefaultTimeout(); 1307var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "missing").DefaultTimeout(); 1331var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "process-task-failure").DefaultTimeout(); 1354var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "null-process-spec").DefaultTimeout(); 1380var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "factory-exception").DefaultTimeout(); 1404var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "null-argument").DefaultTimeout(); 1442var result = await app.ResourceCommands.ExecuteCommandAsync(resource.Resource, "validation-failure").DefaultTimeout(); 1474await processRunner.RunStarted.Task.DefaultTimeout(); 1477var result = await commandTask.DefaultTimeout();
WithReferenceTests.cs (2)
574}).DefaultTimeout(); 610}).DefaultTimeout();
WithUrlsTests.cs (13)
360Assert.NotNull(await tcs.Task.DefaultTimeout()); 618e => e.Snapshot.Urls.Length == 1).DefaultTimeout(); 643e => e.Snapshot.Urls.Length == 3).DefaultTimeout(); 678&& e.Snapshot.Urls.All(url => !url.IsInactive)).DefaultTimeout(); 786e => e.Snapshot.State == KnownResourceStates.Running && e.Snapshot.Urls.Length == 4).DefaultTimeout(); 1122default).DefaultTimeout(); 1127resourceBClient.GetStringAsync("/")).DefaultTimeout(); 1172default).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1179var startResult = await app.ResourceCommands.ExecuteCommandAsync(resourceA.Resource, KnownResourceCommands.StartCommand).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1182Assert.Equal("Hello World!", await resourceAClient.GetStringAsync("/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout)); 1187default).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1190var stopResult = await app.ResourceCommands.ExecuteCommandAsync(resourceA.Resource, KnownResourceCommands.StopCommand).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1196default).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);