CancellationTokenSource

Commands\BaseCommand.cs (1)

32var cts = new CancellationTokenSource(TimeSpan.FromSeconds(10));

ActivityNotifier.cs (1)

21using var cts = new CancellationTokenSource(timeout);

AzureAIFoundryExtensionsTests.cs (1)

71var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3));

AzureBicepProvisionerTests.cs (1)

50var cts = new CancellationTokenSource(TimeSpan.FromMinutes(5));

AzureCosmosDBEmulatorFunctionalTests.cs (4)

27var cts = new CancellationTokenSource(TimeSpan.FromMinutes(10)); 68var cts = new CancellationTokenSource(TimeSpan.FromMinutes(10)); 139var cts = new CancellationTokenSource(TimeSpan.FromMinutes(10)); 272var cts = new CancellationTokenSource(TimeSpan.FromMinutes(10));

AzureEventHubsExtensionsTests.cs (3)

25var cts = new CancellationTokenSource(TimeSpan.FromMinutes(10)); 66var cts = new CancellationTokenSource(TimeSpan.FromMinutes(10)); 118var cts = new CancellationTokenSource(TimeSpan.FromMinutes(10));

AzureServiceBusExtensionsTests.cs (3)

73var cts = new CancellationTokenSource(TimeSpan.FromMinutes(10)); 116var cts = new CancellationTokenSource(TimeSpan.FromMinutes(10)); 776var cts = new CancellationTokenSource(TimeSpan.FromMinutes(10));

AzureSignalREmulatorFunctionalTest.cs (2)

42var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3)); 78var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3));

AzureStorageEmulatorFunctionalTests.cs (3)

20var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3)); 69var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3)); 148var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3));

DockerSocketBindMountTests.cs (1)

39using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(30));

GarnetFunctionalTests.cs (3)

22var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3)); 60var cts = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 104var cts = new CancellationTokenSource(TimeSpan.FromMinutes(5));

KafkaFunctionalTests.cs (2)

61var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3)); 117var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3));

MongoDbFunctionalTests.cs (5)

34var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3)); 71var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3)); 109var cts = new CancellationTokenSource(TimeSpan.FromMinutes(6)); 253var cts = new CancellationTokenSource(TimeSpan.FromMinutes(6)); 351var cts = new CancellationTokenSource(TimeSpan.FromMinutes(6));

MySqlFunctionalTests.cs (11)

NatsFunctionalTests.cs (3)

68var cts = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 110var cts = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 324var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3));

NodeAppFixture.cs (1)

43using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(5));

OracleFunctionalTests.cs (5)

33var cts = new CancellationTokenSource(TimeSpan.FromMinutes(15)); 81var cts = new CancellationTokenSource(TimeSpan.FromMinutes(15)); 251var cts = new CancellationTokenSource(TimeSpan.FromMinutes(15)); 349var cts = new CancellationTokenSource(TimeSpan.FromMinutes(15)); 442var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3));

PostgresFunctionalTests.cs (9)

QdrantFunctionalTests.cs (3)

28var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3)); 92var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3)); 255var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3));

RabbitMQFunctionalTests.cs (1)

99var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3));

RedisFunctionalTests.cs (5)

33var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3)); 131var cts = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 183var cts2 = new CancellationTokenSource(TimeSpan.FromSeconds(2)); 438var cts = new CancellationTokenSource(TimeSpan.FromMinutes(10)); 599var cts = new CancellationTokenSource(TimeSpan.FromMinutes(5));

SqlServerFunctionalTests.cs (7)

25var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3)); 65var cts = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 130var cts = new CancellationTokenSource(TimeSpan.FromMinutes(10)); 338var cts = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 404var cts = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 457var cts = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 533var cts = new CancellationTokenSource(TimeSpan.FromMinutes(5));

DistributedApplicationFactory.cs (2)

426using var cts = new CancellationTokenSource(GetConfiguredTimeout()); 520using var shutdownTimeoutCts = new CancellationTokenSource(_shutdownTimeout);

TestingBuilderTests.cs (3)

445using var cts = new CancellationTokenSource(timeout); 490using var cts = new CancellationTokenSource(timeout); 511using var cts = new CancellationTokenSource(timeout);

TestingFactoryCrashTests.cs (1)

21using var cts = new CancellationTokenSource(timeout);

Codespaces\CodespacesUrlRewriterTests.cs (2)

