CancellationTokenRegistration

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\CancellationTokenSource.cs (1)

680return new CancellationTokenRegistration(id, node);

Backchannel\AuxiliaryBackchannelMonitor.cs (1)

741using var cancellationRegistration = cancellationToken.Register(() => tcs.TrySetCanceled());

Commands\BaseCommand.cs (1)

147using var stoppingMessageRegistration = cancellationToken.Register(() =>

Git\GitRepository.cs (3)

42using var cancellationRegistration = RegisterProcessKillOnCancellation(process, cancellationToken); 128using var cancellationRegistration = RegisterProcessKillOnCancellation(process, cancellationToken); 181private static CancellationTokenRegistration RegisterProcessKillOnCancellation(Process process, CancellationToken cancellationToken)

Processes\WindowsProcessInterop.cs (1)

715var ctr = cancellationToken.Register(static s => ((TaskCompletionSource)s!).TrySetResult(), tcs);

Projects\ProcessGuestLauncher.cs (1)

159using var _ = cancellationToken.Register(() =>

Telemetry\InternalMicrosoftDetector.cs (1)

294using var stageTimeoutRegistration = stageTimeout.Token.Register(

Backchannel\ResourceSnapshotWatcherTests.cs (2)

32using var registration = cancellationToken.Register(() => getCancellationRequested.TrySetResult()); 671using var registration = cancellationToken.Register(

Commands\DescribeCommandTests.cs (1)

1064using var registration = cancellationToken.Register(() => waitForCancellation.TrySetResult());

Commands\LogsCommandTests.cs (1)

1702using var registration = cancellationToken.Register(() => waitForCancellation.TrySetResult());

Processes\LauncherLivenessMonitorTests.cs (1)

36await using var registration = runCts.Token.Register(() => cancelTcs.TrySetResult());

Telemetry\InternalMicrosoftDetectorTests.cs (1)

261using var registration = cancellationToken.Register(stageCancelled.SetResult);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

Model\TraceLinkHelpers.cs (1)

49using var registration = cancellationToken.Register(cts.Cancel);

Otlp\Storage\SqliteTelemetryRepository.Logs.cs (4)

199using var interrupt = connection.RegisterInterrupt(cancellationToken); 279using var interrupt = connection.RegisterInterrupt(cancellationToken); 443using var interrupt = connection.RegisterInterrupt(cancellationToken); 474using var interrupt = connection.RegisterInterrupt(cancellationToken);

Otlp\Storage\SqliteTelemetryRepository.Metrics.Reads.cs (1)

119using var interrupt = connection.RegisterInterrupt(cancellationToken);

Otlp\Storage\SqliteTelemetryRepository.Traces.Reads.cs (5)

20using var interrupt = connection.RegisterInterrupt(cancellationToken); 60using var interrupt = connection.RegisterInterrupt(cancellationToken); 392using var interrupt = connection.RegisterInterrupt(cancellationToken); 561using var interrupt = connection.RegisterInterrupt(cancellationToken); 593using var interrupt = connection.RegisterInterrupt(cancellationToken);

ServiceClient\DashboardDataSourceInitializer.cs (1)

11private CancellationTokenRegistration _startedRegistration;

ServiceClient\TracingSqliteConnection.cs (2)

55/// Dispose the returned registration before closing the connection. <see cref="CancellationTokenRegistration.Dispose"/> 59internal CancellationTokenRegistration RegisterInterrupt(CancellationToken cancellationToken)

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

TelemetryRepositoryTests\SqliteTelemetryPersistenceTests.cs (1)

40using var interrupt = connection.RegisterInterrupt(token);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

ApplicationModel\ResourceLoggerService.cs (1)

462using var _ = _logStreamCts.Token.Register(() => channel.Writer.TryComplete());

Dcp\DcpHost.cs (1)

462using var _ = cancellationToken.Register(s => ((NetworkStream)s!).Close(), stream);

InteractionService.cs (4)

124using var _ = cancellationToken.Register(OnInteractionCancellation, state: newState); 206using var _ = cancellationToken.Register(OnInteractionCancellation, state: newState); 277using var _ = cancellationToken.Register(OnInteractionCancellation, state: newState); 305using var ctRegistration = cancellationToken.Register(OnInteractionCancellation, state: newState);

Lifecycle\TerminalHostOrphanCleanupService.cs (1)

22private readonly CancellationTokenRegistration _applicationStoppedRegistration;

Orchestrator\ParameterProcessor.cs (1)

581using var registration = allParametersResolvedToken.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), allParametersResolved);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

AzureEnvironmentResourceExtensionsTests.cs (2)

5639using var registration = cancellationToken.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), OperationCancellationRequested); 5693using var registration = cancellationToken.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), OperationCancellationRequested);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

