1284 references to TaskCreationOptions
Aspire.Cli.Tests (1)
Hosting\CliOrphanDetectorTests.cs (1)
107var resourcesCreatedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Dashboard (3)
Components\Pages\Resources.razor.cs (1)
550_contextMenuClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResourceService\DashboardClient.cs (2)
45private readonly TaskCompletionSource _whenConnectedTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 46private readonly TaskCompletionSource _initialDataReceivedTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Dashboard.Components.Tests (7)
Layout\MainLayoutTests.cs (3)
35var messageShownTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 55var dismissedSettingSetTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 93var messageShownTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Pages\ConsoleLogsTests.cs (3)
131var subscribedResourceNameTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 295var subscribedResourceNameTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 359var subscribedResourceNameTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
Pages\LoginTests.cs (1)
36var tcs = new TaskCompletionSource<AuthenticationState>(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Dashboard.Tests (6)
Integration\OtlpGrpcServiceTests.cs (1)
199var tcs = new TaskCompletionSource<DashboardOptions>(TaskCreationOptions.RunContinuationsAsynchronously);
ResourceOutgoingPeerResolverTests.cs (1)
123var tcs = new TaskCompletionSource<ResourceViewModelSubscription>(TaskCreationOptions.RunContinuationsAsynchronously);
Telemetry\DashboardTelemetryServiceTests.cs (1)
99var tcs = new TaskCompletionSource<PostOperationRequest>(TaskCreationOptions.RunContinuationsAsynchronously);
TelemetryRepositoryTests\LogTests.cs (3)
451var newApplicationsTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 489var newLogsTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 575var tcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting (1)
Health\ResourceHealthCheckService.cs (1)
359_delayInterruptTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Azure (1)
Provisioning\Provisioners\AzureProvisioner.cs (1)
167r.AzureResource!.ProvisioningTaskCompletionSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Azure.Tests (1)
AzureSignalREmulatorFunctionalTest.cs (1)
111var messageTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Qdrant.Tests (1)
QdrantFunctionalTests.cs (1)
230var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Testing (4)
DistributedApplicationFactory.cs (4)
25private readonly TaskCompletionSource _startedTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 26private readonly TaskCompletionSource _exitTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 27private readonly TaskCompletionSource<DistributedApplicationBuilder> _builderTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 28private readonly TaskCompletionSource<DistributedApplication> _appTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Aspire.Hosting.Tests (8)
Dashboard\ResourcePublisherTests.cs (1)
36var tcs = new TaskCompletionSource<IReadOnlyList<ResourceSnapshotChange>>(TaskCreationOptions.RunContinuationsAsynchronously);
Dcp\DcpExecutorTests.cs (1)
1124var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
DistributedApplicationTests.cs (1)
341var tcs = new TaskCompletionSource<DistributedApplicationModel>(TaskCreationOptions.RunContinuationsAsynchronously);
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
177var beforeResourceStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Health\ResourceHealthCheckServiceTests.cs (4)
57var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 176var monitorStoppedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 568var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 616var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Client.ChannelLayer.IntegrationTests (18)
DuplexChannelShapeTests.4.0.0.cs (6)
93Task.Factory.FromAsync(factory.BeginOpen, factory.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 97Task.Factory.FromAsync(channel.BeginOpen, channel.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 110TaskCreationOptions.None).GetAwaiter().GetResult(); 111replyMessage = Task.Factory.FromAsync(channel.BeginReceive, channel.EndReceive, TaskCreationOptions.None).GetAwaiter().GetResult(); 125Task.Factory.FromAsync(channel.BeginClose, channel.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult(); 126Task.Factory.FromAsync(factory.BeginClose, factory.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult();
DuplexChannelWithSynchronizationContext.cs (2)
152Task.Factory.StartNew(() => SingleThreadedSyncContext_CallbackUsingDefaultSyncCtx_SyncCallNotBlocked_Helper(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 217Task.Factory.StartNew(() => SingleThreadedSyncContext_SyncCallNotBlocked_Helper(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
RequestReplyChannelShapeTests.4.0.0.cs (10)
143Task.Factory.FromAsync(factory.BeginOpen, factory.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 147Task.Factory.FromAsync(channel.BeginOpen, channel.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 159TaskCreationOptions.None).GetAwaiter().GetResult(); 171Task.Factory.FromAsync(channel.BeginClose, channel.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult(); 172Task.Factory.FromAsync(factory.BeginClose, factory.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult(); 199Task.Factory.FromAsync(factory.BeginOpen, factory.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 203Task.Factory.FromAsync(channel.BeginOpen, channel.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 215TaskCreationOptions.None).GetAwaiter().GetResult(); 228Task.Factory.FromAsync(channel.BeginClose, channel.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult(); 229Task.Factory.FromAsync(factory.BeginClose, factory.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult();
Client.TypedClient.IntegrationTests (5)
TypedProxyTests.4.0.0.cs (3)
72Task.Factory.StartNew(() => TypedProxyTests.ServiceContract_TypedProxy_AsyncBeginEnd_Call(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 106Task.Factory.StartNew(() => TypedProxyTests.ServiceContract_TypedProxy_AsyncTask_Call(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 160Task.Factory.StartNew(() => TypedProxyTests.ServiceContract_TypedProxy_Synchronous_Call(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
TypedProxyTests.4.1.0.cs (2)
26Task.Factory.StartNew(() => TypedProxyTests.ServiceContract_TypedProxy_NetTcpBinding_AsyncBeginEnd_Call(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 40Task.Factory.StartNew(() => TypedProxyTests.ServiceContract_TypedProxy_NetTcpBinding_AsyncTask_Call(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
Consumer (1)
ConsumerWorker.cs (1)
39}, stoppingToken, TaskCreationOptions.LongRunning, TaskScheduler.Current);
Contract.Service.IntegrationTests (13)
ServiceContractTests.4.0.0.cs (8)
307Task t = Task.Factory.FromAsync(factory.BeginOpen, factory.EndOpen, TaskCreationOptions.None); 336Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Open_ChannelFactory(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 361Task t = Task.Factory.FromAsync(proxyAsCommunicationObject.BeginOpen, proxyAsCommunicationObject.EndOpen, TaskCreationOptions.None); 389Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Open_Proxy(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 416Task t = Task.Factory.FromAsync(factory.BeginClose, factory.EndClose, TaskCreationOptions.None); 440Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Close_ChannelFactory(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 465Task t = Task.Factory.FromAsync(proxyAsCommunicationObject.BeginClose, proxyAsCommunicationObject.EndClose, TaskCreationOptions.None); 490Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Close_Proxy(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
ServiceContractTests.4.1.0.cs (5)
210Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_DefaultSettings_Echo_RoundTrips_String_Streamed(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 224Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_DefaultSettings_Echo_RoundTrips_String_Streamed_Async(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 614Task.Factory.StartNew(() => ServiceContractTests.NetTcp_NoSecurity_Streamed_RoundTrips_String(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 628Task.Factory.StartNew(() => ServiceContractTests.NetTcp_NoSecurity_Streamed_Async_RoundTrips_String(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 879Task factoryTask = Task.Factory.FromAsync(factory.BeginClose, factory.EndClose, TaskCreationOptions.None);
dotnet-svcutil-lib (3)
FrameworkFork\System.ServiceModel\Internals\System\Runtime\ActionItem.cs (2)
37Task.Factory.StartNew(callback, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 67Task.Factory.StartNew(callback, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\DuplexChannelBinder.cs (1)
1183Task.Factory.StartNew(s_receiveThreadSchedulerCallback, result, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
HttpStress (1)
Program.cs (1)
673var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
IIS.Tests (2)
StrictTestServerTests.cs (1)
28return new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Utilities\TestServer.cs (1)
43private readonly TaskCompletionSource _startedTaskCompletionSource = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
InMemory.FunctionalTests (253)
ChunkedRequestTests.cs (2)
859var readStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 861var exTcs = new TaskCompletionSource<BadHttpRequestException>(TaskCreationOptions.RunContinuationsAsynchronously);
ChunkedResponseTests.cs (1)
489var flushWh = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ConnectionLimitTests.cs (6)
29var requestTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 30var releasedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 31var lockedTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 110var requestTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 177var openedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 178var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ConnectionMiddlewareTests.cs (1)
210var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2ConnectionTests.cs (37)
407var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 497var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 521appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 579var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1176var stream1Read = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1177var stream1ReadFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1178var stream3Read = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1179var stream3ReadFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1739var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1794var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1996var connectionAbortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1997var requestAbortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2296var firstRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2297var finishFirstRequest = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2298var secondRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2299var finishSecondRequest = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2505var requestBlocker = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3212var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3213var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3332var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3333var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3529var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3555var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3581var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3606var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4235var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4236var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4339var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4340var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4589var backpressureObservedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4590var backpressureReleasedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4775var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5178var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5586var requestBlock = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5665var tcs = new TaskCompletionSource<byte[]>(TaskCreationOptions.RunContinuationsAsynchronously); 5913var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5967var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2KeepAliveTests.cs (2)
273var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 327var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2StreamTests.cs (48)
1582var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3821var writeStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4287var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4730var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4731var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4732var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4783var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4784var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4785var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4850var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4851var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4904var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4905var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4906var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4970var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4971var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4972var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5026var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5027var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5028var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5140var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5141var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5142var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5219var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5220var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5221var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5293var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5294var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5295var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5363var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5364var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5365var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5434var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5435var trailersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5436var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5437var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5519var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5520var trailersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5521var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5522var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5608var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5609var trailersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5610var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5611var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5695var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5696var trailersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5697var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5698var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2TestBase.cs (7)
135protected readonly TaskCompletionSource _closingStateReached = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 136protected readonly TaskCompletionSource _closedStateReached = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 617var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 632var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 651var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 693var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 738var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2TimeoutTests.cs (3)
73var setTimeoutTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 327private readonly TaskCompletionSource _writeStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 918var backpressureTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2WebSocketTests.cs (1)
519var finishedSendingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3ConnectionTests.cs (5)
38var appCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 630var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 682var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 744var requestTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 746var abortTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3StreamTests.cs (54)
711var headersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 753var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1127var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1128var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1129var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1174var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1175var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1176var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1227var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1228var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1274var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1275var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1276var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1327var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1328var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1329var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1376var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1377var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1378var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1469var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1470var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1471var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1529var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1530var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1531var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1584var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1585var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1586var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1641var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1642var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1643var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1699var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1700var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1701var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1758var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1759var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1760var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1822var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1823var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1824var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1885var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1886var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1887var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2012var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2044var readTrailersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2838var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2839var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2840var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3074var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3075var startedReadingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3108var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3116tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3124tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3287var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3TimeoutTests.cs (2)
396}, null, true, new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously)); 423private readonly TaskCompletionSource _writeStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\WebTransport\WebTransportHandshakeTests.cs (1)
24var appCompletedTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\WebTransport\WebTransportSessionTests.cs (3)
17var exitTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 38var exitTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 73var exitTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\WebTransport\WebTransportTestUtilities.cs (1)
27var appCompletedTcs = new TaskCompletionSource<IWebTransportSession>(TaskCreationOptions.RunContinuationsAsynchronously);
HttpsTests.cs (2)
274var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 822public TaskCompletionSource LogTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
KeepAliveTimeoutTests.cs (2)
22private readonly TaskCompletionSource _firstRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 312var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
KestrelMetricsTests.cs (9)
216var getNotificationFeatureTcs = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 236var waitForConnectionCloseRequest = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 281var connectionCloseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 282var requestReceivedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 401var finishedSendingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 535var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 536var getNotificationFeatureTcs = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 584var waitForConnectionCloseRequest = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 618var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
RequestBodyTimeoutTests.cs (4)
28var appRunningEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 112var appRunningEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 158var appRunningTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 159var exceptionSwallowedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
RequestTests.cs (11)
112var helloTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 113var readTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 231var pathTcs = new TaskCompletionSource<PathString>(TaskCreationOptions.RunContinuationsAsynchronously); 232var rawTargetTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 233var queryTcs = new TaskCompletionSource<IQueryCollection>(TaskCreationOptions.RunContinuationsAsynchronously); 1160var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1161var tcs2 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1628var appEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1629var delayEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1900var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1997var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseDrainingTests.cs (1)
38var outputBufferedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseTests.cs (29)
39TaskCompletionSource onCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 149var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 150var writeBlockedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 216var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 405var delayTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 442var onCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 675var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 713var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 753var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 792var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 834var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 903var logTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1105var logTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1159var logTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1216var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1439var flushed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1530var flushed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1688var flushed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1723var responseWritten = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2719var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2764var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3037var closeTaskTcs = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 3326var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3507var onStartingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3558var onCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4060var middlewareCompletionTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4761var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4811var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4876var disposedTcs = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (8)
426stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 448stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 479internal TaskCompletionSource OnUnidentifiedStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 480internal TaskCompletionSource OnStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 481internal TaskCompletionSource OnStreamCompletedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 482internal TaskCompletionSource OnHeaderReceivedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1165_disposedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1166_disposingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)
46_messageFilterTcs = new TaskCompletionSource<LogMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
TestTransport\InMemoryTransportConnection.cs (2)
22private readonly TaskCompletionSource _waitForCloseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 116private readonly TaskCompletionSource _tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
UpgradeTests.cs (7)
25var upgrade = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 68var upgrade = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 120var upgradeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 270var upgradeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 304var upgradeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 354var appCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 391var appCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Interop.FunctionalTests (62)
H2SpecCommands.cs (1)
242var exitedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2RequestTests.cs (1)
96var protocolTcs = new TaskCompletionSource<SslProtocols>(TaskCreationOptions.RunContinuationsAsynchronously);
Http2WebSocketInteropTests.cs (1)
100var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3RequestTests.cs (27)
35private readonly TaskCompletionSource _completeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 36private readonly TaskCompletionSource<Stream> _getStreamTcs = new TaskCompletionSource<Stream>(TaskCreationOptions.RunContinuationsAsynchronously); 235var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 455var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 456var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 537var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 538var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 655var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 656var writeAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 968var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 969var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 1071var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1165var writingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1166var cancelTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1167var completionTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1290var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1682var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1683var connectionStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1747var connectionStartedTcs1 = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 1749var connectionStartedTcs2 = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 1751var connectionStartedTcs3 = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 1852var connectionStartedTcs = new TaskCompletionSource<MultiplexedConnectionContext>(TaskCreationOptions.RunContinuationsAsynchronously); 1991var requestStartedTcs = new TaskCompletionSource<HttpContext>(TaskCreationOptions.RunContinuationsAsynchronously); 1992var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 1993var requestAbortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2112var requestStartedTcs = new TaskCompletionSource<HttpContext>(TaskCreationOptions.RunContinuationsAsynchronously); 2113var requestAbortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HttpClientHttp2InteropTests.cs (30)
106var allRequestsReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 154var allRequestsReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 320var lastPacket = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 402var clientEcho = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 453private readonly TaskCompletionSource _sendStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 480_sendComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 548var headersReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 608var receivedHeaders = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 697var clientEcho = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 698var serverReset = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 699var headersReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 753var clientEcho = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 754var serverReset = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 755var responseHeadersReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 812var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 813var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 858var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 859var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 903var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 904var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 945var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 985var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1027var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1079var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1131var serverResult = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1192var requestBlock = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1253var requestBlock = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1414var requestFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1456var responseFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1492var requestFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
InteropTests (3)
Helpers\ClientProcess.cs (1)
40_startTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Helpers\WebsiteProcess.cs (1)
45_startTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Components (2)
Routing\Router.cs (2)
312var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 323var cancellationTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Components.Server.Tests (1)
Circuits\CircuitHostTest.cs (1)
784_renderTcsArray[i] = new(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Components.Tests (5)
RendererTest.cs (5)
2385var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2430var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2469var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2505var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4296var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Components.WebView.Photino (1)
PhotinoWebViewManager.cs (1)
43}, message, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
Microsoft.AspNetCore.Components.WebView.WindowsForms (2)
WindowsFormsDispatcher.cs (2)
80 var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 148 var tcs = new TaskCompletionSource<TResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.DataProtection (1)
KeyManagement\KeyRingProvider.cs (1)
370TaskCreationOptions.DenyChildAttach,
Microsoft.AspNetCore.FunctionalTests (1)
WebApplicationFunctionalTests.cs (1)
139var configChangedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Grpc.JsonTranscoding.Tests (4)
Infrastructure\SyncPoint.cs (3)
13var taskCreationOptions = runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None;
UnaryServerCallHandlerTests.cs (1)
1247var tcs = new TaskCompletionSource<float?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Hosting.FunctionalTests (3)
ShutdownTests.cs (2)
67var startedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 68var completedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
WebHostBuilderTests.cs (1)
39var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Hosting.Tests (2)
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Http.Connections (2)
Internal\HttpConnectionContext.cs (1)
60private readonly TaskCompletionSource _disposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\HttpConnectionDispatcher.cs (1)
209var currentRequestTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Http.Connections.Tests (11)
HttpConnectionDispatcherTests.cs (6)
1566var lastPollTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2409var calledOnReconnectedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2940var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2944tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3149var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4041_pause = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
HttpConnectionManagerTests.cs (3)
290var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 313var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 340var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Http.Extensions (1)
src\Shared\ObjectMethodExecutor\ObjectMethodExecutorFSharpSupport.cs (1)
220.MakeGenericType(typeof(TaskCreationOptions));
Microsoft.AspNetCore.Http.Extensions.Tests (1)
ValidationsGenerator\ValidationsGeneratorTestBase.cs (1)
161var waitForStartTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Http.Tests (8)
HttpContextAccessorTests.cs (8)
38var checkAsyncFlowTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 39var waitForNullTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 40var afterNullCheckTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 83var checkAsyncFlowTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 84var waitForNullTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 85var afterNullCheckTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 129var checkAsyncFlowTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 158var checkAsyncFlowTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.HttpLogging.Tests (1)
TestW3CLoggerProcessor.cs (1)
52_tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Mvc.Core (1)
src\Shared\ObjectMethodExecutor\ObjectMethodExecutorFSharpSupport.cs (1)
220.MakeGenericType(typeof(TaskCreationOptions));
Microsoft.AspNetCore.Mvc.Razor.RuntimeCompilation (1)
RuntimeViewCompiler.cs (1)
144taskSource = new TaskCompletionSource<CompiledViewDescriptor>(creationOptions: TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Mvc.TagHelpers (2)
Cache\DistributedCacheTagHelperService.cs (1)
77var tcs = new TaskCompletionSource<IHtmlContent>(creationOptions: TaskCreationOptions.RunContinuationsAsynchronously);
CacheTagHelper.cs (1)
97var tcs = new TaskCompletionSource<IHtmlContent>(creationOptions: TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Mvc.TagHelpers.Test (12)
CacheTagHelperTest.cs (6)
543var event1 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 544var event2 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 545var event3 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 628var event1 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 629var event2 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 630var event3 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
DistributedCacheTagHelperTest.cs (6)
536var event1 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 537var event2 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 538var event3 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 630var event1 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 631var event2 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 632var event3 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Mvc.Testing (1)
DeferredHostBuilder.cs (1)
22private readonly TaskCompletionSource _hostStartTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.OpenApi (1)
src\Shared\ObjectMethodExecutor\ObjectMethodExecutorFSharpSupport.cs (1)
220.MakeGenericType(typeof(TaskCreationOptions));
Microsoft.AspNetCore.OpenApi.SourceGenerators.Tests (1)
SnapshotTestHelper.cs (1)
160var waitForStartTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.OutputCaching (2)
DispatcherExtensions.cs (2)
24var tcs = new TaskCompletionSource<TValue?>(TaskCreationOptions.RunContinuationsAsynchronously); 63var tcs = new TaskCompletionSource<TValue?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.OutputCaching.StackExchangeRedis (1)
RedisOutputCacheStore.cs (1)
88_ = Task.Factory.StartNew(RunGarbageCollectionLoopAsync, default, TaskCreationOptions.LongRunning, TaskScheduler.Current);
Microsoft.AspNetCore.OutputCaching.Tests (4)
OutputCacheMiddlewareTests.cs (4)
858var blocker1 = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 859var blocker2 = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 921var blocker1 = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 922var blocker2 = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.RateLimiting.Tests (2)
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.ResponseCompression.Tests (20)
ResponseCompressionMiddlewareTest.cs (20)
622var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 668var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 713var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 772var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 827new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 828new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 829new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 830new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 831new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 897new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 898new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 899new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 900new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 901new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 961new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 962new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 963new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 964new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 965new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously), 1176var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Routing (1)
EndpointRoutingMiddleware.cs (1)
253var initialization = new TaskCompletionSource<Matcher>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.HttpSys (2)
MessagePump.cs (1)
25private readonly TaskCompletionSource _shutdownSignal = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (86)
AuthenticationTests.cs (1)
170var completed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2Tests.cs (7)
656var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 698var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 745var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 795var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 847var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 893var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 942var appResult = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Http3Tests.cs (2)
185var headersReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 218var headersReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Listener\ResponseBodyTests.cs (8)
243var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 279var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 315var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 342var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 372var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 412var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 451var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 485var disconnectCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Listener\ServerTests.cs (3)
25var canceled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 54var canceled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 84var canceled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
OpaqueUpgradeTests.cs (4)
109var upgraded = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 131var upgraded = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 164var upgraded = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 309var upgrade = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
RequestTests.cs (4)
508var registered = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 509var result = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 557var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 558var result = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseBodyTests.cs (5)
19var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 45var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 48var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 72var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 283var requestThrew = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseSendFileTests.cs (21)
39var appThrew = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 371var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 399var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 427var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 454var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 481var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 482var requestCancelled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 483var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 484var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 534var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 535var requestCancelled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 536var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 537var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 577var firstSendComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 578var clientDisconnected = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 579var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 580var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 633var firstSendComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 634var clientDisconnected = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 635var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 636var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseTests.cs (8)
130var onStartingCalled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 131var onCompletedCalled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 161var onStartingCalled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 162var onCompletedCalled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 190var onStartingCalled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 191var onCompletedCalled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 220var readStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 221var readCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseTrailersTests.cs (3)
121var responseFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 227var trailersReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 248var trailersReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ServerTests.cs (20)
148var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 168var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 169var stopped = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 189var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 190var shutdown = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 278var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 279var aborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 280var canceled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 312var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 313var canceled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 418var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 419var run = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 452var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 453var run = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 489var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 490var run = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 526var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 527var run = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 563var received = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 564var run = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.IIS (2)
Core\IISHttpServer.cs (1)
33private readonly TaskCompletionSource _shutdownSignal = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.IISIntegration.Tests (8)
IISMiddlewareTests.cs (8)
105var requestExecuted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 106var applicationStoppingFired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 164var requestExecuted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 165var applicationStoppingFired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 209var requestExecuted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 210var applicationStoppingFired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 254var requestExecuted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 255var applicationStoppingFired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.IntegrationTesting (1)
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Core (6)
Internal\ConnectionDispatcher.cs (1)
15private readonly TaskCompletionSource _acceptLoopTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\Infrastructure\KestrelConnection.cs (1)
19private readonly TaskCompletionSource _completionTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\Infrastructure\PipeWriterHelpers\ConcurrentPipeWriter.cs (2)
134_currentFlushTcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously); 168_currentFlushTcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\Infrastructure\TransportConnectionManager.cs (1)
101var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\KestrelServerImpl.cs (1)
32private readonly TaskCompletionSource _stoppedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (25)
CertificatePathWatcherTests.cs (4)
133var signalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 190var signalTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 366var changeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 370var logNoLastModifiedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ConcurrentPipeWriterTests.cs (13)
24new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 25new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 87new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 88new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 89new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 125mockPipeWriter.FlushTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 145mockPipeWriter.FlushTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 185new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 186new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 269new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 270new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 337new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously), 338new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously),
HeartbeatTests.cs (2)
109var handlerStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 152var handlerStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HttpConnectionTests.cs (1)
32var aborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
KestrelServerTests.cs (2)
665var unbindTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 773changeCallbackRegisteredTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
MessageBodyTests.cs (1)
850var logEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)
46_messageFilterTcs = new TaskCompletionSource<LogMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (11)
InMemoryTransportBenchmark.cs (1)
135private readonly TaskCompletionSource<ConnectionContext> _tcs = new TaskCompletionSource<ConnectionContext>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (8)
426stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 448stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 479internal TaskCompletionSource OnUnidentifiedStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 480internal TaskCompletionSource OnStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 481internal TaskCompletionSource OnStreamCompletedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 482internal TaskCompletionSource OnHeaderReceivedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1165_disposedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1166_disposingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)
46_messageFilterTcs = new TaskCompletionSource<LogMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Tests (2)
KestrelConfigurationLoaderTests.cs (2)
917var fileTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1016var fileTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (10)
QuicConnectionContextTests.cs (5)
119var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 170var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 213var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 577var pauseCompleteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 578var allConnectionsOnServerTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
QuicStreamContextTests.cs (2)
270var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 348var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)
46_messageFilterTcs = new TaskCompletionSource<LogMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (1)
src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
41_allBlocksReturned = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Shared.Tests (3)
ObjectMethodExecutorTest.cs (2)
347FSharpOption<TaskCreationOptions>.None, 365FSharpOption<TaskCreationOptions>.None,
src\Shared\ObjectMethodExecutor\ObjectMethodExecutorFSharpSupport.cs (1)
220.MakeGenericType(typeof(TaskCreationOptions));
Microsoft.AspNetCore.SignalR.Client.Core (3)
HubConnection.cs (1)
2253_stopTcs = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\InvocationRequest.cs (1)
169private readonly TaskCompletionSource<object?> _completionSource = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
src\SignalR\common\Shared\MessageBuffer.cs (1)
251var tcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (18)
HubConnectionTests.cs (18)
1363var closedTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 1417var closedTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 2155var reconnectingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2156var reconnectedTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 2215var reconnectingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2216var reconnectedTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 2281var reconnectingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2282var reconnectedTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 2557var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2569tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2616var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2646tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2686var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2722tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2774var closedTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 2860var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2872tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2881var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Client.Tests (66)
HttpConnectionTests.cs (1)
170var negotiateUrlTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
HttpConnectionTests.Negotiate.cs (3)
281var tcs = new TaskCompletionSource<HttpResponseMessage>(TaskCreationOptions.RunContinuationsAsynchronously); 385var tcs = new TaskCompletionSource<HttpResponseMessage>(TaskCreationOptions.RunContinuationsAsynchronously); 450var tcs = new TaskCompletionSource<HttpResponseMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
HttpConnectionTests.Transport.cs (6)
357var startSendTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 358var longPollTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 380var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 467var sendFinishedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 479var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 532var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HubConnectionTests.cs (9)
88var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 108var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 109var methodCalledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 618var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 710var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 727var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 815var resultTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 825var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1035private TaskCompletionSource _disableReconnect = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HubConnectionTests.Protocol.cs (2)
764var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 944var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HubConnectionTests.Reconnect.cs (38)
46var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 79var failReconnectTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 127var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 128var reconnectedConnectionIdTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 129var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 193var failReconnectTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 228var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 229var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 288var failReconnectTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 323var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 324var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 403var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 404var reconnectedConnectionIdTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 405var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 444reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 445reconnectedConnectionIdTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 501var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 502var reconnectedConnectionIdTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 503var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 575var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 639var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 746var secondRetryDelayTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 764var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 765var reconnectedConnectionIdTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 766var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 853var secondRetryDelayTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 871var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 872var reconnectedConnectionIdTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 873var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 968var connectionStartTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 978connectionStartTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 997var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 998var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 1075var reconnectingErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 1076var closedErrorTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 1121public TaskCompletionSource<TestConnection> _testConnectionTcs = new TaskCompletionSource<TestConnection>(TaskCreationOptions.RunContinuationsAsynchronously); 1150_testConnectionTcs = new TaskCompletionSource<TestConnection>(TaskCreationOptions.RunContinuationsAsynchronously); 1159_testConnectionTcs = new TaskCompletionSource<TestConnection>(TaskCreationOptions.RunContinuationsAsynchronously);
HubConnectionTests.Tracing.cs (1)
172var clientActivityTcs = new TaskCompletionSource<Activity>(TaskCreationOptions.RunContinuationsAsynchronously); ;
LongPollingTransportTests.cs (1)
705var secondRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
SendUtilsTests.cs (1)
20var responseTaskCompletionSource = new TaskCompletionSource<HttpResponseMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
ServerSentEventsTransportTests.cs (1)
412var responseTaskCompletionSource = new TaskCompletionSource<HttpResponseMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
TimerAwaitableTests.cs (1)
18var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Core (4)
HubConnectionContext.cs (1)
31private readonly TaskCompletionSource _abortCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\ObjectMethodExecutor\ObjectMethodExecutorFSharpSupport.cs (1)
220.MakeGenericType(typeof(TaskCreationOptions));
src\SignalR\common\Shared\ClientResultsManager.cs (1)
126: base(TaskCreationOptions.RunContinuationsAsynchronously)
src\SignalR\common\Shared\MessageBuffer.cs (1)
251var tcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.StackExchangeRedis (2)
Internal\AckHandler.cs (1)
92Tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\SignalR\common\Shared\ClientResultsManager.cs (1)
126: base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.AspNetCore.SignalR.StackExchangeRedis.Tests (4)
RedisEndToEnd.cs (4)
241reconnectTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 242startedReconnectTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 360private TaskCompletionSource<(WebSocketReceiveResult, ReadOnlyMemory<byte>)> _receiveTcs = new(TaskCreationOptions.RunContinuationsAsynchronously); 409_receiveTcs = new(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Tests (18)
DefaultHubLifetimeManagerTests.cs (9)
43var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 69var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 93var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 115var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 138var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 165var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 190var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 219var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 249var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HubConnectionHandlerTests.cs (3)
2941_waitForRead = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2971_waitForRead = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5354private TaskCompletionSource _reconnectDisabled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HubConnectionHandlerTestUtils\Hubs.cs (4)
308var tcs = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 332var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1221StartedMethod = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 1222EndMethod = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Tests.Utils (1)
CancellationTokenExtensions.cs (1)
10var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SpaServices.Extensions (1)
Util\EventedStreamReader.cs (1)
30Task.Factory.StartNew(Run, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
Microsoft.AspNetCore.StaticFiles.FunctionalTests (3)
StaticFileMiddlewareTests.cs (3)
238var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 239var requestCancelled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 240var responseComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.TestHost (2)
HttpContextBuilder.cs (2)
16private readonly TaskCompletionSource<HttpContext> _responseTcs = new TaskCompletionSource<HttpContext>(TaskCreationOptions.RunContinuationsAsynchronously); 157_ = Task.Factory.StartNew(RunRequestAsync, default, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
Microsoft.AspNetCore.TestHost.Tests (36)
ClientHandlerTests.cs (8)
200var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 295var hasStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 296var hasAssertedResponseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 405var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 424var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 443var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 465var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 523var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HttpContextBuilderTests.cs (8)
120var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 147var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 171var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 193var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 219var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 242var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 283var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 330var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
RequestLifetimeTests.cs (6)
18var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 36var abortReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 52var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 53var abortReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 75var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 76var abortReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseBodyTests.cs (1)
126var emptyReadStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseResetTests.cs (6)
69var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 90var resetReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 109var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 110var resetReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 135var responseReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 136var resetReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Shared\SyncPoint\SyncPoint.cs (2)
11private readonly TaskCompletionSource _atSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 12private readonly TaskCompletionSource _continueFromSyncPoint = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
TestClientTests.cs (5)
346var requestStreamTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 408var requestStreamTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 456var requestStreamTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 829var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 862var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.Tests (2)
WebApplicationTests.cs (1)
1368var changed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
WebHostTests.cs (1)
44var changed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.WebSockets.Tests (5)
WebSocketMiddlewareTests.cs (5)
139var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 171var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 208tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 211tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 801var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Build (4)
BackEnd\BuildManager\BuildManager.cs (1)
1502TaskCreationOptions.LongRunning,
BackEnd\Components\RequestBuilder\RequestBuilder.cs (3)
676TaskCreationOptions.None, 696TaskCreationOptions.None, 708TaskCreationOptions.None,
Microsoft.CodeAnalysis (6)
DiagnosticAnalyzer\AsyncQueue.cs (6)
24private readonly TaskCompletionSource<bool> _whenCompleted = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 102Debug.Assert(waiter.Task.CreationOptions.HasFlag(TaskCreationOptions.RunContinuationsAsynchronously)); 200Debug.Assert(tcs.Task.CreationOptions.HasFlag(TaskCreationOptions.RunContinuationsAsynchronously)); 205Debug.Assert(_whenCompleted.Task.CreationOptions.HasFlag(TaskCreationOptions.RunContinuationsAsynchronously)); 281var waiter = new TaskCompletionSource<Optional<TElement>>(TaskCreationOptions.RunContinuationsAsynchronously); 316Debug.Assert(taskCompletionSource.Task.CreationOptions.HasFlag(TaskCreationOptions.RunContinuationsAsynchronously));
Microsoft.CodeAnalysis.CodeStyle (2)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (1)
472System.Threading.Tasks.Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
Microsoft.CodeAnalysis.EditorFeatures (2)
DocumentationComments\DocumentationCommentSuggestion.cs (1)
164var taskCompletionSource = new TaskCompletionSource<T>(TaskCreationOptions.RunContinuationsAsynchronously);
IWpfDifferenceViewerExtensions.cs (1)
53var completionSource = new TaskCompletionSource<IProjectionSnapshot>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.CodeAnalysis.EditorFeatures.Test.Utilities (1)
Threading\WpfTestRunner.cs (1)
80}, CancellationTokenSource.Token, TaskCreationOptions.None, new SynchronizationContextTaskScheduler(sta.DispatcherSynchronizationContext));
Microsoft.CodeAnalysis.EditorFeatures.UnitTests (3)
Utilities\AsynchronousOperationListenerTests.cs (3)
68}, _tokenSource.Token, TaskCreationOptions.LongRunning, TaskScheduler.Default); 304}, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default); 314}, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default);
Microsoft.CodeAnalysis.InteractiveHost (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Microsoft.CodeAnalysis.LanguageServer (1)
BrokeredServices\WrappedServiceBroker.cs (1)
25private readonly TaskCompletionSource<IServiceBroker> _serviceBrokerTask = new(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.CodeAnalysis.Scripting.TestUtilities (3)
ObjectFormatterFixtures\MockDesktopTask.cs (3)
29public TaskCreationOptions CreationOptions => TaskCreationOptions.None; 41public TaskCreationOptions CreationOptions => m_task.CreationOptions;
Microsoft.CodeAnalysis.Workspaces (5)
FindSymbols\SymbolTree\SymbolTreeInfoCacheService.cs (1)
61=> Task.Factory.StartNew(createWorkAsync, cancellationToken, TaskCreationOptions.None, _scheduler).Unwrap();
Shared\TestHooks\AsynchronousOperationListener.cs (1)
175var source = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
559public Request() : base(TaskCreationOptions.RunContinuationsAsynchronously)
Storage\SQLite\v2\SQLitePersistentStorage_Threading.cs (1)
24var task = Task.Factory.StartNew(boundFunction, cancellationToken, TaskCreationOptions.None, scheduler);
Workspace\Workspace.cs (1)
750}, cancellationToken, TaskCreationOptions.None, _taskSchedulerProvider.CurrentContextScheduler).ConfigureAwait(false);
Microsoft.CodeAnalysis.Workspaces.MSBuild (1)
Rpc\RpcClient.cs (1)
143var requestCompletionSource = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.CodeAnalysis.Workspaces.UnitTests (1)
UtilityTest\AsyncLazyTests.cs (1)
78}, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Current);
Microsoft.DotNet.Open.Api.Tools.Tests (1)
ProcessEx.cs (1)
37_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.ApiDescription.Client.Tests (1)
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.AsyncState.Tests (8)
AsyncStateTests.cs (8)
47var checkAsyncFlowTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 48var waitForNullTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 49var afterNullCheckTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 97var checkAsyncFlowTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 98var waitForNullTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 99var afterNullCheckTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 148var checkAsyncFlowTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 180var checkAsyncFlowTcs = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.Caching.Hybrid (2)
Internal\DefaultHybridCache.StampedeStateT.cs (2)
36_result = new(TaskCreationOptions.RunContinuationsAsynchronously); 91var cancelStub = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.Caching.Memory (3)
CacheEntry.CacheEntryTokens.cs (1)
110CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
CacheEntry.cs (1)
288}, obj, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
MemoryCache.cs (1)
398CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
Microsoft.Extensions.DependencyInjection (1)
ServiceLookup\StackGuard.cs (1)
68Task<R> task = Task.Factory.StartNew((Func<object?, R>)action, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
Microsoft.Extensions.Diagnostics.HealthChecks.Tests (17)
DefaultHealthCheckServiceTest.cs (4)
489var input1 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 490var input2 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 491var output1 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 492var output2 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
HealthCheckPublisherHostedServiceTest.cs (13)
99var unblock0 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 100var unblock1 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 101var unblock2 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 144var unblock = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 187var unblock = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 241var unblock = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 242var unblockDelayedCheck = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 398var unblock0 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 399var unblock1 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 400var unblock2 = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 451var unblock = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 506var unblockDelayedCheck = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 801_started = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.FileProviders.Physical (1)
PhysicalFilesWatcher.cs (1)
464TaskCreationOptions.DenyChildAttach,
Microsoft.Extensions.Hosting.WindowsServices (2)
WindowsServiceLifetime.cs (2)
20private readonly TaskCompletionSource<object?> _delayStart = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 21private readonly TaskCompletionSource<object?> _serviceDispatcherStopped = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.ServiceDiscovery (2)
Http\HttpServiceEndpointResolver.cs (1)
234Interlocked.CompareExchange(ref _onDisposed, new(TaskCreationOptions.RunContinuationsAsynchronously), null);
ServiceEndpointResolver.cs (1)
226Interlocked.CompareExchange(ref _onDisposed, new(TaskCreationOptions.RunContinuationsAsynchronously), null);
Microsoft.ML.Core (1)
Utilities\ThreadUtils.cs (1)
61var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.VisualStudio.LanguageServices (2)
ProjectSystem\FileChangeWatcherProvider.cs (1)
38TaskCreationOptions.RunContinuationsAsynchronously,
Remote\VisualStudioRemoteHostClientProvider.cs (1)
102private readonly TaskCompletionSource<bool> _clientCreationSource = new(TaskCreationOptions.RunContinuationsAsynchronously);
mscorlib (1)
src\libraries\shims\mscorlib\ref\mscorlib.cs (1)
1165[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskCreationOptions))]
netstandard (1)
netstandard.cs (1)
2123[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskCreationOptions))]
OrderProcessor (1)
OrderProcessingWorker.cs (1)
43}, stoppingToken, TaskCreationOptions.LongRunning, TaskScheduler.Current);
Roslyn.VisualStudio.DiagnosticsWindow (1)
OptionPages\ForceLowMemoryMode.cs (1)
80return Task.Factory.StartNew(() => this.PopulateAndMonitorWorkerAsync(size), CancellationToken.None, TaskCreationOptions.LongRunning, TaskScheduler.Default).Unwrap();
Security.TransportSecurity.IntegrationTests (2)
Tcp\StreamingTests.4.1.0.cs (2)
393Task.Factory.StartNew(() => StreamingTests.NetTcp_TransportSecurity_Streamed_RoundTrips_String(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 412Task.Factory.StartNew(() => StreamingTests.NetTcp_TransportSecurity_Streamed_Async_RoundTrips_String(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
Sockets.BindTests (2)
src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)
46_messageFilterTcs = new TaskCompletionSource<LogMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\TransportTestHelpers\HostNameIsReachableAttribute.cs (1)
64var tcs = new TaskCompletionSource<Socket>(TaskCreationOptions.RunContinuationsAsynchronously);
Sockets.FunctionalTests (67)
src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)
46_messageFilterTcs = new TaskCompletionSource<LogMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\TransportTestHelpers\HostNameIsReachableAttribute.cs (1)
64var tcs = new TaskCompletionSource<Socket>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\ConnectionMiddlewareTests.cs (1)
53var connectionCloseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\Http2\ShutdownTests.cs (8)
46var connectionClosed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 47var readFin = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 48var writeFin = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 109var requestStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 110var requestUnblocked = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 111var requestStopping = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 166var requestStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 167var requestUnblocked = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\MaxRequestBufferSizeTests.cs (4)
129var startReadingRequestBody = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 130var clientFinishedSendingRequestBody = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 222var startReadingRequestBody = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 223var clientFinishedSendingRequestBody = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\RequestTests.cs (19)
198var ensureConcurrentRequestTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 405var appErrorLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 406var badRequestLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 407var connectionStoppedLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 695var appDoneTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 702var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 797var appStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 798var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 832var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 868var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 913var readTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 914var registrationTcs = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 1006var readCallbackUnwired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1007var clientClosedConnection = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1008var serverFinConnection = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1009var serverRstConnection = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1010var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1108var readTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1109var appStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\ResponseTests.cs (32)
150var connectionClosed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 151var requestStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 152var appCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 199var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 200var requestAbortedWh = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 201var requestStartWh = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 266var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 267var readCallbackUnwired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 268var clientClosedConnection = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 269var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 362var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 363var appCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 479var responseRateTimeoutMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 480var connectionStopMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 481var connectionWriteFinMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 482var connectionWriteRstMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 483var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 484var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 616var responseRateTimeoutMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 617var connectionStopMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 618var connectionWriteFinMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 619var connectionWriteRstMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 620var aborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 621var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 734var responseRateTimeoutMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 735var connectionStopMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 736var connectionWriteFinMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 737var connectionWriteRstMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 738var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 739var copyToAsyncCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 860var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1021var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\UnixDomainSocketsTests.cs (1)
44var serverConnectionCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System.ComponentModel.EventBasedAsync (1)
System\ComponentModel\BackgroundWorker.cs (1)
132TaskCreationOptions.DenyChildAttach,
System.Diagnostics.Process (1)
System\Diagnostics\Process.cs (1)
1537var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System.IO.Pipes (1)
System\IO\Pipes\NamedPipeClientStream.cs (1)
198}, (this, timeout, cancellationToken, startTime), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System.IO.Ports (2)
System\IO\Ports\SerialStream.Unix.cs (2)
686TaskCreationOptions.LongRunning, 1085: base(TaskCreationOptions.RunContinuationsAsynchronously)
System.Linq.Expressions (1)
System\Linq\Expressions\StackGuard.cs (1)
68Task<R> task = Task.Factory.StartNew(action!, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System.Linq.Parallel (3)
System\Linq\Parallel\Scheduling\QueryTask.cs (3)
64Task task = new Task(s_runTaskSynchronouslyDelegate, this, TaskCreationOptions.AttachedToParent); 84return Task.Factory.StartNew(s_baseWorkDelegate, this, CancellationToken.None, TaskCreationOptions.AttachedToParent | TaskCreationOptions.PreferFairness, taskScheduler);
System.Net.Http (6)
src\libraries\Common\src\System\Threading\Tasks\TaskCompletionSourceWithCancellation.cs (1)
13public TaskCompletionSourceWithCancellation() : base(TaskCreationOptions.RunContinuationsAsynchronously)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (1)
1007CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (2)
364_availableStreamsWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 1145: base(TaskCreationOptions.RunContinuationsAsynchronously)
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (1)
133_expect100ContinueWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
System\Net\Http\SocketsHttpHandler\Http3Connection.cs (1)
259_availableStreamsWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Net.HttpListener (1)
src\libraries\Common\src\System\Net\LazyAsyncResult.cs (1)
372TaskCreationOptions.DenyChildAttach,
System.Net.Mail (1)
src\libraries\Common\src\System\Net\LazyAsyncResult.cs (1)
372TaskCreationOptions.DenyChildAttach,
System.Net.NetworkInformation (1)
System\Net\NetworkInformation\UnixIPGlobalProperties.cs (1)
55CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System.Net.Quic (2)
System\Net\Quic\Internal\ResettableValueTaskSource.cs (1)
321_finalTaskSource = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System\Net\Quic\QuicConnection.cs (1)
142private readonly TaskCompletionSource _connectionCloseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System.Net.Requests (5)
src\libraries\Common\src\System\Net\LazyAsyncResult.cs (1)
372TaskCreationOptions.DenyChildAttach,
System\Net\FileWebRequest.cs (4)
161this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 174}, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 222this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 235}, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System.Net.Security (1)
System\Net\Security\SslStream.IO.cs (1)
811_handshakeWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Net.WebSockets (1)
System\Net\WebSockets\AsyncMutex.cs (1)
249public Waiter(AsyncMutex owner) : base(TaskCreationOptions.RunContinuationsAsynchronously) => Owner = owner;
System.Private.CoreLib (241)
src\libraries\System.Private.CoreLib\src\System\Diagnostics\Tracing\EventPipeEventDispatcher.Threads.cs (1)
18m_dispatchTask = Task.Factory.StartNew(() => DispatchEventsToEventListeners(sessionID, syncTimeUtc, syncTimeQPC, timeQPCFrequency, previousDispatchTask, m_dispatchTaskCancellationSource.Token), CancellationToken.None, TaskCreationOptions.LongRunning, TaskScheduler.Default);
src\libraries\System.Private.CoreLib\src\System\IO\Stream.cs (2)
194cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 657base(function, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach)
src\libraries\System.Private.CoreLib\src\System\IO\TextReader.cs (4)
223cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 281}, new TupleSlim<TextReader, Memory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default)); 288}, new TupleSlim<TextReader, Memory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default)); 311}, new TupleSlim<TextReader, Memory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default));
src\libraries\System.Private.CoreLib\src\System\IO\TextWriter.cs (9)
543}, new TupleSlim<TextWriter, char>(this, value), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 550}, new TupleSlim<TextWriter, string?>(this, value), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 589}, new TupleSlim<TextWriter, char[], int, int>(this, buffer, index, count), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 599}, new TupleSlim<TextWriter, ReadOnlyMemory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 606}, new TupleSlim<TextWriter, char>(this, value), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 613}, new TupleSlim<TextWriter, string?>(this, value), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 653}, new TupleSlim<TextWriter, char[], int, int>(this, buffer, index, count), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 663}, new TupleSlim<TextWriter, ReadOnlyMemory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 673CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\TaskAwaiter.cs (2)
268if (innerEtwLog.TasksSetActivityIds && (innerTask.Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0) 278if (innerEtwLog.TasksSetActivityIds && (innerTask.Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0)
src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\YieldAwaitable.cs (2)
110Task.Factory.StartNew(continuation, default, TaskCreationOptions.PreferFairness, scheduler); 143Task.Factory.StartNew(static s => ((IAsyncStateMachineBox)s!).MoveNext(), box, default, TaskCreationOptions.PreferFairness, scheduler);
src\libraries\System.Private.CoreLib\src\System\Threading\CancellationTokenSource.cs (1)
347}, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
src\libraries\System.Private.CoreLib\src\System\Threading\SemaphoreSlim.cs (1)
72internal TaskNode() : base((object?)null, TaskCreationOptions.RunContinuationsAsynchronously) { }
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ConcurrentExclusiveSchedulerPair.cs (4)
745internal static TaskCreationOptions GetCreationOptionsForTask(bool isReplacementReplica = false) 747TaskCreationOptions options = TaskCreationOptions.DenyChildAttach; 748if (isReplacementReplica) options |= TaskCreationOptions.PreferFairness;
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Future.cs (28)
75internal Task(object? state, TaskCreationOptions options) : 83base(false, TaskCreationOptions.None, default) 88internal Task(bool canceled, TResult? result, TaskCreationOptions creationOptions, CancellationToken ct) 109TaskCreationOptions.None, InternalTaskOptions.None, null) 130TaskCreationOptions.None, InternalTaskOptions.None, null) 142/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 150/// cref="TaskCreationOptions"/>. 152public Task(Func<TResult> function, TaskCreationOptions creationOptions) 166/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 174/// cref="TaskCreationOptions"/>. 179public Task(Func<TResult> function, CancellationToken cancellationToken, TaskCreationOptions creationOptions) 197TaskCreationOptions.None, InternalTaskOptions.None, null) 218TaskCreationOptions.None, InternalTaskOptions.None, null) 231/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 239/// cref="TaskCreationOptions"/>. 241public Task(Func<object?, TResult> function, object? state, TaskCreationOptions creationOptions) 258/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 266/// cref="TaskCreationOptions"/>. 271public Task(Func<object?, TResult> function, object? state, CancellationToken cancellationToken, TaskCreationOptions creationOptions) 287TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler? scheduler) : 303TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler? scheduler) : 311TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler scheduler) 331TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler scheduler) 777out TaskCreationOptions creationOptions, 962out TaskCreationOptions creationOptions, 1176out TaskCreationOptions creationOptions, 1397out TaskCreationOptions creationOptions, 1430public TaskCreationOptions CreationOptions => m_task.CreationOptions;
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\FutureFactory.cs (34)
35private readonly TaskCreationOptions m_defaultCreationOptions; 45&& ((currTask.CreationOptions & TaskCreationOptions.HideScheduler) == 0) 58/// <see cref="TaskCreationOptions"/> property is initialized to 59/// <see cref="TaskCreationOptions.None">TaskCreationOptions.None</see>, the 78/// <see cref="TaskCreationOptions"/> property is initialized to 79/// <see cref="TaskCreationOptions.None">TaskCreationOptions.None</see>, the 101/// <see cref="TaskCreationOptions"/> property is initialized to 102/// <see cref="TaskCreationOptions.None">TaskCreationOptions.None</see>, the 119/// The default <see cref="TaskCreationOptions"> 133/// <see cref="TaskCreationOptions"/> property is initialized to <paramref name="creationOptions"/>, 141public TaskFactory(TaskCreationOptions creationOptions, TaskContinuationOptions continuationOptions) 157/// The default <see cref="TaskCreationOptions"> 176/// <see cref="TaskCreationOptions"/> property is initialized to <paramref name="creationOptions"/>, 185public TaskFactory(CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskContinuationOptions continuationOptions, TaskScheduler? scheduler) 218/// Gets the <see cref="TaskCreationOptions">TaskCreationOptions 225public TaskCreationOptions CreationOptions => m_defaultCreationOptions; 228/// Gets the <see cref="TaskCreationOptions">TaskContinuationOptions 312public Task<TResult> StartNew(Func<TResult> function, TaskCreationOptions creationOptions) 352public Task<TResult> StartNew(Func<TResult> function, CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskScheduler scheduler) 437public Task<TResult> StartNew(Func<object?, TResult> function, object? state, TaskCreationOptions creationOptions) 479public Task<TResult> StartNew(Func<object?, TResult> function, object? state, CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskScheduler scheduler) 587TaskCreationOptions creationOptions) 620TaskCreationOptions creationOptions, 632TaskCreationOptions creationOptions, 664default, TaskCreationOptions.None, InternalTaskOptions.None, null); 744Func<IAsyncResult, TResult> endMethod, object? state, TaskCreationOptions creationOptions) 753object? state, TaskCreationOptions creationOptions) 861TArg1 arg1, object? state, TaskCreationOptions creationOptions) 870TArg1 arg1, object? state, TaskCreationOptions creationOptions) 986TArg1 arg1, TArg2 arg2, object? state, TaskCreationOptions creationOptions) 995TArg1 arg1, TArg2 arg2, object? state, TaskCreationOptions creationOptions) 1119TArg1 arg1, TArg2 arg2, TArg3 arg3, object? state, TaskCreationOptions creationOptions) 1128TArg1 arg1, TArg2 arg2, TArg3 arg3, object? state, TaskCreationOptions creationOptions) 1324Task.CreationOptionsFromContinuationOptions(continuationOptions, out TaskCreationOptions tco, out _);
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Sources\ManualResetValueTaskSourceCore.cs (1)
311Task.Factory.StartNew(continuation, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, scheduler);
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (83)
297internal Task(bool canceled, TaskCreationOptions creationOptions, CancellationToken ct) 324internal Task(object? state, TaskCreationOptions creationOptions, bool promiseStyle) 330if ((creationOptions & ~(TaskCreationOptions.AttachedToParent | TaskCreationOptions.RunContinuationsAsynchronously)) != 0) 336if ((creationOptions & TaskCreationOptions.AttachedToParent) != 0) 354: this(action, null, null, default, TaskCreationOptions.None, InternalTaskOptions.None, null) 369: this(action, null, null, cancellationToken, TaskCreationOptions.None, InternalTaskOptions.None, null) 378/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 386/// cref="TaskCreationOptions"/>. 388public Task(Action action, TaskCreationOptions creationOptions) 399/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 407/// cref="TaskCreationOptions"/>. 412public Task(Action action, CancellationToken cancellationToken, TaskCreationOptions creationOptions) 426: this(action, state, null, default, TaskCreationOptions.None, InternalTaskOptions.None, null) 443: this(action, state, null, cancellationToken, TaskCreationOptions.None, InternalTaskOptions.None, null) 453/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 461/// cref="TaskCreationOptions"/>. 463public Task(Action<object?> action, object? state, TaskCreationOptions creationOptions) 475/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 483/// cref="TaskCreationOptions"/>. 488public Task(Action<object?> action, object? state, CancellationToken cancellationToken, TaskCreationOptions creationOptions) 504TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler? scheduler) 512if (parent != null && (creationOptions & TaskCreationOptions.AttachedToParent) != 0) 536TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler? scheduler) 544~(TaskCreationOptions.AttachedToParent | 545TaskCreationOptions.LongRunning | 546TaskCreationOptions.DenyChildAttach | 547TaskCreationOptions.HideScheduler | 548TaskCreationOptions.PreferFairness | 549TaskCreationOptions.RunContinuationsAsynchronously)) != 0) 584&& ((creationOptions & TaskCreationOptions.AttachedToParent) != 0) 585&& ((parent.CreationOptions & TaskCreationOptions.DenyChildAttach) == 0)) 664((Options & TaskCreationOptions.AttachedToParent) != 0) 665&& ((parent.Options & TaskCreationOptions.DenyChildAttach) == 0)) 677internal TaskCreationOptions Options => OptionsMethod(m_stateFlags); 681internal static TaskCreationOptions OptionsMethod(int flags) 684return (TaskCreationOptions)(flags & (int)TaskStateFlags.OptionsMask); 738Debug.Assert((Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0, 956TaskCreationOptions options = OptionsMethod(flags); 957if ((options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0) 961if ((options & (TaskCreationOptions)InternalTaskOptions.ContinuationTask) != 0) 1048TaskCreationOptions options = OptionsMethod(flags); 1049if ((options & (TaskCreationOptions)InternalTaskOptions.ContinuationTask) != 0) 1055if ((options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0) 1142TaskCreationOptions options, InternalTaskOptions internalOptions) 1230internal static Task? InternalCurrentIfAttached(TaskCreationOptions creationOptions) 1232return (creationOptions & TaskCreationOptions.AttachedToParent) != 0 ? InternalCurrent : null; 1393/// Gets the <see cref="TaskCreationOptions">TaskCreationOptions</see> used 1396public TaskCreationOptions CreationOptions => Options & (TaskCreationOptions)(~InternalTaskOptions.InternalOptionsMask); 1466internal static readonly Task<VoidTaskResult> s_cachedCompleted = new Task<VoidTaskResult>(false, default, (TaskCreationOptions)InternalTaskOptions.DoNotDispose, default); 1601if ((Options & (TaskCreationOptions)InternalTaskOptions.DoNotDispose) != 0) 1679if (TplEventSource.Log.IsEnabled() && (Options & (TaskCreationOptions)InternalTaskOptions.ContinuationTask) == 0) 1704if ((Options & (TaskCreationOptions)InternalTaskOptions.ContinuationTask) == 0) 1945&& ((Options & TaskCreationOptions.AttachedToParent) != 0) 1946&& ((parent.CreationOptions & TaskCreationOptions.DenyChildAttach) == 0) 2140&& ((parent.CreationOptions & TaskCreationOptions.DenyChildAttach) == 0) 2141&& (((TaskCreationOptions)(m_stateFlags & (int)TaskStateFlags.OptionsMask)) & TaskCreationOptions.AttachedToParent) != 0) 3167Debug.Assert((Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) == 0, "Task.InternalCancel() did not expect promise-style task"); 3259Debug.Assert((Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0, "Task.RecordInternalCancellationRequest(CancellationToken) only valid for promise-style task"); 3463(m_stateFlags & (int)TaskCreationOptions.RunContinuationsAsynchronously) == 0 && 3784CreationOptionsFromContinuationOptions(continuationOptions, out TaskCreationOptions creationOptions, out InternalTaskOptions internalOptions); 3966CreationOptionsFromContinuationOptions(continuationOptions, out TaskCreationOptions creationOptions, out InternalTaskOptions internalOptions); 4166CreationOptionsFromContinuationOptions(continuationOptions, out TaskCreationOptions creationOptions, out InternalTaskOptions internalOptions); 4370CreationOptionsFromContinuationOptions(continuationOptions, out TaskCreationOptions creationOptions, out InternalTaskOptions internalOptions); 4394out TaskCreationOptions creationOptions, 4433creationOptions = (TaskCreationOptions)(continuationOptions & CreationOptionsMask); 4505if ((this.Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0 && 5471return new Task(true, TaskCreationOptions.None, cancellationToken); 5482return new Task<TResult>(true, default, TaskCreationOptions.None, cancellationToken); 5527TaskCreationOptions.DenyChildAttach, InternalTaskOptions.None); 5545TaskCreationOptions.DenyChildAttach, InternalTaskOptions.None); 5559TaskCreationOptions.DenyChildAttach, InternalTaskOptions.None, TaskScheduler.Default); 5577TaskCreationOptions.DenyChildAttach, InternalTaskOptions.None, TaskScheduler.Default); 5616Task<Task?> task1 = Task<Task?>.Factory.StartNew(function, cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 5660Task<Task<TResult>?> task1 = Task<Task<TResult>?>.Factory.StartNew(function, cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 5873thisRef.AtomicStateUpdate((int)TaskCreationOptions.RunContinuationsAsynchronously, 0); 6248return new Task<TResult[]>(false, Array.Empty<TResult>(), TaskCreationOptions.None, default); 6282new Task<TResult[]>(false, Array.Empty<TResult>(), TaskCreationOptions.None, default) : 6359return new Task<TResult[]>(false, Array.Empty<TResult>(), TaskCreationOptions.None, default); 7148public TaskCreationOptions CreationOptions => m_task.CreationOptions; 7387: base((object?)null, outerTask.CreationOptions & TaskCreationOptions.AttachedToParent)
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskCache.cs (1)
28new Task<TResult>(false, result, (TaskCreationOptions)InternalTaskOptions.DoNotDispose, default);
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskCompletionSource.cs (3)
46public TaskCompletionSource(TaskCreationOptions creationOptions) : 55this(state, TaskCreationOptions.None) 63public TaskCompletionSource(object? state, TaskCreationOptions creationOptions) =>
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskCompletionSource_T.cs (3)
49public TaskCompletionSource(TaskCreationOptions creationOptions) : 58this(state, TaskCreationOptions.None) 66public TaskCompletionSource(object? state, TaskCreationOptions creationOptions) =>
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskContinuation.cs (5)
15Task antecedent, Delegate action, object? state, TaskCreationOptions creationOptions, InternalTaskOptions internalOptions) : 61Task antecedent, Delegate function, object? state, TaskCreationOptions creationOptions, InternalTaskOptions internalOptions) : 107Task<TAntecedentResult> antecedent, Delegate action, object? state, TaskCreationOptions creationOptions, InternalTaskOptions internalOptions) : 153Task<TAntecedentResult> antecedent, Delegate function, object? state, TaskCreationOptions creationOptions, InternalTaskOptions internalOptions) : 554TaskCreationOptions.None, InternalTaskOptions.QueuedByRuntime, scheduler)
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskFactory.cs (52)
39private readonly TaskCreationOptions m_defaultCreationOptions; 49(currTask != null && (currTask.CreationOptions & TaskCreationOptions.HideScheduler) == 0 ? currTask.ExecutingTaskScheduler! : // a "current" task must be executing, which means it must have a scheduler 64/// <see cref="TaskCreationOptions"/> property is initialized to 65/// <see cref="TaskCreationOptions.None">TaskCreationOptions.None</see>, the 84/// <see cref="TaskCreationOptions"/> property is initialized to 85/// <see cref="TaskCreationOptions.None">TaskCreationOptions.None</see>, the 107/// <see cref="TaskCreationOptions"/> property is initialized to 108/// <see cref="TaskCreationOptions.None">TaskCreationOptions.None</see>, the 125/// The default <see cref="TaskCreationOptions"> 139/// <see cref="TaskCreationOptions"/> property is initialized to <paramref name="creationOptions"/>, 147public TaskFactory(TaskCreationOptions creationOptions, TaskContinuationOptions continuationOptions) 163/// The default <see cref="TaskCreationOptions"> 182/// <see cref="TaskCreationOptions"/> property is initialized to <paramref name="creationOptions"/>, 191public TaskFactory(CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskContinuationOptions continuationOptions, TaskScheduler? scheduler) 198internal static void CheckCreationOptions(TaskCreationOptions creationOptions) 202~(TaskCreationOptions.AttachedToParent | 203TaskCreationOptions.DenyChildAttach | 204TaskCreationOptions.HideScheduler | 205TaskCreationOptions.LongRunning | 206TaskCreationOptions.PreferFairness | 207TaskCreationOptions.RunContinuationsAsynchronously)) != 0) 239/// Gets the <see cref="TaskCreationOptions">TaskCreationOptions 246public TaskCreationOptions CreationOptions => m_defaultCreationOptions; 249/// Gets the <see cref="TaskCreationOptions">TaskContinuationOptions 329public Task StartNew(Action action, TaskCreationOptions creationOptions) 368public Task StartNew(Action action, CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskScheduler scheduler) 452public Task StartNew(Action<object?> action, object? state, TaskCreationOptions creationOptions) 494TaskCreationOptions creationOptions, TaskScheduler scheduler) 583public Task<TResult> StartNew<TResult>(Func<TResult> function, TaskCreationOptions creationOptions) 626public Task<TResult> StartNew<TResult>(Func<TResult> function, CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskScheduler scheduler) 721public Task<TResult> StartNew<TResult>(Func<object?, TResult> function, object? state, TaskCreationOptions creationOptions) 767TaskCreationOptions creationOptions, TaskScheduler scheduler) 821TaskCreationOptions creationOptions) 852TaskCreationOptions creationOptions, 907Action<IAsyncResult> endMethod, object? state, TaskCreationOptions creationOptions) 973TArg1 arg1, object? state, TaskCreationOptions creationOptions) 1046TArg1 arg1, TArg2 arg2, object? state, TaskCreationOptions creationOptions) 1127TArg1 arg1, TArg2 arg2, TArg3 arg3, object? state, TaskCreationOptions creationOptions) 1182IAsyncResult asyncResult, Func<IAsyncResult, TResult> endMethod, TaskCreationOptions creationOptions) 1214IAsyncResult asyncResult, Func<IAsyncResult, TResult> endMethod, TaskCreationOptions creationOptions, TaskScheduler scheduler) 1273Func<IAsyncResult, TResult> endMethod, object? state, TaskCreationOptions creationOptions) 1339Func<IAsyncResult, TResult> endMethod, TArg1 arg1, object? state, TaskCreationOptions creationOptions) 1413Func<IAsyncResult, TResult> endMethod, TArg1 arg1, TArg2 arg2, object? state, TaskCreationOptions creationOptions) 1496Func<IAsyncResult, TResult> endMethod, TArg1 arg1, TArg2 arg2, TArg3 arg3, object? state, TaskCreationOptions creationOptions) 1506internal static void CheckFromAsyncOptions(TaskCreationOptions creationOptions, bool hasBeginMethod) 1511if ((creationOptions & TaskCreationOptions.LongRunning) != 0) 1513if ((creationOptions & TaskCreationOptions.PreferFairness) != 0) 1519~(TaskCreationOptions.AttachedToParent | 1520TaskCreationOptions.DenyChildAttach | 1521TaskCreationOptions.HideScheduler | 1522TaskCreationOptions.PreferFairness | 1523TaskCreationOptions.LongRunning)) != 0)
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskScheduler.cs (1)
315&& ((currentTask.CreationOptions & TaskCreationOptions.HideScheduler) == 0)
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ThreadPoolTaskScheduler.cs (3)
44TaskCreationOptions options = task.Options; 45if (Thread.IsThreadStartSupported && (options & TaskCreationOptions.LongRunning) != 0) 57ThreadPool.UnsafeQueueUserWorkItemInternal(task, (options & TaskCreationOptions.PreferFairness) == 0);
src\libraries\System.Private.CoreLib\src\System\Threading\Timer.cs (1)
660var t = new Task((object?)null, TaskCreationOptions.RunContinuationsAsynchronously, true);
System.Runtime (1)
artifacts\obj\System.Runtime\Debug\net10.0\System.Runtime.Forwards.cs (1)
824[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskCreationOptions))]
System.ServiceModel.Federation (7)
System\Runtime\OperationWithTimeoutAsyncResult.cs (1)
25_ = Task.Factory.StartNew(s_scheduledCallback, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System\ServiceModel\Federation\WSTrustChannel.cs (1)
361Message response = await Task.Factory.FromAsync(RequestChannel.BeginRequest, RequestChannel.EndRequest, requestMessage, null, TaskCreationOptions.None).ConfigureAwait(false);
System\ServiceModel\Federation\WSTrustChannelSecurityTokenProvider.cs (5)
243await Task.Factory.FromAsync(channel.BeginOpen, channel.EndOpen, null, TaskCreationOptions.None); 247Message reply = await Task.Factory.FromAsync(channel.BeginRequest, channel.EndRequest, requestMessage, null, TaskCreationOptions.None); 254await Task.Factory.FromAsync(channel.BeginClose, channel.EndClose, null, TaskCreationOptions.None); 452await Task.Factory.FromAsync(ChannelFactory.BeginClose, ChannelFactory.EndClose, timeout, null, TaskCreationOptions.None); 469await Task.Factory.FromAsync(channelFactory.BeginOpen, channelFactory.EndOpen, null, TaskCreationOptions.None);
System.ServiceModel.NetFramingBase (1)
System\ServiceModel\Security\SecurityUtilsEx.cs (1)
92return Task.Factory.FromAsync(co.BeginClose, co.EndClose, timeout, null, TaskCreationOptions.None);
System.Threading.Channels (10)
System\Threading\Channels\AsyncOperation.cs (2)
292Task.Factory.StartNew(continuation, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, ts); 419CancellationToken.None, TaskCreationOptions.DenyChildAttach, ts);
System\Threading\Channels\BoundedChannel.cs (2)
53_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (2)
45_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System\Threading\Channels\UnboundedChannel.cs (2)
35_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System\Threading\Channels\UnboundedPriorityChannel.cs (2)
40_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System.Threading.RateLimiting (5)
System\Threading\RateLimiting\ConcurrencyLimiter.cs (1)
422: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System\Threading\RateLimiting\DefaultPartitionedRateLimiter.cs (1)
21private readonly TaskCompletionSource<object?> _disposeComplete = new(TaskCreationOptions.RunContinuationsAsynchronously);
System\Threading\RateLimiting\FixedWindowRateLimiter.cs (1)
460: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System\Threading\RateLimiting\SlidingWindowRateLimiter.cs (1)
473: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System\Threading\RateLimiting\TokenBucketRateLimiter.cs (1)
474: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System.Threading.Tasks (1)
System.Threading.Tasks.cs (1)
30[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskCreationOptions))]
System.Threading.Tasks.Dataflow (12)
Base\DataflowBlock.cs (4)
1296}, this, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default); 1307}, this, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default); 1328}, this, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default); 1455base(TaskCreationOptions.RunContinuationsAsynchronously)
Blocks\BroadcastBlock.cs (1)
498private readonly TaskCompletionSource<VoidResult> _completionTask = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Blocks\WriteOnceBlock.cs (2)
80_lazyCompletionTaskSource = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously); 490Interlocked.CompareExchange(ref _lazyCompletionTaskSource, new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously), null);
Internal\Common.cs (4)
441internal static TaskCreationOptions GetCreationOptionsForTask(bool isReplacementReplica = false) 443TaskCreationOptions options = TaskCreationOptions.DenyChildAttach; 444if (isReplacementReplica) options |= TaskCreationOptions.PreferFairness;
Internal\SourceCore.cs (1)
36private readonly TaskCompletionSource<VoidResult> _completionTask = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Threading.Tasks.Parallel (4)
System\Threading\Tasks\Parallel.cs (2)
340tasks[i] = Task.Factory.StartNew(actionsCopy[i], parallelOptions.CancellationToken, TaskCreationOptions.None, 343tasks[0] = new Task(actionsCopy[0], parallelOptions.CancellationToken, TaskCreationOptions.None);
System\Threading\Tasks\Parallel.ForEachAsync.cs (1)
581Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
System\Threading\Tasks\TaskReplicator.cs (1)
79_pendingTask = new Task(s => ((Replica)s!).Execute(), this, CancellationToken.None, TaskCreationOptions.None);
System.Windows.Forms (6)
System\Windows\Forms\Control_InvokeAsync.cs (4)
39TaskCompletionSource completion = new(TaskCreationOptions.RunContinuationsAsynchronously); 105TaskCompletionSource<T> completion = new(TaskCreationOptions.RunContinuationsAsynchronously); 170TaskCompletionSource completion = new(TaskCreationOptions.RunContinuationsAsynchronously); 234TaskCompletionSource<T> completion = new(TaskCreationOptions.RunContinuationsAsynchronously);
System\Windows\Forms\Form.cs (2)
5494_nonModalFormCompletion = new(TaskCreationOptions.RunContinuationsAsynchronously); 5805_modalFormCompletion = new TaskCompletionSource<DialogResult>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Windows.Forms.UI.IntegrationTests (4)
Infra\ControlTestBase.cs (3)
146TaskCompletionSource<VoidResult> idleCompletionSource = new(TaskCreationOptions.RunContinuationsAsynchronously); 307TaskCompletionSource<VoidResult> gate = new(TaskCreationOptions.RunContinuationsAsynchronously); 353TaskCompletionSource<VoidResult> gate = new(TaskCreationOptions.RunContinuationsAsynchronously);
MonthCalendarTests.cs (1)
147TaskCompletionSource<VoidResult> dateChanged = new(TaskCreationOptions.RunContinuationsAsynchronously);
Templates.Blazor.Tests (1)
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Templates.Blazor.WebAssembly.Auth.Tests (1)
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Templates.Blazor.WebAssembly.Tests (1)
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Templates.Mvc.Tests (1)
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
Templates.Tests (1)
src\Shared\Process\ProcessEx.cs (1)
42_exited = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
VBCSCompiler (1)
src\Compilers\Server\VBCSCompiler\ClientConnectionHandler.cs (1)
172var task = new Task<BuildResponse>(func, cancellationToken, TaskCreationOptions.LongRunning);