29var abortToken = new CancellationTokenSource(TimeSpan.FromSeconds(60)); 66var abortToken = new CancellationTokenSource(TimeSpan.FromSeconds(60));

Publishing\PublishingActivityProgressReporterTests.cs (1)

498using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(5));

Publishing\ResourceContainerImageBuilderTests.cs (2)

27using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 43using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan);

ValkeyFunctionalTests.cs (1)

201var cts = new CancellationTokenSource(TimeSpan.FromMinutes(3));

YarpFunctionalTests.cs (1)

77var cts = new CancellationTokenSource(TimeSpan.FromMinutes(5));

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\SslStreamSecurityUpgradeProvider.cs (3)

280using (CancellationTokenSource cts = new CancellationTokenSource(timeout)) 525using (CancellationTokenSource cts = new CancellationTokenSource(timeoutHelper.RemainingTime())) 539using (CancellationTokenSource cts = new CancellationTokenSource(timeoutHelper.RemainingTime()))

TestRunner.cs (7)

140cancellationToken: new CancellationTokenSource(TimeSpan.FromMinutes(2)).Token); 148cancellationToken: new CancellationTokenSource(TimeSpan.FromMinutes(2)).Token); 156cancellationToken: new CancellationTokenSource(TimeSpan.FromMinutes(2)).Token); 178cancellationToken: new CancellationTokenSource(TimeSpan.FromMinutes(2)).Token); 187cancellationToken: new CancellationTokenSource(TimeSpan.FromMinutes(2)).Token); 206cancellationToken: new CancellationTokenSource(TimeSpan.FromMinutes(2)).Token); 230var cts = new CancellationTokenSource(testProcessTimeout);

ConnectionMiddlewareTests.cs (1)

193using (var shutdownCts = new CancellationTokenSource(TestConstants.DefaultTimeout))

EventSourceTests.cs (1)

301using var handshakeCts = new CancellationTokenSource(TestConstants.DefaultTimeout);

HttpClientHttp2InteropTests.cs (3)

214using (var timer = new CancellationTokenSource(TimeSpan.FromSeconds(30))) 234using (var timer = new CancellationTokenSource(TimeSpan.FromSeconds(30))) 250using var timer = new CancellationTokenSource(TimeSpan.FromSeconds(30));

src\Shared\Process\ProcessEx.cs (2)

32private readonly CancellationTokenSource _stdoutLinesCancellationSource = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 62_processTimeoutCts = new CancellationTokenSource(timeout);

Circuits\CircuitRegistry.cs (1)

148var cancellationTokenSource = new CancellationTokenSource(_options.DisconnectedCircuitRetentionPeriod);

Circuits\DefaultInMemoryCircuitPersistenceProvider.cs (1)

58var cancellationTokenSource = new CancellationTokenSource(_options.PersistedCircuitInMemoryRetentionPeriod);

Circuits\RemoteJSRuntime.cs (1)

186CancellationTokenSource cancellationTokenSource = new(TimeSpan.FromSeconds(10));

DebugProxyLauncher.cs (1)

75using var cts = new CancellationTokenSource(DebugProxyLaunchTimeout);

ConcurrencyLimiterEventSourceTests.cs (2)

57using var timeoutTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(30)); 98using var timeoutTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(5));

WebHostExtensions.cs (1)

26using var cts = new CancellationTokenSource(timeout);

HostingApplicationDiagnosticsTests.cs (1)

39using CancellationTokenSource timeoutTokenSource = new CancellationTokenSource(timeout);

Internal\HostingEventSourceTests.cs (1)

192using var timeoutTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(30));

MemoryOutputCacheStoreTests.cs (3)

78using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(30)); 184using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(30)); 224using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(30));

ServerTests.cs (3)

158await server.StopAsync(new CancellationTokenSource(TimeSpan.FromSeconds(5)).Token); 201await server.StopAsync(new CancellationTokenSource(TimeSpan.FromSeconds(5)).Token); 431var cts = new CancellationTokenSource(TimeSpan.FromSeconds(10));

src\Shared\Process\ProcessEx.cs (2)

32private readonly CancellationTokenSource _stdoutLinesCancellationSource = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 62_processTimeoutCts = new CancellationTokenSource(timeout);

TlsListenerTests.cs (1)

70var cts = new CancellationTokenSource(TimeSpan.FromMilliseconds(3));

HubConnection.cs (1)

1511using var handshakeCts = new CancellationTokenSource(HandshakeTimeout);

src\Shared\SignalR\InProcessTestServer.cs (1)

