145 references to WaitAsync
aspire (5)
Backchannel\AuxiliaryBackchannelMonitor.cs (1)
308await _scanLock.WaitAsync(cancellationToken).ConfigureAwait(false);
Documentation\ApiDocs\ApiDocsIndexService.cs (3)
356await _indexLock.WaitAsync(cancellationToken).ConfigureAwait(false); 576await _memberIndexLock.WaitAsync(cancellationToken).ConfigureAwait(false); 662await _memberIndexLock.WaitAsync(cancellationToken).ConfigureAwait(false);
Documentation\Docs\DocsIndexService.cs (1)
158await _indexLock.WaitAsync(cancellationToken).ConfigureAwait(false);
Aspire.Dashboard (5)
Components\Interactions\InteractionsProvider.cs (4)
57await _semaphore.WaitAsync(_cts.Token).ConfigureAwait(false); 144await _semaphore.WaitAsync(_cts.Token).ConfigureAwait(false); 340await _semaphore.WaitAsync(_cts.Token).ConfigureAwait(false); 386await _semaphore.WaitAsync(_cts.Token).ConfigureAwait(false);
Utils\AsyncLock.cs (1)
30await _semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
Aspire.Hosting (20)
ApplicationModel\DockerfileBuildAnnotation.cs (1)
102await _materializationLock.WaitAsync(cancellationToken).ConfigureAwait(false);
ApplicationModel\RequiredCommandValidator.cs (1)
65await state.Gate.WaitAsync(cancellationToken).ConfigureAwait(false);
ApplicationModel\ResourceNotificationService.cs (2)
518await pendingDependencyLock.WaitAsync(CancellationToken.None).ConfigureAwait(false); 564await pendingDependencyLock.WaitAsync(CancellationToken.None).ConfigureAwait(false);
Dcp\ContainerCreator.cs (3)
515await _tunnelSemaphore.WaitAsync(cancellationToken).ConfigureAwait(false); 540await _tunnelSemaphore.WaitAsync(cancellationToken).ConfigureAwait(false); 560await _tunnelSemaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
Dcp\DcpDependencyCheck.cs (1)
34await _lock.WaitAsync(cancellationToken).ConfigureAwait(false);
Dcp\DcpResourceWatcher.cs (1)
208await outputSemaphore.WaitAsync(pipelineCancellationToken).ConfigureAwait(false);
DeveloperCertificateService.cs (2)
187await s_certificateCacheSemaphore.WaitAsync(cancellationToken).ConfigureAwait(false); 220await s_certificateCacheSemaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
Pipelines\Internal\DeploymentStateManagerBase.cs (6)
64await _stateLock.WaitAsync(cancellationToken).ConfigureAwait(false); 103await _stateLock.WaitAsync(cancellationToken).ConfigureAwait(false); 135await _stateLock.WaitAsync(cancellationToken).ConfigureAwait(false); 201await _stateLock.WaitAsync(cancellationToken).ConfigureAwait(false); 221await _stateLock.WaitAsync(cancellationToken).ConfigureAwait(false); 312await _stateLock.WaitAsync(cancellationToken).ConfigureAwait(false);
Publishing\ResourceContainerImageManager.cs (1)
302await _throttle.WaitAsync(cancellationToken).ConfigureAwait(false);
UserSecrets\UserSecretsManagerFactory.cs (1)
161await _semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
Utils\ConcurrencyUtils.cs (1)
52await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Azure (3)
Provisioning\Internal\RunModeProvisioningContextProvider.cs (3)
88await _provisioningOptionsLock.WaitAsync(cancellationToken).ConfigureAwait(false); 154await _provisioningOptionsLock.WaitAsync(cancellationToken).ConfigureAwait(false); 200await _provisioningOptionsLock.WaitAsync(cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Blazor (2)
BrowserDebuggerHelper.cs (2)
139await debugSessionLock.WaitAsync(context.CancellationToken).ConfigureAwait(false); 236await debugSessionLock.WaitAsync(context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.Browsers (11)
BrowserHostRegistry.cs (1)
218await _lock.WaitAsync(cancellationToken).ConfigureAwait(false);
BrowserLogsCdpConnection.cs (1)
250await _sendLock.WaitAsync(sendCts.Token).ConfigureAwait(false);
BrowserLogsSessionManager.cs (4)
74await resourceState.Lock.WaitAsync(cancellationToken).ConfigureAwait(false); 192await resourceState.Lock.WaitAsync(cancellationToken).ConfigureAwait(false); 261await resourceState.Lock.WaitAsync(CancellationToken.None).ConfigureAwait(false); 327await resourceState.Lock.WaitAsync(CancellationToken.None).ConfigureAwait(false);
BrowserPageSession.cs (5)
79await _connectionLock.WaitAsync(cancellationToken).ConfigureAwait(false); 189await _connectionLock.WaitAsync(CancellationToken.None).ConfigureAwait(false); 237await _connectionLock.WaitAsync(cancellationToken).ConfigureAwait(false); 457await _connectionLock.WaitAsync(CancellationToken.None).ConfigureAwait(false); 471await _connectionLock.WaitAsync(CancellationToken.None).ConfigureAwait(false);
Aspire.Hosting.Browsers.Tests (11)
src\Aspire.Hosting.Browsers\BrowserHostRegistry.cs (1)
218await _lock.WaitAsync(cancellationToken).ConfigureAwait(false);
src\Aspire.Hosting.Browsers\BrowserLogsCdpConnection.cs (1)
250await _sendLock.WaitAsync(sendCts.Token).ConfigureAwait(false);
src\Aspire.Hosting.Browsers\BrowserLogsSessionManager.cs (4)
74await resourceState.Lock.WaitAsync(cancellationToken).ConfigureAwait(false); 192await resourceState.Lock.WaitAsync(cancellationToken).ConfigureAwait(false); 261await resourceState.Lock.WaitAsync(CancellationToken.None).ConfigureAwait(false); 327await resourceState.Lock.WaitAsync(CancellationToken.None).ConfigureAwait(false);
src\Aspire.Hosting.Browsers\BrowserPageSession.cs (5)
79await _connectionLock.WaitAsync(cancellationToken).ConfigureAwait(false); 189await _connectionLock.WaitAsync(CancellationToken.None).ConfigureAwait(false); 237await _connectionLock.WaitAsync(cancellationToken).ConfigureAwait(false); 457await _connectionLock.WaitAsync(CancellationToken.None).ConfigureAwait(false); 471await _connectionLock.WaitAsync(CancellationToken.None).ConfigureAwait(false);
Aspire.Hosting.DevTunnels (1)
src\Shared\CoalescingAsyncOperation.cs (1)
32await _gate.WaitAsync(cancellationToken).ConfigureAwait(false);
Aspire.Hosting.EntityFrameworkCore (1)
EFCoreOperationExecutor.cs (1)
275await s_globalDotnetEfLock.WaitAsync(_cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Foundry (2)
FoundryLocalService.cs (2)
30await s_managerLock.WaitAsync(cancellationToken).ConfigureAwait(false); 82await s_managerLock.WaitAsync(CancellationToken.None).ConfigureAwait(false);
Aspire.Hosting.Maui (1)
Lifecycle\MauiBuildQueueEventSubscriber.cs (1)
90await semaphore.WaitAsync(resourceCts.Token).ConfigureAwait(false);
Aspire.TerminalHost (2)
DcpUpstreamAdapter.cs (2)
196await _connectLock.WaitAsync(ct).ConfigureAwait(false); 287await _writeLock.WaitAsync(ct).ConfigureAwait(false);
GenerateDocumentationAndConfigFiles (1)
src\roslyn\src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)
30await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
Microsoft.AspNetCore.Components.Server (2)
Circuits\HybridCacheCircuitPersistenceProvider.cs (2)
50await _lock.WaitAsync(cancellation); 69await _lock.WaitAsync(cancellation);
Microsoft.AspNetCore.Http.Connections.Client (1)
HttpConnection.cs (1)
226await _connectionLock.WaitAsync(cancellationToken).ConfigureAwait(false);
Microsoft.AspNetCore.OutputCaching.StackExchangeRedis (1)
RedisOutputCacheStore.cs (1)
326await _connectionLock.WaitAsync(token).ConfigureAwait(false);
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\KestrelServerImpl.cs (1)
292await _bindSemaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
Microsoft.AspNetCore.SignalR.Client.Core (3)
HubConnection.cs (1)
2797return _connectionLock.WaitAsync(token);
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (2)
166await _writeLock.WaitAsync(cancellationToken: default).ConfigureAwait(false); 197await _writeLock.WaitAsync(cancellationToken: default).ConfigureAwait(false);
Microsoft.AspNetCore.SignalR.Core (4)
HubConnectionContext.cs (2)
455await _writeLock.WaitAsync(cancellationToken); 484await _writeLock.WaitAsync(cancellationToken);
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (2)
166await _writeLock.WaitAsync(cancellationToken: default).ConfigureAwait(false); 197await _writeLock.WaitAsync(cancellationToken: default).ConfigureAwait(false);
Microsoft.AspNetCore.TestHost (1)
TestWebSocket.cs (1)
265await _sem.WaitAsync(cancellationToken);
Microsoft.Build (1)
Graph\ParallelWorkSet.cs (1)
170await _semaphore.WaitAsync(_cancellationToken);
Microsoft.Build.Tasks.Core (1)
AssemblyDependency\Node\RarNodeBuildEngine.cs (1)
158await _completion.WaitAsync(cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis (1)
InternalUtilities\SemaphoreSlimExtensions.cs (1)
30await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.Analyzers (2)
src\roslyn\src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)
30await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
src\roslyn\src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
489return _lock.WaitAsync(CancellationToken.None);
Microsoft.CodeAnalysis.AnalyzerUtilities (2)
src\roslyn\src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)
30await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
src\roslyn\src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
489return _lock.WaitAsync(CancellationToken.None);
Microsoft.CodeAnalysis.CodeStyle (2)
src\roslyn\src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)
30await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
src\roslyn\src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
489return _lock.WaitAsync(CancellationToken.None);
Microsoft.CodeAnalysis.Features (3)
ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.UnitTestingAsyncWorkItemQueue.cs (1)
66=> _semaphore.WaitAsync(cancellationToken);
ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.UnitTestingSemanticChangeProcessor.cs (2)
75=> _gate.WaitAsync(cancellationToken); 397=> _gate.WaitAsync(cancellationToken);
Microsoft.CodeAnalysis.ResxSourceGenerator (2)
src\roslyn\src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)
30await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
src\roslyn\src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
489return _lock.WaitAsync(CancellationToken.None);
Microsoft.CodeAnalysis.Workspaces (1)
src\roslyn\src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)
30await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (1)
src\roslyn\src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)
30await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
Microsoft.DotNet.HotReload.Watch (3)
Aspire\AspireServiceFactory.cs (1)
81await _postDisposalSessionInitializationCompleted.WaitAsync(CancellationToken.None);
Build\ProjectBuildManager.cs (1)
47await s_buildSemaphore.WaitAsync(cancellationToken);
src\sdk\src\Dotnet.Watch\AspireService\AspireServerService.cs (1)
403await _webSocketAccess.WaitAsync(cancelTokenSource.Token);
Microsoft.Extensions.AI (1)
ChatRouting\SemanticRoutingChatClient.cs (1)
308await _indexGate.WaitAsync(cancellationToken).ConfigureAwait(false);
Microsoft.Extensions.Caching.Hybrid.Tests (6)
StampedeTests.cs (6)
348await semaphore.WaitAsync(CancellationToken.None); 355await semaphore.WaitAsync(CancellationToken.None); 388await semaphore.WaitAsync(CancellationToken.None); 395await semaphore.WaitAsync(CancellationToken.None); 432await semaphore.WaitAsync(CancellationToken.None); 439await semaphore.WaitAsync(CancellationToken.None);
Microsoft.Extensions.Caching.StackExchangeRedis (1)
RedisCache.cs (1)
329await _connectionLock.WaitAsync(token).ConfigureAwait(false);
Microsoft.Extensions.DotNetDeltaApplier (1)
src\sdk\src\Dotnet.Watch\HotReloadAgent.Host\Listener.cs (1)
164await _messageToClientLock.WaitAsync(cancellationToken).ConfigureAwait(false);
Microsoft.Extensions.ServiceDiscovery.Tests (1)
ServiceEndpointResolverTests.cs (1)
219await sem.WaitAsync(ct).ConfigureAwait(false);
Microsoft.Maui.Essentials (1)
TextToSpeech\TextToSpeech.shared.cs (1)
178 await semaphore.WaitAsync(cancelToken);
Microsoft.TemplateEngine.Edge (1)
Constraints\WorkloadConstraintFactory.cs (1)
103await Mutex.WaitAsync(token).ConfigureAwait(false);
NuGet.Commands (5)
RestoreCommand\SourceRepositoryDependencyProvider.cs (4)
260await _throttle.WaitAsync(cancellationToken); 393await _throttle.WaitAsync(cancellationToken); 491await _throttle.WaitAsync(cancellationToken); 662await _throttle.WaitAsync(cancellationToken);
RestoreCommand\VulnerabilityInformationProvider.cs (1)
37await _semaphore.WaitAsync(cancellationToken);
NuGet.Common (2)
KeyedLock.cs (2)
40await _dictionaryLock.WaitAsync(token); 53await lockState.Semaphore.WaitAsync(token);
NuGet.Protocol (11)
HttpSource\HttpSourceAuthenticationHandler.cs (2)
174await _httpClientLock.WaitAsync(cancellationToken); 270await _credentialPromptLock.WaitAsync(token);
HttpSource\ProxyAuthenticationHandler.cs (1)
152await _credentialPromptLock.WaitAsync(cancellationToken);
LegacyFeed\ODataServiceDocumentResourceV2Provider.cs (1)
49await _semaphore.WaitAsync(token);
LocalPackageArchiveDownloader.cs (1)
175await _throttle.WaitAsync(cancellationToken);
Plugins\PluginDiscoverer.cs (1)
85await _semaphore.WaitAsync(cancellationToken);
Plugins\PluginPackageReader.cs (2)
149await _getFilesSemaphore.WaitAsync(cancellationToken); 479await _getNuspecReaderSemaphore.WaitAsync(cancellationToken);
Providers\ServiceIndexResourceV3Provider.cs (1)
70await _semaphore.WaitAsync(token);
RemotePackageArchiveDownloader.cs (1)
170await _throttle.WaitAsync(cancellationToken);
RemoteRepositories\RemoteV3FindPackageByIdResource.cs (1)
460await _dependencyInfoSemaphore.WaitAsync(cancellationToken);
Roslyn.Diagnostics.Analyzers (2)
src\roslyn\src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)
30await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
src\roslyn\src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)
489return _lock.WaitAsync(CancellationToken.None);
System.Private.CoreLib (11)
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\BufferedStream.cs (5)
317await EnsureAsyncActiveSemaphoreInitialized().WaitAsync(cancellationToken).ConfigureAwait(false); 589Task semaphoreLockTask = sem.WaitAsync(cancellationToken); 640Task semaphoreLockTask = sem.WaitAsync(cancellationToken); 1017Task semaphoreLockTask = sem.WaitAsync(cancellationToken); 1290await EnsureAsyncActiveSemaphoreInitialized().WaitAsync(cancellationToken).ConfigureAwait(false);
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Strategies\BufferedFileStreamStrategy.cs (6)
311Task semaphoreLockTask = semaphore.WaitAsync(cancellationToken); 355await EnsureAsyncActiveSemaphoreInitialized().WaitAsync(cancellationToken).ConfigureAwait(false); 612Task semaphoreLockTask = semaphore.WaitAsync(cancellationToken); 663await EnsureAsyncActiveSemaphoreInitialized().WaitAsync(cancellationToken).ConfigureAwait(false); 799await EnsureAsyncActiveSemaphoreInitialized().WaitAsync(cancellationToken).ConfigureAwait(false); 847await EnsureAsyncActiveSemaphoreInitialized().WaitAsync(cancellationToken).ConfigureAwait(false);
System.Security.Cryptography (2)
System\Security\Cryptography\CryptoStream.cs (2)
240await AsyncActiveSemaphore.WaitAsync(cancellationToken).ConfigureAwait(false); 479await AsyncActiveSemaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
System.ServiceModel.Primitives (2)
System\ServiceModel\Channels\BufferedReadStream.cs (1)
322Task semaphoreLockTask = _sem.WaitAsync(cancellationToken);
System\ServiceModel\Channels\BufferedWriteStream.cs (1)
423Task semaphoreLockTask = _sem.WaitAsync(cancellationToken);
System.Threading.Tasks.Parallel (1)
System\Threading\Tasks\Parallel.ForEachAsync.cs (1)
602return _lock.WaitAsync(CancellationToken.None);