663 references to DefaultTimeout
Aspire.Hosting.Tests (663)
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\AuxiliaryBackchannelRpcTargetTests.cs (48)
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(); 418var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 468var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 531var firstResult = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 552var secondResult = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 606var firstResult = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 626var secondResult = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 678var firstResult = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 697var secondResult = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 747var firstResult = await firstConnection.GetResourceSnapshotsAsync().DefaultTimeout(); 773var secondResult = await secondConnection.GetResourceSnapshotsAsync().DefaultTimeout(); 839var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 896var result = await firstConnection.GetResourceSnapshotsAsync().DefaultTimeout(); 932_ = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 945.DefaultTimeout()); 984await target.GetResourceSnapshotsAsync(cts.Token).DefaultTimeout(); 1002.DefaultTimeout(); 1050var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 1106var before = await ReadSnapshotAsync(enumerator, s => s.Name == "myresource" && HasEnvironmentVariable(s, "PHASE", "before")).DefaultTimeout(); 1122var after = await ReadSnapshotAsync(enumerator, s => s.Name == "myresource" && HasEnvironmentVariable(s, "PHASE", "after")).DefaultTimeout(); 1164var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 1237}).DefaultTimeout(); 1274var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 1322}).DefaultTimeout(); 1367var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 1403var result = await target.GetResourceSnapshotsAsync().DefaultTimeout(); 1443var response = await waitTask.DefaultTimeout(); 1482var response = await waitTask.DefaultTimeout(); 1583}).DefaultTimeout(); 2181var result = await target.GetDashboardUrlsAsync().DefaultTimeout(); 2302}).DefaultTimeout(); 2355}).DefaultTimeout(); 2413}).DefaultTimeout(); 2484}).DefaultTimeout(); 2559}).DefaultTimeout(); 2609}).DefaultTimeout(); 2668}).DefaultTimeout(); 2696}).DefaultTimeout(); 2723}).DefaultTimeout(); 2747var result = await target.GetDashboardUrlsAsync().DefaultTimeout(); 2773}).DefaultTimeout(); 2806}).DefaultTimeout(); 2839var result = await target.GetAppHostInformationAsync().DefaultTimeout(); 2876var 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)
39await app.ResourceNotifications.WaitForResourceHealthyAsync(yarp.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 42var response = await clientA.GetAsync("/servicea/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 44var body = await response.Content.ReadAsStringAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 82await app.ResourceNotifications.WaitForResourceHealthyAsync(yarp.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 85var response = await clientA.GetAsync("/servicea/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 87var body = await response.Content.ReadAsStringAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
Dashboard\DashboardEventHandlersTests.cs (1)
292.DefaultTimeout();
Dashboard\DashboardResourceTests.cs (2)
778var log = await testLogger.FirstLogTask.DefaultTimeout(); 804var manifest = await ManifestUtils.GetManifestOrNull(dashboard).DefaultTimeout();
Dashboard\DashboardServiceDataTerminalTests.cs (5)
37var snapshot = await data.WaitForResourceAsync(resource.Name, _ => true).DefaultTimeout(); 52var snapshot = await data.WaitForResourceAsync(resource.Name, r => HasTerminalProperty(r, "terminal.enabled")).DefaultTimeout(); 89var snapshot = await data.WaitForResourceAsync("myapp-ccc", r => HasTerminalProperty(r, "terminal.enabled")).DefaultTimeout(); 112var snapshot = await data.WaitForResourceAsync(resource.Name, r => HasTerminalProperty(r, "terminal.enabled")).DefaultTimeout(); 137var snapshot = await data.WaitForResourceAsync("myapp-unknown", r => HasTerminalProperty(r, "terminal.enabled")).DefaultTimeout();
Dashboard\DashboardServiceTests.cs (35)
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(); 501var update = await writer.ReadNextAsync().DefaultTimeout(); 518Assert.Equal(result, (await resultTask.DefaultTimeout()).Data); 528Assert.True((await resultTask.DefaultTimeout()).Canceled); 573var update = await writer.ReadNextAsync().DefaultTimeout(); 607var update = await writer.ReadNextAsync().DefaultTimeout(); 626var promptResult = await prompt.DefaultTimeout(); 629var complete = await writer.ReadNextAsync().DefaultTimeout(); 673Assert.True((await prompt.DefaultTimeout()).Canceled); 735var update = await writer.ReadNextAsync().DefaultTimeout(); 749var result = await resultTask.DefaultTimeout(); 791await Assert.ThrowsAnyAsync<Exception>(() => task).DefaultTimeout(); 833await Assert.ThrowsAnyAsync<Exception>(() => task).DefaultTimeout(); 1430var initial = await responses.ReadNextAsync().DefaultTimeout(); 1434var recovery = WatchTerminalsUpdate.Parser.ParseFrom((await responses.ReadNextAsync().DefaultTimeout()).ToByteArray()); 1453var change = await responses.ReadNextAsync().DefaultTimeout(); 1531var status = await responses.ReadNextAsync().DefaultTimeout(); 1552new CloseTerminalRequest { TerminalId = "unknown" }, TestServerCallContext.Create()).DefaultTimeout(); 1583new CloseTerminalRequest { TerminalId = terminal.Id }, TestServerCallContext.Create())).DefaultTimeout(); 1612new CloseTerminalRequest { TerminalId = terminal.Id }, TestServerCallContext.Create())).DefaultTimeout(); 1643var response = await service.CloseTerminal(request, TestServerCallContext.Create()).DefaultTimeout(); 1648Assert.NotNull(await service.CloseTerminal(request, TestServerCallContext.Create()).DefaultTimeout()); 1687var exception = await Assert.ThrowsAnyAsync<OperationCanceledException>(() => close).DefaultTimeout(); 1717await run.DefaultTimeout(); 1769var exception = await Assert.ThrowsAnyAsync<OperationCanceledException>(() => close).DefaultTimeout(); 1792var log = await logs.Reader.ReadAsync().AsTask().DefaultTimeout(); 1828var log = await logs.Reader.ReadAsync().AsTask().DefaultTimeout();
Dashboard\ResourcePublisherTests.cs (1)
67var change = Assert.Single(await tcs.Task.DefaultTimeout());
Dcp\DcpExecutorTests.cs (15)
259await endpointEventsProcessed.Reader.ReadAsync().AsTask().DefaultTimeout(); 268await endpointEventsProcessed.Reader.ReadAsync().AsTask().DefaultTimeout(); 368var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => executor.RunApplicationAsync()).DefaultTimeout(); 2325Assert.Equal(1, await terminalLogCountAtNotification.Task.DefaultTimeout()); 2576var followStdErrPipe = await followStdErrPipeChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 3064var change = await changes.Reader.ReadAsync().AsTask().DefaultTimeout(); 3106var change = await changes.Reader.ReadAsync().AsTask().DefaultTimeout(); 4514var allocatedPort = await allocatedPortChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4515var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4563var connectionStringAvailableResource = await connectionStringAvailableChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4645var resolvedUrl = await resolvedUrlChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4687var resolvedUrl = await resolvedUrlChannel.Reader.ReadAsync().AsTask().DefaultTimeout(); 4866var failedContext = await tcs.Task.DefaultTimeout(); 9696var allocatedEndpoint = await endpoint.AllAllocatedEndpoints.Single(x => x.NetworkID == network).Snapshot.GetValueAsync().DefaultTimeout(); 10614await Assert.ThrowsAnyAsync<OperationCanceledException>(() => startTask).DefaultTimeout();
Dcp\KubernetesServiceTests.cs (48)
103}).DefaultTimeout(); 114await Assert.ThrowsAnyAsync<OperationCanceledException>(() => moveNext).DefaultTimeout(); 127await moveNext.DefaultTimeout(); 183}).DefaultTimeout(); 193Assert.True(await moveNext.DefaultTimeout()); 228await moveNext.DefaultTimeout(); 271}).DefaultTimeout(); 279.DefaultTimeout(TestConstants.LongTimeoutDuration); 283await Assert.ThrowsAnyAsync<OperationCanceledException>(() => moveNext).DefaultTimeout(); 291await moveNext.DefaultTimeout(); 336}).DefaultTimeout(); 344Assert.True(await moveNext.DefaultTimeout()); 351Assert.True(await moveNext.DefaultTimeout()); 361await Assert.ThrowsAnyAsync<OperationCanceledException>(() => moveNext).DefaultTimeout(); 380context.RequestAborted)).DefaultTimeout(); 387var error = await Assert.ThrowsAsync<KubernetesException>(() => moveNext).DefaultTimeout(); 396await Assert.ThrowsAnyAsync<OperationCanceledException>(() => moveNext).DefaultTimeout(); 434}).DefaultTimeout(); 443Assert.True(await moveNext.DefaultTimeout()); 453await Assert.ThrowsAnyAsync<OperationCanceledException>(() => moveNext).DefaultTimeout(); 482context.Response.WriteAsync(line + (appendNewline ? "\n" : string.Empty), context.RequestAborted)).DefaultTimeout(); 489await Assert.ThrowsAnyAsync<JsonException>(() => moveNext).DefaultTimeout(); 496await Assert.ThrowsAnyAsync<OperationCanceledException>(() => moveNext).DefaultTimeout(); 534}).DefaultTimeout(); 584}).DefaultTimeout(); 625}).DefaultTimeout(); 632Assert.True(await moveNext.DefaultTimeout()); 641await Assert.ThrowsAnyAsync<OperationCanceledException>(() => moveNext).DefaultTimeout(); 679}).DefaultTimeout(); 688Assert.True(await moveNext.DefaultTimeout()); 700await moveNext.DefaultTimeout(); 754}).DefaultTimeout(); 803}).DefaultTimeout(); 809var error = await Assert.ThrowsAsync<HttpOperationException>(WatchAsync).DefaultTimeout(); 814var error = await Assert.ThrowsAsync<KubernetesException>(WatchAsync).DefaultTimeout(); 845return TestDcpApiServer.StartAsync(certificateFixture.Certificate, cancellationToken, successfulRequestNumber, requestHandler).DefaultTimeout(); 1456var exception = await Assert.ThrowsAsync<TimeoutRejectedException>(() => createTask).DefaultTimeout(); 1498var exception = await Assert.ThrowsAsync<TimeoutRejectedException>(() => createTask).DefaultTimeout(); 1550Assert.Empty(await service.ListAsync<Container>(cancellationToken: cts.Token).DefaultTimeout()); 1552var result = await service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token).DefaultTimeout(); 1638var exception = await Assert.ThrowsAsync<TimeoutRejectedException>(() => createTask).DefaultTimeout(); 1729var result = await listTask.DefaultTimeout(); 1755var result = await listTask.DefaultTimeout(); 1834await Assert.ThrowsAsync<TimeoutRejectedException>(() => listTask).DefaultTimeout(); 1887var result = await createTask.DefaultTimeout(); 2132await Assert.ThrowsAnyAsync<OperationCanceledException>(() => watchTask).DefaultTimeout(); 2162await using var stream = await service.GetLogStreamAsync(Container.Create("frontend", "test-image"), "stdout", cts.Token).DefaultTimeout(); 2231var 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 (49)
80}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 125}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 154}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 353await rns.WaitForResourceAsync(normalResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 356await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 405await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 458}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 478}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 499}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 787await Task.WhenAll(clientA.GetStringAsync("/pid"), clientC.GetStringAsync("/pid")).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 800var pidText = await clientB.GetStringAsync(url).DefaultTimeout(); 837var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 894var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 938var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1013var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1148r => r.Spec.Env != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1188r => r.Spec.Env != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1229var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1237redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Exited, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1269var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1276serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Finished, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1281serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.LongTimeoutDuration); 1311var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, $"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1314var serviceA = await KubernetesHelper.GetResourceByNameAsync<Executable>(kubernetes, $"{testName}-servicea", suffix!, r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1317var nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1392var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1429var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1524r => r.Status?.State == ContainerState.FailedToStart && (r.Status?.Message.Contains("bob") ?? false)).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1553$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1581$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1610$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1616var containerVolume = Assert.Single(await s.ListAsync<ContainerVolume>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout)); 1713var allocatedEndpoint = await allocatedEndpointSnapshot.Snapshot.GetValueAsync().DefaultTimeout(); 1738var result = await client.GetStringAsync("pid").DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1750}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1812var value = await client.GetStringAsync($"{httpsEndpoint}urls", token).DefaultTimeout(); 1855await clientA.GetStringAsync("/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1858var exeList = await s.ListAsync<Executable>().DefaultTimeout(); 1867var list = await s.ListAsync<Container>().DefaultTimeout(); 1880.DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1929await clientA.GetStringAsync("/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1933var serviceList = await s.ListAsync<Service>().DefaultTimeout(); 1936var exeList = await s.ListAsync<Executable>().DefaultTimeout(); 1945var list = await s.ListAsync<Container>().DefaultTimeout(); 1958.DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 2022var networks = await s.ListAsync<ContainerNetwork>().DefaultTimeout(); 2064.DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 2073.DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 2249.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)
343).DefaultTimeout(); 370).DefaultTimeout(); 397).DefaultTimeout(); 471CancellationToken.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 (23)
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(); 456var result = await resultTask.DefaultTimeout(); 874var result = await resultTask.DefaultTimeout(); 1056var result = await resultTask.DefaultTimeout(); 1143}).DefaultTimeout(); 1176var result = await resultTask.DefaultTimeout(); 1212var result = await resultTask.DefaultTimeout(); 1246var result = await resultTask.DefaultTimeout(); 1266var result = await resultTask.DefaultTimeout(); 1287var result = await resultTask.DefaultTimeout(); 1306await 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(); 545var manifest = await ManifestUtils.GetManifest(param.Resource).DefaultTimeout(); 571var destManifest = await ManifestUtils.GetManifest(destContainer.Resource).DefaultTimeout(); 614var destManifest = await ManifestUtils.GetManifest(destContainer.Resource).DefaultTimeout(); 665var destManifest = await ManifestUtils.GetManifest(destContainer.Resource).DefaultTimeout();
Orchestrator\ApplicationOrchestratorTests.cs (6)
738TestContext.Current.CancellationToken).DefaultTimeout(); 796TestContext.Current.CancellationToken).DefaultTimeout(); 847TestContext.Current.CancellationToken).DefaultTimeout(); 901TestContext.Current.CancellationToken).DefaultTimeout(); 909TestContext.Current.CancellationToken).DefaultTimeout(); 1096TestContext.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(); 1311await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("firstValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1316await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("secondValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1383var result = await parameterProcessor.SetParameterCoreAsync(secretParam, CreateSetParameterArguments("replacement-secret"), CancellationToken.None).DefaultTimeout(); 1443await Assert.ThrowsAnyAsync<OperationCanceledException>(() => parameter.SetValueAsync("canceled-notification-secret", cts.Token)).DefaultTimeout(); 1691Assert.Equal("existingValue", await parameterWithGenerateDefault.WaitForValueTcs.Task.DefaultTimeout()); 1828await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1831var result = await parameterProcessor.DeleteParameterCoreAsync(parameter, CreateDeleteParameterArguments(deleteFromUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1835var section = await capturingStateManager.AcquireSectionAsync($"Parameters:{parameter.Name}").DefaultTimeout(); 1847await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1849var result = await parameterProcessor.DeleteParameterCoreAsync(parameter, new InteractionInputCollection([]), CancellationToken.None).DefaultTimeout(); 1864await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1866var result = await parameterProcessor.DeleteParameterCoreAsync(parameter, CreateDeleteParameterArguments(deleteFromUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1885await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1886await parameterProcessor.DeleteParameterCoreAsync(parameter, CreateDeleteParameterArguments(), CancellationToken.None).DefaultTimeout(); 1888var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1893var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 1912await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue"), CancellationToken.None).DefaultTimeout(); 1914var result = await parameterProcessor.DeleteParameterCoreAsync(parameter, CreateDeleteParameterArguments(), CancellationToken.None).DefaultTimeout(); 1990await Assert.ThrowsAsync<MissingParameterValueException>(() => parameter.GetValueAsync(CancellationToken.None).AsTask()).DefaultTimeout(); 2054await Assert.ThrowsAsync<MissingParameterValueException>(() => parameter.GetValueAsync(CancellationToken.None).AsTask()).DefaultTimeout(); 2090var section = await stateManager.AcquireSectionAsync(configurationKey).DefaultTimeout(); 2151var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2208Assert.Null(await waitingValue.DefaultTimeout()); 2235() => parameter.GetValueAsync(CancellationToken.None).AsTask()).DefaultTimeout(); 2285await Assert.ThrowsAsync<MissingParameterValueException>(() => parameter.GetValueAsync(CancellationToken.None).AsTask()).DefaultTimeout(); 2321await Assert.ThrowsAsync<MissingParameterValueException>(() => parameter.GetValueAsync(CancellationToken.None).AsTask()).DefaultTimeout(); 2326var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2330var inputsInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2396var section = await capturingStateManager.AcquireSectionAsync($"Parameters:{parameter.Name}").DefaultTimeout(); 2399var notificationInteraction = await testInteractionService.Interactions.Reader.ReadAsync().AsTask().DefaultTimeout(); 2403var 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(); 602var manifest = await ManifestUtils.GetManifest(resource).DefaultTimeout(); 650var 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(); 233var 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)
1235var result = await pendingResult.WaitAsync(TestContext.Current.CancellationToken).DefaultTimeout(); 1299var 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(); 1393var result = await resultTask.DefaultTimeout(); 1471CancellationToken.None).DefaultTimeout(); 1526CancellationToken.None).DefaultTimeout(); 1560CancellationToken.None).DefaultTimeout(); 1594CancellationToken.None).DefaultTimeout(); 1875var result = await resultTask.DefaultTimeout(); 1925var 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)
450var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 478var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 505var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 532var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 559var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 586var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 613var manifest = await ManifestUtils.GetManifest(container.Resource).DefaultTimeout(); 644var manifest = await ManifestUtils.GetManifest(project.Resource).DefaultTimeout(); 712var manifest = await ManifestUtils.GetManifest(project.Resource).DefaultTimeout(); 737var manifests = await ManifestUtils.GetManifests([container0.Resource, container1.Resource]).DefaultTimeout(); 867var manifest = await ManifestUtils.GetManifest(project.Resource).DefaultTimeout();
WithEnvironmentTests.cs (1)
168)).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)
306}).DefaultTimeout(); 342}).DefaultTimeout();
WithUrlsTests.cs (13)
151Assert.NotNull(await tcs.Task.DefaultTimeout()); 409e => e.Snapshot.Urls.Length == 1).DefaultTimeout(); 434e => e.Snapshot.Urls.Length == 3).DefaultTimeout(); 469&& e.Snapshot.Urls.All(url => !url.IsInactive)).DefaultTimeout(); 693e => e.Snapshot.State == KnownResourceStates.Running && e.Snapshot.Urls.Length == 4).DefaultTimeout(); 1085default).DefaultTimeout(); 1090resourceBClient.GetStringAsync("/")).DefaultTimeout(); 1135default).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1142var startResult = await app.ResourceCommands.ExecuteCommandAsync(resourceA.Resource, KnownResourceCommands.StartCommand).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1145Assert.Equal("Hello World!", await resourceAClient.GetStringAsync("/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout)); 1150default).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1153var stopResult = await app.ResourceCommands.ExecuteCommandAsync(resourceA.Resource, KnownResourceCommands.StopCommand).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1159default).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);