1102 references to TaskCreationOptions
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 (221)
ChunkedRequestTests.cs (2)
856var readStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 858var 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); 109var requestTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 161var openedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 162var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ConnectionMiddlewareTests.cs (1)
200var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2ConnectionTests.cs (30)
1139var stream1Read = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1140var stream1ReadFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1141var stream3Read = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1142var stream3ReadFinished = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1684var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1737var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1930var connectionAbortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1931var requestAbortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2214var firstRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2215var finishFirstRequest = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2216var secondRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2217var finishSecondRequest = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2419var requestBlocker = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3034var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3035var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3152var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3153var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3337var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3361var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3385var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3408var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4002var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4003var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4104var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4105var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4332var backpressureObservedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4333var backpressureReleasedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4845var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5233var requestBlock = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5310var tcs = new TaskCompletionSource<byte[]>(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2KeepAliveTests.cs (2)
262var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 315var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2StreamTests.cs (45)
1589var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3188var appFinished = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 3247var writeStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3713var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4156var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4157var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4158var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4209var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4210var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4211var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4276var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4277var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4330var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4331var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4332var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4396var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4397var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4398var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4452var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4453var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4454var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4566var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4567var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4568var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4645var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4646var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4647var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4719var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4720var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4721var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4789var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4790var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4791var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4860var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4861var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4862var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4940var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4941var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4942var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5024var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5025var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5026var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5106var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5107var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 5108var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2TestBase.cs (7)
134protected readonly TaskCompletionSource _closingStateReached = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 135protected readonly TaskCompletionSource _closedStateReached = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 589var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 604var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 623var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 665var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 710var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2TimeoutTests.cs (3)
73var setTimeoutTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 310private readonly TaskCompletionSource _writeStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 891var backpressureTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3ConnectionTests.cs (1)
40var appCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3StreamTests.cs (48)
714var headersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 756var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1130var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1131var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1132var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1177var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1178var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1179var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1230var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1231var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1277var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1278var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1279var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1330var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1331var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1332var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1379var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1380var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1381var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1472var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1473var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1474var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1532var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1533var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1534var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1587var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1588var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1589var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1644var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1645var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1646var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1702var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1703var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1704var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1761var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1762var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1763var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1825var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1826var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1827var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1888var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1889var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1890var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2015var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2040var readTrailersTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2797var startingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2798var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2799var clientTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3TimeoutTests.cs (2)
391}, null, true, new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously)); 417private 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)
20private readonly TaskCompletionSource _firstRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 280var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
RequestBodyTimeoutTests.cs (4)
23var appRunningEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 102var appRunningEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 143var appRunningTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 144var exceptionSwallowedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
RequestTests.cs (11)
111var helloTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 112var readTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 230var pathTcs = new TaskCompletionSource<PathString>(TaskCreationOptions.RunContinuationsAsynchronously); 231var rawTargetTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 232var queryTcs = new TaskCompletionSource<IQueryCollection>(TaskCreationOptions.RunContinuationsAsynchronously); 1156var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1157var tcs2 = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1622var appEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1623var delayEvent = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1894var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1991var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseDrainingTests.cs (1)
38var outputBufferedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
ResponseTests.cs (27)
38TaskCompletionSource onCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 145var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 146var writeBlockedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 210var appTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 399var delayTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 436var onCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 666var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 702var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 742var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 781var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 823var responseWriteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 892var logTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1085var logTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1139var logTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1196var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1416var flushed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1447var flushed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1480var flushed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1515var responseWritten = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2507var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2552var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2809var closeTaskTcs = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 3098var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3279var onStartingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3330var onCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 3832var middlewareCompletionTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 4542var disposedTcs = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (8)
420stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 441stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 472internal TaskCompletionSource OnUnidentifiedStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 473internal TaskCompletionSource OnStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 474internal TaskCompletionSource OnStreamCompletedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 475internal TaskCompletionSource OnHeaderReceivedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1158_disposedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1159_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); 118private 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 (58)
H2SpecCommands.cs (1)
242var exitedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Http2\Http2RequestTests.cs (1)
30var protocolTcs = new TaskCompletionSource<SslProtocols>(TaskCreationOptions.RunContinuationsAsynchronously);
Http3\Http3RequestTests.cs (24)
34private readonly TaskCompletionSource _completeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 35private readonly TaskCompletionSource<Stream> _getStreamTcs = new TaskCompletionSource<Stream>(TaskCreationOptions.RunContinuationsAsynchronously); 234var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 454var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 455var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 536var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 537var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 654var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 655var writeAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 965var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 966var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 1068var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1157var cancelledTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1549var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1550var connectionStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1614var connectionStartedTcs1 = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 1616var connectionStartedTcs2 = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 1618var connectionStartedTcs3 = new TaskCompletionSource<IConnectionLifetimeNotificationFeature>(TaskCreationOptions.RunContinuationsAsynchronously); 1719var connectionStartedTcs = new TaskCompletionSource<MultiplexedConnectionContext>(TaskCreationOptions.RunContinuationsAsynchronously); 1858var requestStartedTcs = new TaskCompletionSource<HttpContext>(TaskCreationOptions.RunContinuationsAsynchronously); 1859var readAsyncTask = new TaskCompletionSource<Task>(TaskCreationOptions.RunContinuationsAsynchronously); 1860var requestAbortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1970var requestStartedTcs = new TaskCompletionSource<HttpContext>(TaskCreationOptions.RunContinuationsAsynchronously); 1971var 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)
38_startTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Helpers\WebsiteProcess.cs (1)
43_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)
285var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 296var 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.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.IntegrationTests (7)
Infrastructure\SyncPoint.cs (3)
13var taskCreationOptions = runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None;
ServerStreamingTests.cs (2)
49var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 86var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
UnaryTests.cs (2)
52var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 90var tcs = 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)
68var startedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 69var 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); 4009_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)
219.MakeGenericType(typeof(TaskCreationOptions));
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)
219.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)
219.MakeGenericType(typeof(TaskCreationOptions));
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); 920var blocker1 = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 921var 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)
478var registered = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 479var result = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 527var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 528var 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)
38var appThrew = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 370var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 398var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 426var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 453var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 480var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 481var requestCancelled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 482var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 483var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 533var requestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 534var requestCancelled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 535var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 536var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 576var firstSendComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 577var clientDisconnected = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 578var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 579var testComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 632var firstSendComplete = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 633var clientDisconnected = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 634var cancellationReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 635var 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)
96var 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)
664var unbindTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 772changeCallbackRegisteredTcs = 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)
420stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 441stream.StartStreamDisposeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 472internal TaskCompletionSource OnUnidentifiedStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 473internal TaskCompletionSource OnStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 474internal TaskCompletionSource OnStreamCompletedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 475internal TaskCompletionSource OnHeaderReceivedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1158_disposedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1159_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)
889var fileTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 988var 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); 574var pauseCompleteTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 575var allConnectionsOnServerTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
QuicStreamContextTests.cs (2)
269var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 347var 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)
219.MakeGenericType(typeof(TaskCreationOptions));
Microsoft.AspNetCore.SignalR.Client.Core (3)
HubConnection.cs (1)
2036_stopTcs = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Internal\InvocationRequest.cs (1)
130private readonly TaskCompletionSource<object?> _completionSource = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
src\SignalR\common\Shared\MessageBuffer.cs (1)
250var tcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (18)
HubConnectionTests.cs (18)
1357var closedTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 1411var closedTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 2149var reconnectingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2150var reconnectedTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 2209var reconnectingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2210var reconnectedTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 2275var reconnectingTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2276var reconnectedTcs = new TaskCompletionSource<string>(TaskCreationOptions.RunContinuationsAsynchronously); 2549var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2561tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2608var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2638tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2678var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2714tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2766var closedTcs = new TaskCompletionSource<Exception>(TaskCreationOptions.RunContinuationsAsynchronously); 2852var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2864tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 2873var closedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.AspNetCore.SignalR.Client.Tests (65)
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)
736var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 916var 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);
LongPollingTransportTests.cs (1)
705var secondRequestReceived = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
SendUtilsTests.cs (1)
20var responseTaskCompletionSource = new TaskCompletionSource<HttpResponseMessage>(TaskCreationOptions.RunContinuationsAsynchronously);
ServerSentEventsTransportTests.cs (1)
418var 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)
219.MakeGenericType(typeof(TaskCreationOptions));
src\SignalR\common\Shared\ClientResultsManager.cs (1)
126: base(TaskCreationOptions.RunContinuationsAsynchronously)
src\SignalR\common\Shared\MessageBuffer.cs (1)
250var 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.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); 5336private TaskCompletionSource _reconnectDisabled = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HubConnectionHandlerTestUtils\Hubs.cs (4)
307var tcs = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 331var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1202StartedMethod = new TaskCompletionSource<object>(TaskCreationOptions.RunContinuationsAsynchronously); 1203EndMethod = 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); 403var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 422var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 441var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 463var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 521var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
HttpContextBuilderTests.cs (8)
118var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 145var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 169var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 191var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 217var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 240var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 281var block = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 328var 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 (4)
WebSocketMiddlewareTests.cs (4)
139var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 171var tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 208tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 211tcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Build (4)
BackEnd\BuildManager\BuildManager.cs (1)
1433TaskCreationOptions.LongRunning,
BackEnd\Components\RequestBuilder\RequestBuilder.cs (3)
675TaskCreationOptions.None, 695TaskCreationOptions.None, 707TaskCreationOptions.None,
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.Caching.Hybrid (2)
Internal\DefaultHybridCache.StampedeStateT.cs (2)
25_result = new(TaskCreationOptions.RunContinuationsAsynchronously); 257var cancelStub = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.Caching.Memory (3)
CacheEntry.CacheEntryTokens.cs (1)
110CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
CacheEntry.cs (1)
284}, obj, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
MemoryCache.cs (1)
357CancellationToken.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); 505var unblockDelayedCheck = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously); 800_started = new TaskCompletionSource<object?>(TaskCreationOptions.RunContinuationsAsynchronously);
Microsoft.Extensions.FileProviders.Physical (1)
PhysicalFilesWatcher.cs (1)
463TaskCreationOptions.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);
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))]
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 (64)
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)
59var connectionCloseTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\Http2\ShutdownTests.cs (8)
52var connectionClosed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 53var readFin = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 54var writeFin = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 115var requestStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 116var requestUnblocked = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 117var requestStopping = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 173var requestStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 174var 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 (16)
196var ensureConcurrentRequestTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 625var appDoneTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 632var abortedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 721var appStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 722var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 756var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 792var connectionClosedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 837var readTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 838var registrationTcs = new TaskCompletionSource<int>(TaskCreationOptions.RunContinuationsAsynchronously); 930var readCallbackUnwired = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 931var clientClosedConnection = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 932var serverFinConnection = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 933var serverRstConnection = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 934var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1032var readTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1033var appStartedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
src\Servers\Kestrel\test\FunctionalTests\ResponseTests.cs (32)
157var connectionClosed = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 158var requestStarted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 159var appCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 206var writeTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 207var requestAbortedWh = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 208var 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); 361var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 362var appCompletedTcs = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 469var responseRateTimeoutMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 470var connectionStopMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 471var connectionWriteFinMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 472var connectionWriteRstMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 473var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 474var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 601var responseRateTimeoutMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 602var connectionStopMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 603var connectionWriteFinMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 604var connectionWriteRstMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 605var aborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 606var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 719var responseRateTimeoutMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 720var connectionStopMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 721var connectionWriteFinMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 722var connectionWriteRstMessageLogged = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 723var requestAborted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 724var copyToAsyncCts = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 840var appFuncCompleted = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously); 1001var 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)
1535var 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.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 (5)
src\libraries\Common\src\System\Threading\Tasks\TaskCompletionSourceWithCancellation.cs (1)
13public TaskCompletionSourceWithCancellation() : base(TaskCreationOptions.RunContinuationsAsynchronously)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (1)
966CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (2)
358_availableStreamsWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously); 1132: base(TaskCreationOptions.RunContinuationsAsynchronously)
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (1)
133_expect100ContinueWaiter = 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)
57CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System.Net.Quic (2)
System\Net\Quic\Internal\ResettableValueTaskSource.cs (1)
313_finalTaskSource = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
System\Net\Quic\QuicConnection.cs (1)
114private 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)
159this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 172}, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 220this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 233}, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System.Net.Security (1)
System\Net\Security\SslStream.IO.cs (1)
785_handshakeWaiter = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
System.Net.WebSockets (1)
System\Net\WebSockets\AsyncMutex.cs (1)
235public Waiter(AsyncMutex owner) : base(TaskCreationOptions.RunContinuationsAsynchronously) => Owner = owner;
System.Private.CoreLib (241)
src\libraries\System.Private.CoreLib\src\System\Diagnostics\Tracing\EventPipeEventDispatcher.cs (1)
139m_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); 665base(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)
343}, 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) 775out TaskCreationOptions creationOptions, 960out TaskCreationOptions creationOptions, 1174out TaskCreationOptions creationOptions, 1395out TaskCreationOptions creationOptions, 1428public 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)
299internal Task(bool canceled, TaskCreationOptions creationOptions, CancellationToken ct) 326internal Task(object? state, TaskCreationOptions creationOptions, bool promiseStyle) 332if ((creationOptions & ~(TaskCreationOptions.AttachedToParent | TaskCreationOptions.RunContinuationsAsynchronously)) != 0) 338if ((creationOptions & TaskCreationOptions.AttachedToParent) != 0) 356: this(action, null, null, default, TaskCreationOptions.None, InternalTaskOptions.None, null) 371: this(action, null, null, cancellationToken, TaskCreationOptions.None, InternalTaskOptions.None, null) 380/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 388/// cref="TaskCreationOptions"/>. 390public Task(Action action, TaskCreationOptions creationOptions) 401/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 409/// cref="TaskCreationOptions"/>. 414public Task(Action action, CancellationToken cancellationToken, TaskCreationOptions creationOptions) 428: this(action, state, null, default, TaskCreationOptions.None, InternalTaskOptions.None, null) 445: this(action, state, null, cancellationToken, TaskCreationOptions.None, InternalTaskOptions.None, null) 455/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 463/// cref="TaskCreationOptions"/>. 465public Task(Action<object?> action, object? state, TaskCreationOptions creationOptions) 477/// The <see cref="TaskCreationOptions">TaskCreationOptions</see> used to 485/// cref="TaskCreationOptions"/>. 490public Task(Action<object?> action, object? state, CancellationToken cancellationToken, TaskCreationOptions creationOptions) 506TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler? scheduler) 514if (parent != null && (creationOptions & TaskCreationOptions.AttachedToParent) != 0) 538TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler? scheduler) 546~(TaskCreationOptions.AttachedToParent | 547TaskCreationOptions.LongRunning | 548TaskCreationOptions.DenyChildAttach | 549TaskCreationOptions.HideScheduler | 550TaskCreationOptions.PreferFairness | 551TaskCreationOptions.RunContinuationsAsynchronously)) != 0) 586&& ((creationOptions & TaskCreationOptions.AttachedToParent) != 0) 587&& ((parent.CreationOptions & TaskCreationOptions.DenyChildAttach) == 0)) 666((Options & TaskCreationOptions.AttachedToParent) != 0) 667&& ((parent.Options & TaskCreationOptions.DenyChildAttach) == 0)) 679internal TaskCreationOptions Options => OptionsMethod(m_stateFlags); 683internal static TaskCreationOptions OptionsMethod(int flags) 686return (TaskCreationOptions)(flags & (int)TaskStateFlags.OptionsMask); 740Debug.Assert((Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0, 957TaskCreationOptions options = OptionsMethod(flags); 958if ((options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0) 962if ((options & (TaskCreationOptions)InternalTaskOptions.ContinuationTask) != 0) 1049TaskCreationOptions options = OptionsMethod(flags); 1050if ((options & (TaskCreationOptions)InternalTaskOptions.ContinuationTask) != 0) 1056if ((options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0) 1143TaskCreationOptions options, InternalTaskOptions internalOptions) 1231internal static Task? InternalCurrentIfAttached(TaskCreationOptions creationOptions) 1233return (creationOptions & TaskCreationOptions.AttachedToParent) != 0 ? InternalCurrent : null; 1394/// Gets the <see cref="TaskCreationOptions">TaskCreationOptions</see> used 1397public TaskCreationOptions CreationOptions => Options & (TaskCreationOptions)(~InternalTaskOptions.InternalOptionsMask); 1467internal static readonly Task<VoidTaskResult> s_cachedCompleted = new Task<VoidTaskResult>(false, default, (TaskCreationOptions)InternalTaskOptions.DoNotDispose, default); 1602if ((Options & (TaskCreationOptions)InternalTaskOptions.DoNotDispose) != 0) 1680if (TplEventSource.Log.IsEnabled() && (Options & (TaskCreationOptions)InternalTaskOptions.ContinuationTask) == 0) 1705if ((Options & (TaskCreationOptions)InternalTaskOptions.ContinuationTask) == 0) 1946&& ((Options & TaskCreationOptions.AttachedToParent) != 0) 1947&& ((parent.CreationOptions & TaskCreationOptions.DenyChildAttach) == 0) 2141&& ((parent.CreationOptions & TaskCreationOptions.DenyChildAttach) == 0) 2142&& (((TaskCreationOptions)(m_stateFlags & (int)TaskStateFlags.OptionsMask)) & TaskCreationOptions.AttachedToParent) != 0) 3147Debug.Assert((Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) == 0, "Task.InternalCancel() did not expect promise-style task"); 3239Debug.Assert((Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0, "Task.RecordInternalCancellationRequest(CancellationToken) only valid for promise-style task"); 3443(m_stateFlags & (int)TaskCreationOptions.RunContinuationsAsynchronously) == 0 && 3764CreationOptionsFromContinuationOptions(continuationOptions, out TaskCreationOptions creationOptions, out InternalTaskOptions internalOptions); 3946CreationOptionsFromContinuationOptions(continuationOptions, out TaskCreationOptions creationOptions, out InternalTaskOptions internalOptions); 4146CreationOptionsFromContinuationOptions(continuationOptions, out TaskCreationOptions creationOptions, out InternalTaskOptions internalOptions); 4350CreationOptionsFromContinuationOptions(continuationOptions, out TaskCreationOptions creationOptions, out InternalTaskOptions internalOptions); 4374out TaskCreationOptions creationOptions, 4413creationOptions = (TaskCreationOptions)(continuationOptions & CreationOptionsMask); 4485if ((this.Options & (TaskCreationOptions)InternalTaskOptions.PromiseTask) != 0 && 5426return new Task(true, TaskCreationOptions.None, cancellationToken); 5437return new Task<TResult>(true, default, TaskCreationOptions.None, cancellationToken); 5482TaskCreationOptions.DenyChildAttach, InternalTaskOptions.None); 5500TaskCreationOptions.DenyChildAttach, InternalTaskOptions.None); 5514TaskCreationOptions.DenyChildAttach, InternalTaskOptions.None, TaskScheduler.Default); 5532TaskCreationOptions.DenyChildAttach, InternalTaskOptions.None, TaskScheduler.Default); 5571Task<Task?> task1 = Task<Task?>.Factory.StartNew(function, cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 5615Task<Task<TResult>?> task1 = Task<Task<TResult>?>.Factory.StartNew(function, cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 5828thisRef.AtomicStateUpdate((int)TaskCreationOptions.RunContinuationsAsynchronously, 0); 6198return new Task<TResult[]>(false, Array.Empty<TResult>(), TaskCreationOptions.None, default); 6232new Task<TResult[]>(false, Array.Empty<TResult>(), TaskCreationOptions.None, default) : 6307return new Task<TResult[]>(false, Array.Empty<TResult>(), TaskCreationOptions.None, default); 7083public TaskCreationOptions CreationOptions => m_task.CreationOptions; 7322: 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)
321&& ((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)
657var t = new Task((object?)null, TaskCreationOptions.RunContinuationsAsynchronously, true);
System.Runtime (1)
artifacts\obj\System.Runtime\Debug\net9.0\System.Runtime.Forwards.cs (1)
795[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskCreationOptions))]
System.Threading.Channels (8)
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)
37_completion = new TaskCompletionSource(runContinuationsAsynchronously ? TaskCreationOptions.RunContinuationsAsynchronously : TaskCreationOptions.None);
System.Threading.RateLimiting (5)
System\Threading\RateLimiting\ConcurrencyLimiter.cs (1)
427: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System\Threading\RateLimiting\DefaultPartitionedRateLimiter.cs (1)
21private readonly TaskCompletionSource<object?> _disposeComplete = new(TaskCreationOptions.RunContinuationsAsynchronously);
System\Threading\RateLimiting\FixedWindowRateLimiter.cs (1)
464: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System\Threading\RateLimiting\SlidingWindowRateLimiter.cs (1)
477: base(limiter, TaskCreationOptions.RunContinuationsAsynchronously)
System\Threading\RateLimiting\TokenBucketRateLimiter.cs (1)
478: 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)
1329}, this, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default); 1340}, this, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default); 1361}, this, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default); 1488base(TaskCreationOptions.RunContinuationsAsynchronously)
Blocks\BroadcastBlock.cs (1)
504private readonly TaskCompletionSource<VoidResult> _completionTask = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously);
Blocks\WriteOnceBlock.cs (2)
83_lazyCompletionTaskSource = new TaskCompletionSource<VoidResult>(TaskCreationOptions.RunContinuationsAsynchronously); 502Interlocked.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)
605Task.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);
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);