4493 references to ConfigureAwait
aspire (283)
Commands\ExportCommand.cs (3)
202await AddConsoleLogsAsync(exportArchive, connection, resourceName, snapshots, hiddenResourceNames, cancellationToken).ConfigureAwait(false);
212await AddStructuredLogsAsync(exportArchive, client!, baseUrl!, resolvedTelemetryResources, allOtlpResources, cancellationToken).ConfigureAwait(false);
219await AddTracesAsync(exportArchive, client!, baseUrl!, resolvedTelemetryResources, allOtlpResources, cancellationToken).ConfigureAwait(false);
Documentation\CachedHttpDocumentFetcher.cs (5)
59await cache.SetETagAsync(storageKey, null, cancellationToken).ConfigureAwait(false);
68await cache.SetETagAsync(storageKey, retryETag, cancellationToken).ConfigureAwait(false);
71await cache.SetAsync(storageKey, retryContent, cancellationToken).ConfigureAwait(false);
82await cache.SetETagAsync(storageKey, newETag, cancellationToken).ConfigureAwait(false);
86await cache.SetAsync(storageKey, content, cancellationToken).ConfigureAwait(false);
Documentation\Docs\DocsCache.cs (19)
61await MigrateLegacyIndexFingerprintAsync(cancellationToken).ConfigureAwait(false);
62await ClearLegacyCacheAsync(cancellationToken).ConfigureAwait(false);
77await _contentCache.SetJsonAsync(_indexCacheKey, legacyDocuments, JsonSourceGenerationContext.Default.LlmsDocumentArray, cancellationToken).ConfigureAwait(false);
78await MigrateLegacyIndexFingerprintAsync(cancellationToken).ConfigureAwait(false);
79await ClearLegacyCacheAsync(cancellationToken).ConfigureAwait(false);
85await _contentCache.SetJsonAsync(_indexCacheKey, documents, JsonSourceGenerationContext.Default.LlmsDocumentArray, cancellationToken).ConfigureAwait(false);
86await ClearLegacyCacheAsync(cancellationToken).ConfigureAwait(false);
94await ClearLegacyIndexCacheAsync(cancellationToken).ConfigureAwait(false);
109await _contentCache.SetAsync(_indexSourceFingerprintCacheKey, legacyFingerprint, cancellationToken).ConfigureAwait(false);
110await ClearLegacyIndexCacheAsync(cancellationToken).ConfigureAwait(false);
116await _contentCache.SetAsync(_indexSourceFingerprintCacheKey, fingerprint, cancellationToken).ConfigureAwait(false);
117await ClearLegacyIndexCacheAsync(cancellationToken).ConfigureAwait(false);
138await _contentCache.SetAsync(_indexSourceFingerprintCacheKey, legacyFingerprint, cancellationToken).ConfigureAwait(false);
144await ClearLegacySourceCacheAsync(cancellationToken).ConfigureAwait(false);
145await ClearLegacyIndexCacheAsync(cancellationToken).ConfigureAwait(false);
155await _contentCache.InvalidateAsync(_llmsTxtUrl, cancellationToken).ConfigureAwait(false);
156await _contentCache.SetETagAsync(_llmsTxtUrl, null, cancellationToken).ConfigureAwait(false);
166await _contentCache.InvalidateJsonAsync(_legacyIndexCacheKey, cancellationToken).ConfigureAwait(false);
167await _contentCache.InvalidateAsync(_legacyIndexSourceFingerprintCacheKey, cancellationToken).ConfigureAwait(false);
DotNet\DotNetCliRunner.cs (7)
314await options.ExtensionAppHostLaunchCompletedAsync().ConfigureAwait(false);
317await StartBackchannelAsync(null, socketPath!, backchannelCompletionSource, backchannelParentContext, cancellationToken).ConfigureAwait(false);
324await backchannel.WaitForDisconnectAsync(cancellationToken).ConfigureAwait(false);
565await backchannel.ConnectAsync(socketPath, connectionAttempts, cancellationToken).ConfigureAwait(false);
607await Task.Delay(1000, cancellationToken).ConfigureAwait(false);
873await Task.Delay(TimeSpan.FromSeconds(attempt + 1), cancellationToken).ConfigureAwait(false);
1617await _diskCache.SetAsync(rawKey, stdout, cancellationToken).ConfigureAwait(false);
src\Shared\ChildProcess.cs (22)
248await process.WaitForExitAsync(cancellationToken).ConfigureAwait(false);
261await process.WaitForExitAsync(cancellationToken).ConfigureAwait(false);
269await ShutdownOnCancelAsync(process).ConfigureAwait(false);
285await DrainOutputAsync(CancellationToken.None).ConfigureAwait(false);
293await VerifyContainedTerminationAsync(process).ConfigureAwait(false);
302await DrainOutputAsync(cancellationToken).ConfigureAwait(false);
331await ShutdownLadderAsync(process, requestShutdown, gracefulToken).ConfigureAwait(false);
337_options.TerminationTimeout, _options.TimeProvider, CancellationToken.None).ConfigureAwait(false);
342await VerifyContainedTerminationAsync(process).ConfigureAwait(false);
355await process.WaitForExitAsync(gracefulToken).ConfigureAwait(false);
369_options.TerminationTimeout, _options.TimeProvider, CancellationToken.None).ConfigureAwait(false);
376await signalTask.WaitAsync(_options.TerminationTimeout, _options.TimeProvider, CancellationToken.None).ConfigureAwait(false);
393await signaler(pid, gracefulToken).ConfigureAwait(false);
429await process.WaitForExitAsync().WaitAsync(_options.TerminationTimeout, _options.TimeProvider).ConfigureAwait(false);
438await Task.Delay(TimeSpan.FromMilliseconds(25), _options.TimeProvider, deadline.Token).ConfigureAwait(false);
576await ShutdownOnCancelAsync(process).ConfigureAwait(false);
584await process.WaitForExitAsync().WaitAsync(_options.TerminationTimeout, _options.TimeProvider).ConfigureAwait(false);
591await VerifyContainedTerminationAsync(process).ConfigureAwait(false);
595await ShutdownOnCancelAsync(process).ConfigureAwait(false);
597await DrainOutputAsync(CancellationToken.None).ConfigureAwait(false);
643await drained.ConfigureAwait(false);
670await drained.WaitAsync(s_drainPollInterval, _options.TimeProvider, cancellationToken).ConfigureAwait(false);
aspire-managed (12)
aspire-tray (33)
Aspire.Acquisition.Tests (1)
Aspire.Cli.Tests (20)
Aspire.Dashboard (227)
DashboardEndpointsBuilder.cs (6)
40CookieAuthenticationDefaults.AuthenticationScheme).ConfigureAwait(false);
158await StreamNdjsonAsync(httpContext, service.FollowSpansAsync(resource, traceId, hasError, search, cancellationToken), cancellationToken).ConfigureAwait(false);
190await StreamNdjsonAsync(httpContext, service.FollowLogsAsync(resource, traceId, severity, search, cancellationToken), cancellationToken).ConfigureAwait(false);
263await httpContext.Response.WriteAsync(json, cancellationToken).ConfigureAwait(false);
264await httpContext.Response.WriteAsync("\n", cancellationToken).ConfigureAwait(false);
265await httpContext.Response.Body.FlushAsync(cancellationToken).ConfigureAwait(false);
Model\TelemetryImportService.cs (11)
67await ImportCoreAsync(fileName, stream, allowZipFile: true, cancellationToken).ConfigureAwait(false);
85await stream.CopyToAsync(memoryStream, cancellationToken).ConfigureAwait(false);
88await ImportZipAsync(memoryStream, cancellationToken).ConfigureAwait(false);
91await ImportJsonAsync(fileName, stream, cancellationToken).ConfigureAwait(false);
110await ImportCoreAsync(entry.Name, entryStream, allowZipFile: false, cancellationToken).ConfigureAwait(false);
147await ImportLogsAsync(telemetryData.ResourceLogs).ConfigureAwait(false);
154await ImportTracesAsync(telemetryData.ResourceSpans).ConfigureAwait(false);
161await ImportMetricsAsync(telemetryData.ResourceMetrics).ConfigureAwait(false);
178await _telemetryRepositoryWriter.AddLogsAsync(addContext, protobufRequest.ResourceLogs).ConfigureAwait(false);
189await _telemetryRepositoryWriter.AddTracesAsync(addContext, protobufRequest.ResourceSpans).ConfigureAwait(false);
200await _telemetryRepositoryWriter.AddMetricsAsync(addContext, protobufRequest.ResourceMetrics).ConfigureAwait(false);
ServiceClient\DashboardClient.cs (22)
384await WatchWithRecoveryAsync(WatchResourcesAsync, "resources", onRetry: ResetResourceReadiness, cancellationToken).ConfigureAwait(false);
389await WatchWithRecoveryAsync(WatchInteractionsAsync, "interactions", onRetry: null, cancellationToken).ConfigureAwait(false);
391}, cancellationToken)).ConfigureAwait(false);
432await Task.Delay(delay, delayCts.Token).ConfigureAwait(false);
536await Task.Delay(delay, delayCts.Token).ConfigureAwait(false);
710await _resourceRepositoryWriter.ReplaceResourcesAsync(response.InitialData.Resources).ConfigureAwait(false);
717await _resourceRepositoryWriter.ApplyChangesAsync(response.Changes.Value).ConfigureAwait(false);
762await call.RequestStream.WriteAsync(update).ConfigureAwait(false);
911await WhenResourcesReady.WaitAsync(cts.Token).ConfigureAwait(false);
1001await MarkConsoleLogsLoadedAsync(resourceName).ConfigureAwait(false);
1022await _resourceRepositoryWriter.AddConsoleLogsAsync(resourceName, response.LogLines).ConfigureAwait(false);
1038await readTask.ConfigureAwait(false);
1045await MarkConsoleLogsLoadedAsync(resourceName).ConfigureAwait(false);
1056await _resourceRepositoryWriter.AddConsoleLogsAsync(resourceName, response.LogLines).ConfigureAwait(false);
1075await _resourceRepositoryWriter.MarkConsoleLogsLoadedAsync(resourceName).ConfigureAwait(false);
1198await call.RequestStream.WriteAsync(chunk, combinedTokens.Token).ConfigureAwait(false);
1205await call.RequestStream.WriteAsync(new UploadFileChunk { FileName = fileName, InteractionId = interactionId, InputName = inputName }, combinedTokens.Token).ConfigureAwait(false);
1208await call.RequestStream.CompleteAsync().ConfigureAwait(false);
1225await WhenConnected.WaitAsync(cts.Token).ConfigureAwait(false);
1273await Task.Delay(delay, cts.Token).ConfigureAwait(false);
1311await stream.SendSelectorAsync(combinedTokens.Token).ConfigureAwait(false);
1334await TaskHelpers.WaitIgnoreCancelAsync(_connection, _logger, "Unexpected error from connection task.").ConfigureAwait(false);
src\Shared\ChildProcess.cs (22)
248await process.WaitForExitAsync(cancellationToken).ConfigureAwait(false);
261await process.WaitForExitAsync(cancellationToken).ConfigureAwait(false);
269await ShutdownOnCancelAsync(process).ConfigureAwait(false);
285await DrainOutputAsync(CancellationToken.None).ConfigureAwait(false);
293await VerifyContainedTerminationAsync(process).ConfigureAwait(false);
302await DrainOutputAsync(cancellationToken).ConfigureAwait(false);
331await ShutdownLadderAsync(process, requestShutdown, gracefulToken).ConfigureAwait(false);
337_options.TerminationTimeout, _options.TimeProvider, CancellationToken.None).ConfigureAwait(false);
342await VerifyContainedTerminationAsync(process).ConfigureAwait(false);
355await process.WaitForExitAsync(gracefulToken).ConfigureAwait(false);
369_options.TerminationTimeout, _options.TimeProvider, CancellationToken.None).ConfigureAwait(false);
376await signalTask.WaitAsync(_options.TerminationTimeout, _options.TimeProvider, CancellationToken.None).ConfigureAwait(false);
393await signaler(pid, gracefulToken).ConfigureAwait(false);
429await process.WaitForExitAsync().WaitAsync(_options.TerminationTimeout, _options.TimeProvider).ConfigureAwait(false);
438await Task.Delay(TimeSpan.FromMilliseconds(25), _options.TimeProvider, deadline.Token).ConfigureAwait(false);
576await ShutdownOnCancelAsync(process).ConfigureAwait(false);
584await process.WaitForExitAsync().WaitAsync(_options.TerminationTimeout, _options.TimeProvider).ConfigureAwait(false);
591await VerifyContainedTerminationAsync(process).ConfigureAwait(false);
595await ShutdownOnCancelAsync(process).ConfigureAwait(false);
597await DrainOutputAsync(CancellationToken.None).ConfigureAwait(false);
643await drained.ConfigureAwait(false);
670await drained.WaitAsync(s_drainPollInterval, _options.TimeProvider, cancellationToken).ConfigureAwait(false);
Terminal\TerminalWebSocketProxy.cs (33)
35await HandleAsync(context, resolver, sessions, logger, context.TraceIdentifier).ConfigureAwait(false);
46await HandleAppHostTerminalAsync(context, dashboardClient, sessions, logger, context.TraceIdentifier).ConfigureAwait(false);
65await context.Response.WriteAsync("Missing 'terminalId' query parameter.").ConfigureAwait(false);
91await CloseEndedAsync(context, session, logger).ConfigureAwait(false);
96await WriteUnavailableAsync(context, logger, connectionId, ex).ConfigureAwait(false);
100await HandleConnectionAsync(context, upstream, session, logger, connectionId).ConfigureAwait(false);
118await context.Response.WriteAsync("Missing 'resource' query parameter.").ConfigureAwait(false);
142await WriteUnavailableAsync(context, logger, connectionId, ex).ConfigureAwait(false);
149await context.Response.WriteAsync("Terminal is not available for the requested resource instance.").ConfigureAwait(false);
153await HandleConnectionAsync(context, upstream, session, logger, connectionId).ConfigureAwait(false);
181await context.Response.WriteAsync("Expected a WebSocket upgrade request.").ConfigureAwait(false);
195await context.Response.WriteAsync("Origin not allowed.").ConfigureAwait(false);
209await context.Response.WriteAsync("Terminal is unavailable.").ConfigureAwait(false);
225await CloseAsync(socket, TerminalEndedCloseStatus, "Terminal ended", receive: null, logger).ConfigureAwait(false);
245await workload.ConnectAsync(handshake.Token).ConfigureAwait(false);
255await CloseEndedAsync(context, session, logger).ConfigureAwait(false);
261await WriteUnavailableAsync(context, logger, connectionId, ex).ConfigureAwait(false);
269await BridgeAsync(socket, workload, upstream, session, logger, context.RequestAborted).ConfigureAwait(false);
282ended ? "Terminal ended" : "Terminal view failed", receive: null, logger).ConfigureAwait(false);
312await PumpViewAsync(socket, presentation, workload, upstream, session, logger, cancellationToken).ConfigureAwait(false);
329await completed.ConfigureAwait(false);
372await ObserveTeardownAsync(disconnected, logger).ConfigureAwait(false);
380await sending.CancelAsync().ConfigureAwait(false);
387await ObserveTeardownAsync(send, logger).WaitAsync(s_closeTimeout, CancellationToken.None).ConfigureAwait(false);
401await CloseAsync(socket, closeStatus, closeReason, receive, logger).ConfigureAwait(false);
407await stopping.CancelAsync().ConfigureAwait(false);
411await ObserveTeardownAsync(Task.WhenAll(tasks), logger).ConfigureAwait(false);
420await workload.DisconnectedTask.WaitAsync(cancellationToken).ConfigureAwait(false);
449await task.ConfigureAwait(false);
474await socket.CloseAsync(status, reason, timeout.Token).ConfigureAwait(false);
478await socket.CloseOutputAsync(status, reason, timeout.Token).ConfigureAwait(false);
482await ObserveTeardownAsync(receive, logger).WaitAsync(timeout.Token).ConfigureAwait(false);
550await presentation.HandleMessageAsync(buffer.AsMemory(0, length), cancellationToken).ConfigureAwait(false);
Aspire.Dashboard.Components.Tests (2)
Aspire.Dashboard.Playwright.Tests (2)
Aspire.Dashboard.Tests (2)
Aspire.EndToEnd.Tests (5)
Aspire.Hosting (518)
ApplicationModel\Hex1bAspireTerminal.cs (10)
139await onEnded(cancellationToken).ConfigureAwait(false);
148await clientCts.CancelAsync().ConfigureAwait(false);
149await clientTask.ConfigureAwait(false);
177await lifetimeEnded.ConfigureAwait(false);
274await _workloadCts.CancelAsync().ConfigureAwait(false);
275await Task.WhenAll(clients).ConfigureAwait(false);
296await TerminalAutomation.SendTextAsync(_automator!, text, cancellationToken).ConfigureAwait(false);
302await TerminalAutomation.SendKeyAsync(terminal, _automator!, key, cancellationToken).ConfigureAwait(false);
310await TerminalAutomation.WaitForTextAsync(_automator!, Id, text, timeout, cancellationToken).ConfigureAwait(false);
361await Task.WhenAll(_workloadCts.CancelAsync(), _sessionEnded.Task).ConfigureAwait(false);
ApplicationModel\ResourceExtensions.cs (10)
283await callback.Callback(context).ConfigureAwait(false);
335await annotation.Callback(context).ConfigureAwait(false);
430await callback.Callback(context).ConfigureAwait(false);
529await annotation.Callback(context).ConfigureAwait(false);
630await callback.Callback(containerRunArgsContext).ConfigureAwait(false);
1349await callback.Callback(context).ConfigureAwait(false);
1570await GatherDirectDependenciesAsync(resource, dependencies, newDependencies, executionContext, options, cancellationToken).ConfigureAwait(false);
1586await GatherDirectDependenciesAsync(dep, dependencies, newDependencies, executionContext, options, cancellationToken).ConfigureAwait(false);
1685await ann.Callback(context).ConfigureAwait(false);
1726await ann.Callback(context).ConfigureAwait(false);
ApplicationModel\ResourceNotificationService.cs (18)
178await resourceEvent.Snapshot.ResourceReadyEvent!.EventTask.WaitAsync(cancellationToken).ConfigureAwait(false);
181}, cancellationToken, onDependencyReady).ConfigureAwait(false);
305await eventTask.WaitAsync(cancellationToken).ConfigureAwait(false);
346await Task.WhenAll(tasks).ConfigureAwait(false);
392await onDependencyReady(resourceId).ConfigureAwait(false);
416await Task.WhenAll(tasks).ConfigureAwait(false);
456await postRunningAction(resourceLogger, displayName, resourceId, resourceEvent).ConfigureAwait(false);
460await onDependencyReady(resourceId).ConfigureAwait(false);
489}, cancellationToken, onDependencyReady).ConfigureAwait(false);
541await PublishWaitingForDependenciesAsync(resource, pendingDependencyCounts.Keys).ConfigureAwait(false);
547await pendingDependencyLock.WaitAsync(CancellationToken.None).ConfigureAwait(false);
568await PublishWaitingForDependenciesAsync(resource, waitingFor).ConfigureAwait(false);
572await ClearWaitingForDependenciesAsync(resource).ConfigureAwait(false);
590await Task.WhenAll(pendingDependencies).ConfigureAwait(false);
593await pendingDependencyLock.WaitAsync(CancellationToken.None).ConfigureAwait(false);
606await ClearWaitingForDependenciesAsync(resource).ConfigureAwait(false);
1088await readyEventTask.ConfigureAwait(false);
1271await PublishUpdateAsync(resource, resourceName, stateFactory).ConfigureAwait(false);
Dashboard\DashboardService.cs (15)
92context).ConfigureAwait(false);
170await responseStream.WriteAsync(change, cts.Token).ConfigureAwait(false);
188await serviceData.SendInteractionRequestAsync(request, cts.Token).ConfigureAwait(false);
319context).ConfigureAwait(false);
332await responseStream.WriteAsync(new() { InitialData = data }, cancellationToken).ConfigureAwait(false);
358await responseStream.WriteAsync(new() { Changes = changes }, cancellationToken).ConfigureAwait(false);
370context).ConfigureAwait(false);
415await responseStream.WriteAsync(update, cancellationToken).ConfigureAwait(false);
506await execute(cts.Token).ConfigureAwait(false);
651await stream.WriteEndedAsync(ct).ConfigureAwait(false);
656await Task.Delay(Timeout.InfiniteTimeSpan, ct).ConfigureAwait(false);
657}, cancellationToken).ConfigureAwait(false);
701await responseStream.WriteAsync(new WatchTerminalsUpdate { Snapshot = snapshot }, cancellationToken).ConfigureAwait(false);
721await responseStream.WriteAsync(message, cancellationToken).ConfigureAwait(false);
753await CloseTerminalAsync(terminal, context.CancellationToken).ConfigureAwait(false);
Dcp\ContainerCreator.cs (9)
171await CreateHostDependentContainerAsync(cr, hostDependencies, context, factory, cancellationToken).ConfigureAwait(false);
175await BuildAndCreateContainerAsync(cr, logger, factory, cancellationToken).ConfigureAwait(false);
213await ApplyBuildArgumentsAsync(dcpContainer, cr.ModelResource, _executionContext, logger, cToken).ConfigureAwait(false);
301await factory.CreateDcpObjectsAsync(new[] { dcpContainer }, cToken).ConfigureAwait(false);
307await factory.CreateRenderedResourcesAsync(containerExecCreator, containerExes, EmptyCreationContext.s_instance, cToken).ConfigureAwait(false);
321await factory.CreateDcpObjectsAsync([containerExe], cancellationToken).ConfigureAwait(false);
357.ConfigureAwait(false);
366await BuildAndCreateContainerAsync(cr, _loggerService.GetLogger(cr.ModelResource), factory, cToken).ConfigureAwait(false);
617await DockerfileHelper.ExecuteDockerfileFactoryAsync(dockerfileBuildAnnotation, modelContainerResource, executionContext.Services, cancellationToken).ConfigureAwait(false);
Dcp\DcpExecutor.cs (47)
183await _executorEvents.PublishAsync(new OnResourcesPreparedContext(ct)).ConfigureAwait(false);
191await createServices.ConfigureAwait(false);
196await UpdateWithEffectiveAddressInfo(proxiedWithNoAddress, ct, TimeSpan.FromMinutes(1)).ConfigureAwait(false);
203await CreateDcpObjectsAsync(containerVolumes, ct).ConfigureAwait(false);
215await Task.WhenAll([getProxyAddresses, createContainerNetworks]).WaitAsync(ct).ConfigureAwait(false);
259await createWorkloadEndpoints.ConfigureAwait(false);
261await CreateRenderedResourcesAsync(_executableCreator, executables, endpointContext, ct).ConfigureAwait(false);
266await Task.WhenAll(createWorkloadEndpoints, createContainerVolumes).ConfigureAwait(false);
268await CreateRenderedResourcesAsync(_containerCreator, containers, endpointContext, ct).ConfigureAwait(false);
272await Task.WhenAll(createExecutables, createContainers).WaitAsync(ct).ConfigureAwait(false);
294await _resourceWatcher.StopAsync(cancellationToken).ConfigureAwait(false);
309await _kubernetesService.CleanupResourcesAsync(cancellationToken).ConfigureAwait(false);
318await _kubernetesService.StopServerAsync(Model.ResourceCleanup.Full, cancellationToken).ConfigureAwait(false);
334await StopAsync(disposeCts.Token).ConfigureAwait(false);
620await Task.WhenAll(tasks).WaitAsync(cancellationToken).ConfigureAwait(false);
949await Task.WhenAll(tasks).WaitAsync(cancellationToken).ConfigureAwait(false);
986).ConfigureAwait(false);
1008).ConfigureAwait(false);
1029).ConfigureAwait(false);
1034await CreateReplicaAsync(er).ConfigureAwait(false);
1040await PublishConnectionStringAvailableEventAsync(modelResource, cancellationToken).ConfigureAwait(false);
1045await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, modelResource, startingDcpName)).ConfigureAwait(false);
1049await CreateReplicaAsync(er).ConfigureAwait(false);
1056await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, modelResource, DcpResourceName: null)).ConfigureAwait(false);
1081await creator.CreateObjectAsync(er, context, resourceLogger, this, cancellationToken).ConfigureAwait(false);
1082await PublishConnectionStringAvailableEventAsync(er.ModelResource, cancellationToken).ConfigureAwait(false);
1093await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name, ex.Message)).ConfigureAwait(false);
1098await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false);
1177await appResource.Initialized.WaitAsync(cancellationToken).ConfigureAwait(false);
1248await appResource.Initialized.WaitAsync(cancellationToken).ConfigureAwait(false);
1257await PublishConnectionStringAvailableEventAsync(cr.ModelResource, cancellationToken).ConfigureAwait(false);
1258await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, cr.ModelResource, cr.DcpResourceName)).ConfigureAwait(false);
1263await PublishConnectionStringAvailableEventAsync(er.ModelResource, cancellationToken).ConfigureAwait(false);
1264await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, er.ModelResource, er.DcpResourceName)).ConfigureAwait(false);
1269await EnsureResourceDeletedAsync<Container>(resourceReference, cancellationToken).ConfigureAwait(false);
1274await PublishConnectionStringAvailableEventAsync(resourceReference.ModelResource, cancellationToken).ConfigureAwait(false);
1275await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false);
1277await _containerCreator.CreateObjectAsync(cr, containerEndpointContext, resourceLogger, this, cancellationToken).ConfigureAwait(false);
1278await PublishConnectionStringAvailableEventAsync(resourceReference.ModelResource, cancellationToken).ConfigureAwait(false);
1281await EnsureResourceDeletedAsync<Executable>(resourceReference, cancellationToken).ConfigureAwait(false);
1286await PublishConnectionStringAvailableEventAsync(resourceReference.ModelResource, cancellationToken).ConfigureAwait(false);
1287await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false);
1289await _executableCreator.CreateObjectAsync(er, executableEndpointContext, resourceLogger, this, cancellationToken).ConfigureAwait(false);
1290await PublishConnectionStringAvailableEventAsync(resourceReference.ModelResource, cancellationToken).ConfigureAwait(false);
1307await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName, ex.Message)).ConfigureAwait(false);
1425await _distributedApplicationEventing.PublishAsync(ev, EventDispatchBehavior.BlockingSequential, ct).ConfigureAwait(false);
1444await _executorEvents.PublishAsync(new OnConnectionStringAvailableContext(ct, resource)).ConfigureAwait(false);
Orchestrator\ApplicationOrchestrator.cs (34)
112.ConfigureAwait(false);
186await completedTask.ConfigureAwait(false);
211await ProcessResourceUrlCallbacks(resource, cancellationToken).ConfigureAwait(false);
215await _notificationService.PublishUpdateAsync(resource, s => s with { Urls = [.. urls] }).ConfigureAwait(false);
248.ConfigureAwait(false);
267.ConfigureAwait(false);
270await SetChildResourceAsync(context.Resource, state: KnownResourceStates.Starting, startTimeStamp: null, stopTimeStamp: null).ConfigureAwait(false);
281await _eventing.PublishAsync(beforeResourceStartedEvent, context.CancellationToken).ConfigureAwait(false);
293await PublishResourcesInitialStateAsync(context.CancellationToken).ConfigureAwait(false);
298await PublishConnectionStringAvailableEvent(context.Resource, context.CancellationToken).ConfigureAwait(false);
463await callback.Callback(urlsCallbackContext).ConfigureAwait(false);
575await PublishResourceEndpointUrls(@event.Resource, cancellationToken).ConfigureAwait(false);
580await _notificationService.PublishUpdateAsync(context.Resource, context.DcpResourceName, context.UpdateSnapshot).ConfigureAwait(false);
584await SetChildResourceAsync(context.Resource, context.Status.State, context.Status.StartupTimestamp, context.Status.FinishedTimestamp).ConfigureAwait(false);
598await PublishEventToHierarchy(r => new ResourceStoppedEvent(r, _serviceProvider, currentResourceEvent), context.Resource, context.CancellationToken).ConfigureAwait(false);
611await _notificationService.PublishUpdateAsync(context.Resource, context.DcpResourceName, s => s with { State = stateSnapshot }).ConfigureAwait(false);
615await SetChildResourceAsync(context.Resource, KnownResourceStates.FailedToStart, startTimeStamp: null, stopTimeStamp: null).ConfigureAwait(false);
620await _notificationService.PublishUpdateAsync(context.Resource, s => s with { State = stateSnapshot }).ConfigureAwait(false);
626await _dcpExecutor.RunApplicationAsync(cancellationToken).ConfigureAwait(false);
629await _eventing.PublishAsync(afterResourcesCreatedEvent, cancellationToken).ConfigureAwait(false);
633await lifecycleHook.AfterResourcesCreatedAsync(_model, cancellationToken).ConfigureAwait(false);
641await _dcpExecutor.StopAsync(cancellationToken).ConfigureAwait(false);
663}).ConfigureAwait(false);
669await _dcpExecutor.StartResourceAsync(resourceReference, cancellationToken).ConfigureAwait(false);
676await _dcpExecutor.StopResourceAsync(resourceReference, cancellationToken).ConfigureAwait(false);
694}).ConfigureAwait(false);
698.ConfigureAwait(false);
705await _parameterProcessor.InitializeParametersAsync(_model.Resources.OfType<ParameterResource>(), waitForResolution: false).ConfigureAwait(false);
726}).ConfigureAwait(false);
730await _eventing.PublishAsync(initializeEvent, EventDispatchBehavior.NonBlockingConcurrent, cancellationToken).ConfigureAwait(false);
751await _eventing.PublishAsync(connectionStringAvailableEvent, cancellationToken).ConfigureAwait(false);
766await PublishConnectionStringAvailableEvent(child, cancellationToken).ConfigureAwait(false);
775await _eventing.PublishAsync(createEvent(resource), cancellationToken).ConfigureAwait(false);
787await PublishEventToHierarchy(createEvent, child, cancellationToken).ConfigureAwait(false);
Orchestrator\ParameterProcessor.cs (24)
64await ProcessParameterAsync(parameterResource).ConfigureAwait(false);
76await task.ConfigureAwait(false);
96await HandleUnresolvedParametersAsync(_unresolvedParameters, cts.Token).ConfigureAwait(false);
120await cancellation.ConfigureAwait(false);
166await CollectDependentParameterResourcesAsync(model, referencedParameters, cancellationToken).ConfigureAwait(false);
175await InitializeParametersAsync(allParameters, waitForResolution).ConfigureAwait(false);
181await SaveParametersToDeploymentStateAsync(allParameters, cancellationToken).ConfigureAwait(false);
215await parameterResource.SetValueAsync(value).ConfigureAwait(false);
232await parameterResource.SetExceptionAsync(ex).ConfigureAwait(false);
240await UpdateParameterStateAsync(parameterResource, ex.Message, new(KnownResourceStates.ValueMissing, KnownResourceStateStyles.Warn)).ConfigureAwait(false);
269await updateLock.WaitAsync().ConfigureAwait(false);
281await UpdateParameterStateAsync(parameterResource, eventArgs.Value, KnownResourceStates.Running).ConfigureAwait(false);
292await UpdateParameterStateAsync(parameterResource, eventArgs.Exception.Message, new(KnownResourceStates.ValueMissing, KnownResourceStateStyles.Warn)).ConfigureAwait(false);
297await UpdateParameterStateAsync(parameterResource, eventArgs.Exception.Message, new("Error initializing parameter", KnownResourceStateStyles.Error)).ConfigureAwait(false);
551await SetValueAndIgnoreResultAsync(parameterResource, value, shouldSave, ParameterValueSource.UserInteraction, expectedVersion: null, cancellationToken).ConfigureAwait(false);
568await deploymentStateManager.DeleteSectionAsync(parameterSection, cancellationToken).ConfigureAwait(false);
585await parameterResource.SetExceptionAsync(new MissingParameterValueException("Parameter value has been deleted."), cancellationToken).ConfigureAwait(false);
590await parameterResource.SetValueAsync(null, cancellationToken).ConfigureAwait(false);
629await parameterResource.SetValueAsync(inputValue, cancellationToken).ConfigureAwait(false);
652await deploymentStateManager.SaveSectionAsync(slot, cancellationToken).ConfigureAwait(false);
718await allParametersResolved.Task.ConfigureAwait(false);
904await deploymentStateManager.SaveSectionAsync(slot, cancellationToken).ConfigureAwait(false);
913await deploymentStateManager.DeleteSectionAsync(slot, cancellationToken).ConfigureAwait(false);
942}).ConfigureAwait(false);
Pipelines\Internal\DeploymentStateManagerBase.cs (12)
74await _stateLock.WaitAsync(cancellationToken).ConfigureAwait(false);
145await _stateLock.WaitAsync(cancellationToken).ConfigureAwait(false);
148await SaveStateToStorageAsync(state, sectionName: null, originalSectionData: null, cancellationToken).ConfigureAwait(false);
184await _stateLock.WaitAsync(cancellationToken).ConfigureAwait(false);
247await EnsureStateAndSectionAsync(section, cancellationToken).ConfigureAwait(false);
251await _stateLock.WaitAsync(cancellationToken).ConfigureAwait(false);
256await SaveStateToStorageAsync(_state, section.SectionName, section.OriginalData, cancellationToken).ConfigureAwait(false);
268await EnsureStateAndSectionAsync(section, cancellationToken).ConfigureAwait(false);
272await _stateLock.WaitAsync(cancellationToken).ConfigureAwait(false);
277await SaveStateToStorageAsync(_state, section.SectionName, section.OriginalData, cancellationToken).ConfigureAwait(false);
358await _stateLock.WaitAsync(cancellationToken).ConfigureAwait(false);
361await ClearStateStorageAsync(cancellationToken).ConfigureAwait(false);
Pipelines\ReportingStep.cs (3)
170await Reporter.CompleteStepAsync(this, completionText, completionState, enableMarkdown: false, cancellationToken: cancellationToken).ConfigureAwait(false);
183await Reporter.CompleteStepAsync(this, completionText.Value, completionState, enableMarkdown: true, cancellationToken: cancellationToken).ConfigureAwait(false);
216await Reporter.CompleteStepAsync(this, completionText, finalState, enableMarkdown: false, cancellationToken: CancellationToken.None).ConfigureAwait(false);
Pipelines\ReportingTask.cs (5)
52await ParentStep.Reporter.UpdateTaskAsync(this, statusText, enableMarkdown: false, cancellationToken: cancellationToken).ConfigureAwait(false);
59await ParentStep.Reporter.UpdateTaskAsync(this, statusText.Value, enableMarkdown: true, cancellationToken: cancellationToken).ConfigureAwait(false);
65await ParentStep.Reporter.CompleteTaskAsync(this, completionState, completionMessage, enableMarkdown: false, cancellationToken: cancellationToken).ConfigureAwait(false);
72await ParentStep.Reporter.CompleteTaskAsync(this, completionState, completionMessage.Value, enableMarkdown: true, cancellationToken: cancellationToken).ConfigureAwait(false);
86await CompleteAsync(cancellationToken: CancellationToken.None).ConfigureAwait(false);
Publishing\PublishingExtensions.cs (14)
25await step.CompleteAsync(completionText, CompletionState.Completed, cancellationToken).ConfigureAwait(false);
41await step.CompleteAsync(message, CompletionState.Completed, cancellationToken).ConfigureAwait(false);
58await step.CompleteAsync(completionText, CompletionState.CompletedWithWarning, cancellationToken).ConfigureAwait(false);
74await step.CompleteAsync(message, CompletionState.CompletedWithWarning, cancellationToken).ConfigureAwait(false);
91await step.CompleteAsync(completionText, CompletionState.CompletedWithError, cancellationToken).ConfigureAwait(false);
107await step.CompleteAsync(errorMessage, CompletionState.CompletedWithError, cancellationToken).ConfigureAwait(false);
123await task.UpdateAsync(statusText, cancellationToken).ConfigureAwait(false);
139await task.UpdateAsync(statusText, cancellationToken).ConfigureAwait(false);
155await task.CompleteAsync(message, CompletionState.Completed, cancellationToken).ConfigureAwait(false);
171await task.CompleteAsync(message, CompletionState.Completed, cancellationToken).ConfigureAwait(false);
187await task.CompleteAsync(message, CompletionState.CompletedWithWarning, cancellationToken).ConfigureAwait(false);
203await task.CompleteAsync(message, CompletionState.CompletedWithWarning, cancellationToken).ConfigureAwait(false);
219await task.CompleteAsync(errorMessage, CompletionState.CompletedWithError, cancellationToken).ConfigureAwait(false);
235await task.CompleteAsync(errorMessage, CompletionState.CompletedWithError, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Azure (189)
AzureProvisioningController.cs (91)
574await RunOperationAsync(model, new ResetStateIntent(ReprovisionAfterReset: false), cancellationToken).ConfigureAwait(false);
582await RunOperationAsync(model, new ForgetResourceStateIntent(resourceName), cancellationToken).ConfigureAwait(false);
618await RunOperationAsync(model, new DeleteAzureResourcesIntent(), cancellationToken).ConfigureAwait(false);
665await CancelResourceCoreAsync(model, resourceName, cancellationToken).ConfigureAwait(false);
673await RunOperationAsync(model, new DeleteAzureResourceIntent(resourceName), cancellationToken).ConfigureAwait(false);
1082cancellationToken).ConfigureAwait(false);
1089await ApplyResourceOverridesAsync(resource.AzureResource, cancellationToken).ConfigureAwait(false);
1105}).ConfigureAwait(false);
1110await ProvisionAzureResourcesAsync(azureResources, parentChildLookup, cancellationToken).ConfigureAwait(false);
1127cancellationToken).ConfigureAwait(false);
1229await ClearCachedDeploymentStateAsync(bicepResource, preserveOverrides, environmentLocation, currentLocationOverride, preserveInferredLocationOverrides, cancellationToken).ConfigureAwait(false);
1252}).ConfigureAwait(false);
1262await deploymentStateManager.DeleteSectionAsync(section, cancellationToken).ConfigureAwait(false);
1496await Task.Delay(DriftCheckInterval, _timeProvider, stoppingToken).ConfigureAwait(false);
1497await CheckForDriftAsync(model, stoppingToken).ConfigureAwait(false);
1520await ProcessOperationLoopAsync(stoppingToken).ConfigureAwait(false);
1548await ProcessQueuedOperationAsync(operation).ConfigureAwait(false);
1593await RefreshCommandStatesAsync(queuedOperation.Model, operationCancellationToken).ConfigureAwait(false);
1621await RefreshCommandStatesAsync(queuedOperation.Model, CancellationToken.None).ConfigureAwait(false);
1673await PromptForMissingAzureContextAsync(model, stoppingToken).ConfigureAwait(false);
1739await provisioningOptionsManager.PersistProvisioningOptionsAsync(cancellationToken).ConfigureAwait(false);
1774await DeleteSectionAsync("Azure", cancellationToken).ConfigureAwait(false);
1777await ResetResourcesAsync(model, azureResources, preserveOverrides: false, cancellationToken).ConfigureAwait(false);
1779await PublishAzureEnvironmentStateAsync(model, KnownResourceStates.NotStarted, cancellationToken).ConfigureAwait(false);
1795await ResetResourcesAsync(model, targetResources, preserveOverrides: false, cancellationToken).ConfigureAwait(false);
1817await provisioningOptionsManager.PersistProvisioningOptionsAsync(cancellationToken).ConfigureAwait(false);
1828await ResetResourcesAsync(model, GetProvisionableAzureResources(model), preserveOverrides: true, cancellationToken, preserveInferredLocationOverrides: false).ConfigureAwait(false);
1829await PublishAzureEnvironmentStateAsync(model, KnownResourceStates.NotStarted, cancellationToken).ConfigureAwait(false);
1838await ResetResourcesAsync(model, GetProvisionableAzureResources(model), preserveOverrides: true, cancellationToken, preserveInferredLocationOverrides: false).ConfigureAwait(false);
1839await PublishAzureEnvironmentStateAsync(model, KnownResourceStates.NotStarted, cancellationToken).ConfigureAwait(false);
1854await ResetResourcesAsync(model, GetProvisionableAzureResources(model), preserveOverrides: true, cancellationToken).ConfigureAwait(false);
1855await PublishAzureEnvironmentStateAsync(model, KnownResourceStates.NotStarted, cancellationToken).ConfigureAwait(false);
1870cancellationToken).ConfigureAwait(false);
1888preserveOverrides: true, cancellationToken).ConfigureAwait(false);
1889await PublishAzureEnvironmentStateAsync(model, KnownResourceStates.NotStarted, cancellationToken).ConfigureAwait(false);
1896cancellationToken).ConfigureAwait(false);
2008}).ConfigureAwait(false);
2020await DeleteCachedResourceForLocationChangeAsync(targetBicepResource, intent.Location, resourceDeletion, cancellationToken).ConfigureAwait(false);
2021await SetResourceLocationOverrideAsync(targetBicepResource.Name, intent.Location, cancellationToken).ConfigureAwait(false);
2028await ResetResourcesAsync(model, targetResources, preserveOverrides: true, cancellationToken).ConfigureAwait(false);
2038await ResetResourcesAsync(model, targetResources, preserveOverrides: true, cancellationToken).ConfigureAwait(false);
2076await PublishSyntheticProvisioningFailureAsync(model, targetResources, failureDetails).ConfigureAwait(false);
2080await ResetResourcesAsync(model, targetResources, preserveOverrides: true, cancellationToken).ConfigureAwait(false);
2155}).ConfigureAwait(false);
2172}).ConfigureAwait(false);
2197}).ConfigureAwait(false);
2219await DeleteAzureResourceIdsAsync(resourceIds, intent.ResourceName, effectiveLocation, currentContext.Location, allowKeyVaultPurgeTimeout: true, cancellationToken).ConfigureAwait(false);
2220await ResetResourcesAsync(model, targetResources, preserveOverrides: true, cancellationToken).ConfigureAwait(false);
2229}).ConfigureAwait(false);
2241}).ConfigureAwait(false);
2298}).ConfigureAwait(false);
2309cancellationToken).ConfigureAwait(false);
2477await action().ConfigureAwait(false);
2880await deploymentStateManager.SaveSectionAsync(section, cancellationToken).ConfigureAwait(false);
2904await deploymentStateManager.SaveSectionAsync(section, cancellationToken).ConfigureAwait(false);
2942await CancelCachedDeploymentAsync(deploymentId, loggerService.GetLogger(resource.AzureResource), cancellationToken).ConfigureAwait(false);
2948cancellationToken).ConfigureAwait(false);
2979await deploymentStateManager.SaveSectionAsync(section, cancellationToken).ConfigureAwait(false);
3001await armClient.CancelDeploymentAsync(deploymentId, cancellationToken).ConfigureAwait(false);
3039await AddDeploymentOperationTargetResourceIdsAsync(bicepResource, resourceIds, cancellationToken).ConfigureAwait(false);
3104await armClient.DeleteResourceAsync(resourceId, cancellationToken).ConfigureAwait(false);
3613await resourceDeletion.ArmClient.DeleteResourceAsync(resourceDeletion.ResourceId, cancellationToken).ConfigureAwait(false);
3726await deploymentStateManager.SaveSectionAsync(section, cancellationToken).ConfigureAwait(false);
3732await deploymentStateManager.DeleteSectionAsync(section, cancellationToken).ConfigureAwait(false);
3771await notificationService.PublishUpdateAsync(resource, state => ApplyActiveOperationProperties(resource, state)).ConfigureAwait(false);
3811await notificationService.PublishUpdateAsync(targetResource, state => ApplyActiveOperationProperties(targetResource, stateFactory(state))).ConfigureAwait(false);
3817await PublishAsync(resource.AzureResource).ConfigureAwait(false);
3821await PublishAsync(resource.Resource).ConfigureAwait(false);
3840await PublishAsync(child).ConfigureAwait(false);
3850await resource.AzureResource.ProvisioningTaskCompletionSource!.Task.ConfigureAwait(false);
3861}).ConfigureAwait(false);
3869}).ConfigureAwait(false);
3876}).ConfigureAwait(false);
3892}).ConfigureAwait(false);
3911}).ConfigureAwait(false);
3933}).ConfigureAwait(false);
3958}).ConfigureAwait(false);
3998await roleAssignment.RolesResource.ProvisioningTaskCompletionSource!.Task.ConfigureAwait(false);
4007}).ConfigureAwait(false);
4049await eventing.PublishAsync(beforeResourceStartedEvent, cancellationToken).ConfigureAwait(false);
4071await WaitForProvisioningDependenciesAsync(bicepResource, executionContext, cancellationToken).ConfigureAwait(false);
4085cancellationToken).ConfigureAwait(false);
4095await PublishConnectionStringAvailableEventAsync(resource.Resource, parentChildLookup, cancellationToken).ConfigureAwait(false);
4118cancellationToken).ConfigureAwait(false);
4122await PublishConnectionStringAvailableEventAsync(resource.Resource, parentChildLookup, cancellationToken).ConfigureAwait(false);
4195.OfType<Task>()).ConfigureAwait(false);
4236await eventing.PublishAsync(connectionStringAvailableEvent, cancellationToken).ConfigureAwait(false);
4245await PublishConnectionStringAvailableEventAsync(child, parentChildLookup, cancellationToken).ConfigureAwait(false);
4270cancellationToken).ConfigureAwait(false);
4282cancellationToken).ConfigureAwait(false);
4317})).ConfigureAwait(false);
AzurePublishingContext.cs (16)
117await WriteAzureArtifactsOutputAsync(ReportingStep, model, environment, cancellationToken).ConfigureAwait(false);
119await SaveToDiskAsync(outputPath).ConfigureAwait(false);
148await MapParameterAsync(environment.ResourceGroupName, cancellationToken).ConfigureAwait(false);
149await MapParameterAsync(environment.Location, cancellationToken).ConfigureAwait(false);
150await MapParameterAsync(environment.PrincipalId, cancellationToken).ConfigureAwait(false);
207await VisitAsync(existingAnnotation.ResourceGroup, MapParameterAsync, cancellationToken).ConfigureAwait(false);
208await VisitAsync(existingAnnotation.Subscription, MapParameterAsync, cancellationToken).ConfigureAwait(false);
209await VisitAsync(existingAnnotation.Name, MapParameterAsync, cancellationToken).ConfigureAwait(false);
216await VisitAsync(scope.ResourceGroup, MapParameterAsync, cancellationToken).ConfigureAwait(false);
218await VisitAsync(scope.Subscription, MapParameterAsync, cancellationToken).ConfigureAwait(false);
224await VisitAsync(parameter.Value, MapParameterAsync, cancellationToken).ConfigureAwait(false);
423await computeEnvironmentTask.CompleteAsync(message, state, cancellationToken).ConfigureAwait(false);
462await dockerfileBuildAnnotation.EmitDockerfileArtifactsAsync(context, resourceDockerfilePath).ConfigureAwait(false);
576await visitor(value, cancellationToken).ConfigureAwait(false);
582await VisitAsync(reference, visitor, visited, cancellationToken).ConfigureAwait(false);
609await File.WriteAllTextAsync(bicepPath, compiledBicep.Value).ConfigureAwait(false);
Provisioning\BicepUtilities.cs (4)
110await SetScopeValueAsync(scope, "resourceGroup", targetScope.ResourceGroup, cancellationToken).ConfigureAwait(false);
112await SetScopeValueAsync(scope, "subscription", targetScope.Subscription, cancellationToken).ConfigureAwait(false);
166await SetParametersAsync(parameters, resource, executionContext, skipKnownValues: true, cancellationToken: cancellationToken).ConfigureAwait(false);
169await SetScopeAsync(scope, resource, cancellationToken).ConfigureAwait(false);
Provisioning\Provisioners\BicepProvisioner.cs (31)
148}).ConfigureAwait(false);
218await ClearCachedRunningDeploymentStateAsync(stateSection, cancellationToken).ConfigureAwait(false);
240await ClearCachedRunningDeploymentStateAsync(stateSection, cancellationToken).ConfigureAwait(false);
269await PublishCachedRunningDeploymentStateAsync(resource, context, deploymentId, currentLocation, tracker, cancellationToken).ConfigureAwait(false);
284await Task.Delay(s_deploymentOperationPollingInterval, _timeProvider, cancellationToken).ConfigureAwait(false);
337}).ConfigureAwait(false);
384await deploymentStateManager.SaveSectionAsync(stateSection, cancellationToken).ConfigureAwait(false);
419await PersistReconciledProvisioningStateAsync(stateSection, DeploymentStateProvisioningStateCanceled, cancellationToken).ConfigureAwait(false);
420await PublishReconciledTerminalStateAsync(resource, AzureProvisioningStrings.ResourceStateAzureDeploymentCanceled).ConfigureAwait(false);
428await PersistReconciledProvisioningStateAsync(stateSection, DeploymentStateProvisioningStateFailed, cancellationToken).ConfigureAwait(false);
429await PublishReconciledTerminalStateAsync(resource, AzureProvisioningStrings.ResourceStateAzureDeploymentFailed).ConfigureAwait(false);
439await deploymentStateManager.SaveSectionAsync(stateSection, cancellationToken).ConfigureAwait(false);
447}).ConfigureAwait(false);
458await deploymentStateManager.SaveSectionAsync(stateSection, cancellationToken).ConfigureAwait(false);
462await deploymentStateManager.DeleteSectionAsync(stateSection, cancellationToken).ConfigureAwait(false);
542}).ConfigureAwait(false);
559.ConfigureAwait(false);
566await BicepUtilities.SetParametersAsync(parameters, resource, executionContext, cancellationToken: cancellationToken).ConfigureAwait(false);
569await BicepUtilities.SetScopeAsync(scope, resource, cancellationToken: cancellationToken).ConfigureAwait(false);
594.ConfigureAwait(false);
626await deploymentStateManager.SaveSectionAsync(canceledStateSection, CancellationToken.None).ConfigureAwait(false);
663}).ConfigureAwait(false);
683await deploymentStateManager.SaveSectionAsync(stateSection, statePersistenceCancellationToken).ConfigureAwait(false);
699.ConfigureAwait(false);
753await deploymentStateManager.SaveSectionAsync(stateSection, statePersistenceCancellationToken).ConfigureAwait(false);
784await deploymentStateManager.SaveSectionAsync(stateSection, statePersistenceCancellationToken).ConfigureAwait(false);
803await deploymentStateManager.SaveSectionAsync(stateSection, statePersistenceCancellationToken).ConfigureAwait(false);
840.ConfigureAwait(false);
954await Task.Delay(s_deploymentOperationPollingInterval, _timeProvider, cancellationToken).ConfigureAwait(false);
1003.ConfigureAwait(false);
1299await deployments.CancelAsync(deploymentName, CancellationToken.None).ConfigureAwait(false);
Aspire.Hosting.Azure.AppContainers (6)
Aspire.Hosting.Azure.AppService (9)
Aspire.Hosting.Azure.ContainerRegistry (2)
Aspire.Hosting.Azure.EntraId (8)
EntraIdResourceExtensions.cs (8)
89await InitializeEntraIdResourceOnceAsync(resource, evt, cancellationToken).ConfigureAwait(false);
113await InitializeEntraIdResourceOnceAsync(resource, evt, cancellationToken).ConfigureAwait(false);
129await PublishFailedToStartAsync(resource, evt).ConfigureAwait(false);
152await PublishFailedToStartAsync(resource, evt).ConfigureAwait(false);
191await PublishFailedToStartAsync(resource, evt).ConfigureAwait(false);
200await evt.Eventing.PublishAsync(new BeforeResourceStartedEvent(resource, evt.Services), cancellationToken).ConfigureAwait(false);
206await PublishFailedToStartAsync(resource, evt).ConfigureAwait(false);
245}).ConfigureAwait(false);
Aspire.Hosting.Azure.Functions (1)
Aspire.Hosting.Azure.Kubernetes (6)
Aspire.Hosting.Azure.Kusto (2)
Aspire.Hosting.Azure.Kusto.Tests (2)
Aspire.Hosting.Azure.Sandboxes (53)
AzureSandboxContainerDeployment.cs (42)
281await deploymentStateManager.SaveSectionAsync(stateSection, context.CancellationToken).ConfigureAwait(false);
312await diskTask.CompleteAsync($"Created sandbox disk image {diskImageId}", CompletionState.Completed, context.CancellationToken).ConfigureAwait(false);
338await createTask.CompleteAsync($"Created sandbox {sandboxId}", CompletionState.Completed, context.CancellationToken).ConfigureAwait(false);
351await lifecycleTask.CompleteAsync("Lifecycle policy configured", CompletionState.Completed, context.CancellationToken).ConfigureAwait(false);
376await exposeTask.CompleteAsync(new MarkdownString($"Public URL: [{endpointUrl}]({endpointUrl})"), CompletionState.Completed, context.CancellationToken).ConfigureAwait(false);
411await deploymentStateManager.SaveSectionAsync(stateSection, context.CancellationToken).ConfigureAwait(false);
441throwOnError: securityConfigurationChanged).ConfigureAwait(false);
453throwOnError: true).ConfigureAwait(false);
467throwOnError: true).ConfigureAwait(false);
477await deploymentStateManager.SaveSectionAsync(stateSection, context.CancellationToken).ConfigureAwait(false);
522deploymentCleanupCts.Token).ConfigureAwait(false);
533deploymentCleanupCts.Token).ConfigureAwait(false);
543deploymentCleanupCts.Token).ConfigureAwait(false);
712await Task.Delay(TimeSpan.FromSeconds(2), context.CancellationToken).ConfigureAwait(false);
1078await callback.Callback(callbackContext).ConfigureAwait(false);
1149await callback.Callback(callbackContext).ConfigureAwait(false);
1334context.CancellationToken).ConfigureAwait(false);
1348throwOnError: true).ConfigureAwait(false);
1352context.CancellationToken).ConfigureAwait(false);
1364await DeleteExistingDeploymentAsync(context, client, scope, stateSection, throwOnError: true).ConfigureAwait(false);
1368await DeleteRemoteDeploymentsByResourceLabelAsync(context, client, scope, ownerId, resource.Name, s_noExcludedIds, s_noExcludedIds, s_noExcludedIds, throwOnError: true).ConfigureAwait(false);
1377throwOnError: true).ConfigureAwait(false);
1381await DeleteRemoteDeploymentsByResourceLabelAsync(context, client, scope, pendingOwnerCleanupId, resource.Name, s_noExcludedIds, s_noExcludedIds, s_noExcludedIds, throwOnError: true).ConfigureAwait(false);
1386await DeleteRemoteDeploymentsByResourceLabelAsync(context, client, scope, stableOwnerIdForScope, resource.Name, s_noExcludedIds, s_noExcludedIds, s_noExcludedIds, throwOnError: true).ConfigureAwait(false);
1388await deploymentStateManager.DeleteSectionAsync(stateSection, context.CancellationToken).ConfigureAwait(false);
1416await deploymentStateManager.DeleteSectionAsync(stateSection, context.CancellationToken).ConfigureAwait(false);
1435await DeleteExistingDeploymentAsync(context, client, scope, stateSection, throwOnError: true).ConfigureAwait(false);
1439await DeleteRemoteDeploymentsByResourceLabelAsync(context, client, scope, ownerId, resourceName, s_noExcludedIds, s_noExcludedIds, s_noExcludedIds, throwOnError: true).ConfigureAwait(false);
1448throwOnError: true).ConfigureAwait(false);
1463throwOnError: true).ConfigureAwait(false);
1465await deploymentStateManager.DeleteSectionAsync(stateSection, context.CancellationToken).ConfigureAwait(false);
1466await cleanupTask.CompleteAsync($"Deleted stale sandbox deployment {sectionName}", CompletionState.Completed, context.CancellationToken).ConfigureAwait(false);
1597await DeleteSandboxAsync(context, client, scope, sandboxId, GetStatePorts(stateSection), throwOnError).ConfigureAwait(false);
1610await DeleteDiskImageAsync(context, client, scope, diskImageId, throwOnError).ConfigureAwait(false);
1668throwOnError).ConfigureAwait(false);
1684await DeleteDiskImageAsync(context, client, scope, diskImage.Id, throwOnError).ConfigureAwait(false);
1721cancellationToken).ConfigureAwait(false);
1742cancellationToken).ConfigureAwait(false);
1757await Task.Delay(delay, cancellationToken).ConfigureAwait(false);
1807pollInterval).ConfigureAwait(false);
2256await client.DeleteSandboxAsync(scope, sandboxId, effectiveCancellationToken).ConfigureAwait(false);
2291await client.DeleteDiskImageAsync(scope, diskImageId, effectiveCancellationToken).ConfigureAwait(false);
Internal\Adc\AzureDevComputeClient.cs (6)
197await EnsureSuccessAsync(response, method, path, cancellationToken).ConfigureAwait(false);
214await EnsureSuccessAsync(response, method, path, cancellationToken).ConfigureAwait(false);
255await EnsureSuccessAsync(response, method, path, cancellationToken).ConfigureAwait(false);
320await Task.Delay(networkRetryDelay, cancellationToken).ConfigureAwait(false);
346await Task.Delay(forbiddenRetryDelay, cancellationToken).ConfigureAwait(false);
365await Task.Delay(delay, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Azure.Tests (16)
Aspire.Hosting.Blazor (13)
Aspire.Hosting.Blazor.Tests (3)
Aspire.Hosting.Browsers (49)
Aspire.Hosting.Browsers.Tests (53)
Aspire.Hosting.Containers.Tests (2)
Aspire.Hosting.DevTunnels (61)
DevTunnelCliClient.cs (9)
100await EnsureAccessAsync(existing.TunnelId, portNumber: null, options.AllowAnonymous ? true : null, access, logger, cancellationToken).ConfigureAwait(false);
188await Task.Delay(_cliRetryOnErrorDelay, cancellationToken).ConfigureAwait(false);
244await EnsureAccessAsync(tunnelId, portNumber, portOptions.AllowAnonymous, access, logger, cancellationToken).ConfigureAwait(false);
275await EnsureAccessAsync(port.TunnelId, portNumber, portOptions.AllowAnonymous, port.AccessControl ?? [], logger, cancellationToken).ConfigureAwait(false);
296await Task.Delay(_cliRetryOnErrorDelay, cancellationToken).ConfigureAwait(false);
317await Task.Delay(_cliRetryOnErrorDelay, cancellationToken).ConfigureAwait(false);
348await Task.Delay(_cliRetryOnErrorDelay, cancellationToken).ConfigureAwait(false);
409await CreateAnonymousAccessAsync(tunnelId, portNumber, allow: false, logger, cancellationToken).ConfigureAwait(false);
435await CreateAnonymousAccessAsync(tunnelId, portNumber, allow, logger, cancellationToken).ConfigureAwait(false);
DevTunnelMonitor.cs (36)
77await StopRunAsync().ConfigureAwait(false);
88await PublishAsync(run).ConfigureAwait(false);
102await StopRunAsync().ConfigureAwait(false);
107await DevTunnelsResourceBuilderExtensions.StopPortAsync(port, _services, cancellationToken).ConfigureAwait(false);
133await healthTask.WaitAsync(cancellationToken).ConfigureAwait(false);
144await ApplyLogsAsync(run, [new(1, content, false)]).ConfigureAwait(false);
152await task.WaitAsync(cancellationToken).ConfigureAwait(false);
163await run.HostReady.Task.WaitAsync(StartupLogTimeout, _timeProvider, run.Cancellation.Token).ConfigureAwait(false);
181await ReconcileAsync(run, run.Cancellation.Token).ConfigureAwait(false);
184await Task.Delay(ReconciliationRetryInterval, _timeProvider, run.Cancellation.Token).ConfigureAwait(false);
190await run.Ready.Task.WaitAsync(run.Cancellation.Token).ConfigureAwait(false);
205await task.WaitAsync(cancellationToken).ConfigureAwait(false);
262await PublishAsync(run).ConfigureAwait(false);
301await PublishAsync(run).ConfigureAwait(false);
306await CheckLoginAsync(run).ConfigureAwait(false);
320.Prepend(RefreshAccessAsync(run, port: null, portNumber: null))).ConfigureAwait(false);
356await DevTunnelsResourceBuilderExtensions.UpdatePortAccessAsync(port, _notifications, _logs, _timeProvider.GetUtcNow()).ConfigureAwait(false);
363await CheckLoginAsync(run).ConfigureAwait(false);
389await _loggedOutNotifications.NotifyUserLoggedOutAsync(cancellationToken).WaitAsync(cancellationToken).ConfigureAwait(false);
411await ApplyLogsAsync(run, batch).ConfigureAwait(false);
543await PublishAsync(run).ConfigureAwait(false);
615await _notifications.PublishUpdateAsync(_resource, snapshot => WithConnectionHealth(snapshot, _resource.Name, healthy, description)).ConfigureAwait(false);
619await DevTunnelsResourceBuilderExtensions.UpdatePortAsync(port, available, _notifications, _logs, run.Cancellation.Token).ConfigureAwait(false);
634.WaitAsync(cancellationToken).ConfigureAwait(false);
640await PublishAsync(current).ConfigureAwait(false);
644await DeactivatePortUrlsAsync(port).ConfigureAwait(false);
663await PublishAsync(current).ConfigureAwait(false);
667await DeactivatePortUrlsAsync(port).ConfigureAwait(false);
711await run.Cancellation.CancelAsync().ConfigureAwait(false);
714await Task.WhenAll(run.LogTask, run.StateTask, run.ReconciliationTask, run.AccessTask, run.LoginTask, run.InitialHealthTask ?? Task.CompletedTask).ConfigureAwait(false);
725await completion.Task.WaitAsync(cancellationToken).ConfigureAwait(false);
736await operation.Action().ConfigureAwait(false);
758await _stopping.CancelAsync().ConfigureAwait(false);
764await _processing.ConfigureAwait(false);
765await StopRunAsync().ConfigureAwait(false);
766await Task.WhenAll(_endpointEvents.Values).ConfigureAwait(false);
DevTunnelResourceBuilderExtensions.cs (10)
141await devTunnelEnvironmentManager.EnsureUserLoggedInAsync(ct).ConfigureAwait(false);
176await Task.WhenAll(portTasks).ConfigureAwait(false);
178await e.Services.GetRequiredKeyedService<DevTunnelMonitor>(tunnelResource).StartAsync(resolvedTunnelId, ct).ConfigureAwait(false);
202}).ConfigureAwait(false);
226await eventing.PublishAsync<BeforeResourceStartedEvent>(new(portResource, e.Services), EventDispatchBehavior.NonBlockingConcurrent, ct).ConfigureAwait(false);
731}, portResource.Name, false, description)).ConfigureAwait(false);
754}, portResource.Name, true, description)).ConfigureAwait(false);
817}).ConfigureAwait(false);
838}).ConfigureAwait(false);
843EventDispatchBehavior.NonBlockingSequential, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.DevTunnels.Tests (4)
Aspire.Hosting.Docker (25)
DockerComposeEnvironmentResource.cs (12)
152ctx.CancellationToken).ConfigureAwait(false);
156await ConfirmDestroyAsync(ctx, Name).ConfigureAwait(false);
177await runtime.ComposeDownAsync(composeContext, ctx.CancellationToken).ConfigureAwait(false);
181ctx.CancellationToken).ConfigureAwait(false);
187await deploymentStateManager.DeleteSectionAsync(stateSection, ctx.CancellationToken).ConfigureAwait(false);
448await runtime.ComposeUpAsync(composeContext, context.CancellationToken).ConfigureAwait(false);
456await deploymentStateManager.SaveSectionAsync(stateSection, context.CancellationToken).ConfigureAwait(false);
461context.CancellationToken).ConfigureAwait(false);
465await deployTask.CompleteAsync($"Compose deployment failed ({runtime.Name}): {ex.Message}", CompletionState.CompletedWithError, context.CancellationToken).ConfigureAwait(false);
494await runtime.ComposeDownAsync(composeContext, context.CancellationToken).ConfigureAwait(false);
499context.CancellationToken).ConfigureAwait(false);
503await deployTask.CompleteAsync($"Compose shutdown failed ({runtime.Name}): {ex.Message}", CompletionState.CompletedWithError, context.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.Dotnet (11)
Aspire.Hosting.Dotnet.Tests (2)
Aspire.Hosting.DotnetTool.Tests (2)
Aspire.Hosting.EntityFrameworkCore (22)
EFResourceBuilderExtensions.cs (17)
524}).ConfigureAwait(false);
562}).ConfigureAwait(false);
572}).ConfigureAwait(false);
584}).ConfigureAwait(false);
595await Task.WhenAll(stdoutTask, stderrTask).ConfigureAwait(false);
596await process.WaitForExitAsync(context.CancellationToken).ConfigureAwait(false);
604}).ConfigureAwait(false);
640}).ConfigureAwait(false);
665}).ConfigureAwait(false);
770await callback.Callback(context).ConfigureAwait(false);
935await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.Waiting, KnownResourceStateStyles.Info).ConfigureAwait(false);
936await resourceNotificationService.WaitForDependenciesAsync(migrationResource, context.CancellationToken).ConfigureAwait(false);
939await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.Running, KnownResourceStateStyles.Info).ConfigureAwait(false);
955await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.Finished, KnownResourceStateStyles.Info).ConfigureAwait(false);
959await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error).ConfigureAwait(false);
967await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.NotStarted, KnownResourceStateStyles.Info).ConfigureAwait(false);
974await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error).ConfigureAwait(false);
Aspire.Hosting.Foundry (51)
Aspire.Hosting.Foundry.Tests (2)
Aspire.Hosting.JavaScript.Tests (2)
Aspire.Hosting.Kafka.Tests (2)
Aspire.Hosting.Kubernetes (60)
Deployment\HelmDeploymentEngine.cs (16)
141await HelmVersionValidator.EnsureMinimumVersionAsync(helmRunner, ctx.CancellationToken).ConfigureAwait(false);
209ctx.CancellationToken).ConfigureAwait(false);
215await ConfirmDestroyAsync(ctx, $"Uninstall Helm release '{savedReleaseName}' from namespace '{@namespace}'? This action cannot be undone.").ConfigureAwait(false);
217await HelmUninstallAsync(ctx, environment, savedReleaseName, @namespace).ConfigureAwait(false);
223await deploymentStateManager.DeleteSectionAsync(stateSection, ctx.CancellationToken).ConfigureAwait(false);
266await ResolveAndWriteDeployValuesAsync(outputPath, environment, context.CancellationToken).ConfigureAwait(false);
271context.CancellationToken).ConfigureAwait(false);
278context.CancellationToken).ConfigureAwait(false);
366await File.WriteAllTextAsync(overrideFilePath, overrideContent, cancellationToken).ConfigureAwait(false);
491await deploymentStateManager.SaveSectionAsync(stateSection, context.CancellationToken).ConfigureAwait(false);
496context.CancellationToken).ConfigureAwait(false);
504context.CancellationToken).ConfigureAwait(false);
590await HelmUninstallAsync(context, environment, releaseName, @namespace).ConfigureAwait(false);
613context.CancellationToken).ConfigureAwait(false);
641context.CancellationToken).ConfigureAwait(false);
649context.CancellationToken).ConfigureAwait(false);
KubernetesEnvironmentResource.cs (13)
520await ProcessIngressResources(appModel, deploymentTargets, logger, context.CancellationToken).ConfigureAwait(false);
523await ProcessGatewayResources(appModel, deploymentTargets, logger, context.CancellationToken).ConfigureAwait(false);
526await ProcessPersistentVolumeResources(appModel, context.CancellationToken).ConfigureAwait(false);
987await BuildGatewayObjects(gatewayResource, deploymentTargets, logger, cancellationToken).ConfigureAwait(false);
1464context).ConfigureAwait(false);
1521await File.WriteAllTextAsync(patchFilePath, patchJson, context.CancellationToken).ConfigureAwait(false);
1570gatewayName, @namespace, environment, context).ConfigureAwait(false);
1634await File.WriteAllTextAsync(certPath, certPem, context.CancellationToken).ConfigureAwait(false);
1635await File.WriteAllTextAsync(keyPath, keyPem, context.CancellationToken).ConfigureAwait(false);
1967await File.WriteAllTextAsync(patchFilePath, patchJson, context.CancellationToken).ConfigureAwait(false);
2148await File.WriteAllTextAsync(manifestPath, minimal.ToJsonString(), context.CancellationToken).ConfigureAwait(false);
2271await File.WriteAllTextAsync(certPath, certPem, context.CancellationToken).ConfigureAwait(false);
2272await File.WriteAllTextAsync(keyPath, keyPem, context.CancellationToken).ConfigureAwait(false);
KubernetesPublishingContext.cs (17)
64await WriteKubernetesOutputAsync(model, environment).ConfigureAwait(false);
96await dockerfileBuildAnnotation.EmitDockerfileArtifactsAsync(dockerfileContext, resourceDockerfilePath).ConfigureAwait(false);
113await WriteKubernetesTemplatesForResource(resource, serviceResource.GetTemplatedResources()).ConfigureAwait(false);
114await AppendResourceContextToHelmValuesAsync(resource, serviceResource).ConfigureAwait(false);
123await WriteKubernetesTemplatesForResource(ingressResource, [generatedIngress]).ConfigureAwait(false);
134await WriteKubernetesTemplatesForResource(gatewayResource, gatewayObjects).ConfigureAwait(false);
143await WriteKubernetesTemplatesForResource(volumeResource, [generatedClaim]).ConfigureAwait(false);
147await WriteKubernetesHelmChartAsync(environment).ConfigureAwait(false);
156await WriteKubernetesHelmValuesAsync().ConfigureAwait(false);
205await AddValuesToHelmSectionAsync(resource, parameterItems, HelmExtensions.ParametersKey).ConfigureAwait(false);
206await AddValuesToHelmSectionAsync(resource, configItems, HelmExtensions.ConfigKey).ConfigureAwait(false);
207await AddValuesToHelmSectionAsync(resource, secretItems, HelmExtensions.SecretsKey).ConfigureAwait(false);
377await writer.WriteLineAsync(HelmExtensions.TemplateFileSeparator).ConfigureAwait(false);
378await writer.WriteAsync(yaml).ConfigureAwait(false);
403await File.WriteAllTextAsync(outputFile, valuesYaml, cancellationToken).ConfigureAwait(false);
408await ResolveHelmChartMetadataAsync(environment).ConfigureAwait(false);
425await File.WriteAllTextAsync(outputFile, chartYaml, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Maui (19)
MauiOtlpExtensions.cs (3)
188await AllocateOtlpStubEndpointAsync(currentTunnelConfig, dashboardOtlpEndpoint.Value, evt.Services, appBuilder.Eventing, ct).ConfigureAwait(false);
202await AllocateOtlpStubEndpointAsync(currentTunnelConfig, dashboardOtlpEndpoint, evt.Services, appBuilder.Eventing, ct).ConfigureAwait(false);
524await eventing.PublishAsync(new ResourceEndpointsAllocatedEvent(tunnelConfig.OtlpStub, services), cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Maui.Tests (4)
Aspire.Hosting.MongoDB (12)
Aspire.Hosting.MySql (2)
Aspire.Hosting.MySql.Tests (2)
Aspire.Hosting.OpenAI (4)
Aspire.Hosting.OpenAI.Tests (2)
Aspire.Hosting.Orleans.Tests (1)
Aspire.Hosting.PostgreSQL (2)
Aspire.Hosting.PostgreSQL.Tests (2)
Aspire.Hosting.RabbitMQ.Tests (2)
Aspire.Hosting.Radius (38)
Publishing\RadiusInfrastructureBuilder.cs (17)
401await ApplyBackingResourceCredentialsAsync(radiusResources, options, envConstruct, appConstruct).ConfigureAwait(false);
2166resource, withConnectionString, construct, referencedResourceNames).ConfigureAwait(false);
2172propertyName, secretKey).ConfigureAwait(false);
2472await SetTypePropertyAsync(construct, "password", withConnectionString, "password").ConfigureAwait(false);
2499await SetTypePropertyAsync(construct, "username", withConnectionString, "username").ConfigureAwait(false);
2536await SetTypePropertyAsync(construct, "database", withConnectionString, "username").ConfigureAwait(false);
2634await SetTypePropertyAsync(construct, "database", databaseChild, "databasename").ConfigureAwait(false);
2785await SetTypePropertyAsync(construct, "username", withConnectionString, "username").ConfigureAwait(false);
3262await ResolveEnvPartsAsync(expression, resource, parts, resource, allowRecipeSubstitutions: false).ConfigureAwait(false);
3662await callback.Callback(context).ConfigureAwait(false);
3692await ResolveEnvPartsAsync(rawValue, resource, parts, ResolveEnvValueProvenance(rawValue, key, resource, referencePrefixes)).ConfigureAwait(false);
4170await ResolveEnvPartsAsync(connectionStringReference.ConnectionStringExpression, owner, parts, ResolveToParent(connectionStringReference.Resource), allowRecipeSubstitutions).ConfigureAwait(false);
4174await ResolveEnvPartsAsync(resourceWithConnectionString.ConnectionStringExpression, owner, parts, ResolveToParent(resourceWithConnectionString), allowRecipeSubstitutions).ConfigureAwait(false);
4178await ResolveReferenceExpressionPartsAsync(referenceExpression, owner, parts, referencedResource, allowRecipeSubstitutions).ConfigureAwait(false);
4364await ResolveEnvPartsAsync(expression.Condition, owner, conditionParts, referencedResource, allowRecipeSubstitutions).ConfigureAwait(false);
4418await ResolveReferenceExpressionPartsAsync(branch, owner, parts, referencedResource, allowRecipeSubstitutions).ConfigureAwait(false);
4434await ResolveEnvPartsAsync(expression.ValueProviders[i], owner, inner, referencedResource, allowRecipeSubstitutions).ConfigureAwait(false);
Aspire.Hosting.Radius.Tests (1)
Aspire.Hosting.RemoteHost (49)
src\Shared\ChildProcess.cs (24)
248await process.WaitForExitAsync(cancellationToken).ConfigureAwait(false);
261await process.WaitForExitAsync(cancellationToken).ConfigureAwait(false);
269await ShutdownOnCancelAsync(process).ConfigureAwait(false);
285await DrainOutputAsync(CancellationToken.None).ConfigureAwait(false);
293await VerifyContainedTerminationAsync(process).ConfigureAwait(false);
302await DrainOutputAsync(cancellationToken).ConfigureAwait(false);
331await ShutdownLadderAsync(process, requestShutdown, gracefulToken).ConfigureAwait(false);
337_options.TerminationTimeout, _options.TimeProvider, CancellationToken.None).ConfigureAwait(false);
342await VerifyContainedTerminationAsync(process).ConfigureAwait(false);
355await process.WaitForExitAsync(gracefulToken).ConfigureAwait(false);
369_options.TerminationTimeout, _options.TimeProvider, CancellationToken.None).ConfigureAwait(false);
376await signalTask.WaitAsync(_options.TerminationTimeout, _options.TimeProvider, CancellationToken.None).ConfigureAwait(false);
393await signaler(pid, gracefulToken).ConfigureAwait(false);
429await process.WaitForExitAsync().WaitAsync(_options.TerminationTimeout, _options.TimeProvider).ConfigureAwait(false);
438await Task.Delay(TimeSpan.FromMilliseconds(25), _options.TimeProvider, deadline.Token).ConfigureAwait(false);
576await ShutdownOnCancelAsync(process).ConfigureAwait(false);
584await process.WaitForExitAsync().WaitAsync(_options.TerminationTimeout, _options.TimeProvider).ConfigureAwait(false);
591await VerifyContainedTerminationAsync(process).ConfigureAwait(false);
595await ShutdownOnCancelAsync(process).ConfigureAwait(false);
597await DrainOutputAsync(CancellationToken.None).ConfigureAwait(false);
643await drained.ConfigureAwait(false);
670await drained.WaitAsync(s_drainPollInterval, _options.TimeProvider, cancellationToken).ConfigureAwait(false);
707await readers.ConfigureAwait(false);
720process.StartInfo.RedirectStandardError ? ReadAsync(process.StandardError, true) : Task.CompletedTask).ConfigureAwait(false);
Aspire.Hosting.RemoteHost.Tests (4)
Aspire.Hosting.Rust (6)
Aspire.Hosting.Rust.Tests (1)
Aspire.Hosting.SqlServer (4)
Aspire.Hosting.Testing (12)
Aspire.Hosting.Testing.Tests (3)
Aspire.Hosting.Tests (19)
Aspire.Hosting.TestUtilities (4)
Aspire.Hosting.Valkey.Tests (2)
Aspire.Microsoft.Extensions.Configuration.AzureAppConfiguration.Tests (2)
Aspire.Playground.Tests (3)
Aspire.Templates.Tests (5)
Aspire.TerminalHost (36)
Aspire.TerminalHost.Tests (17)
TerminalHostAppTests.cs (15)
723await releaseCallback.Task.ConfigureAwait(false);
863await SendFrameAsync(FrameHello, System.Text.Encoding.UTF8.GetBytes(json), ct).ConfigureAwait(false);
894await ReadExactlyAsync(header, ct).ConfigureAwait(false);
906await ReadExactlyAsync(payload, ct).ConfigureAwait(false);
939await _stream.FlushAsync(ct).ConfigureAwait(false);
966await socket.ConnectAsync(new UnixDomainSocketEndPoint(socketPath)).ConfigureAwait(false);
973await Task.Delay(50).ConfigureAwait(false);
1015await socket.ConnectAsync(new UnixDomainSocketEndPoint(socketPath)).ConfigureAwait(false);
1022await Task.Delay(50).ConfigureAwait(false);
1034await SendFrameAsync(FrameClientHello, System.Text.Encoding.UTF8.GetBytes(json), ct).ConfigureAwait(false);
1056await SendFrameAsync(FrameRequestPrimary, System.Text.Encoding.UTF8.GetBytes(json), ct).ConfigureAwait(false);
1063await ReadExactlyAsync(header, ct).ConfigureAwait(false);
1074await ReadExactlyAsync(payload, ct).ConfigureAwait(false);
1108await _stream.FlushAsync(ct).ConfigureAwait(false);
1132await Task.Delay(25).ConfigureAwait(false);
Aspire.TestTools (3)
Aspire.Tray.Tests (43)
Binding.Tcp.IntegrationTests (1)
cdac-build-tool (1)
CreateLayout (4)
csc (12)
src\roslyn\src\Compilers\Shared\BuildProtocol.cs (7)
128await ReadAllAsync(inStream, lengthBuffer, 4, cancellationToken).ConfigureAwait(false);
187cancellationToken).ConfigureAwait(false);
190await memoryStream.CopyToAsync(outStream, bufferSize: length, cancellationToken: cancellationToken).ConfigureAwait(false);
305cancellationToken).ConfigureAwait(false);
308await memoryStream.CopyToAsync(outStream, bufferSize: length, cancellationToken: cancellationToken).ConfigureAwait(false);
324await ReadAllAsync(stream, lengthBuffer, 4, cancellationToken).ConfigureAwait(false);
332cancellationToken).ConfigureAwait(false);
dotnet-aot (2)
dotnet-svcutil-lib (132)
CommandProcessorOptions.cs (22)
207await ProcessProjectFileOptionAsync(cancellationToken).ConfigureAwait(false);
212await ProcessUpdateOptionAsync(cancellationToken).ConfigureAwait(false);
215await ProcessOutputDirOptionAsync(this.Project?.DirectoryPath, cancellationToken).ConfigureAwait(false);
220await ProcessBootstrapDirOptionAsync(cancellationToken).ConfigureAwait(false);
223await ProcessNamespaceMappingsOptionAsync(cancellationToken).ConfigureAwait(false);
226await ProcessInputsAsync(cancellationToken).ConfigureAwait(false);
229await ProcessTargetFrameworkOptionAsync(cancellationToken).ConfigureAwait(false);
234await ProcessReferencesOptionAsync(cancellationToken).ConfigureAwait(false);
239await ProcessReferenceAssembliesAsync(cancellationToken).ConfigureAwait(false);
292await safeLogger.WriteMessageAsync($"Tool context: {this.ToolContext}", logToUI: false).ConfigureAwait(false);
309await safeLogger.WriteMessageAsync($"Resetting unexpected option '{InputsKey}' ...", logToUI: false).ConfigureAwait(false);
316await safeLogger.WriteMessageAsync($"Resetting unexpected option '{option.Name}' ...", logToUI: false).ConfigureAwait(false);
371await logger.WriteMessageAsync($"{ProjectFileKey}:\"{projectFile}\"", logToUI: false).ConfigureAwait(false);
393await ProcessOutputFileOptionAsync(defaultDir, cancellationToken).ConfigureAwait(false);
407await logger.WriteMessageAsync($"{OutputDirKey}:\"{this.OutputDir}\"", logToUI: false).ConfigureAwait(false);
465await logger.WriteMessageAsync($"{OutputFileKey}:\"{filePath}\"", logToUI: false).ConfigureAwait(false);
566await logger.WriteMessageAsync($"Update option read from \"{paramsFilePath}\" ...", logToUI: false).ConfigureAwait(false);
589await logger.WriteMessageAsync($"{BootstrapPathKey}:\"{this.BootstrapPath}\"", logToUI: false).ConfigureAwait(false);
625await logger.WriteMessageAsync(Shared.Resources.ResolvingProjectReferences, logToUI: this.ToolContext <= OperationalContext.Global).ConfigureAwait(false);
713await SetupBootstrappingDirectoryAsync(logger, cancellationToken).ConfigureAwait(false);
743await safeLogger.WriteMessageAsync($"resolved inputs: {inputFiles.Count()}", logToUI: false).ConfigureAwait(false);
1035await RuntimeEnvironmentHelper.TryCopyingConfigFiles(workingDirectory, this.BootstrapPath.FullName, logger, cancellationToken).ConfigureAwait(false);
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\BufferedWriteStream.cs (10)
178await _sem.WaitAsync().ConfigureAwait(false);
183await FlushWriteAsync(cancellationToken).ConfigureAwait(false);
189await _stream.FlushAsync(cancellationToken).ConfigureAwait(false);
215await _stream.WriteAsync(_buffer, 0, _writePos, cancellationToken).ConfigureAwait(false);
217await _stream.FlushAsync(cancellationToken).ConfigureAwait(false);
457await semaphoreLockTask.ConfigureAwait(false);
485await _stream.WriteAsync(_buffer, 0, _writePos, cancellationToken).ConfigureAwait(false);
508await _stream.WriteAsync(_buffer, 0, totalUserBytes, cancellationToken).ConfigureAwait(false);
513await _stream.WriteAsync(_buffer, 0, _writePos, cancellationToken).ConfigureAwait(false);
518await _stream.WriteAsync(array, offset, count, cancellationToken).ConfigureAwait(false);
Metadata\MetadataDocumentLoader.cs (10)
184await LoadAsync(this.MetadataSourceUrl.AbsoluteUri, string.Empty, Directory.GetCurrentDirectory(), cancellationToken).ConfigureAwait(false);
190await LoadAsync(fileUri.LocalPath, string.Empty, Directory.GetCurrentDirectory(), cancellationToken).ConfigureAwait(false);
223await LoadFromStreamAsync(fileStream, fileInfo.FullName, fileInfo.DirectoryName, cancellationToken).ConfigureAwait(false);
297await LoadAsXmlSchemaAsync(reader, uri, basePath, cancellationToken).ConfigureAwait(false);
300await LoadAsWsdlAsync(reader, uri, basePath, cancellationToken).ConfigureAwait(false);
306await LoadAsEPRAsync(reader, cancellationToken).ConfigureAwait(false);
326await LoadAsXmlSchemaIncludesAsync(schema, uri, basePath, cancellationToken).ConfigureAwait(false);
364await LoadAsXmlSchemaIncludesAsync(schema, wsdl.RetrievalUrl, basePath, cancellationToken).ConfigureAwait(false);
380await LoadAsync(schemaUri.LocalPath, baseUrl, basePath, cancellationToken).ConfigureAwait(false);
389await LoadFromStreamAsync(stream, schemaUri.AbsoluteUri, basePath, cancellationToken).ConfigureAwait(false);
Shared\MSBuildProj.cs (13)
687await SaveAsync(logger, cancellationToken).ConfigureAwait(false);
708await AsyncHelper.RunAsync(() => ProjectNode.Save(writer), cancellationToken).ConfigureAwait(false);
722await this.SaveAsync(logger, cancellationToken).ConfigureAwait(false);
778await safeLogger.WriteWarningAsync(Shared.Resources.WarningMultiFxOrNoSupportedDnxVersion, logToUI: true).ConfigureAwait(false);
782await safeLogger.WriteMessageAsync($"Resolved project reference count: {dependencies.Count()}", logToUI: false).ConfigureAwait(false);
844await safeLogger.WriteWarningAsync(Shared.Resources.WarningMultiFxOrNoSupportedDnxVersion, logToUI: true).ConfigureAwait(false);
849await safeLogger.WriteWarningAsync(Shared.Resources.WarningCannotResolveProjectReferences, logToUI: true).ConfigureAwait(false);
856await safeLogger.WriteWarningAsync(ex.Message, logToUI: false).ConfigureAwait(false);
860await safeLogger.WriteMessageAsync($"Package reference count: {packageDependencies.Count}", logToUI: false).ConfigureAwait(false);
937await safeLogger.WriteWarningAsync(ex.Message, logToUI: false).ConfigureAwait(false);
945await safeLogger.WriteWarningAsync("Deps file not found (project not built), unable to resolve assembly/project dependencies!", logToUI: false).ConfigureAwait(false);
948await safeLogger.WriteMessageAsync($"Assembly reference count: {assemblyDependencies.Count}", logToUI: false).ConfigureAwait(false);
1018await safeLogger.WriteMessageAsync($"deps file: {depsFile}", logToUI: false).ConfigureAwait(false);
GenerateDocumentationAndConfigFiles (32)
Program.cs (11)
277await Console.Error.WriteLineAsync($"'{path}' does not exist".AsMemory(), cancellationToken).ConfigureAwait(false);
378await Console.Out.WriteLineAsync($"Failed to create analyzer rules missing documentation file. Http response timed out".AsMemory(), cancellationToken).ConfigureAwait(false);
384await Console.Error.WriteLineAsync("One or more auto-generated documentation files were either edited manually, or not updated. Please revert changes made to the following files (if manually edited) and run `dotnet msbuild /t:pack` at the root of the repo to automatically update them:".AsMemory(), cancellationToken).ConfigureAwait(false);
821await Console.Error.WriteLineAsync($"Missing entry in {fileWithPath}".AsMemory(), cancellationToken).ConfigureAwait(false);
822await Console.Error.WriteLineAsync(line.AsMemory(), cancellationToken).ConfigureAwait(false);
877await Console.Error.WriteLineAsync($"'{assemblyPath}' does not exist".AsMemory(), cancellationToken).ConfigureAwait(false);
889await Console.Error.WriteLineAsync(ex.Message.AsMemory(), cancellationToken).ConfigureAwait(false);
915await Console.Error.WriteLineAsync($"Expected both '{shippedFile}' and '{unshippedFile}' to exist or not exist, but '{existingFile}' exists and '{nonExistingFile}' does not exist.".AsMemory(), cancellationToken).ConfigureAwait(false);
925await Console.Error.WriteLineAsync($"'{shippedFile}' exists but was not expected".AsMemory(), cancellationToken).ConfigureAwait(false);
954await Console.Error.WriteLineAsync(ex.Message.AsMemory(), cancellationToken).ConfigureAwait(false);
962await Console.Error.WriteLineAsync($"Could not find any 'AnalyzerReleases.Shipped.md' file".AsMemory(), cancellationToken).ConfigureAwait(false);
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (8)
37await consumeItems(items.ToImmutableAndClear(), args, cancellationToken).ConfigureAwait(false);
77await args.consumeItems(items.ReadAllAsync(cancellationToken), args.args, cancellationToken).ConfigureAwait(false);
114await args.consumeItems(items, args.args, cancellationToken).ConfigureAwait(false);
238await args.produceItems(source, callback, args.args, cancellationToken).ConfigureAwait(false)),
299source, callback, args.args, cancellationToken).ConfigureAwait(false)),
344await Task.WhenAll(writeTask, readTask).ConfigureAwait(false);
367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
384await action(args, cancellationToken).ConfigureAwait(false);
GenerateTemplateManifest (1)
ILCompiler.DependencyAnalysisFramework (2)
Infrastructure.Tests (9)
Microsoft.Agents.AI.ProjectTemplates.Tests (2)
Microsoft.Analyzers.Extra.Tests (1)
Microsoft.Analyzers.Local.Tests (1)
Microsoft.AspNetCore.Authorization (4)
Microsoft.AspNetCore.Components (1)
Microsoft.AspNetCore.Components.Testing (30)
Microsoft.AspNetCore.Components.WebView.Maui (1)
Microsoft.AspNetCore.Diagnostics.Middleware (4)
Microsoft.AspNetCore.Diagnostics.Middleware.Tests (7)
Microsoft.AspNetCore.Hosting (5)
Microsoft.AspNetCore.Http.Connections.Client (29)
HttpConnection.cs (9)
212await StartAsyncCore(transferFormat, cancellationToken).ConfigureAwait(false);
226await _connectionLock.WaitAsync(cancellationToken).ConfigureAwait(false);
239await SelectAndStartTransport(transferFormat, cancellationToken).ConfigureAwait(false);
262await DisposeAsyncCore().ConfigureAwait(false);
273await _connectionLock.WaitAsync().ConfigureAwait(false);
284await _transport!.StopAsync().ConfigureAwait(false);
325await StartTransport(uri, _httpConnectionOptions.Transports, transferFormat, cancellationToken, useStatefulReconnect: false).ConfigureAwait(false);
423await StartTransport(connectUrl, transportType, transferFormat, cancellationToken, negotiationResponse.UseStatefulReconnect).ConfigureAwait(false);
547await transport.StartAsync(connectUrl, transferFormat, cancellationToken).ConfigureAwait(false);
Microsoft.AspNetCore.Identity (2)
Microsoft.AspNetCore.Identity.EntityFrameworkCore (4)
Microsoft.AspNetCore.InternalTesting (23)
Microsoft.AspNetCore.Mvc.Testing (3)
Microsoft.AspNetCore.OutputCaching.StackExchangeRedis (2)
Microsoft.AspNetCore.Server.HttpSys (3)
Microsoft.AspNetCore.Server.Kestrel.Core (21)
Microsoft.AspNetCore.SignalR.Client.Core (59)
HubConnection.cs (55)
299await StartAsyncInner(cancellationToken).ConfigureAwait(false);
305await _state.WaitConnectionLockAsync(token: cancellationToken).ConfigureAwait(false);
322await StartAsyncCore(linkedToken).ConfigureAwait(false);
352await StopAsyncCore(disposing: false).ConfigureAwait(false);
368await StopAsyncCore(disposing: true).ConfigureAwait(false);
509await SendCoreAsyncCore(methodName, args, cancellationToken).ConfigureAwait(false);
556await HandshakeAsync(startingConnectionState, usedProtocolVersion, cancellationToken).ConfigureAwait(false);
576await SendHubMessage(startingConnectionState, PingMessage.Instance, cancellationToken).ConfigureAwait(false);
637Log.AuthenticationRefreshCallbackFailed).ConfigureAwait(false);
658Log.AuthenticationRefreshCallbackFailed).ConfigureAwait(false);
674await handler(argument).ConfigureAwait(false);
855await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false);
867await reconnectTask.ConfigureAwait(false);
868await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false);
945await connectionStateStopTask.ConfigureAwait(false);
1005await InvokeStreamCore(connectionState, methodName, irq, args, streamIds?.ToArray(), cancellationToken).ConfigureAwait(false);
1170await SendStreamItemAsync(connectionState, streamId, enumerator.Current, tokenSource).ConfigureAwait(false);
1206await SendStreamItemAsync(connectionState, streamId, item, tokenSource).ConfigureAwait(false);
1221await SendStreamItemAsync(connectionState, streamId, streamValue, tokenSource).ConfigureAwait(false);
1230await SendWithLock(connectionState, new StreamItemMessage(streamId, item), tokenSource.Token).ConfigureAwait(false);
1243await createAndConsumeStream().ConfigureAwait(false);
1258await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false);
1265await SendHubMessage(connectionState, CompletionMessage.WithError(streamId, responseError), cancellationToken: default).ConfigureAwait(false);
1356await InvokeCore(connectionState, methodName, irq, args, streamIds?.ToArray(), cancellationToken).ConfigureAwait(false);
1411await Task.WhenAll(streamTasks).ConfigureAwait(false);
1415await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false);
1423await SendHubMessage(_state.CurrentConnectionStateUnsynchronized, new CancelInvocationMessage(irq.InvocationId), cancellationToken: default).ConfigureAwait(false);
1462await SendHubMessage(connectionState, invocationMessage, cancellationToken).ConfigureAwait(false);
1493await SendHubMessage(connectionState, invocationMessage, cancellationToken).ConfigureAwait(false);
1556await SendHubMessage(connectionState, invocationMessage, cancellationToken).ConfigureAwait(false);
1587await SendHubMessage(connectionState, message, cancellationToken).ConfigureAwait(false);
1622await SendWithLock(connectionState, CompletionMessage.WithError(bindingFailure.InvocationId, error), cancellationToken: default).ConfigureAwait(false);
1651await DispatchInvocationStreamItemAsync(streamItem, irq).ConfigureAwait(false);
1677await connectionState.AckAsync(ackMessage).ConfigureAwait(false);
1700await SendWithLock(connectionState, CompletionMessage.WithError(invocation.InvocationId!, "Client didn't provide a result."), cancellationToken: default).ConfigureAwait(false);
1731await task.ConfigureAwait(false);
1750await SendWithLock(connectionState, CompletionMessage.WithError(invocation.InvocationId!, resultException.Message), cancellationToken: default).ConfigureAwait(false);
1754await SendWithLock(connectionState, CompletionMessage.WithResult(invocation.InvocationId!, result), cancellationToken: default).ConfigureAwait(false);
1759await SendWithLock(connectionState, CompletionMessage.WithError(invocation.InvocationId!, "Client didn't provide a result."), cancellationToken: default).ConfigureAwait(false);
1943await invokeTask.ConfigureAwait(false);
2028await timerTask.ConfigureAwait(false);
2030await HandleConnectionClose(connectionState).ConfigureAwait(false);
2053await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false);
2109await InvokeEventHandlersAsync(closed, closeException, _logger, Log.ErrorDuringClosedEvent).ConfigureAwait(false);
2159await Task.Delay(nextRetryDelay.Value, _state.StopCts.Token).ConfigureAwait(false);
2165await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false);
2180await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false);
2186await StartAsyncCore(_state.StopCts.Token).ConfigureAwait(false);
2221await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false);
2279await InvokeEventHandlersAsync(reconnecting, closeException, _logger, Log.ErrorDuringReconnectingEvent).ConfigureAwait(false);
2299await InvokeEventHandlersAsync(reconnected, ConnectionId, _logger, Log.ErrorDuringReconnectedEvent).ConfigureAwait(false);
2567await ((ReceiveTask ?? Task.CompletedTask).ConfigureAwait(false));
2592await RunTimerActions().ConfigureAwait(false);
2683await _hubConnection.SendHubMessage(this, PingMessage.Instance).ConfigureAwait(false);
2822await WaitConnectionLockAsync(token, methodName).ConfigureAwait(false);
Microsoft.AspNetCore.SignalR.Core (4)
Microsoft.AspNetCore.SignalR.Specification.Tests (2)
Microsoft.Build (3)
Microsoft.Build.Tasks.CodeAnalysis (12)
src\roslyn\src\Compilers\Shared\BuildProtocol.cs (7)
128await ReadAllAsync(inStream, lengthBuffer, 4, cancellationToken).ConfigureAwait(false);
187cancellationToken).ConfigureAwait(false);
190await memoryStream.CopyToAsync(outStream, bufferSize: length, cancellationToken: cancellationToken).ConfigureAwait(false);
305cancellationToken).ConfigureAwait(false);
308await memoryStream.CopyToAsync(outStream, bufferSize: length, cancellationToken: cancellationToken).ConfigureAwait(false);
324await ReadAllAsync(stream, lengthBuffer, 4, cancellationToken).ConfigureAwait(false);
332cancellationToken).ConfigureAwait(false);
Microsoft.Build.Tasks.Core (14)
Microsoft.CodeAnalysis (24)
DiagnosticAnalyzer\AnalyzerDriver.cs (12)
654await ExecutePrimaryAnalysisTaskAsync(analysisScope, usingPrePopulatedEventQueue: true, cancellationToken).ConfigureAwait(false);
708await WhenInitializedTask.ConfigureAwait(false);
716await ProcessCompilationEventsAsync(analysisScope, usingPrePopulatedEventQueue, cancellationToken).ConfigureAwait(false);
879await this.WhenCompletedTask.ConfigureAwait(false);
1558await Task.WhenAll(workerTasks.Concat(syntaxTreeActionsTask).Concat(additionalFileActionsTask)).ConfigureAwait(false);
1581await ProcessEventAsync(completedEvent, analysisScope, cancellationToken).ConfigureAwait(false);
1638await ProcessEventAsync(compilationEvent, analysisScope, cancellationToken).ConfigureAwait(false);
1668await OnEventProcessedCoreAsync(e, processedAnalyzers, analysisScope, cancellationToken).ConfigureAwait(false);
1680await onSymbolAndMembersProcessedAsync(symbolDeclaredEvent.Symbol, analyzer).ConfigureAwait(false);
1712await processContainerOnMemberCompletedAsync(symbol.ContainingNamespace, symbol, analyzer).ConfigureAwait(false);
1715await processContainerOnMemberCompletedAsync(type, symbol, analyzer).ConfigureAwait(false);
1725await OnEventProcessedCoreAsync(processedContainerEvent, ImmutableArray.Create(analyzer), analysisScope, cancellationToken).ConfigureAwait(false);
DiagnosticAnalyzer\CompilationWithAnalyzers.cs (11)
340await ComputeAnalyzerDiagnosticsAsync(analysisScope, cancellationToken).ConfigureAwait(false);
347await ComputeAnalyzerDiagnosticsAsync(analysisScope, cancellationToken).ConfigureAwait(false);
354await ComputeAnalyzerDiagnosticsAsync(analysisScope, cancellationToken).ConfigureAwait(false);
378await driver.WhenInitializedTask.ConfigureAwait(false);
575await ComputeAnalyzerDiagnosticsAsync(analysisScope, cancellationToken).ConfigureAwait(false);
582await ComputeAnalyzerDiagnosticsAsync(analysisScope, cancellationToken).ConfigureAwait(false);
649await ComputeAnalyzerDiagnosticsAsync(analysisScope, cancellationToken).ConfigureAwait(false);
656await ComputeAnalyzerDiagnosticsAsync(analysisScope, cancellationToken).ConfigureAwait(false);
754await driver.WhenCompletedTask.ConfigureAwait(false);
795await attachQueueAndProcessAllEventsAsync(builder, driver, cancellationToken).ConfigureAwait(false);
828await driver.AttachQueueAndProcessAllEventsAsync(eventQueue, analysisScope, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.Analyzers (21)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (8)
37await consumeItems(items.ToImmutableAndClear(), args, cancellationToken).ConfigureAwait(false);
77await args.consumeItems(items.ReadAllAsync(cancellationToken), args.args, cancellationToken).ConfigureAwait(false);
114await args.consumeItems(items, args.args, cancellationToken).ConfigureAwait(false);
238await args.produceItems(source, callback, args.args, cancellationToken).ConfigureAwait(false)),
299source, callback, args.args, cancellationToken).ConfigureAwait(false)),
344await Task.WhenAll(writeTask, readTask).ConfigureAwait(false);
367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
384await action(args, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.AnalyzerUtilities (15)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (8)
37await consumeItems(items.ToImmutableAndClear(), args, cancellationToken).ConfigureAwait(false);
77await args.consumeItems(items.ReadAllAsync(cancellationToken), args.args, cancellationToken).ConfigureAwait(false);
114await args.consumeItems(items, args.args, cancellationToken).ConfigureAwait(false);
238await args.produceItems(source, callback, args.args, cancellationToken).ConfigureAwait(false)),
299source, callback, args.args, cancellationToken).ConfigureAwait(false)),
344await Task.WhenAll(writeTask, readTask).ConfigureAwait(false);
367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
384await action(args, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.BuildClient.Package (12)
src\roslyn\src\Compilers\Shared\BuildProtocol.cs (7)
128await ReadAllAsync(inStream, lengthBuffer, 4, cancellationToken).ConfigureAwait(false);
187cancellationToken).ConfigureAwait(false);
190await memoryStream.CopyToAsync(outStream, bufferSize: length, cancellationToken: cancellationToken).ConfigureAwait(false);
305cancellationToken).ConfigureAwait(false);
308await memoryStream.CopyToAsync(outStream, bufferSize: length, cancellationToken: cancellationToken).ConfigureAwait(false);
324await ReadAllAsync(stream, lengthBuffer, 4, cancellationToken).ConfigureAwait(false);
332cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.CodeStyle (17)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (8)
37await consumeItems(items.ToImmutableAndClear(), args, cancellationToken).ConfigureAwait(false);
77await args.consumeItems(items.ReadAllAsync(cancellationToken), args.args, cancellationToken).ConfigureAwait(false);
114await args.consumeItems(items, args.args, cancellationToken).ConfigureAwait(false);
238await args.produceItems(source, callback, args.args, cancellationToken).ConfigureAwait(false)),
299source, callback, args.args, cancellationToken).ConfigureAwait(false)),
344await Task.WhenAll(writeTask, readTask).ConfigureAwait(false);
367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
384await action(args, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.CodeStyle.Fixes (24)
src\roslyn\src\Analyzers\Core\CodeFixes\GenerateVariable\AbstractGenerateVariableService.cs (4)
58await AddPropertyCodeActionsAsync(actions, semanticDocument, state, cancellationToken).ConfigureAwait(false);
64await AddPropertyCodeActionsAsync(actions, semanticDocument, state, cancellationToken).ConfigureAwait(false);
68await AddLocalCodeActionsAsync(actions, document, state, cancellationToken).ConfigureAwait(false);
69await AddParameterCodeActionsAsync(actions, document, state, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.CSharp.CodeStyle.Fixes (18)
src\roslyn\src\Analyzers\CSharp\CodeFixes\UseImplicitOrExplicitType\UseExplicitTypeCodeFixProvider.cs (4)
57await HandleDeclarationAsync(document, editor, node, cancellationToken).ConfigureAwait(false);
74await HandleVariableDeclarationAsync(document, editor, varDecl, cancellationToken).ConfigureAwait(false);
78await HandleForEachStatementAsync(document, editor, forEach, cancellationToken).ConfigureAwait(false);
82await HandleDeclarationExpressionAsync(document, editor, declarationExpression, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.CSharp.Features (31)
src\roslyn\src\Analyzers\CSharp\CodeFixes\UseImplicitOrExplicitType\UseExplicitTypeCodeFixProvider.cs (4)
57await HandleDeclarationAsync(document, editor, node, cancellationToken).ConfigureAwait(false);
74await HandleVariableDeclarationAsync(document, editor, varDecl, cancellationToken).ConfigureAwait(false);
78await HandleForEachStatementAsync(document, editor, forEach, cancellationToken).ConfigureAwait(false);
82await HandleDeclarationExpressionAsync(document, editor, declarationExpression, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.CSharp.Workspaces (2)
Microsoft.CodeAnalysis.ExternalAccess.Extensions (1)
Microsoft.CodeAnalysis.ExternalAccess.HotReload (2)
Microsoft.CodeAnalysis.Features (243)
AddImport\AbstractAddImportFeatureService.cs (6)
185await FindResultsInAllSymbolsInStartingProjectAsync(allReferences, finder, exact, cancellationToken).ConfigureAwait(false);
194await FindResultsInUnreferencedProjectSourceSymbolsAsync(projectToAssembly, project, allReferences, maxResults, finder, exact, cancellationToken).ConfigureAwait(false);
198await FindResultsInUnreferencedMetadataSymbolsAsync(referenceToCompilation, project, allReferences, maxResults, finder, exact, cancellationToken).ConfigureAwait(false);
202await finder.FindNugetOrReferenceAssemblyReferencesAsync(allReferences, exact, cancellationToken).ConfigureAwait(false);
251linkedTokenSource.Token).ConfigureAwait(false);
308linkedTokenSource.Token).ConfigureAwait(false);
AddImport\SymbolReferenceFinder_PackageAssemblySearch.cs (5)
47await FindWorkerAsync(new(typeQuery.Name + AttributeSuffix, typeQuery.Arity), namespaceQuery, isAttributeSearch: true).ConfigureAwait(false);
49await FindWorkerAsync(typeQuery, namespaceQuery, isAttributeSearch: false).ConfigureAwait(false);
60allReferences, nameNode, typeQuery, namespaceQuery, isAttributeSearch, cancellationToken).ConfigureAwait(false);
67sourceName, sourceUrl, allReferences, nameNode, typeQuery, namespaceQuery, isAttributeSearch, cancellationToken).ConfigureAwait(false);
147cancellationToken: cancellationToken).ConfigureAwait(false);
ConvertTupleToStruct\AbstractConvertTupleToStructCodeRefactoringProvider.cs (4)
312containingNamespace, parameterNamingRule, isRecord, cancellationToken).ConfigureAwait(false);
316documentToEditorMap, cancellationToken).ConfigureAwait(false);
471project, result, tupleFieldNames, cancellationToken).ConfigureAwait(false);
484project, result, tupleFieldNames, cancellationToken).ConfigureAwait(false);
DesignerAttribute\DesignerAttributeDiscoveryService.cs (3)
145frozenProject, frozenDocument, callback, lazyProjectVersion, cancellationToken).ConfigureAwait(false);
172await ProcessProjectAsync(frozenSolution.GetRequiredProject(projectId), callback, cancellationToken).ConfigureAwait(false);
193project, specificDocument: null, callback, lazyProjectVersion, cancellationToken).ConfigureAwait(false);
Diagnostics\Service\DiagnosticAnalyzerService_CoreAnalyze.cs (4)
155document, documentAnalysisScope.Span, diagnosticsBuilder.Add, cancellationToken).ConfigureAwait(false);
169document, span: null, callback, cancellationToken).ConfigureAwait(false);
181document, span: null, diagnosticsBuilder.Add, cancellationToken).ConfigureAwait(false);
200semanticModel, span, hostCompilationWithAnalyzers, analyzerInfoCache.GetDiagnosticDescriptors, reportDiagnostic, cancellationToken).ConfigureAwait(false);
Diagnostics\Service\DiagnosticAnalyzerService_GetDiagnosticsForSpan.cs (3)
297await ComputeDocumentDiagnosticsAsync(this, document, compilationWithAnalyzers, logPerformanceInfo, syntaxAnalyzers, AnalysisKind.Syntax, range, incrementalAnalysis: false, list, cancellationToken).ConfigureAwait(false);
298await ComputeDocumentDiagnosticsAsync(this, document, compilationWithAnalyzers, logPerformanceInfo, semanticSpanAnalyzers, AnalysisKind.Semantic, range, incrementalAnalysis, list, cancellationToken).ConfigureAwait(false);
299await ComputeDocumentDiagnosticsAsync(this, document, compilationWithAnalyzers, logPerformanceInfo, semanticDocumentAnalyzers, AnalysisKind.Semantic, span: null, incrementalAnalysis: false, list, cancellationToken).ConfigureAwait(false);
Diagnostics\Service\DiagnosticAnalyzerService.IncrementalMemberEditAnalyzer.cs (6)
120await ExecuteCompilerAnalyzerAsync(compilerAnalyzerData, oldMemberSpans, builder).ConfigureAwait(false);
121await ExecuteSpanBasedAnalyzersAsync(spanBasedAnalyzers, oldMemberSpans, builder).ConfigureAwait(false);
122await ExecuteDocumentBasedAnalyzersAsync(documentBasedAnalyzers, oldMemberSpans, builder).ConfigureAwait(false);
144await ExecuteAnalyzersAsync(executor, analyzers, oldMemberSpans, builder).ConfigureAwait(false);
156await ExecuteAnalyzersAsync(executor, analyzers, oldMemberSpans, builder).ConfigureAwait(false);
168await ExecuteAnalyzersAsync(executor, analyzers, oldMemberSpans, builder).ConfigureAwait(false);
DocumentHighlighting\AbstractDocumentHighlightsService.cs (5)
127documentsToSearch, options, cancellationToken).ConfigureAwait(false);
233await AddLocationSpanAsync(symbol.Locations.First(), solution, spanSet, tagMap, HighlightSpanKind.Definition, cancellationToken).ConfigureAwait(false);
259await AddLocationSpanAsync(location, solution, spanSet, tagMap, HighlightSpanKind.Definition, cancellationToken).ConfigureAwait(false);
268await AddLocationSpanAsync(referenceLocation.Location, solution, spanSet, tagMap, referenceKind, cancellationToken).ConfigureAwait(false);
275await AddLocationSpanAsync(location, solution, spanSet, tagMap, HighlightSpanKind.Reference, cancellationToken).ConfigureAwait(false);
ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.cs (19)
240await EnqueueFullProjectWorkItemAsync(addedProject, UnitTestingInvocationReasons.DocumentAdded, processSourceGeneratedDocuments).ConfigureAwait(false);
245await EnqueueWorkItemAsync(projectChanges, processSourceGeneratedDocuments).ConfigureAwait(continueOnCapturedContext: false);
250await EnqueueFullProjectWorkItemAsync(removedProject, UnitTestingInvocationReasons.DocumentRemoved, processSourceGeneratedDocuments).ConfigureAwait(false);
262await EnqueueFullProjectWorkItemAsync(solution.GetRequiredProject(projectId), invocationReasons, processSourceGeneratedDocuments).ConfigureAwait(false);
275await EnqueueWorkItemAsync(newProject.GetChanges(oldProject), processSourceGeneratedDocuments).ConfigureAwait(false);
304await EnqueueChangedDocumentWorkItemAsync(oldProject.GetRequiredDocument(documentId), newProject.GetRequiredDocument(documentId)).ConfigureAwait(false);
335await EnqueueChangedDocumentWorkItemAsync(oldDocument, newDocument).ConfigureAwait(continueOnCapturedContext: false);
384await EnqueueDocumentWorkItemAsync(project, documentId, document: null, invocationReasons).ConfigureAwait(false);
387await EnqueueDocumentWorkItemAsync(project, documentId, document: null, invocationReasons).ConfigureAwait(false);
390await EnqueueDocumentWorkItemAsync(project, documentId, document: null, invocationReasons).ConfigureAwait(false);
397await EnqueueDocumentWorkItemAsync(project, document.Id, document, invocationReasons).ConfigureAwait(false);
408await EnqueueWorkItemAsync(analyzer, project, documentId, document: null, invocationReasons).ConfigureAwait(false);
425await EnqueueProjectConfigurationChangeWorkItemAsync(projectChanges, processSourceGeneratedDocuments).ConfigureAwait(false);
428await EnqueueDocumentWorkItemAsync(projectChanges.NewProject, addedDocumentId, document: null, UnitTestingInvocationReasons.DocumentAdded).ConfigureAwait(false);
433.ConfigureAwait(continueOnCapturedContext: false);
437await EnqueueDocumentWorkItemAsync(projectChanges.OldProject, removedDocumentId, document: null, UnitTestingInvocationReasons.DocumentRemoved).ConfigureAwait(false);
503await EnqueueFullProjectWorkItemAsync(projectChanges.NewProject, projectConfigurationChange, processSourceGeneratedDocuments).ConfigureAwait(false);
515await EnqueueDocumentWorkItemAsync(newDocument.Project, newDocument.Id, newDocument, UnitTestingInvocationReasons.DocumentChanged).ConfigureAwait(false);
522await EnqueueDocumentWorkItemAsync(newDocument.Project, newDocument.Id, newDocument, differenceResult.ChangeType, differenceResult.ChangedMember).ConfigureAwait(false);
ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.UnitTestingNormalPriorityProcessor.cs (7)
116await WaitForHigherPriorityOperationsAsync().ConfigureAwait(false);
140await ProcessDocumentAsync(Analyzers, workItem, documentCancellation).ConfigureAwait(false);
210await ProcessReanalyzeDocumentAsync(workItem, textDocument, cancellationToken).ConfigureAwait(false);
212await Processor.ProcessDocumentAnalyzersAsync(textDocument, analyzers, workItem, cancellationToken).ConfigureAwait(false);
218await RemoveDocumentAsync(documentId, cancellationToken).ConfigureAwait(false);
278c), cancellationToken).ConfigureAwait(false);
296await analyzer.RemoveDocumentAsync(documentId, cancellationToken).ConfigureAwait(false);
FindUsages\AbstractFindUsagesService_FindReferences.cs (6)
26definitionTrackingContext, document, position, classificationOptions, cancellationToken).ConfigureAwait(false);
62context, document, position, classificationOptions, cancellationToken).ConfigureAwait(false);
100context, symbol, project, classificationOptions, cancellationToken).ConfigureAwait(false);
121await FindReferencesAsync(context, symbol, project, searchOptions, classificationOptions, cancellationToken).ConfigureAwait(false);
152context, symbol, project, searchOptions, classificationOptions, cancellationToken).ConfigureAwait(false);
239tokenValue, Type.GetTypeCode(tokenValue.GetType()), solution, progressAdapter, cancellationToken).ConfigureAwait(false);
InlineHints\AbstractInlineHintsService.cs (2)
28await inlineParameterService.AddInlineHintsAsync(document, textSpan, options.ParameterOptions, options.DisplayOptions, displayAllOverride, result, cancellationToken).ConfigureAwait(false);
33await inlineTypeService.AddInlineHintsAsync(document, textSpan, options.TypeOptions, options.DisplayOptions, displayAllOverride, result, cancellationToken).ConfigureAwait(false);
NavigateTo\AbstractNavigateToSearchService.CachedDocumentSearch.cs (4)
106storageService, documentKeys, priorityDocumentKeys, searchPattern, kinds, onItemsFound, onProjectCompleted, cancellationToken).ConfigureAwait(false);
138ProcessSingleProjectGroupAsync, onItemsFound, args: default, cancellationToken).ConfigureAwait(false);
173}).ConfigureAwait(false);
176await onProjectCompleted().ConfigureAwait(false);
NavigateTo\AbstractNavigateToSearchService.GeneratedDocumentSearch.cs (4)
57projects, searchPattern, kinds, onItemsFound, onProjectCompleted, cancellationToken).ConfigureAwait(false);
74projects, ProcessSingleProjectAsync, onItemsFound, args: default, cancellationToken).ConfigureAwait(false);
87document, patternInfo, declaredSymbolInfoKindsSet, onItemFound, cancellationToken)).ConfigureAwait(false);
89await onProjectCompleted().ConfigureAwait(false);
NavigateTo\AbstractNavigateToSearchService.NormalSearch.cs (7)
50await SearchDocumentAndRelatedDocumentsInCurrentProcessAsync(document, searchPattern, kinds, onItemsFound, cancellationToken).ConfigureAwait(false);
71SearchRelatedDocumentsInCurrentProcessAsync()).ConfigureAwait(false);
99await SearchDocumentsInCurrentProcessAsync(relatedDocuments).ConfigureAwait(false);
185projects, priorityDocuments, searchPattern, kinds, onItemsFound, onProjectCompleted, cancellationToken).ConfigureAwait(false);
212SearchSingleProjectAsync, onItemsFound, args: default, cancellationToken).ConfigureAwait(false);
227document, patternInfo, declaredSymbolInfoKindsSet, onItemFound, cancellationToken)).ConfigureAwait(false);
229await onProjectCompleted().ConfigureAwait(false);
NavigateTo\NavigateToSearcher.cs (20)
149await SearchCurrentDocumentAsync(cancellationToken).ConfigureAwait(false);
153await SearchCurrentProjectAsync(documentSupport, cancellationToken).ConfigureAwait(false);
166await SearchAllProjectsAsync(isFullyLoaded, documentSupport, cancellationToken).ConfigureAwait(false);
176await ProgressItemsCompletedAsync(_remainingProgressItems, cancellationToken).ConfigureAwait(false);
192await AddProgressItemsAsync(1, cancellationToken).ConfigureAwait(false);
196cancellationToken).ConfigureAwait(false);
226await SearchSpecificProjectsAsync(isFullyLoaded, documentSupport, orderedProjects, cancellationToken).ConfigureAwait(false);
252cancellationToken).ConfigureAwait(false);
255await SearchFullyLoadedProjectsAsync(orderedProjects, seenItems, cancellationToken).ConfigureAwait(false);
258await SearchGeneratedDocumentsAsync(orderedProjects, seenItems, cancellationToken).ConfigureAwait(false);
266await AddProgressItemsAsync(projectCount, cancellationToken).ConfigureAwait(false);
267await SearchCachedDocumentsAsync(orderedProjects, seenItems, cancellationToken).ConfigureAwait(false);
373SearchCoreAsync).ConfigureAwait(false);
406nonDuplicates.ToImmutableAndClear(), _activeDocument, cancellationToken).ConfigureAwait(false);
409() => this.ProgressItemsCompletedAsync(count: 1, cancellationToken)).ConfigureAwait(false);
451await onProjectCompleted().ConfigureAwait(false);
457onResultsFound, onProjectCompleted, cancellationToken).ConfigureAwait(false);
508await onProjectCompleted().ConfigureAwait(false);
513_solution, projects, _searchPattern, _kinds, _activeDocument, onResultsFound, onProjectCompleted, cancellationToken).ConfigureAwait(false);
539await onProjectCompleted().ConfigureAwait(false);
SpellCheck\AbstractSpellCheckCodeFixProvider.cs (5)
50await CheckNodeAsync(context, document, node, cancellationToken).ConfigureAwait(false);
58await CheckTokenAsync(context, document, token, cancellationToken).ConfigureAwait(false);
83await CreateSpellCheckCodeIssueAsync(context, token, IsGeneric(name), cancellationToken).ConfigureAwait(false);
100await CreateSpellCheckCodeIssueAsync(context, token, IsGeneric(token), cancellationToken).ConfigureAwait(false);
142completionList, similarityChecker).ConfigureAwait(false);
src\roslyn\src\Analyzers\Core\CodeFixes\GenerateVariable\AbstractGenerateVariableService.cs (4)
58await AddPropertyCodeActionsAsync(actions, semanticDocument, state, cancellationToken).ConfigureAwait(false);
64await AddPropertyCodeActionsAsync(actions, semanticDocument, state, cancellationToken).ConfigureAwait(false);
68await AddLocalCodeActionsAsync(actions, document, state, cancellationToken).ConfigureAwait(false);
69await AddParameterCodeActionsAsync(actions, document, state, cancellationToken).ConfigureAwait(false);
ValueTracking\ValueTracker.cs (13)
52await TrackVariableReferencesAsync(symbol, operationCollector, cancellationToken).ConfigureAwait(false);
59await AddItemsFromAssignmentAsync(document, node, operationCollector, cancellationToken).ConfigureAwait(false);
90await TrackVariableDefinitionsAsync(symbol, operationCollector, cancellationToken).ConfigureAwait(false);
91await TrackVariableReferencesAsync(symbol, operationCollector, cancellationToken).ConfigureAwait(false);
117await TrackVariableReferencesAsync(parameterSymbol, operationCollector, cancellationToken).ConfigureAwait(false);
122await TrackParameterSymbolAsync(parameterSymbol, operationCollector, cancellationToken).ConfigureAwait(false);
131await TrackMethodSymbolAsync(methodSymbol, operationCollector, cancellationToken).ConfigureAwait(false);
161await collector.VisitAsync(assignmentOperation, cancellationToken).ConfigureAwait(false);
171documents: null, FindReferencesSearchOptions.Default, cancellationToken).ConfigureAwait(false);
185documents: null, FindReferencesSearchOptions.Default, cancellationToken).ConfigureAwait(false);
226await collector.VisitAsync(operation, cancellationToken).ConfigureAwait(false);
239await TrackVariableReferencesAsync(outOrRefParam, collector, cancellationToken).ConfigureAwait(false);
316await collector.VisitAsync(initializer, cancellationToken).ConfigureAwait(false);
ValueTracking\ValueTracker.FindReferencesProgress.cs (8)
54await TrackConstructorAsync(location, cancellationToken).ConfigureAwait(false);
60await TrackMethodInvocationArgumentsAsync(location, cancellationToken).ConfigureAwait(false);
79await AddItemsFromAssignmentAsync(location.Document, node, _operationCollector, cancellationToken).ConfigureAwait(false);
90await _operationCollector.VisitAsync(operation, cancellationToken).ConfigureAwait(false);
118await _operationCollector.VisitAsync(argumentOperation, cancellationToken).ConfigureAwait(false);
136await _operationCollector.VisitAsync(expressionOperation, cancellationToken).ConfigureAwait(false);
164await _operationCollector.VisitAsync(operation, cancellationToken).ConfigureAwait(false);
199await _operationCollector.VisitAsync(operation, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.NetAnalyzers (6)
Microsoft.CodeAnalysis.ResxSourceGenerator (15)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (8)
37await consumeItems(items.ToImmutableAndClear(), args, cancellationToken).ConfigureAwait(false);
77await args.consumeItems(items.ReadAllAsync(cancellationToken), args.args, cancellationToken).ConfigureAwait(false);
114await args.consumeItems(items, args.args, cancellationToken).ConfigureAwait(false);
238await args.produceItems(source, callback, args.args, cancellationToken).ConfigureAwait(false)),
299source, callback, args.args, cancellationToken).ConfigureAwait(false)),
344await Task.WhenAll(writeTask, readTask).ConfigureAwait(false);
367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
384await action(args, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.Scripting (1)
Microsoft.CodeAnalysis.Workspaces (176)
Classification\AbstractClassificationService.cs (3)
102document, textSpans, type, options, result, cancellationToken).ConfigureAwait(false);
151document, textSpans, options, getNodeClassifiers, getTokenClassifiers, result, cancellationToken).ConfigureAwait(false);
175document, textSpans, options, result, cancellationToken).ConfigureAwait(false);
Classification\ClassifierHelper.cs (4)
39.ConfigureAwait(false);
78await classificationService.AddSyntacticClassificationsAsync(document, spans, syntaxSpans, cancellationToken).ConfigureAwait(false);
82await classificationService.AddSemanticClassificationsAsync(document, spans, options, semanticSpans, cancellationToken).ConfigureAwait(false);
83await classificationService.AddEmbeddedLanguageClassificationsAsync(document, spans, options, semanticSpans, cancellationToken).ConfigureAwait(false);
FindSymbols\Declarations\DeclarationFinder_AllDeclarations.cs (9)
72await SearchCurrentProjectAsync().ConfigureAwait(false);
73await SearchProjectReferencesAsync().ConfigureAwait(false);
74await SearchMetadataReferencesAsync().ConfigureAwait(false);
86project, query, criteria, buffer, cancellationToken).ConfigureAwait(false);
89await AddAllAsync(buffer, mapSymbol: false).ConfigureAwait(false);
104referencedProject, query, criteria, buffer, cancellationToken).ConfigureAwait(false);
108await AddAllAsync(buffer, mapSymbol: referencedProject.Language != project.Language).ConfigureAwait(false);
129query, criteria, buffer, cancellationToken).ConfigureAwait(false);
132await AddAllAsync(buffer, mapSymbol: false).ConfigureAwait(false);
FindSymbols\FindReferences\DependentTypeFinder.cs (9)
137await DescendInheritanceTreeInProjectAsync(project).ConfigureAwait(false);
155await AddDescendantMetadataTypesInProjectAsync(tempBuffer, project).ConfigureAwait(false);
175await AddDescendantSourceTypesInProjectAsync(tempBuffer, project).ConfigureAwait(false);
220predicate: static n => n.BaseType?.SpecialType == SpecialType.System_Object).ConfigureAwait(false);
224projectIndex.ValueTypes, tempBuffer, predicate: null).ConfigureAwait(false);
228projectIndex.Enums, tempBuffer, predicate: null).ConfigureAwait(false);
232projectIndex.Delegates, tempBuffer, predicate: null).ConfigureAwait(false);
236await AddSourceTypesThatDeriveFromNameAsync(tempBuffer, type.Name).ConfigureAwait(false);
321typesToSearchFor, project, compilation, peReference, tempBuffer).ConfigureAwait(false);
FindSymbols\FindReferences\Finders\AbstractReferenceFinder.cs (2)
158project, documents, static (index, predefinedType) => index.ContainsPredefinedType(predefinedType), predefinedType, processResult, processResultData, cancellationToken).ConfigureAwait(false);
727await DetermineDocumentsToSearchAsync(typedSymbol, globalAliases, project, documents, processResult, processResultData, options, cancellationToken).ConfigureAwait(false);
FindSymbols\FindReferences\Finders\ConstructorSymbolReferenceFinder.cs (8)
67project, documents, typeName, processResult, processResultData, cancellationToken).ConfigureAwait(false);
74project, documents, globalAlias, processResult, processResultData, cancellationToken).ConfigureAwait(false);
79project, documents, containingType.SpecialType.ToPredefinedType(), processResult, processResultData, cancellationToken).ConfigureAwait(false);
82project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
87project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
90await FindDocumentsWithCollectionExpressionsAsync(project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
112await FindDocumentsAsync(project, documents, processResult, processResultData, cancellationToken, typeName).ConfigureAwait(false);
115await FindDocumentsAsync(project, documents, processResult, processResultData, cancellationToken, simpleName).ConfigureAwait(false);
FindSymbols\FindReferences\Finders\ExplicitConversionSymbolReferenceFinder.cs (2)
50await FindDocumentsAsync(project, documents, StandardCallbacks<Document>.AddToHashSet, result, cancellationToken, underlyingNamedType.Name).ConfigureAwait(false);
51await FindDocumentsAsync(project, documents, underlyingNamedType.SpecialType.ToPredefinedType(), StandardCallbacks<Document>.AddToHashSet, result, cancellationToken).ConfigureAwait(false);
FindSymbols\FindReferences\Finders\NamedTypeSymbolReferenceFinder.cs (6)
67await AddDocumentsToSearchAsync(symbol.Name, project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
71await AddDocumentsToSearchAsync(alias, project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
75project, documents, symbol.SpecialType.ToPredefinedType(), processResult, processResultData, cancellationToken).ConfigureAwait(false);
78project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
96project, documents, processResult, processResultData, cancellationToken, throughName).ConfigureAwait(false);
99await FindDocumentsAsync(project, documents, processResult, processResultData, cancellationToken, simpleName).ConfigureAwait(false);
FindSymbols\FindReferences\Finders\NamespaceSymbolReferenceFinder.cs (4)
37await FindDocumentsAsync(project, documents, processResult, processResultData, cancellationToken, symbol.Name).ConfigureAwait(false);
39await FindDocumentsWithPredicateAsync(project, documents, static index => index.ContainsGlobalKeyword, processResult, processResultData, cancellationToken).ConfigureAwait(false);
46project, documents, processResult, processResultData, cancellationToken, globalAlias).ConfigureAwait(false);
50await FindDocumentsWithGlobalSuppressMessageAttributeAsync(project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
FindSymbols\FindReferences\Finders\OperatorSymbolReferenceFinder.cs (3)
32await FindDocumentsAsync(project, documents, op, processResult, processResultData, cancellationToken).ConfigureAwait(false);
33await FindDocumentsWithGlobalSuppressMessageAttributeAsync(project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
48project, documents, static (index, op) => index.ContainsPredefinedOperator(op), op, processResult, processResultData, cancellationToken).ConfigureAwait(false);
FindSymbols\FindReferences\Finders\OrdinaryMethodReferenceFinder.cs (8)
91await FindDocumentsAsync(project, documents, processResult, processResultData, cancellationToken, methodSymbol.Name).ConfigureAwait(false);
92await FindDocumentsWithGlobalSuppressMessageAttributeAsync(project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
95await FindDocumentsWithForEachStatementsAsync(project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
98await FindDocumentsWithDeconstructionAsync(project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
101await FindDocumentsWithAwaitExpressionAsync(project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
104await FindDocumentsWithCollectionInitializersAsync(project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
107await FindDocumentsWithUsingStatementsAsync(project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
110await FindDocumentsWithCollectionExpressionsAsync(project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
FindSymbols\FindReferences\Finders\PropertySymbolReferenceFinder.cs (5)
117await FindDocumentsAsync(project, documents, processResult, processResultData, cancellationToken, symbol.Name).ConfigureAwait(false);
120await FindDocumentsWithForEachStatementsAsync(project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
123await FindDocumentWithExplicitOrImplicitElementAccessExpressionsAsync(project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
126await FindDocumentWithIndexerMemberCrefAsync(project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
128await FindDocumentsWithGlobalSuppressMessageAttributeAsync(project, documents, processResult, processResultData, cancellationToken).ConfigureAwait(false);
FindSymbols\FindReferences\FindReferencesSearchEngine.BidirectionalSymbolSet.cs (2)
58await AddDownSymbolsAsync(this.Engine, current, _allSymbols, workQueue, projects, cancellationToken).ConfigureAwait(false);
59await AddUpSymbolsAsync(this.Engine, current, _allSymbols, workQueue, projects, _includeImplementationsThroughDerivedTypes, cancellationToken).ConfigureAwait(false);
FindSymbols\FindReferences\FindReferencesSearchEngine.cs (7)
74cancellationToken).ConfigureAwait(false);
123tuple.project, tuple.allSymbols, onReferenceFound, cancellationToken).ConfigureAwait(false)).ConfigureAwait(false);
148await symbolSet.InheritanceCascadeAsync(currentProject, cancellationToken).ConfigureAwait(false);
226await AddGlobalAliasesAsync(project, allSymbols, symbolToGlobalAliases, cancellationToken).ConfigureAwait(false);
238_options, cancellationToken).ConfigureAwait(false);
254ProcessDocumentAsync(kvp.Key, kvp.Value, symbolToGlobalAliases, onReferenceFound, cancellationToken)).ConfigureAwait(false);
314}).ConfigureAwait(false);
FindSymbols\FindReferences\FindReferencesSearchEngine.SymbolSet.cs (8)
153await AddCascadedAndLinkedSymbolsToAsync(engine, currentSymbol, result, workQueue, cancellationToken).ConfigureAwait(false);
173engine, currentSymbol, upSymbols, workQueue, allProjects, includeImplementationsThroughDerivedTypes, cancellationToken).ConfigureAwait(false);
183await AddCascadedAndLinkedSymbolsToAsync(engine, symbol, seenSymbols, workQueue, cancellationToken).ConfigureAwait(false);
248await AddCascadedAndLinkedSymbolsToAsync(engine, implementations, seenSymbols, workQueue, cancellationToken).ConfigureAwait(false);
255await AddCascadedAndLinkedSymbolsToAsync(engine, overrides, seenSymbols, workQueue, cancellationToken).ConfigureAwait(false);
285await AddCascadedAndLinkedSymbolsToAsync(engine, match, seenSymbols, workQueue, cancellationToken).ConfigureAwait(false);
290await AddCascadedAndLinkedSymbolsToAsync(engine, overriddenMember, seenSymbols, workQueue, cancellationToken).ConfigureAwait(false);
293await AddCascadedAndLinkedSymbolsToAsync(engine, symbol.ExplicitInterfaceImplementations(), seenSymbols, workQueue, cancellationToken).ConfigureAwait(false);
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (8)
37await consumeItems(items.ToImmutableAndClear(), args, cancellationToken).ConfigureAwait(false);
77await args.consumeItems(items.ReadAllAsync(cancellationToken), args.args, cancellationToken).ConfigureAwait(false);
114await args.consumeItems(items, args.args, cancellationToken).ConfigureAwait(false);
238await args.produceItems(source, callback, args.args, cancellationToken).ConfigureAwait(false)),
299source, callback, args.args, cancellationToken).ConfigureAwait(false)),
344await Task.WhenAll(writeTask, readTask).ConfigureAwait(false);
367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
384await action(args, cancellationToken).ConfigureAwait(false);
Workspace\Solution\ChecksumCollection.cs (2)
71await stateChecksums.FindAsync(assetPath, state, searchingChecksumsLeft, onAssetFound, arg, cancellationToken).ConfigureAwait(false);
84await stateChecksums.FindAsync(assetPath, state, searchingChecksumsLeft, onAssetFound, arg, cancellationToken).ConfigureAwait(false);
Workspace\Solution\StateChecksums.cs (8)
130compilationState.FrozenSourceGeneratedDocumentStates, searchingChecksumsLeft, onAssetFound, arg, cancellationToken).ConfigureAwait(false);
175await solutionChecksums.FindAsync(solutionState, projectCone, assetPath, searchingChecksumsLeft, onAssetFound, arg, cancellationToken).ConfigureAwait(false);
181await solutionChecksums.FindAsync(solutionState, projectCone, assetPath, searchingChecksumsLeft, onAssetFound, arg, cancellationToken).ConfigureAwait(false);
298await projectStateChecksums.FindAsync(projectState, assetPath, searchingChecksumsLeft, onAssetFound, arg, cancellationToken).ConfigureAwait(false);
321await projectStateChecksums.FindAsync(projectState, assetPath, searchingChecksumsLeft, onAssetFound, arg, cancellationToken).ConfigureAwait(false);
473await ChecksumCollection.FindAsync(assetPath, state.DocumentStates, searchingChecksumsLeft, onAssetFound, arg, cancellationToken).ConfigureAwait(false);
474await ChecksumCollection.FindAsync(assetPath, state.AdditionalDocumentStates, searchingChecksumsLeft, onAssetFound, arg, cancellationToken).ConfigureAwait(false);
475await ChecksumCollection.FindAsync(assetPath, state.AnalyzerConfigDocumentStates, searchingChecksumsLeft, onAssetFound, arg, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.Workspaces.MSBuild (7)
Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (8)
Microsoft.Deployment.DotNet.Releases (7)
Microsoft.Diagnostics.NETCore.Client (33)
DiagnosticsServerRouter\DiagnosticsServerRouterFactory.cs (23)
135await Task.Delay(IsStreamConnectedTimeoutMs, token).ConfigureAwait(false);
471await ConnectAsyncInternal(clientSocket, clientTcpEndPoint, connectTokenSource.Token).ConfigureAwait(false);
503await Task.Delay(TcpClientRetryTimeoutMs, token).ConfigureAwait(false);
523await Task.Factory.FromAsync(beginConnect, clientSocket.EndConnect, this).ConfigureAwait(false);
652await namedPipe.ConnectAsync(IpcClientTimeoutMs, token).ConfigureAwait(false);
684await unixDomainSocket.ConnectAsync(new IpcUnixDomainSocketEndPoint(_ipcClientPath), token).ConfigureAwait(false);
701await Task.Delay(IpcClientRetryTimeoutMs, token).ConfigureAwait(false);
823await Task.WhenAll(netServerStreamTask, checkIpcStreamTask).ConfigureAwait(false);
860await Task.WhenAll(ipcServerStreamTask, checkTcpStreamTask).ConfigureAwait(false);
1006await Task.WhenAll(tcpClientStreamTask, checkIpcStreamTask).ConfigureAwait(false);
1140await Task.WhenAll(ipcClientStreamTask, checkTcpStreamTask).ConfigureAwait(false);
1164await IpcAdvertise.SerializeAsync(ipcClientStream, _tcpServerRouterFactory.RuntimeInstanceId, (ulong)_tcpServerRouterFactory.RuntimeProcessId, token).ConfigureAwait(false);
1259await UpdateRuntimeInfo(token).ConfigureAwait(false);
1285await Task.WhenAll(ipcClientStreamTask, checkTcpStreamTask).ConfigureAwait(false);
1309await IpcAdvertise.SerializeAsync(ipcClientStream, _runtimeInstanceId, _runtimeProcessId, token).ConfigureAwait(false);
1365await Task.WhenAll(readTask, checkTcpStreamTask).ConfigureAwait(false);
1390await tcpClientStream.WriteAsync(buffer, 0, bytesRead, token).ConfigureAwait(false);
1413await tcpClientStream.WriteAsync(buffer, 0, buffer.Length, token).ConfigureAwait(false);
1506await Task.WhenAll(runningTasks.ToArray()).ConfigureAwait(false);
1573await _frontendStream.WriteAsync(buffer, 0, bytesRead, token).ConfigureAwait(false);
1575await _frontendStream.FlushAsync().ConfigureAwait(false);
1616await _backendStream.WriteAsync(buffer, 0, bytesRead, token).ConfigureAwait(false);
1618await _backendStream.FlushAsync().ConfigureAwait(false);
Microsoft.DotNet.Arcade.Sdk (2)
Microsoft.DotNet.Cli.InternalMicrosoft (9)
Microsoft.DotNet.Cli.Telemetry (2)
Microsoft.Extensions.AI (4)
Microsoft.Extensions.AI.Abstractions (12)
Microsoft.Extensions.AI.Abstractions.Tests (1)
Microsoft.Extensions.AI.Evaluation (1)
Microsoft.Extensions.AI.Evaluation.Console (4)
Microsoft.Extensions.AI.Evaluation.NLP (1)
Microsoft.Extensions.AI.Evaluation.Quality (1)
Microsoft.Extensions.AI.Evaluation.Reporting (13)
Microsoft.Extensions.AI.Evaluation.Reporting.Azure (5)
Microsoft.Extensions.AI.Evaluation.Safety (2)
Microsoft.Extensions.AI.OpenAI (19)
OpenAIRealtimeClientSession.cs (18)
91await _sessionClient.ConfigureTranscriptionSessionAsync(rawTransOptions, cancellationToken).ConfigureAwait(false);
96await _sessionClient.ConfigureTranscriptionSessionAsync(transOpts, cancellationToken).ConfigureAwait(false);
101await _sessionClient.ConfigureConversationSessionAsync(convOpts, cancellationToken).ConfigureAwait(false);
123await UpdateSessionAsync(sessionUpdate.Options, cancellationToken).ConfigureAwait(false);
127await SendResponseCreateAsync(responseCreate, cancellationToken).ConfigureAwait(false);
131await SendConversationItemCreateAsync(itemCreate, cancellationToken).ConfigureAwait(false);
135await SendInputAudioAppendAsync(audioAppend, cancellationToken).ConfigureAwait(false);
142await _sessionClient.SendCommandAsync(cmd, cancellationToken).ConfigureAwait(false);
146await _sessionClient.CommitPendingAudioAsync(cancellationToken).ConfigureAwait(false);
152await SendRawCommandAsync(message, cancellationToken).ConfigureAwait(false);
294await _sessionClient!.SendCommandAsync(cmd, cancellationToken).ConfigureAwait(false);
298await _sessionClient!.StartResponseAsync(responseOptions, cancellationToken).ConfigureAwait(false);
328await _sessionClient!.SendCommandAsync(cmd, cancellationToken).ConfigureAwait(false);
332await _sessionClient!.AddItemAsync(sdkItem, cancellationToken).ConfigureAwait(false);
348await _sessionClient!.SendCommandAsync(cmd, cancellationToken).ConfigureAwait(false);
352await _sessionClient!.SendInputAudioAsync(audioData, cancellationToken).ConfigureAwait(false);
360await _sessionClient!.SendCommandAsync(sdkCmd, cancellationToken).ConfigureAwait(false);
379await _sessionClient!.SendCommandAsync(BinaryData.FromString(jsonString), null).ConfigureAwait(false);
Microsoft.Extensions.AI.Templates.Tests (2)
Microsoft.Extensions.AI.Tests (3)
Microsoft.Extensions.Caching.Hybrid (1)
Microsoft.Extensions.Caching.SqlServer (7)
Microsoft.Extensions.Caching.StackExchangeRedis (5)
Microsoft.Extensions.Configuration.FileExtensions (1)
Microsoft.Extensions.Configuration.KeyPerFile (1)
Microsoft.Extensions.DataIngestion (7)
Microsoft.Extensions.DataIngestion.MarkItDown (2)
Microsoft.Extensions.Diagnostics.HealthChecks (4)
Microsoft.Extensions.Diagnostics.Probes (2)
Microsoft.Extensions.Diagnostics.ResourceMonitoring (2)
Microsoft.Extensions.Diagnostics.Testing (2)
Microsoft.Extensions.DotNetDeltaApplier (6)
Microsoft.Extensions.Hosting (13)
Microsoft.Extensions.Hosting.Abstractions (5)
Microsoft.Extensions.Hosting.Testing (8)
Microsoft.Extensions.Hosting.WindowsServices (1)
Microsoft.Extensions.Http.Diagnostics (2)
Microsoft.Extensions.Http.Diagnostics.Tests (1)
Microsoft.Extensions.Http.Resilience.Tests (1)
Microsoft.Extensions.Identity.Core (59)
UserManager.cs (52)
505await UpdateSecurityStampInternal(user).ConfigureAwait(false);
513await GetUserLockoutStore().SetLockoutEnabledAsync(user, true, CancellationToken).ConfigureAwait(false);
515await UpdateNormalizedUserNameAsync(user).ConfigureAwait(false);
516await UpdateNormalizedEmailAsync(user).ConfigureAwait(false);
701await Store.SetNormalizedUserNameAsync(user, normalizedName, CancellationToken).ConfigureAwait(false);
730await Store.SetUserNameAsync(user, userName, CancellationToken).ConfigureAwait(false);
731await UpdateSecurityStampInternal(user).ConfigureAwait(false);
1001await UpdateSecurityStampInternal(user).ConfigureAwait(false);
1098await loginStore.RemoveLoginAsync(user, loginProvider, providerKey, CancellationToken).ConfigureAwait(false);
1099await UpdateSecurityStampInternal(user).ConfigureAwait(false);
1147await loginStore.AddLoginAsync(user, login, CancellationToken).ConfigureAwait(false);
1199await claimStore.AddClaimsAsync(user, claims, CancellationToken).ConfigureAwait(false);
1230await claimStore.ReplaceClaimAsync(user, claim, newClaim, CancellationToken).ConfigureAwait(false);
1273await claimStore.RemoveClaimsAsync(user, claims, CancellationToken).ConfigureAwait(false);
1334await userRoleStore.AddToRoleAsync(user, normalizedRole, CancellationToken).ConfigureAwait(false);
1377await userRoleStore.AddToRoleAsync(user, normalizedRole, CancellationToken).ConfigureAwait(false);
1407await userRoleStore.RemoveFromRoleAsync(user, normalizedRole, CancellationToken).ConfigureAwait(false);
1468await userRoleStore.RemoveFromRoleAsync(user, normalizedRole, CancellationToken).ConfigureAwait(false);
1534await store.SetEmailAsync(user, email, CancellationToken).ConfigureAwait(false);
1535await store.SetEmailConfirmedAsync(user, false, CancellationToken).ConfigureAwait(false);
1536await UpdateSecurityStampInternal(user).ConfigureAwait(false);
1596await store.SetNormalizedEmailAsync(user, ProtectPersonalData(NormalizeEmail(email)!), CancellationToken).ConfigureAwait(false);
1648await store.SetEmailConfirmedAsync(user, true, CancellationToken).ConfigureAwait(false);
1718await store.SetEmailAsync(user, newEmail, CancellationToken).ConfigureAwait(false);
1719await store.SetEmailConfirmedAsync(user, true, CancellationToken).ConfigureAwait(false);
1720await UpdateSecurityStampInternal(user).ConfigureAwait(false);
1755await store.SetPhoneNumberAsync(user, phoneNumber, CancellationToken).ConfigureAwait(false);
1756await store.SetPhoneNumberConfirmedAsync(user, false, CancellationToken).ConfigureAwait(false);
1757await UpdateSecurityStampInternal(user).ConfigureAwait(false);
1805await store.SetPhoneNumberAsync(user, phoneNumber, CancellationToken).ConfigureAwait(false);
1806await store.SetPhoneNumberConfirmedAsync(user, true, CancellationToken).ConfigureAwait(false);
1807await UpdateSecurityStampInternal(user).ConfigureAwait(false);
2073await store.SetTwoFactorEnabledAsync(user, enabled, CancellationToken).ConfigureAwait(false);
2074await UpdateSecurityStampInternal(user).ConfigureAwait(false);
2124await store.SetLockoutEnabledAsync(user, enabled, CancellationToken).ConfigureAwait(false);
2198await store.SetLockoutEndDateAsync(user, lockoutEnd, CancellationToken).ConfigureAwait(false);
2226CancellationToken).ConfigureAwait(false);
2227await store.ResetAccessFailedCountAsync(user, CancellationToken).ConfigureAwait(false);
2268await store.ResetAccessFailedCountAsync(user, CancellationToken).ConfigureAwait(false);
2357await store.SetTokenAsync(user, loginProvider, tokenName, tokenValue, CancellationToken).ConfigureAwait(false);
2385await store.RemoveTokenAsync(user, loginProvider, tokenName, CancellationToken).ConfigureAwait(false);
2421await store.SetAuthenticatorKeyAsync(user, GenerateNewAuthenticatorKey(), CancellationToken).ConfigureAwait(false);
2422await UpdateSecurityStampInternal(user).ConfigureAwait(false);
2460await store.ReplaceCodesAsync(user, newCodes.Distinct(), CancellationToken).ConfigureAwait(false);
2647await passkeyStore.AddOrUpdatePasskeyAsync(user, passkey, CancellationToken).ConfigureAwait(false);
2733await passkeyStore.RemovePasskeyAsync(user, credentialId, CancellationToken).ConfigureAwait(false);
2734await UpdateSecurityStampInternal(user).ConfigureAwait(false);
2823await GetSecurityStore().SetSecurityStampAsync(user, NewSecurityStamp(), CancellationToken).ConfigureAwait(false);
2849await passwordStore.SetPasswordHashAsync(user, hash, CancellationToken).ConfigureAwait(false);
2850await UpdateSecurityStampInternal(user).ConfigureAwait(false);
3002await UpdateNormalizedUserNameAsync(user).ConfigureAwait(false);
3003await UpdateNormalizedEmailAsync(user).ConfigureAwait(false);
Microsoft.Extensions.Identity.Stores (3)
Microsoft.Extensions.Logging.AzureAppServices (4)
Microsoft.Extensions.Logging.Console (1)
Microsoft.Extensions.Options (1)
Microsoft.Extensions.Primitives (1)
Microsoft.Extensions.ServiceDiscovery (9)
Microsoft.Extensions.ServiceDiscovery.Dns (1)
Microsoft.Extensions.ServiceDiscovery.Tests (1)
Microsoft.Extensions.TimeProvider.Testing.Tests (1)
Microsoft.Extensions.VectorData.Abstractions (1)
Microsoft.Gen.BuildMetadata.Unit.Tests (1)
Microsoft.Gen.ComplianceReports.Unit.Tests (1)
Microsoft.Gen.ContextualOptions.Unit.Tests (1)
Microsoft.Gen.Logging.Unit.Tests (1)
Microsoft.Gen.MetadataExtractor.Unit.Tests (1)
Microsoft.Gen.Metrics.Unit.Tests (1)
Microsoft.Gen.MetricsReports.Unit.Tests (1)
Microsoft.Interop.ComInterfaceGenerator (4)
Microsoft.Interop.LibraryImportGenerator (7)
Microsoft.Maui (2)
Microsoft.Maui.Controls (14)
Microsoft.Maui.Essentials (1)
Microsoft.Maui.Maps (1)
Microsoft.ML.AutoML.Tests (1)
Microsoft.ML.Samples (1)
Microsoft.ML.Samples.GPU (1)
Microsoft.ML.SamplesUtils (1)
Microsoft.ML.TestFrameworkCommon (2)
Microsoft.ML.Tokenizers.Data.Tests (2)
Microsoft.ML.Tokenizers.Tests (2)
Microsoft.NET.Build.Containers (79)
LocalDaemons\ContainerArchive.cs (22)
41await WriteDockerImageToStreamAsync(image, sourceReference, destinationReference, imageStream, cancellationToken).ConfigureAwait(false);
45await WriteOciImageToStreamAsync(image, sourceReference, destinationReference, imageStream, cancellationToken).ConfigureAwait(false);
65.ConfigureAwait(false);
68await WriteImageConfigAsync(writer, image, configTarballPath, cancellationToken).ConfigureAwait(false);
70.ConfigureAwait(false);
83await WriteOciImageToBlobsAsync(writer, image, sourceReference, cancellationToken).ConfigureAwait(false);
84await WriteIndexJsonForOciImageAsync(writer, image, destinationReference, cancellationToken).ConfigureAwait(false);
85await WriteOciLayoutAsync(writer, cancellationToken).ConfigureAwait(false);
101await WriteOciImageToBlobsAsync(writer, image, sourceReference, cancellationToken).ConfigureAwait(false);
105.ConfigureAwait(false);
106await WriteOciLayoutAsync(writer, cancellationToken).ConfigureAwait(false);
132await writer.WriteEntryAsync(localPath, layerTarballPath, cancellationToken).ConfigureAwait(false);
145await writer.WriteEntryAsync(configEntry, cancellationToken).ConfigureAwait(false);
179await writer.WriteEntryAsync(manifestEntry, cancellationToken).ConfigureAwait(false);
194await writer.WriteEntryAsync(layoutEntry, cancellationToken).ConfigureAwait(false);
210await writer.WriteEntryAsync(manifestEntry, cancellationToken).ConfigureAwait(false);
241await writer.WriteEntryAsync(indexEntry, cancellationToken).ConfigureAwait(false);
255.ConfigureAwait(false);
256await WriteImageConfigAsync(writer, image, $"{BlobsPath}/{GetRequiredImageSha(image)}", cancellationToken).ConfigureAwait(false);
257await WriteManifestForOciImageAsync(writer, image, cancellationToken).ConfigureAwait(false);
282await writer.WriteEntryAsync(manifestListEntry, cancellationToken).ConfigureAwait(false);
301await writer.WriteEntryAsync(indexEntry, cancellationToken).ConfigureAwait(false);
Registry\Registry.cs (11)
455.ConfigureAwait(false);
472await Task.Delay(_retryDelayProvider(), cancellationToken).ConfigureAwait(false);
488await UploadBlobAsync(repository, digest, contents, cancellationToken).ConfigureAwait(false);
577await _registryAPI.Blob.Upload.CompleteAsync(finalChunkUri.UploadUri, digest, cancellationToken).ConfigureAwait(false);
592await _registryAPI.Manifest.PutAsync(destinationImageReference.Repository, tag, multiArchImage.ImageIndex, multiArchImage.ImageIndexMediaType, cancellationToken).ConfigureAwait(false);
638await destinationRegistry.PushLayerAsync(Layer.FromDescriptor(descriptor), destination.Repository, cancellationToken).ConfigureAwait(false);
652await Task.WhenAll(builtImage.LayerDescriptors.Select(descriptor => uploadLayerFunc(descriptor))).ConfigureAwait(false);
658await uploadLayerFunc(descriptor).ConfigureAwait(false);
667await UploadBlobAsync(destination.Repository, configDigest, stringStream, cancellationToken).ConfigureAwait(false);
681await _registryAPI.Manifest.PutAsync(destination.Repository, tag, builtImage.Manifest, builtImage.ManifestMediaType, cancellationToken).ConfigureAwait(false);
688await _registryAPI.Manifest.PutAsync(destination.Repository, builtImage.ManifestDigest, builtImage.Manifest, builtImage.ManifestMediaType, cancellationToken).ConfigureAwait(false);
Microsoft.NET.Sdk.Razor.Tasks (9)
Microsoft.TemplateEngine.Cli (15)
Microsoft.TemplateEngine.Edge (13)
Microsoft.TemplateEngine.Orchestrator.RunnableProjects (5)
Microsoft.TemplateSearch.Common (1)
Microsoft.TestPlatform.CommunicationUtilities (1)
Microsoft.TestPlatform.VsTestConsole.TranslationLayer (34)
Microsoft.VisualBasic.Forms (4)
NuGet.Protocol (1)
Pipelines.AppHost (16)
Pipelines.Library (9)
Roslyn.Diagnostics.Analyzers (21)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (8)
37await consumeItems(items.ToImmutableAndClear(), args, cancellationToken).ConfigureAwait(false);
77await args.consumeItems(items.ReadAllAsync(cancellationToken), args.args, cancellationToken).ConfigureAwait(false);
114await args.consumeItems(items, args.args, cancellationToken).ConfigureAwait(false);
238await args.produceItems(source, callback, args.args, cancellationToken).ConfigureAwait(false)),
299source, callback, args.args, cancellationToken).ConfigureAwait(false)),
344await Task.WhenAll(writeTask, readTask).ConfigureAwait(false);
367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
384await action(args, cancellationToken).ConfigureAwait(false);
Roslyn.Diagnostics.CSharp.Analyzers (2)
rzc (11)
SimplePipelines.AppHost (6)
Stress.AppHost (1)
System.Data.Common (13)
System.Diagnostics.Process (8)
System.DirectoryServices.Protocols (1)
System.Formats.Tar (6)
System.IO.Compression (49)
System\IO\Compression\ZipArchive.Async.cs (15)
83await backingStream.CopyToAsync(stream, cancellationToken).ConfigureAwait(false);
95await zipArchive.ReadEndOfCentralDirectoryAsync(cancellationToken).ConfigureAwait(false);
99await zipArchive.EnsureCentralDirectoryReadAsync(cancellationToken).ConfigureAwait(false);
110await zipArchive.ReadEndOfCentralDirectoryAsync(cancellationToken).ConfigureAwait(false);
111await zipArchive.EnsureCentralDirectoryReadAsync(cancellationToken).ConfigureAwait(false);
115await entry.ThrowIfNotOpenableAsync(needToUncompress: false, needToLoadIntoMemory: true, cancellationToken).ConfigureAwait(false);
166await entry.UnloadStreamsAsync().ConfigureAwait(false);
174await CloseStreamsAsync().ConfigureAwait(false);
208await ReadCentralDirectoryAsync(cancellationToken).ConfigureAwait(false);
246await lastEntry.ReadEncryptionSaltIfNeededAsync(cancellationToken).ConfigureAwait(false);
391await entry.LoadLocalHeaderExtraFieldIfNeededAsync(cancellationToken).ConfigureAwait(false);
394await entry.LoadCompressedBytesIfNeededAsync(cancellationToken).ConfigureAwait(false);
412await entry.WriteAndFinishLocalEntryAsync(forceWriteLocalEntry, cancellationToken).ConfigureAwait(false);
425await entry.WriteCentralDirectoryFileHeaderAsync(centralDirectoryEntryRequiresUpdate, cancellationToken).ConfigureAwait(false);
468await ZipEndOfCentralDirectoryBlock.WriteBlockAsync(_archiveStream, _entries.Count, startOfCentralDirectory, sizeOfCentralDirectory, _archiveComment, cancellationToken).ConfigureAwait(false);
System\IO\Compression\ZipArchiveEntry.Async.cs (19)
271await ThrowIfNotOpenableAsync(needToUncompress: true, needToLoadIntoMemory: false, cancellationToken).ConfigureAwait(false);
317await ThrowIfNotOpenableAsync(needToUncompress: true, needToLoadIntoMemory: true, cancellationToken).ConfigureAwait(false);
380await decompressor.CopyToAsync(_storedUncompressedData, cancellationToken).ConfigureAwait(false);
411await CloseStreamsAsync().ConfigureAwait(false);
412await WriteLocalFileHeaderAndDataIfNeededAsync(forceWrite, cancellationToken).ConfigureAwait(false);
413await UnloadStreamsAsync().ConfigureAwait(false);
439await CreateAesExtraField().WriteBlockAsync(_archive.ArchiveStream, cancellationToken).ConfigureAwait(false);
442await ZipGenericExtraField.WriteAllBlocksExcludingTagAsync(_cdUnknownExtraFields, _cdTrailingExtraFieldData ?? Array.Empty<byte>(), _archive.ArchiveStream, WinZipAesExtraField.HeaderId, cancellationToken).ConfigureAwait(false);
447await ZipGenericExtraField.WriteAllBlocksAsync(_cdUnknownExtraFields, _cdTrailingExtraFieldData ?? Array.Empty<byte>(), _archive.ArchiveStream, cancellationToken).ConfigureAwait(false);
572await ThrowIfNotOpenableAsync(needToUncompress: true, needToLoadIntoMemory: true, cancellationToken).ConfigureAwait(false);
589await ThrowIfNotOpenableAsync(needToUncompress: true, needToLoadIntoMemory: true, cancellationToken).ConfigureAwait(false);
624await decompressed.CopyToAsync(_storedUncompressedData, cancellationToken).ConfigureAwait(false);
712await CreateAesExtraField().WriteBlockAsync(_archive.ArchiveStream, cancellationToken).ConfigureAwait(false);
715await ZipGenericExtraField.WriteAllBlocksExcludingTagAsync(_lhUnknownExtraFields, _lhTrailingExtraFieldData ?? Array.Empty<byte>(), _archive.ArchiveStream, WinZipAesExtraField.HeaderId, cancellationToken).ConfigureAwait(false);
719await ZipGenericExtraField.WriteAllBlocksAsync(_lhUnknownExtraFields, _lhTrailingExtraFieldData ?? Array.Empty<byte>(), _archive.ArchiveStream, cancellationToken).ConfigureAwait(false);
775await _storedUncompressedData.CopyToAsync(crcStream, cancellationToken).ConfigureAwait(false);
837await _storedUncompressedData.CopyToAsync(crcStream, cancellationToken).ConfigureAwait(false);
860await WriteCrcAndSizesInLocalHeaderAsync(usedZip64InLH, cancellationToken).ConfigureAwait(false);
874await _storedUncompressedData.CopyToAsync(entryWriter, cancellationToken).ConfigureAwait(false);
System.IO.Compression.Brotli (1)
System.IO.Compression.ZipFile (15)
System\IO\Compression\ZipFile.Create.Async.cs (4)
456await CreateZipArchiveFromDirectoryAsync(sourceDirectoryName, archive, options.CompressionLevel, options.IncludeBaseDirectory, options.Password, options.EncryptionMethod, cancellationToken).ConfigureAwait(false);
483await CreateZipArchiveFromDirectoryAsync(sourceDirectoryName, archive, options.CompressionLevel, options.IncludeBaseDirectory, options.Password, options.EncryptionMethod, cancellationToken).ConfigureAwait(false);
502await CreateZipArchiveFromDirectoryAsync(sourceDirectoryName, archive, compressionLevel, includeBaseDirectory, cancellationToken: cancellationToken).ConfigureAwait(false);
516await CreateZipArchiveFromDirectoryAsync(sourceDirectoryName, archive, compressionLevel, includeBaseDirectory, cancellationToken: cancellationToken).ConfigureAwait(false);
System\IO\Compression\ZipFile.Extract.Async.cs (4)
204await archive.ExtractToDirectoryAsync(destinationDirectoryName, overwriteFiles, cancellationToken).ConfigureAwait(false);
276await entry.ExtractRelativeToDirectoryAsync(destinationDirectoryName, overwriteFiles, password, cancellationToken).ConfigureAwait(false);
435await archive.ExtractToDirectoryAsync(destinationDirectoryName, overwriteFiles, cancellationToken).ConfigureAwait(false);
494await entry.ExtractRelativeToDirectoryAsync(destinationDirectoryName, overwriteFiles, password, cancellationToken).ConfigureAwait(false);
System\IO\Compression\ZipFileExtensions.ZipArchiveEntry.Extract.Async.cs (4)
75await ExtractToFileCoreAsync(source, destinationFileName, overwrite, fileStreamOptions, password: default, usePassword: false, cancellationToken).ConfigureAwait(false);
93await ExtractToFileCoreAsync(source, destinationFileName, overwrite, fileStreamOptions, password, usePassword: true, cancellationToken).ConfigureAwait(false);
122await es.CopyToAsync(fs, cancellationToken).ConfigureAwait(false);
155await ExtractToFileAsync(source, fileDestinationPath, overwrite, password, cancellationToken).ConfigureAwait(false);
System.IO.Pipelines (3)
System.Memory.Data (1)
System.Net.Http (38)
System.Net.Http.Json (1)
System.Net.Http.WinHttpHandler (4)
System.Net.HttpListener (3)
System.Net.Mail (19)
System.Net.NameResolution (4)
System\Net\DnsResolverPal.Managed.cs (4)
705await SendExactAsync(socket, buffer.AsMemory(0, 2), timeoutCts.Token).ConfigureAwait(false);
706await SendExactAsync(socket, query, timeoutCts.Token).ConfigureAwait(false);
708await ReceiveExactAsync(socket, buffer.AsMemory(0, 2), timeoutCts.Token).ConfigureAwait(false);
717await ReceiveExactAsync(socket, buffer.AsMemory(0, responseLength), timeoutCts.Token).ConfigureAwait(false);
System.Net.Ping (1)
System.Net.Quic (3)
System.Net.Requests (3)
System.Net.Security (19)
System\Net\Security\NegotiateStream.cs (8)
742SendBlobAsync<TIOAdapter>(message: null, cancellationToken)).ConfigureAwait(false); // client should send the first blob
787await SendAuthResetSignalAndThrowAsync<TIOAdapter>(message, exception, cancellationToken).ConfigureAwait(false);
811await _framer!.WriteMessageAsync<TIOAdapter>(InnerStream, message, cancellationToken).ConfigureAwait(false);
848await SendAuthResetSignalAndThrowAsync<TIOAdapter>(message!, exception, cancellationToken).ConfigureAwait(false);
858await _framer!.WriteMessageAsync<TIOAdapter>(InnerStream, message, cancellationToken).ConfigureAwait(false);
861await ReceiveBlobAsync<TIOAdapter>(cancellationToken).ConfigureAwait(false);
920await SendBlobAsync<TIOAdapter>(message, cancellationToken).ConfigureAwait(false);
930await _framer.WriteMessageAsync<TIOAdapter>(InnerStream, message, cancellationToken).ConfigureAwait(false);
System.Net.ServerSentEvents (1)
System.Net.Sockets (1)
System.Net.WebSockets (9)
System.Net.WebSockets.Client (7)
System.Private.CoreLib (83)
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\StreamWriter.cs (9)
286await FlushAsync().ConfigureAwait(false);
702await FlushAsyncInternal(flushStream: false, flushEncoder: false).ConfigureAwait(false);
713await FlushAsyncInternal(flushStream: false, flushEncoder: false).ConfigureAwait(false);
722await FlushAsyncInternal(flushStream: true, flushEncoder: false).ConfigureAwait(false);
804await FlushAsyncInternal(flushStream: false, flushEncoder: false, cancellationToken).ConfigureAwait(false);
821await FlushAsyncInternal(flushStream: false, flushEncoder: false, cancellationToken).ConfigureAwait(false);
830await FlushAsyncInternal(flushStream: true, flushEncoder: false, cancellationToken).ConfigureAwait(false);
981await FlushAsyncInternal(flushStream, flushEncoder, cancellationToken).ConfigureAwait(false);
1025await _stream.FlushAsync(cancellationToken).ConfigureAwait(false);
System.Private.DataContractSerialization (29)
System\Xml\XmlBaseWriter.cs (14)
377await FlushBase64Async().ConfigureAwait(false);
419await _writer.WriteEndAttributeAsync().ConfigureAwait(false);
548await _writer.WriteStartElementAsync(prefix, localName).ConfigureAwait(false);
553await FlushBase64Async().ConfigureAwait(false);
554await AutoCompleteAsync(WriteState.Element).ConfigureAwait(false);
644await WriteEndAttributeAsync().ConfigureAwait(false);
650await _writer.WriteEndStartElementAsync(true).ConfigureAwait(false);
655await _writer.WriteEndElementAsync(element.Prefix, element.LocalName!).ConfigureAwait(false);
725await FlushElementAsync().ConfigureAwait(false);
786await EndStartElementAsync().ConfigureAwait(false);
1549await StartContentAsync().ConfigureAwait(false);
1550await _writer.WriteBase64TextAsync(_trailBytes, _trailByteCount, buffer, offset, actualByteCount - _trailByteCount).ConfigureAwait(false);
1768await StartContentAsync().ConfigureAwait(false);
1769await _writer.WriteBase64TextAsync(_trailBytes, _trailByteCount, _trailBytes, 0, 0).ConfigureAwait(false);
System.Private.Xml (407)
System\Xml\Core\XmlEncodedRawTextWriterAsync.cs (82)
40await RawTextAsync("<?xml version=\"").ConfigureAwait(false);
43await RawTextAsync("1.0").ConfigureAwait(false);
48await RawTextAsync("\" encoding=\"").ConfigureAwait(false);
49await RawTextAsync(_encoding.WebName).ConfigureAwait(false);
55await RawTextAsync("\" standalone=\"").ConfigureAwait(false);
56await RawTextAsync(standalone == XmlStandalone.Yes ? "yes" : "no").ConfigureAwait(false);
59await RawTextAsync("\"?>").ConfigureAwait(false);
79await FlushBufferAsync().ConfigureAwait(false);
90await _stream.FlushAsync().ConfigureAwait(false);
111await _writer.FlushAsync().ConfigureAwait(false);
139await RawTextAsync("<!DOCTYPE ").ConfigureAwait(false);
140await RawTextAsync(name).ConfigureAwait(false);
143await RawTextAsync(" PUBLIC \"").ConfigureAwait(false);
144await RawTextAsync(pubid).ConfigureAwait(false);
145await RawTextAsync("\" \"").ConfigureAwait(false);
148await RawTextAsync(sysid).ConfigureAwait(false);
154await RawTextAsync(" SYSTEM \"").ConfigureAwait(false);
155await RawTextAsync(sysid).ConfigureAwait(false);
166await RawTextAsync(subset).ConfigureAwait(false);
309await WriteStartNamespaceDeclarationAsync(prefix).ConfigureAwait(false);
310await WriteStringAsync(namespaceName).ConfigureAwait(false);
311await WriteEndNamespaceDeclarationAsync().ConfigureAwait(false);
328await RawTextAsync("xmlns=\"").ConfigureAwait(false);
332await RawTextAsync("xmlns:").ConfigureAwait(false);
333await RawTextAsync(prefix).ConfigureAwait(false);
386await WriteCDataSectionAsync(text).ConfigureAwait(false);
409await WriteCommentOrPiAsync(text, '-').ConfigureAwait(false);
427await RawTextAsync(name).ConfigureAwait(false);
432await WriteCommentOrPiAsync(text, '?').ConfigureAwait(false);
448await RawTextAsync(name).ConfigureAwait(false);
453await FlushBufferAsync().ConfigureAwait(false);
476await RawTextAsync(strVal).ConfigureAwait(false);
481await FlushBufferAsync().ConfigureAwait(false);
537await RawTextAsync(surrogateChar.ToString("X", NumberFormatInfo.InvariantInfo)).ConfigureAwait(false);
576await WriteRawWithCharCheckingAsync(buffer, index, count).ConfigureAwait(false);
590await WriteRawWithCharCheckingAsync(data).ConfigureAwait(false);
599await FlushBufferAsync().ConfigureAwait(false);
600await FlushEncoderAsync().ConfigureAwait(false);
604await _stream.FlushAsync().ConfigureAwait(false);
608await _writer.FlushAsync().ConfigureAwait(false);
645await EncodeCharsAsync(1, _bufPos, true).ConfigureAwait(false);
652await _writer!.WriteAsync(_bufChars.AsMemory(1, _bufPos - 1)).ConfigureAwait(false);
884await FlushBufferAsync().ConfigureAwait(false);
909await FlushBufferAsync().ConfigureAwait(false);
917await FlushBufferAsync().ConfigureAwait(false);
1097await RawTextAsync(_newLineChars).ConfigureAwait(false);
1103await FlushBufferAsync().ConfigureAwait(false);
1137await RawTextAsync(_newLineChars).ConfigureAwait(false);
1143await FlushBufferAsync().ConfigureAwait(false);
1154await RawTextAsync(_newLineChars).ConfigureAwait(false);
1160await FlushBufferAsync().ConfigureAwait(false);
1319await FlushBufferAsync().ConfigureAwait(false);
1328await FlushBufferAsync().ConfigureAwait(false);
1335await RawTextAsync(text2, text3, text4).ConfigureAwait(false);
1495await RawTextAsync(_newLineChars).ConfigureAwait(false);
1501await FlushBufferAsync().ConfigureAwait(false);
1519await RawTextAsync(_newLineChars).ConfigureAwait(false);
1525await FlushBufferAsync().ConfigureAwait(false);
1690await FlushBufferAsync().ConfigureAwait(false);
1706await RawTextAsync(_newLineChars).ConfigureAwait(false);
1712await FlushBufferAsync().ConfigureAwait(false);
1874await FlushBufferAsync().ConfigureAwait(false);
1890await RawTextAsync(_newLineChars).ConfigureAwait(false);
1896await FlushBufferAsync().ConfigureAwait(false);
1911await WriteIndentAsync().ConfigureAwait(false);
1913await base.WriteDocTypeAsync(name, pubid, sysid, subset).ConfigureAwait(false);
1924await WriteIndentAsync().ConfigureAwait(false);
1929await base.WriteStartElementAsync(prefix, localName, ns).ConfigureAwait(false);
1942await WriteIndentAsync().ConfigureAwait(false);
1947await base.WriteEndElementAsync(prefix, localName, ns).ConfigureAwait(false);
1960await WriteIndentAsync().ConfigureAwait(false);
1965await base.WriteFullEndElementAsync(prefix, localName, ns).ConfigureAwait(false);
1975await WriteIndentAsync().ConfigureAwait(false);
1978await base.WriteStartAttributeAsync(prefix, localName, ns).ConfigureAwait(false);
1988await WriteIndentAsync().ConfigureAwait(false);
1991await base.WriteStartNamespaceDeclarationAsync(prefix).ConfigureAwait(false);
2006await WriteIndentAsync().ConfigureAwait(false);
2009await base.WriteCommentAsync(text).ConfigureAwait(false);
2017await WriteIndentAsync().ConfigureAwait(false);
2020await base.WriteProcessingInstructionAsync(target, text).ConfigureAwait(false);
2090await RawTextAsync(base._newLineChars).ConfigureAwait(false);
2093await RawTextAsync(_indentChars).ConfigureAwait(false);
System\Xml\Core\XmlTextReaderImplAsync.cs (39)
46await FinishPartialValueAsync().ConfigureAwait(false);
51await FinishOtherValueIteratorAsync().ConfigureAwait(false);
95await InitStreamInputAsync(_laterInitParam.inputbaseUri, _reportedBaseUri, stream, null, 0, enc).ConfigureAwait(false);
102await ProcessDtdFromParserContextAsync(_laterInitParam.inputContext).ConfigureAwait(false);
126await InitStreamInputAsync(_laterInitParam.inputbaseUri, _reportedBaseUri, _laterInitParam!.inputStream!, _laterInitParam.inputBytes, _laterInitParam.inputByteCount, enc).ConfigureAwait(false);
133await ProcessDtdFromParserContextAsync(_laterInitParam.inputContext).ConfigureAwait(false);
148await ProcessDtdFromParserContextAsync(_laterInitParam.inputContext).ConfigureAwait(false);
330await SkipPartialTextValueAsync().ConfigureAwait(false);
333await FinishReadValueChunkAsync().ConfigureAwait(false);
336await FinishReadContentAsBinaryAsync().ConfigureAwait(false);
339await FinishReadElementContentAsBinaryAsync().ConfigureAwait(false);
770await ParseCDataOrCommentAsync(XmlNodeType.Comment).ConfigureAwait(false);
778await ParseCDataOrCommentAsync(XmlNodeType.Comment).ConfigureAwait(false);
841await PushExternalEntityOrSubsetAsync(publicId, systemId, _ps.baseUri, null).ConfigureAwait(false);
1247await SwitchEncodingToUTF8Async().ConfigureAwait(false);
1252await SwitchEncodingAsync(encoding).ConfigureAwait(false);
1460await SwitchEncodingToUTF8Async().ConfigureAwait(false);
1636await ParseEntityReferenceAsync().ConfigureAwait(false);
1946await ParseElementAsync_SetElement(colonPos, pos).ConfigureAwait(false);
2057await ParseElementAsync_NoAttributes().ConfigureAwait(false);
2077await ParseEndElmentAsync_PrepareData().ConfigureAwait(false);
2078await ParseEndElementAsync_CheckNameAndParse().ConfigureAwait(false);
2166await task.ConfigureAwait(false);
2539await ParseAttributeValueSlowAsync(pos, quoteChar, attr).ConfigureAwait(false);
3570await FinishPartialValueAsync().ConfigureAwait(false);
3587await FinishPartialValueAsync().ConfigureAwait(false);
3650await SkipPartialTextValueAsync().ConfigureAwait(false);
3665await FinishReadContentAsBinaryAsync().ConfigureAwait(false);
3815await ParseDtdFromParserContextAsync().ConfigureAwait(false);
4178await ParseCDataOrCommentAsync(XmlNodeType.Comment).ConfigureAwait(false);
4184await ParseCDataOrCommentAsync(XmlNodeType.Comment).ConfigureAwait(false);
4451await ParseDtdAsync().ConfigureAwait(false);
4462await SkipDtdAsync().ConfigureAwait(false);
4521await SkipPublicOrSystemIdLiteralAsync().ConfigureAwait(false);
4530await SkipPublicOrSystemIdLiteralAsync().ConfigureAwait(false);
4558await SkipPublicOrSystemIdLiteralAsync().ConfigureAwait(false);
4572await SkipUntilAsync(']', true).ConfigureAwait(false);
5187await InitStreamInputAsync(uri, stream, null).ConfigureAwait(false);
5207await PushExternalEntityOrSubsetAsync(entity.PublicId, entity.SystemId, entityBaseUri, entity.Name).ConfigureAwait(false);
System\Xml\Core\XmlUtf8RawTextWriterAsync.cs (77)
39await RawTextAsync("<?xml version=\"").ConfigureAwait(false);
42await RawTextAsync("1.0").ConfigureAwait(false);
47await RawTextAsync("\" encoding=\"").ConfigureAwait(false);
48await RawTextAsync(_encoding.WebName).ConfigureAwait(false);
54await RawTextAsync("\" standalone=\"").ConfigureAwait(false);
55await RawTextAsync(standalone == XmlStandalone.Yes ? "yes" : "no").ConfigureAwait(false);
58await RawTextAsync("\"?>").ConfigureAwait(false);
78await FlushBufferAsync().ConfigureAwait(false);
89await _stream.FlushAsync().ConfigureAwait(false);
115await RawTextAsync("<!DOCTYPE ").ConfigureAwait(false);
116await RawTextAsync(name).ConfigureAwait(false);
119await RawTextAsync(" PUBLIC \"").ConfigureAwait(false);
120await RawTextAsync(pubid).ConfigureAwait(false);
121await RawTextAsync("\" \"").ConfigureAwait(false);
124await RawTextAsync(sysid).ConfigureAwait(false);
130await RawTextAsync(" SYSTEM \"").ConfigureAwait(false);
131await RawTextAsync(sysid).ConfigureAwait(false);
142await RawTextAsync(subset).ConfigureAwait(false);
275await WriteStartNamespaceDeclarationAsync(prefix).ConfigureAwait(false);
276await WriteStringAsync(namespaceName).ConfigureAwait(false);
277await WriteEndNamespaceDeclarationAsync().ConfigureAwait(false);
292await RawTextAsync("xmlns=\"").ConfigureAwait(false);
296await RawTextAsync("xmlns:").ConfigureAwait(false);
297await RawTextAsync(prefix).ConfigureAwait(false);
344await WriteCDataSectionAsync(text).ConfigureAwait(false);
365await WriteCommentOrPiAsync(text, '-').ConfigureAwait(false);
381await RawTextAsync(name).ConfigureAwait(false);
386await WriteCommentOrPiAsync(text, '?').ConfigureAwait(false);
400await RawTextAsync(name).ConfigureAwait(false);
405await FlushBufferAsync().ConfigureAwait(false);
426await RawTextAsync(strVal).ConfigureAwait(false);
431await FlushBufferAsync().ConfigureAwait(false);
481await RawTextAsync(surrogateChar.ToString("X", NumberFormatInfo.InvariantInfo)).ConfigureAwait(false);
516await WriteRawWithCharCheckingAsync(buffer, index, count).ConfigureAwait(false);
528await WriteRawWithCharCheckingAsync(data).ConfigureAwait(false);
537await FlushBufferAsync().ConfigureAwait(false);
541await _stream.FlushAsync().ConfigureAwait(false);
757await FlushBufferAsync().ConfigureAwait(false);
782await FlushBufferAsync().ConfigureAwait(false);
790await FlushBufferAsync().ConfigureAwait(false);
969await RawTextAsync(_newLineChars).ConfigureAwait(false);
975await FlushBufferAsync().ConfigureAwait(false);
1009await RawTextAsync(_newLineChars).ConfigureAwait(false);
1015await FlushBufferAsync().ConfigureAwait(false);
1026await RawTextAsync(_newLineChars).ConfigureAwait(false);
1032await FlushBufferAsync().ConfigureAwait(false);
1190await FlushBufferAsync().ConfigureAwait(false);
1199await FlushBufferAsync().ConfigureAwait(false);
1206await RawTextAsync(text2, text3, text4).ConfigureAwait(false);
1365await RawTextAsync(_newLineChars).ConfigureAwait(false);
1371await FlushBufferAsync().ConfigureAwait(false);
1389await RawTextAsync(_newLineChars).ConfigureAwait(false);
1395await FlushBufferAsync().ConfigureAwait(false);
1559await FlushBufferAsync().ConfigureAwait(false);
1575await RawTextAsync(_newLineChars).ConfigureAwait(false);
1581await FlushBufferAsync().ConfigureAwait(false);
1742await FlushBufferAsync().ConfigureAwait(false);
1758await RawTextAsync(_newLineChars).ConfigureAwait(false);
1764await FlushBufferAsync().ConfigureAwait(false);
1779await WriteIndentAsync().ConfigureAwait(false);
1781await base.WriteDocTypeAsync(name, pubid, sysid, subset).ConfigureAwait(false);
1792await WriteIndentAsync().ConfigureAwait(false);
1797await base.WriteStartElementAsync(prefix, localName, ns).ConfigureAwait(false);
1810await WriteIndentAsync().ConfigureAwait(false);
1815await base.WriteEndElementAsync(prefix, localName, ns).ConfigureAwait(false);
1828await WriteIndentAsync().ConfigureAwait(false);
1833await base.WriteFullEndElementAsync(prefix, localName, ns).ConfigureAwait(false);
1843await WriteIndentAsync().ConfigureAwait(false);
1846await base.WriteStartAttributeAsync(prefix, localName, ns).ConfigureAwait(false);
1856await WriteIndentAsync().ConfigureAwait(false);
1859await base.WriteStartNamespaceDeclarationAsync(prefix).ConfigureAwait(false);
1874await WriteIndentAsync().ConfigureAwait(false);
1877await base.WriteCommentAsync(text).ConfigureAwait(false);
1885await WriteIndentAsync().ConfigureAwait(false);
1888await base.WriteProcessingInstructionAsync(target, text).ConfigureAwait(false);
1958await RawTextAsync(base._newLineChars).ConfigureAwait(false);
1961await RawTextAsync(_indentChars).ConfigureAwait(false);
System\Xml\Core\XmlWellFormedWriterAsync.cs (79)
38await WriteEndElementAsync().ConfigureAwait(false);
41await AdvanceStateAsync(Token.EndDocument).ConfigureAwait(false);
49await _writer.WriteEndDocumentAsync().ConfigureAwait(false);
72await AdvanceStateAsync(Token.Dtd).ConfigureAwait(false);
114await _writer.WriteDocTypeAsync(name, pubid, sysid, subset).ConfigureAwait(false);
141await task.ConfigureAwait(false);
167await task.ConfigureAwait(false);
168await nextTaskFun(arg).ConfigureAwait(false);
263await task.ConfigureAwait(false);
264await WriteStartElementAsync_NoAdvanceState(prefix, localName, ns).ConfigureAwait(false);
306await t.ConfigureAwait(false);
598await task.ConfigureAwait(false);
599await WriteStartAttributeAsync_NoAdvanceState(prefix, localName, namespaceName).ConfigureAwait(false);
660await _rawWriter.WriteStartNamespaceDeclarationAsync(string.Empty).ConfigureAwait(false);
661await _attrValueCache.ReplayAsync(_rawWriter).ConfigureAwait(false);
662await _rawWriter.WriteEndNamespaceDeclarationAsync().ConfigureAwait(false);
666await _rawWriter.WriteNamespaceDeclarationAsync(string.Empty, value).ConfigureAwait(false);
671await _writer.WriteStartAttributeAsync(string.Empty, "xmlns", XmlReservedNs.NsXmlNs).ConfigureAwait(false);
672await _attrValueCache.ReplayAsync(_writer).ConfigureAwait(false);
673await _writer.WriteEndAttributeAsync().ConfigureAwait(false);
697await _rawWriter.WriteStartNamespaceDeclarationAsync(_curDeclPrefix).ConfigureAwait(false);
698await _attrValueCache.ReplayAsync(_rawWriter).ConfigureAwait(false);
699await _rawWriter.WriteEndNamespaceDeclarationAsync().ConfigureAwait(false);
703await _rawWriter.WriteNamespaceDeclarationAsync(_curDeclPrefix, value).ConfigureAwait(false);
708await _writer.WriteStartAttributeAsync("xmlns", _curDeclPrefix, XmlReservedNs.NsXmlNs).ConfigureAwait(false);
709await _attrValueCache.ReplayAsync(_writer).ConfigureAwait(false);
710await _writer.WriteEndAttributeAsync().ConfigureAwait(false);
731await _writer.WriteStartAttributeAsync("xml", "space", XmlReservedNs.NsXml).ConfigureAwait(false);
732await _attrValueCache.ReplayAsync(_writer).ConfigureAwait(false);
733await _writer.WriteEndAttributeAsync().ConfigureAwait(false);
738await _writer.WriteStartAttributeAsync("xml", "lang", XmlReservedNs.NsXml).ConfigureAwait(false);
739await _attrValueCache.ReplayAsync(_writer).ConfigureAwait(false);
740await _writer.WriteEndAttributeAsync().ConfigureAwait(false);
759await AdvanceStateAsync(Token.CData).ConfigureAwait(false);
760await _writer.WriteCDataAsync(text).ConfigureAwait(false);
775await AdvanceStateAsync(Token.Comment).ConfigureAwait(false);
776await _writer.WriteCommentAsync(text).ConfigureAwait(false);
805await AdvanceStateAsync(Token.PI).ConfigureAwait(false);
810await _rawWriter.WriteXmlDeclarationAsync(text).ConfigureAwait(false);
814await _writer.WriteProcessingInstructionAsync(name, text).ConfigureAwait(false);
819await AdvanceStateAsync(Token.PI).ConfigureAwait(false);
820await _writer.WriteProcessingInstructionAsync(name, text).ConfigureAwait(false);
838await AdvanceStateAsync(Token.Text).ConfigureAwait(false);
845await _writer.WriteEntityRefAsync(name).ConfigureAwait(false);
864await AdvanceStateAsync(Token.Text).ConfigureAwait(false);
871await _writer.WriteCharEntityAsync(ch).ConfigureAwait(false);
890await AdvanceStateAsync(Token.Text).ConfigureAwait(false);
897await _writer.WriteSurrogateCharEntityAsync(lowChar, highChar).ConfigureAwait(false);
918await AdvanceStateAsync(Token.Whitespace).ConfigureAwait(false);
925await _writer.WriteWhitespaceAsync(ws).ConfigureAwait(false);
987await task.ConfigureAwait(false);
988await WriteStringAsync_NoAdvanceState(text).ConfigureAwait(false);
1006await AdvanceStateAsync(Token.Text).ConfigureAwait(false);
1013await _writer.WriteCharsAsync(buffer, index, count).ConfigureAwait(false);
1032await AdvanceStateAsync(Token.RawData).ConfigureAwait(false);
1039await _writer.WriteRawAsync(buffer, index, count).ConfigureAwait(false);
1058await AdvanceStateAsync(Token.RawData).ConfigureAwait(false);
1065await _writer.WriteRawAsync(data).ConfigureAwait(false);
1106await task.ConfigureAwait(false);
1107await _writer.WriteBase64Async(buffer, index, count).ConfigureAwait(false);
1120await _writer.FlushAsync().ConfigureAwait(false);
1136await AdvanceStateAsync(Token.Text).ConfigureAwait(false);
1157await WriteStringAsync(prefix).ConfigureAwait(false);
1158await WriteStringAsync(":").ConfigureAwait(false);
1160await WriteStringAsync(localName).ConfigureAwait(false);
1164await _rawWriter.WriteQualifiedNameAsync(prefix, localName, ns).ConfigureAwait(false);
1182await AdvanceStateAsync(Token.Text).ConfigureAwait(false);
1183await base.WriteBinHexAsync(buffer, index, count).ConfigureAwait(false);
1196await AdvanceStateAsync(Token.StartDocument).ConfigureAwait(false);
1212await _rawWriter.WriteXmlDeclarationAsync(standalone).ConfigureAwait(false);
1218await _writer.WriteStartDocumentAsync().ConfigureAwait(false);
1244await task.ConfigureAwait(false);
1263await task.ConfigureAwait(false);
1265await AdvanceStateAsync(token).ConfigureAwait(false);
1385await _nsStack[i].WriteDeclAsync(_writer, _rawWriter).ConfigureAwait(false);
1414await WriteEndElementAsync().ConfigureAwait(false);
1424await AdvanceStateAsync(Token.EndElement).ConfigureAwait(false);
1436await _rawWriter.WriteEndBase64Async().ConfigureAwait(false);
1439await _writer.FlushAsync().ConfigureAwait(false);
System\Xml\Core\XmlWellFormedWriterHelpersAsync.cs (15)
34await rawWriter.WriteNamespaceDeclarationAsync(prefix, namespaceUri).ConfigureAwait(false);
40await writer.WriteStartAttributeAsync(string.Empty, "xmlns", XmlReservedNs.NsXmlNs).ConfigureAwait(false);
44await writer.WriteStartAttributeAsync("xmlns", prefix, XmlReservedNs.NsXmlNs).ConfigureAwait(false);
46await writer.WriteStringAsync(namespaceUri).ConfigureAwait(false);
47await writer.WriteEndAttributeAsync().ConfigureAwait(false);
58await writer.WriteStringAsync(_singleStringValue).ConfigureAwait(false);
69await writer.WriteEntityRefAsync((string)item.data).ConfigureAwait(false);
72await writer.WriteCharEntityAsync((char)item.data).ConfigureAwait(false);
76await writer.WriteSurrogateCharEntityAsync(chars[0], chars[1]).ConfigureAwait(false);
79await writer.WriteWhitespaceAsync((string)item.data).ConfigureAwait(false);
82await writer.WriteStringAsync((string)item.data).ConfigureAwait(false);
86await writer.WriteCharsAsync(bufChunk.buffer, bufChunk.index, bufChunk.count).ConfigureAwait(false);
89await writer.WriteRawAsync((string)item.data).ConfigureAwait(false);
93await writer.WriteCharsAsync(bufChunk.buffer, bufChunk.index, bufChunk.count).ConfigureAwait(false);
96await writer.WriteStringAsync((string)item.data).ConfigureAwait(false);
System\Xml\Core\XmlWriterAsync.cs (53)
79await task.ConfigureAwait(false);
80await WriteStringAsync(value).ConfigureAwait(false);
81await WriteEndAttributeAsync().ConfigureAwait(false);
222await WriteStringAsync(prefix).ConfigureAwait(false);
223await WriteStringAsync(":").ConfigureAwait(false);
225await WriteStringAsync(localName).ConfigureAwait(false);
242await WriteAttributesAsync(reader, defattr).ConfigureAwait(false);
258await WriteStartAttributeAsync(reader.Prefix, reader.LocalName, reader.NamespaceURI).ConfigureAwait(false);
263await WriteEntityRefAsync(reader.Name).ConfigureAwait(false);
267await WriteStringAsync(reader.Value).ConfigureAwait(false);
270await WriteEndAttributeAsync().ConfigureAwait(false);
305await WriteStartElementAsync(reader.Prefix, reader.LocalName, reader.NamespaceURI).ConfigureAwait(false);
306await WriteAttributesAsync(reader, defattr).ConfigureAwait(false);
309await WriteEndElementAsync().ConfigureAwait(false);
319await WriteCharsAsync(_writeNodeBuffer, 0, read).ConfigureAwait(false);
324await WriteStringAsync(reader.Value).ConfigureAwait(false);
329await WriteWhitespaceAsync(reader.Value).ConfigureAwait(false);
332await WriteCDataAsync(reader.Value).ConfigureAwait(false);
335await WriteEntityRefAsync(reader.Name).ConfigureAwait(false);
339await WriteProcessingInstructionAsync(reader.Name, reader.Value).ConfigureAwait(false);
342await WriteDocTypeAsync(reader.Name, reader.GetAttribute("PUBLIC"), reader.GetAttribute("SYSTEM"), reader.Value).ConfigureAwait(false);
346await WriteCommentAsync(reader.Value).ConfigureAwait(false);
349await WriteFullEndElementAsync().ConfigureAwait(false);
367await WriteStartElementAsync(reader.Prefix, reader.LocalName, reader.NamespaceURI).ConfigureAwait(false);
368await WriteAttributesAsync(reader, defattr).ConfigureAwait(false);
371await WriteEndElementAsync().ConfigureAwait(false);
381await WriteCharsAsync(_writeNodeBuffer, 0, read).ConfigureAwait(false);
387await WriteStringAsync(await reader.GetValueAsync().ConfigureAwait(false)).ConfigureAwait(false);
392await WriteWhitespaceAsync(await reader.GetValueAsync().ConfigureAwait(false)).ConfigureAwait(false);
395await WriteCDataAsync(reader.Value).ConfigureAwait(false);
398await WriteEntityRefAsync(reader.Name).ConfigureAwait(false);
402await WriteProcessingInstructionAsync(reader.Name, reader.Value).ConfigureAwait(false);
405await WriteDocTypeAsync(reader.Name, reader.GetAttribute("PUBLIC"), reader.GetAttribute("SYSTEM"), reader.Value).ConfigureAwait(false);
409await WriteCommentAsync(reader.Value).ConfigureAwait(false);
412await WriteFullEndElementAsync().ConfigureAwait(false);
438await WriteStartElementAsync(navigator.Prefix, navigator.LocalName, navigator.NamespaceURI).ConfigureAwait(false);
448await WriteStartAttributeAsync(navigator.Prefix, navigator.LocalName, navigator.NamespaceURI).ConfigureAwait(false);
450await WriteStringAsync(navigator.Value).ConfigureAwait(false);
451await WriteEndAttributeAsync().ConfigureAwait(false);
460await WriteLocalNamespacesAsync(navigator).ConfigureAwait(false);
469await WriteStringAsync(navigator.Value).ConfigureAwait(false);
473await WriteWhitespaceAsync(navigator.Value).ConfigureAwait(false);
479await WriteCommentAsync(navigator.Value).ConfigureAwait(false);
482await WriteProcessingInstructionAsync(navigator.LocalName, navigator.Value).ConfigureAwait(false);
506await WriteEndElementAsync().ConfigureAwait(false);
510await WriteFullEndElementAsync().ConfigureAwait(false);
536await WriteFullEndElementAsync().ConfigureAwait(false);
547await WriteStartElementAsync(prefix, localName, ns).ConfigureAwait(false);
550await WriteStringAsync(value).ConfigureAwait(false);
552await WriteEndElementAsync().ConfigureAwait(false);
564await WriteLocalNamespacesAsync(nsNav).ConfigureAwait(false);
569await WriteAttributeStringAsync(string.Empty, "xmlns", XmlReservedNs.NsXmlNs, ns).ConfigureAwait(false);
573await WriteAttributeStringAsync("xmlns", prefix, XmlReservedNs.NsXmlNs, ns).ConfigureAwait(false);
System.Private.Xml.Linq (29)
System.Security.Cryptography (6)
System.Security.Cryptography.Cose (6)
System\Security\Cryptography\Cose\CoseMultiSignMessage.cs (3)
408await WriteSignatureAsync(writer, signer, buffer, buffer.AsMemory(0, protectedMapBytesWritten), associatedData, content, cancellationToken).ConfigureAwait(false);
487await AppendToBeSignedAsync(buffer, toBeSignedBuilder, SigStructureContext.Signature, bodyProtected, buffer.AsMemory(start, signProtectedBytesWritten), associatedData, contentStream, cancellationToken).ConfigureAwait(false);
861await AppendToBeSignedAsync(buffer, toBeSignedBuilder, SigStructureContext.Signature, _protectedHeaderAsBstr, encodedSignProtected, associatedData, content, cancellationToken).ConfigureAwait(false);
System\Security\Cryptography\Cose\CoseSign1Message.cs (2)
346await AppendToBeSignedAsync(buffer, toBeSignedBuilder, SigStructureContext.Signature1, buffer.AsMemory(0, protectedMapBytesWritten), ReadOnlyMemory<byte>.Empty, associatedData, content, cancellationToken).ConfigureAwait(false);
940await AppendToBeSignedAsync(buffer, toBeSignedBuilder, SigStructureContext.Signature1, _protectedHeaderAsBstr, ReadOnlyMemory<byte>.Empty, associatedData, content, cancellationToken).ConfigureAwait(false);
System.ServiceModel.Primitives (11)
System\ServiceModel\Channels\BufferedWriteStream.cs (10)
188await _sem.WaitAsync().ConfigureAwait(false);
193await FlushWriteAsync(cancellationToken).ConfigureAwait(false);
199await _stream.FlushAsync(cancellationToken).ConfigureAwait(false);
225await _stream.WriteAsync(_buffer, 0, _writePos, cancellationToken).ConfigureAwait(false);
227await _stream.FlushAsync(cancellationToken).ConfigureAwait(false);
468await semaphoreLockTask.ConfigureAwait(false);
496await _stream.WriteAsync(_buffer, 0, _writePos, cancellationToken).ConfigureAwait(false);
519await _stream.WriteAsync(_buffer, 0, totalUserBytes, cancellationToken).ConfigureAwait(false);
524await _stream.WriteAsync(_buffer, 0, _writePos, cancellationToken).ConfigureAwait(false);
529await _stream.WriteAsync(array, offset, count, cancellationToken).ConfigureAwait(false);
System.Text.Json (4)
System.Threading.RateLimiting (1)
System.Threading.Tasks.Dataflow (4)
System.Windows.Forms (4)
TestingAppHost1.AppHost (1)
vbc (12)
src\roslyn\src\Compilers\Shared\BuildProtocol.cs (7)
128await ReadAllAsync(inStream, lengthBuffer, 4, cancellationToken).ConfigureAwait(false);
187cancellationToken).ConfigureAwait(false);
190await memoryStream.CopyToAsync(outStream, bufferSize: length, cancellationToken: cancellationToken).ConfigureAwait(false);
305cancellationToken).ConfigureAwait(false);
308await memoryStream.CopyToAsync(outStream, bufferSize: length, cancellationToken: cancellationToken).ConfigureAwait(false);
324await ReadAllAsync(stream, lengthBuffer, 4, cancellationToken).ConfigureAwait(false);
332cancellationToken).ConfigureAwait(false);
VBCSCompiler (15)
src\roslyn\src\Compilers\Shared\BuildProtocol.cs (7)
128await ReadAllAsync(inStream, lengthBuffer, 4, cancellationToken).ConfigureAwait(false);
187cancellationToken).ConfigureAwait(false);
190await memoryStream.CopyToAsync(outStream, bufferSize: length, cancellationToken: cancellationToken).ConfigureAwait(false);
305cancellationToken).ConfigureAwait(false);
308await memoryStream.CopyToAsync(outStream, bufferSize: length, cancellationToken: cancellationToken).ConfigureAwait(false);
324await ReadAllAsync(stream, lengthBuffer, 4, cancellationToken).ConfigureAwait(false);
332cancellationToken).ConfigureAwait(false);