115var cts = new CancellationTokenSource(TimeSpan.FromSeconds(30));

TestClientTests.cs (1)

879using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(1));

Program.cs (1)

84using var timeoutSource = new CancellationTokenSource(timeout);

Ordering\RequestOrderingTests.cs (1)

142using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(1));

MEF\UseExportProviderAttribute.cs (1)

123using (var timeoutTokenSource = new CancellationTokenSource(CleanupTimeout))

src\common\UploadToAzure.cs (1)

117CancellationTokenSource timeoutTokenSource = new CancellationTokenSource(TimeSpan.FromMinutes(UploadTimeoutInMinutes));

src\PublishArtifactsInManifestBase.cs (2)

942using CancellationTokenSource timeoutTokenSource = new CancellationTokenSource(TimeSpan.FromMinutes(TimeoutInMinutes)); 977new CancellationTokenSource(TimeSpan.FromMinutes(TimeoutInMinutes));

src\Shared\Process\ProcessEx.cs (2)

32private readonly CancellationTokenSource _stdoutLinesCancellationSource = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 62_processTimeoutCts = new CancellationTokenSource(timeout);

KeyPerFileTests.cs (1)

220using (var cts = new CancellationTokenSource(TimeSpan.FromMilliseconds(250)))

DefaultHealthCheckServiceTest.cs (1)

575using (var cts = new CancellationTokenSource(TimeSpan.FromSeconds(3)))

HostingAbstractionsHostExtensions.cs (1)

34using CancellationTokenSource cts = new CancellationTokenSource(timeout);

PolicyHttpMessageHandlerTest.cs (1)

394using (var cts = new CancellationTokenSource(TimeSpan.FromSeconds(3)))

FakeTimeProviderTests.cs (1)

332using var cancellationTokenSource = new CancellationTokenSource(TimeSpan.FromMilliseconds(1000));

JSObjectReferenceExtensions.cs (3)

97using var cancellationTokenSource = timeout == Timeout.InfiniteTimeSpan ? null : new CancellationTokenSource(timeout); 115using var cancellationTokenSource = timeout == Timeout.InfiniteTimeSpan ? null : new CancellationTokenSource(timeout); 165using var cancellationTokenSource = timeout == Timeout.InfiniteTimeSpan ? null : new CancellationTokenSource(timeout);

JSRuntime.cs (1)

115using var cts = new CancellationTokenSource(DefaultAsyncTimeout.Value);

JSRuntimeExtensions.cs (3)

97using var cancellationTokenSource = timeout == Timeout.InfiniteTimeSpan ? null : new CancellationTokenSource(timeout); 115using var cancellationTokenSource = timeout == Timeout.InfiniteTimeSpan ? null : new CancellationTokenSource(timeout); 165using var cancellationTokenSource = timeout == Timeout.InfiniteTimeSpan ? null : new CancellationTokenSource(timeout);

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (1)

818var cts = new CancellationTokenSource(Settings._connectTimeout);

System\Net\Quic\QuicStream.Stream.cs (2)

124cts = new CancellationTokenSource(_readTimeout); 183cts = new CancellationTokenSource(_writeTimeout);

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

267cts = new CancellationTokenSource(timeout);

src\Shared\Process\ProcessEx.cs (2)

32private readonly CancellationTokenSource _stdoutLinesCancellationSource = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 62_processTimeoutCts = new CancellationTokenSource(timeout);

src\Shared\Process\ProcessEx.cs (2)

32private readonly CancellationTokenSource _stdoutLinesCancellationSource = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 62_processTimeoutCts = new CancellationTokenSource(timeout);

src\Shared\Process\ProcessEx.cs (2)

32private readonly CancellationTokenSource _stdoutLinesCancellationSource = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 62_processTimeoutCts = new CancellationTokenSource(timeout);

src\Shared\Process\ProcessEx.cs (2)

32private readonly CancellationTokenSource _stdoutLinesCancellationSource = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 62_processTimeoutCts = new CancellationTokenSource(timeout);

src\Shared\Process\ProcessEx.cs (2)

32private readonly CancellationTokenSource _stdoutLinesCancellationSource = new CancellationTokenSource(TimeSpan.FromMinutes(5)); 62_processTimeoutCts = new CancellationTokenSource(timeout);

Program.cs (2)

48stressRunCancellation = new CancellationTokenSource(stressRunDuration).Token; 89using var runCancellationToken = new CancellationTokenSource(timeForEachRun);