70 writes to CancellationToken
Aspire.Hosting (2)
ApplicationModel\ResourceCommandService.cs (2)
370CancellationToken = cancellationToken, 444CancellationToken = linkedCts.Token,
Aspire.Hosting.Azure.Tests (61)
AzureEnvironmentResourceExtensionsTests.cs (61)
360CancellationToken = CancellationToken.None, 414CancellationToken = CancellationToken.None, 752CancellationToken = CancellationToken.None, 833CancellationToken = CancellationToken.None, 917CancellationToken = CancellationToken.None, 1186CancellationToken = CancellationToken.None, 1250CancellationToken = CancellationToken.None, 1311CancellationToken = CancellationToken.None, 1372CancellationToken = CancellationToken.None, 1507CancellationToken = CancellationToken.None, 1565CancellationToken = CancellationToken.None, 1616CancellationToken = CancellationToken.None, 1628CancellationToken = CancellationToken.None, 1712CancellationToken = CancellationToken.None, 1796CancellationToken = CancellationToken.None, 1890CancellationToken = CancellationToken.None, 1961CancellationToken = CancellationToken.None, 2039CancellationToken = CancellationToken.None, 2053CancellationToken = CancellationToken.None, 2118CancellationToken = CancellationToken.None, 2182CancellationToken = CancellationToken.None, 2236CancellationToken = CancellationToken.None, 2296CancellationToken = CancellationToken.None, 2373CancellationToken = CancellationToken.None, 2387CancellationToken = CancellationToken.None, 2450CancellationToken = CancellationToken.None, 2467CancellationToken = CancellationToken.None, 2548CancellationToken = CancellationToken.None, 2594CancellationToken = CancellationToken.None, 2647CancellationToken = CancellationToken.None, 2661CancellationToken = CancellationToken.None, 2714CancellationToken = CancellationToken.None, 2787CancellationToken = CancellationToken.None, 2840CancellationToken = CancellationToken.None, 2900CancellationToken = CancellationToken.None, 2961CancellationToken = CancellationToken.None, 3031CancellationToken = CancellationToken.None, 3092CancellationToken = CancellationToken.None, 3161CancellationToken = CancellationToken.None, 3218CancellationToken = CancellationToken.None, 3281CancellationToken = CancellationToken.None, 3352CancellationToken = CancellationToken.None, 3407CancellationToken = CancellationToken.None, 3447CancellationToken = CancellationToken.None, 3521CancellationToken = CancellationToken.None, 3569CancellationToken = CancellationToken.None, 3625CancellationToken = CancellationToken.None, 3772CancellationToken = CancellationToken.None, 3851CancellationToken = CancellationToken.None, 3923CancellationToken = CancellationToken.None, 4003CancellationToken = CancellationToken.None, 4077CancellationToken = CancellationToken.None, 4129CancellationToken = CancellationToken.None, 4175CancellationToken = CancellationToken.None, 4221CancellationToken = CancellationToken.None, 4289CancellationToken = cts.Token, 4528CancellationToken = CancellationToken.None, 4580CancellationToken = CancellationToken.None, 4627CancellationToken = CancellationToken.None, 4675CancellationToken = CancellationToken.None, 4813CancellationToken = CancellationToken.None,
Aspire.Hosting.Blazor.Tests (2)
BlazorHostedExtensionsTests.cs (1)
251CancellationToken = CancellationToken.None,
WithBlazorAppTests.cs (1)
324CancellationToken = CancellationToken.None,
Aspire.Hosting.DevTunnels.Tests (3)
DevTunnelResourceBuilderExtensionsTests.cs (3)
472CancellationToken = CancellationToken.None, 524CancellationToken = CancellationToken.None, 572CancellationToken = CancellationToken.None,
Aspire.Hosting.Foundry.Tests (1)
PromptAgentTests.cs (1)
103CancellationToken = cts.Token,
Aspire.Hosting.Maui.Tests (1)
MauiBuildQueueTests.cs (1)
780CancellationToken = CancellationToken.None,
100 references to CancellationToken
Aspire.Hosting (22)
ApplicationModel\CommandOptions.cs (1)
137/// <see cref="ExecuteCommandContext.CancellationToken"/>.
ApplicationModel\CommandsConfigurationExtensions.cs (11)
32await orchestrator.StartResourceAsync(context.ResourceName, context.CancellationToken).ConfigureAwait(false); 65await orchestrator.StopResourceAsync(context.ResourceName, context.CancellationToken).ConfigureAwait(false); 104await orchestrator.StopResourceAsync(context.ResourceName, context.CancellationToken).ConfigureAwait(false); 105await orchestrator.StartResourceAsync(context.ResourceName, context.CancellationToken).ConfigureAwait(false); 237await Task.WhenAll(replicasToStop.Select(name => orchestrator.StopResourceAsync(name, context.CancellationToken))).ConfigureAwait(false); 249using var logCts = CancellationTokenSource.CreateLinkedTokenSource(context.CancellationToken); 269await orchestrator.StartResourceAsync(rebuilderInstanceName, context.CancellationToken).ConfigureAwait(false); 273using var buildTimeoutCts = CancellationTokenSource.CreateLinkedTokenSource(context.CancellationToken); 288catch (OperationCanceledException) when (!context.CancellationToken.IsCancellationRequested) 331await orchestrator.StartResourceAsync(name, context.CancellationToken).ConfigureAwait(false); 366catch (OperationCanceledException) when (context.CancellationToken.IsCancellationRequested)
Orchestrator\ParameterProcessor.cs (2)
267executeCommand: context => SetParameterCoreAsync(parameterResource, context.Arguments, context.CancellationToken), 303executeCommand: context => DeleteParameterCoreAsync(parameterResource, context.Arguments, context.CancellationToken),
ResourceBuilderExtensions.cs (8)
3293var processResult = await pendingProcessResult.WaitAsync(context.CancellationToken).ConfigureAwait(false); 3296catch (OperationCanceledException) when (context.CancellationToken.IsCancellationRequested) 3470CancellationToken = context.CancellationToken, 3732CancellationToken = context.CancellationToken, 3742response = await httpClient.SendAsync(request, context.CancellationToken).ConfigureAwait(false); 3750CancellationToken = context.CancellationToken, 3758return await GetDefaultHttpCommandResultAsync(response, commandOptions, context.CancellationToken).ConfigureAwait(false); 3760catch (OperationCanceledException) when (context.CancellationToken.IsCancellationRequested)
Aspire.Hosting.Azure (19)
AzureProvisioningController.cs (19)
738() => RunOperationAsync<bool>(model, new ResetStateIntent(ReprovisionAfterReset: true), context.CancellationToken), 740() => CreateEnvironmentCommandResultDataAsync(ResetProvisioningStateCommandName, model, context.CancellationToken), 751() => ChangeAzureContextCommandAsync(model, context.Arguments, context.CancellationToken), 753() => CreateEnvironmentCommandResultDataAsync(ChangeAzureContextCommandName, model, context.CancellationToken), 764() => ReprovisionAllAsync(model, context.CancellationToken), 766() => CreateEnvironmentCommandResultDataAsync(ReprovisionAllCommandName, model, context.CancellationToken), 777() => DeleteAzureResourcesAsync(model, context.CancellationToken), 779() => CreateEnvironmentCommandResultDataAsync(DeleteAzureResourcesCommandName, model, context.CancellationToken)); 790() => ChangeResourceLocationCommandAsync(model, resourceName, context.Arguments, context.CancellationToken), 792() => CreateResourceCommandResultDataAsync(ChangeResourceLocationCommandName, model, resourceName, context.CancellationToken), 806() => CreateAzureResourceInfoCommandResultDataAsync(model, resourceName, context.CancellationToken)); 817() => CancelResourceAsync(model, resourceName, context.CancellationToken), 819() => CreateResourceCommandResultDataAsync(CancelCommandName, model, resourceName, context.CancellationToken)); 830() => RunOperationAsync<DeleteAzureResourceResult>(model, new DeleteAzureResourceIntent(resourceName), context.CancellationToken), 832result => CreateDeleteAzureResourceCommandResultDataAsync(model, resourceName, result, context.CancellationToken)); 843() => ForgetResourceStateAsync(model, resourceName, context.CancellationToken), 845() => CreateResourceCommandResultDataAsync(ForgetStateCommandName, model, resourceName, context.CancellationToken)); 856() => ReprovisionResourceAsync(model, resourceName, context.CancellationToken), 858() => CreateResourceCommandResultDataAsync(ReprovisionResourceCommandName, model, resourceName, context.CancellationToken),
Aspire.Hosting.Azure.Kusto (3)
AzureKustoBuilderExtensions.cs (3)
384.GetValueAsync(context.CancellationToken) 399.GetValueAsync(context.CancellationToken) 423context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.Blazor (4)
BrowserDebuggerHelper.cs (4)
139await debugSessionLock.WaitAsync(context.CancellationToken).ConfigureAwait(false); 176await orchestrator.StartResourceAsync(dcpInstanceName, context.CancellationToken).ConfigureAwait(false); 236await debugSessionLock.WaitAsync(context.CancellationToken).ConfigureAwait(false); 246await orchestrator.StopResourceAsync(dcpInstanceName, context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.Browsers (3)
BrowserLogsBuilderExtensions.cs (3)
163await sessionManager.StartSessionAsync(browserLogsResource, currentConfiguration, context.ResourceName, url, context.CancellationToken).ConfigureAwait(false); 206return await configurationManager.ConfigureAsync(browserLogsResource, context.Arguments, context.CancellationToken).ConfigureAwait(false); 240var result = await sessionManager.CaptureScreenshotAsync(context.ResourceName, context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.Browsers.Tests (3)
src\Aspire.Hosting.Browsers\BrowserLogsBuilderExtensions.cs (3)
163await sessionManager.StartSessionAsync(browserLogsResource, currentConfiguration, context.ResourceName, url, context.CancellationToken).ConfigureAwait(false); 206return await configurationManager.ConfigureAsync(browserLogsResource, context.Arguments, context.CancellationToken).ConfigureAwait(false); 240var result = await sessionManager.CaptureScreenshotAsync(context.ResourceName, context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.DevTunnels (1)
DevTunnelResourceBuilderExtensions.cs (1)
828context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.EntityFrameworkCore (10)
EFResourceBuilderExtensions.cs (10)
431.BuildAsync(executionContext, context.Logger, context.CancellationToken).ConfigureAwait(false); 460context.CancellationToken).ConfigureAwait(false); 505process.StandardOutput, resourceLogger, isErrorOutput: false, captureBuilder: null, context.CancellationToken); 507process.StandardError, resourceLogger, isErrorOutput: true, captureBuilder: stderrBuilder, context.CancellationToken); 510await process.WaitForExitAsync(context.CancellationToken).ConfigureAwait(false); 850await resourceNotificationService.WaitForDependenciesAsync(migrationResource, context.CancellationToken).ConfigureAwait(false); 862context.CancellationToken, 939cancellationToken: context.CancellationToken).ConfigureAwait(false); 981cancellationToken: context.CancellationToken).ConfigureAwait(false); 1020cancellationToken: context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.Foundry (4)
PromptAgent\PromptAgentBuilderExtensions.cs (4)
84var endpoint = await agent.Project.Endpoint.GetValueAsync(ctx.CancellationToken).ConfigureAwait(false); 92ctx.CancellationToken.ThrowIfCancellationRequested(); 97var response = await responseClient.CreateResponseAsync(message, cancellationToken: ctx.CancellationToken).ConfigureAwait(false); 101catch (OperationCanceledException) when (ctx.CancellationToken.IsCancellationRequested)
Aspire.Hosting.Tests (3)
ResourceCommandServiceTests.cs (3)
1739await Task.Delay(Timeout.Infinite, e.CancellationToken); 1787await Task.Delay(Timeout.Infinite, e.CancellationToken); 1789catch (OperationCanceledException) when (e.CancellationToken.IsCancellationRequested)
Stress.AppHost (28)
CommandResources.cs (2)
1110await ExecuteCommandForAllResourcesAsync(c.Services, KnownResourceCommands.StopCommand, c.CancellationToken); 1119await ExecuteCommandForAllResourcesAsync(c.Services, KnownResourceCommands.StartCommand, c.CancellationToken);
InteractionCommands.cs (26)
20var resultTask1 = interactionService.PromptConfirmationAsync("Command confirmation", "Are you sure?", cancellationToken: commandContext.CancellationToken); 21var resultTask2 = interactionService.PromptMessageBoxAsync("Command confirmation", "Are you really sure?", new MessageBoxInteractionOptions { Intent = MessageIntent.Warning, ShowSecondaryButton = true }, cancellationToken: commandContext.CancellationToken); 125cancellationToken: commandContext.CancellationToken); 175cancellationToken: commandContext.CancellationToken); 261cancellationToken: commandContext.CancellationToken); 400cancellationToken: commandContext.CancellationToken); 500cancellationToken: commandContext.CancellationToken); 533cancellationToken: commandContext.CancellationToken); 541cancellationToken: commandContext.CancellationToken); 549cancellationToken: commandContext.CancellationToken); 559cancellationToken: commandContext.CancellationToken); 582cancellationToken: commandContext.CancellationToken); 773commandContext.CancellationToken); 810commandContext.CancellationToken); 837cancellationToken: commandContext.CancellationToken); 855using var cts = CancellationTokenSource.CreateLinkedTokenSource(commandContext.CancellationToken); 863await Task.Delay(10000, commandContext.CancellationToken); 889commandContext.CancellationToken); 912cancellationToken: commandContext.CancellationToken); 937commandContext.CancellationToken); 957commandContext.CancellationToken); 975await Task.Delay(10000, commandContext.CancellationToken); 1004cancellationToken: commandContext.CancellationToken); 1019var content = await file.ReadAllBytesAsync(commandContext.CancellationToken); 1051cancellationToken: commandContext.CancellationToken); 1071var bytes = await file.ReadAllBytesAsync(commandContext.CancellationToken);