BrowserLogsCdpConnection.cs (1)

242using var registration = sendCts.Token.Register(static state =>

src\Aspire.Hosting.Browsers\BrowserLogsCdpConnection.cs (1)

242using var registration = sendCts.Token.Register(static state =>

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

DevTunnelCli.cs (1)

262using var ctr = cancellationToken.Register(() =>

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

DotnetProjectBuildArtifactManager.cs (3)

24private CancellationTokenRegistration _applicationStoppedRegistration; 120var registration = applicationLifetime.ApplicationStopped.Register( 147CancellationTokenRegistration registration;

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

FoundryLocalService.cs (3)

317using var cancellationRegistration = linkedCancellation.Token.Register(static state => 404using var cancellationRegistration = cancellationToken.Register(static state => KillProcess((Process)state!), process); 425using var startCancellationRegistration = startCancellation.Token.Register(static state => KillProcess((Process)state!), process);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

MauiBuildQueueTests.cs (2)

43using var _ = cts.Token.Register(() => throw new InvalidOperationException("callback failure")); 1255using var reg = cancellationToken.Register(() => tcs.TrySetCanceled(cancellationToken));

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

JsonRpcServer.cs (1)

240using var registration = cancellationToken.Register(() =>

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

ParentProcessWatchdogTests.cs (2)

45using var registration = operationCts.Token.Register(static () => throw new InvalidOperationException("simulated cancellation callback failure")); 64using var registration = operationCts.Token.Register(() =>

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

tests\Shared\AsyncTestHelpers.cs (2)

264var registration = token.Register(static state => ((TaskCompletionSource)state!).TrySetResult(), tcs); 265tcs.Task.ContinueWith(static (_, state) => ((CancellationTokenRegistration)state!).Dispose(), registration, TaskScheduler.Default);

parent\dotnet\Commands\Test\MTP\IPC\HttpTestHostGateway.cs (1)

22private readonly CancellationTokenRegistration _cancellationRegistration;

src\roslyn\src\Dependencies\Threading\AsyncBatchingWorkQueue`2.cs (1)

66private readonly CancellationTokenRegistration _externalCancellationTokenRegistration;

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

334using var _ = cancellationToken.Register(

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

552private CancellationTokenRegistration _cancellationTokenRegistration;

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)

89CancellationTokenRegistration cancellationTokenRegistration = default;

Commands\GetDocumentCommandWorker.cs (1)

139using (var registration = applicationLifetime.ApplicationStarted.Register(() => waitForStartTcs.TrySetResult(null)))

Virtualization\Virtualize.cs (1)

334using var renderReg = token.Register(static state => ((TaskCompletionSource)state!).TrySetCanceled(), renderCommitTcs);

DebugProxyLauncher.cs (2)

76var ctr = default(CancellationTokenRegistration);

Internal\HttpContextStreamWriter.cs (1)

47CancellationTokenRegistration? registration = null;

DeferredHostBuilder.cs (2)

148using var reg = cancellationToken.UnsafeRegister(_ => _hostStartedTcs.TrySetCanceled(), null); 152using var reg2 = _host.Services.GetRequiredService<IHostApplicationLifetime>().ApplicationStarted.UnsafeRegister(_ => _hostStartedTcs.TrySetResult(), null);

MessagePump.cs (1)

224using var registration = cancellationToken.Register(static state =>

RequestProcessing\ClientCertLoader.cs (1)

31private readonly CancellationTokenRegistration _cancellationRegistration;

RequestProcessing\RequestContext.cs (1)

189internal CancellationTokenRegistration RegisterForCancellation(CancellationToken cancellationToken)

RequestProcessing\RequestStream.cs (2)

221var cancellationRegistration = default(CancellationTokenRegistration);

RequestProcessing\RequestStreamAsyncResult.cs (2)

20private readonly CancellationTokenRegistration _cancellationRegistration; 22internal RequestStreamAsyncResult(RequestStream requestStream, object? userState, AsyncCallback? callback, byte[] buffer, int offset, int size, uint dataAlreadyRead, CancellationTokenRegistration cancellationRegistration)

RequestProcessing\ResponseStreamAsyncResult.cs (3)

22private readonly CancellationTokenRegistration _cancellationRegistration; 29var cancellationRegistration = default(CancellationTokenRegistration);

Core\IISHttpServer.cs (1)

36private CancellationTokenRegistration _cancellationTokenRegistration;

Internal\HttpConnection.cs (1)

117using var closedRegistration = _context.ConnectionContext.ConnectionClosed.Register(state => ((HttpConnection)state!).OnConnectionClosed(), this);

Internal\WebTransport\WebTransportSession.cs (1)

21private readonly CancellationTokenRegistration _connectionClosedRegistration;

Internal\WebTransport\WebTransportStream.cs (1)

18private readonly CancellationTokenRegistration _connectionClosedRegistration;

HubConnection.cs (2)

1011var registration = cancellationToken.Register(static state => 1362var registration = cancellationToken.Register(static state =>

Internal\InvocationRequest.cs (3)

17private readonly CancellationTokenRegistration _cancellationTokenRegistration; 18private CancellationTokenRegistration _cancelInvocationRegistration; 70public void AttachCancelInvocationRegistration(CancellationTokenRegistration registration)

src\aspnetcore\src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (3)

87var registration = cancellationToken.Register((ctsState) => 101private readonly CancellationTokenRegistration _cancellationTokenRegistration; 105public CancelableEnumerator(IAsyncEnumerator<T> asyncEnumerator, CancellationTokenRegistration registration)

HubConnectionContext.cs (3)

37private readonly CancellationTokenRegistration _closedRegistration; 38private readonly CancellationTokenRegistration? _closedRequestedRegistration; 615using (var registration = cts.Token.UnsafeRegister(_cancelReader, input))

src\aspnetcore\src\SignalR\common\Shared\AsyncEnumerableAdapters.cs (3)

87var registration = cancellationToken.Register((ctsState) => 101private readonly CancellationTokenRegistration _cancellationTokenRegistration; 105public CancelableEnumerator(IAsyncEnumerator<T> asyncEnumerator, CancellationTokenRegistration registration)

src\aspnetcore\src\SignalR\common\Shared\ClientResultsManager.cs (1)

122private CancellationTokenRegistration _tokenRegistration;

RedisHubLifetimeManager.cs (1)

541CancellationTokenRegistration? tokenRegistration = null;

src\aspnetcore\src\SignalR\common\Shared\ClientResultsManager.cs (1)

122private CancellationTokenRegistration _tokenRegistration;

HttpContextBuilder.cs (1)

86var registration = cancellationToken.Register(ClientInitiatedAbort);

ResponseBodyReaderStream.cs (1)

86using var registration = cancellationToken.Register(Cancel);

BackEnd\TaskExecutionHost\TaskExecutionHost.cs (1)

110private CancellationTokenRegistration _cancellationTokenRegistration;

DiagnosticAnalyzer\AnalyzerDriver.cs (2)

71private CancellationTokenRegistration? _lazyQueueRegistration; 652_lazyQueueRegistration = default(CancellationTokenRegistration);

DiagnosticAnalyzer\AsyncQueue.cs (1)

364internal CancellationTokenRegistration CancellationTokenRegistration { get; set; }

src\roslyn\src\Dependencies\Threading\AsyncBatchingWorkQueue`2.cs (1)

66private readonly CancellationTokenRegistration _externalCancellationTokenRegistration;

src\roslyn\src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

387protected readonly CancellationTokenRegistration _registration;

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

334using var _ = cancellationToken.Register(

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

552private CancellationTokenRegistration _cancellationTokenRegistration;

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)

89CancellationTokenRegistration cancellationTokenRegistration = default;

src\roslyn\src\Dependencies\Threading\AsyncBatchingWorkQueue`2.cs (1)

66private readonly CancellationTokenRegistration _externalCancellationTokenRegistration;

src\roslyn\src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

387protected readonly CancellationTokenRegistration _registration;

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

334using var _ = cancellationToken.Register(

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

552private CancellationTokenRegistration _cancellationTokenRegistration;

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)

89CancellationTokenRegistration cancellationTokenRegistration = default;

src\roslyn\src\Dependencies\Threading\AsyncBatchingWorkQueue`2.cs (1)

66private readonly CancellationTokenRegistration _externalCancellationTokenRegistration;

src\roslyn\src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

387protected readonly CancellationTokenRegistration _registration;

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

334using var _ = cancellationToken.Register(

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

552private CancellationTokenRegistration _cancellationTokenRegistration;

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)

89CancellationTokenRegistration cancellationTokenRegistration = default;

src\roslyn\src\Dependencies\Threading\AsyncBatchingWorkQueue`2.cs (1)

66private readonly CancellationTokenRegistration _externalCancellationTokenRegistration;

src\roslyn\src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

387protected readonly CancellationTokenRegistration _registration;

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

334using var _ = cancellationToken.Register(

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

552private CancellationTokenRegistration _cancellationTokenRegistration;

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)

89CancellationTokenRegistration cancellationTokenRegistration = default;

src\roslyn\src\Dependencies\Threading\AsyncBatchingWorkQueue`2.cs (1)

66private readonly CancellationTokenRegistration _externalCancellationTokenRegistration;

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

334using var _ = cancellationToken.Register(

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

552private CancellationTokenRegistration _cancellationTokenRegistration;

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)

89CancellationTokenRegistration cancellationTokenRegistration = default;

HandleableCollection.cs (2)

144using CancellationTokenRegistration _ = cancellation.Token.Register( 177using CancellationTokenRegistration _ = token.Register(() => completionSource.TrySetCanceled(token));

Build\ProjectBuildManager.cs (1)

50using var _ = buildCancellationTokenSource.Token.Register(manager.CancelAllSubmissions);

src\sdk\src\Dotnet.Watch\AspireService\Helpers\WebSocketConnection.cs (3)

24private CancellationTokenRegistration? _cancelTokenRegistration; 31CancellationTokenRegistration? registrationToDispose = null; 49var cancelTokenRegistration = HttpRequestAborted.Register(() => callback(this));

Internal\DefaultHybridCache.StampedeStateT.cs (1)

91using CancellationTokenRegistration reg = token.Register(static obj =>

StampedeTests.cs (4)

101using var reg = ct.Register(() => Interlocked.Increment(ref cancelCount)); 137using var reg = ct.Register(() => Interlocked.Increment(ref cancelCount)); 190using var reg = ct.Register(() => Interlocked.Increment(ref cancelCount)); 271using var reg = ct.Register(() => Interlocked.Increment(ref cancelCount));

Internal\ConsoleLifetime.cs (2)

23private CancellationTokenRegistration _applicationStartedRegistration; 24private CancellationTokenRegistration _applicationStoppingRegistration;

HostingAbstractionsHostExtensions.cs (1)

94using var _ = token.Register(static state =>

SystemdLifetime.cs (2)

22private CancellationTokenRegistration _applicationStartedRegistration; 23private CancellationTokenRegistration _applicationStoppingRegistration;

JSRuntime.cs (2)

25private readonly ConcurrentDictionary<long, CancellationTokenRegistration> _cancellationRegistrations = new(); 190if (_cancellationRegistrations.TryRemove(taskId, out var registration))

API\BinaryClassificationExperiment.cs (1)

452using (var ctRegistration = ct.Register(() =>

API\MulticlassClassificationExperiment.cs (1)

430using (var ctRegistration = ct.Register(() =>

API\RegressionExperiment.cs (1)

384using (var ctRegistration = ct.Register(() =>

AutoMLExperiment\Runner\SweepablePipelineRunner.cs (1)

98using (var ctRegistration = ct.Register(() =>

parent\ref\mscorlib.cs (1)

1122[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.CancellationTokenRegistration))]

netstandard.cs (1)

2071[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.CancellationTokenRegistration))]

src\roslyn\src\Dependencies\Threading\AsyncBatchingWorkQueue`2.cs (1)

66private readonly CancellationTokenRegistration _externalCancellationTokenRegistration;

src\roslyn\src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

387protected readonly CancellationTokenRegistration _registration;

src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)

334using var _ = cancellationToken.Register(

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

552private CancellationTokenRegistration _cancellationTokenRegistration;

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\NonReentrantLock.cs (1)

89CancellationTokenRegistration cancellationTokenRegistration = default;

System\Data\Common\DbCommand.cs (3)

129CancellationTokenRegistration registration = default; 170CancellationTokenRegistration registration = default; 202CancellationTokenRegistration registration = default;

Microsoft\Win32\SafeHandles\SafeProcessHandle.cs (2)

360CancellationTokenRegistration ctr = default; 433CancellationTokenRegistration ctr = default;

System\IO\Pipelines\Pipe.cs (2)

1045CancellationTokenRegistration cancellationTokenRegistration = default; 1123CancellationTokenRegistration cancellationTokenRegistration = default;

System\IO\Pipelines\PipeAwaitable.cs (4)

19private CancellationTokenRegistration _cancellationTokenRegistration; 60if (_cancellationTokenRegistration == default(CancellationTokenRegistration)) 178public CancellationTokenRegistration ReleaseCancellationTokenRegistration(out CancellationToken cancellationToken) 181CancellationTokenRegistration cancellationTokenRegistration = _cancellationTokenRegistration;

System\IO\Pipelines\StreamPipeReader.cs (3)

244CancellationTokenRegistration reg = default; 320CancellationTokenRegistration reg = default; 391CancellationTokenRegistration reg = default;

System\IO\Pipelines\StreamPipeWriter.cs (1)

297CancellationTokenRegistration reg = default;

System\IO\Ports\SerialStream.Unix.cs (1)

1081private readonly CancellationTokenRegistration _cancellationTokenRegistration;

System\Net\Http\HttpContent.cs (1)

407CancellationTokenRegistration cancellationRegistration = cancellationToken.Register(static s => ((HttpContent)s!).Dispose(), this);

System\Net\Http\SocketsHttpHandler\ChunkedEncodingReadStream.cs (5)

168CancellationTokenRegistration ctr = _connection.RegisterCancellation(cancellationToken); 256CancellationTokenRegistration ctr = _connection!.RegisterCancellation(cancellationToken); 294private int ReadChunksFromConnectionBuffer(Span<byte> buffer, CancellationTokenRegistration cancellationRegistration) 313private ReadOnlyMemory<byte>? ReadChunkFromConnectionBuffer(int maxBytesToRead, CancellationTokenRegistration cancellationRegistration) 473CancellationTokenRegistration ctr = default;

System\Net\Http\SocketsHttpHandler\ConnectionCloseReadStream.cs (2)

57CancellationTokenRegistration ctr = connection.RegisterCancellation(cancellationToken); 118CancellationTokenRegistration ctr = connection.RegisterCancellation(cancellationToken);

System\Net\Http\SocketsHttpHandler\ContentLengthReadStream.cs (3)

82CancellationTokenRegistration ctr = _connection.RegisterCancellation(cancellationToken); 147CancellationTokenRegistration ctr = _connection.RegisterCancellation(cancellationToken); 213CancellationTokenRegistration ctr = default;

System\Net\Http\SocketsHttpHandler\CreditWaiter.cs (1)

22private CancellationTokenRegistration _registration;

System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)

1163private readonly CancellationTokenRegistration _cancellationRegistration;

System\Net\Http\SocketsHttpHandler\Http2Stream.cs (4)

77private CancellationTokenRegistration _waitSourceCancellation; 198CancellationTokenRegistration linkedRegistration = default; 1271CancellationTokenRegistration linkedRegistration = cancellationToken.CanBeCanceled && cancellationToken != _requestBodyCancellationSource.Token ? 1411private CancellationTokenRegistration RegisterRequestBodyCancellation(CancellationToken cancellationToken) =>

System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (1)

162CancellationTokenRegistration linkedTokenRegistration = cancellationToken.UnsafeRegister(cts => ((CancellationTokenSource)cts!).Cancel(), _requestBodyCancellationSource);

System\Net\Http\SocketsHttpHandler\HttpConnection.cs (2)

554CancellationTokenRegistration cancellationRegistration = RegisterCancellation(cancellationToken); 957private CancellationTokenRegistration RegisterCancellation(CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\RawConnectionStream.cs (3)

65CancellationTokenRegistration ctr = connection.RegisterCancellation(cancellationToken); 121CancellationTokenRegistration ctr = connection.RegisterCancellation(cancellationToken); 212CancellationTokenRegistration ctr = connection.RegisterCancellation(cancellationToken);

System\Net\Http\WinHttpResponseStream.cs (2)

116using var ctr = cancellationToken.Register(s => ((WinHttpResponseStream)s!).CancelPendingResponseStreamReadOperation(), this); 220using var ctr = token.Register(s => ((WinHttpResponseStream)s!).CancelPendingResponseStreamReadOperation(), this);

System\Net\NetworkInformation\Ping.cs (1)

717using CancellationTokenRegistration _ = cancellationToken.UnsafeRegister(static state => ((Ping)state!).SetCanceled(), this);

src\runtime\src\libraries\Common\src\System\Net\StreamBuffer.cs (1)

294private CancellationTokenRegistration _waitSourceCancellation;

System\Net\Quic\Internal\ResettableValueTaskSource.cs (2)

31private CancellationTokenRegistration _cancellationRegistration; 138CancellationTokenRegistration cancellationRegistration = default;

System\Net\Quic\Internal\ValueTaskSource.cs (2)

27private CancellationTokenRegistration _cancellationRegistration; 98CancellationTokenRegistration cancellationRegistration = default;

System\Net\Sockets\SocketAsyncContext.Unix.cs (1)

132public CancellationTokenRegistration CancellationRegistration;

System\Net\WebSockets\AsyncMutex.cs (1)

251public CancellationTokenRegistration CancellationRegistration { get; set; }

System\Net\WebSockets\ManagedWebSocket.cs (1)

787CancellationTokenRegistration registration = default;

System\Net\WebSockets\BrowserWebSockets\BrowserWebSocket.cs (1)

569using (var receiveRegistration = cancellationToken.Register(static s =>

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\CancellationToken.cs (16)

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\CancellationTokenRegistration.cs (15)

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\CancellationTokenSource.cs (7)

586internal CancellationTokenRegistration Register( 891private readonly CancellationTokenRegistration _reg1; 912private readonly CancellationTokenRegistration _reg1; 913private readonly CancellationTokenRegistration _reg2; 941private CancellationTokenRegistration[]? _linkingRegistrations; 945_linkingRegistrations = new CancellationTokenRegistration[tokens.Length]; 966CancellationTokenRegistration[]? linkingRegistrations = _linkingRegistrations;

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\PeriodicTimer.cs (1)

186private CancellationTokenRegistration _ctr;

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\SemaphoreSlim.cs (1)

338CancellationTokenRegistration cancellationTokenRegistration = cancellationToken.UnsafeRegister(s_cancellationTokenCanceledEventHandler, this);

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (5)

376internal StrongBox<CancellationTokenRegistration>? m_cancellationRegistration; // Task's registration with the cancellation token 777CancellationTokenRegistration ctr; 802props.m_cancellationRegistration = new StrongBox<CancellationTokenRegistration>(ctr); 3012private readonly CancellationTokenRegistration _registration; 6020private readonly CancellationTokenRegistration _registration;

src\runtime\artifacts\obj\System.Runtime\Release\net11.0\System.Runtime.Forwards.cs (1)

828[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.CancellationTokenRegistration))]

System\Runtime\InteropServices\JavaScript\JSHostImplementation.cs (1)

99using (var receiveRegistration = cancellationToken.Register(static s =>

System\Threading\Channels\AsyncOperation.cs (1)

36private readonly CancellationTokenRegistration _cancellationRegistration;

System\Threading\Channels\AsyncOperation.netcoreapp.cs (1)

13private static void Unregister(CancellationTokenRegistration registration) =>

System\Threading\RateLimiting\ConcurrencyLimiter.cs (1)

413private CancellationTokenRegistration _cancellationTokenRegistration;

System\Threading\RateLimiting\FixedWindowRateLimiter.cs (1)

465private CancellationTokenRegistration _cancellationTokenRegistration;

System\Threading\RateLimiting\SlidingWindowRateLimiter.cs (1)

527private CancellationTokenRegistration _cancellationTokenRegistration;

System\Threading\RateLimiting\TokenBucketRateLimiter.cs (1)

465private CancellationTokenRegistration _cancellationTokenRegistration;

System.Threading.Tasks.cs (1)

21[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.CancellationTokenRegistration))]

Base\DataflowBlock.cs (4)

355private readonly CancellationTokenRegistration _cancellationRegistration; 503Debug.Assert(_cancellationRegistration != default(CancellationTokenRegistration), 1131internal CancellationTokenRegistration _regFromExternalCancellationToken; 1424CancellationTokenRegistration registration = default;

Internal\Common.cs (2)

192CancellationTokenRegistration reg = cancellationToken.Register( 204completionTask.ContinueWith(static (completed, state) => ((CancellationTokenRegistration)state!).Dispose(),

System\Threading\Tasks\Parallel.cs (4)

953CancellationTokenRegistration ctr = (!parallelOptions.CancellationToken.CanBeCanceled) 954? default(CancellationTokenRegistration) 2552CancellationTokenRegistration ctr = (!parallelOptions.CancellationToken.CanBeCanceled) 2553? default(CancellationTokenRegistration)

System\Threading\Tasks\Parallel.ForEachAsync.cs (1)

511protected readonly CancellationTokenRegistration _registration;

System\Windows\Forms\Control_InvokeAsync.cs (2)

292CancellationTokenRegistration registration = cancellationToken.Register( 397CancellationTokenRegistration registration = cancellationToken.Register(