Enqueue

137 references to Enqueue

aspire (7)

Projects\ProjectUpdater.cs (7)

160context.AnalyzeSteps.Enqueue(appHostAnalyzeStep); 232context.AnalyzeSteps.Enqueue(appHostSdkAnalyzeStep); 235context.AnalyzeSteps.Enqueue(appHostProjectAnalyzeStep); 286context.UpdateSteps.Enqueue(sdkUpdateStep); 639context.AnalyzeSteps.Enqueue(new AnalyzeStep(string.Format(CultureInfo.InvariantCulture, UpdateCommandStrings.AnalyzeProjectFormat, referencedProjectFile.FullName), () => AnalyzeProjectAsync(referencedProjectFile, context, cancellationToken))); 728context.UpdateSteps.Enqueue(updateStep); 758context.UpdateSteps.Enqueue(updateStep);

Aspire.Cli.Tests (2)

tests\Shared\Logging\TestSink.cs (2)

40_writes.Enqueue(context); 49_scopes.Enqueue(context);

Aspire.Confluent.Kafka (3)

MetricsService.cs (3)

46metrics.ReplyQueueMeasurements.Enqueue(new Measurement<long>(statistics.ReplyQueue, tags)); 47metrics.MessageCountMeasurements.Enqueue(new Measurement<long>(statistics.MessageCount, tags)); 48metrics.MessageSizeMeasurements.Enqueue(new Measurement<long>(statistics.MessageSize, tags));

Aspire.Dashboard.Components.Tests (2)

tests\Shared\Logging\TestSink.cs (2)

40_writes.Enqueue(context); 49_scopes.Enqueue(context);

Aspire.Dashboard.Tests (2)

tests\Shared\Logging\TestSink.cs (2)

40_writes.Enqueue(context); 49_scopes.Enqueue(context);

Aspire.Hosting.Analyzers (1)

AppHostAnalyzer.cs (1)

51concurrentQueue.Enqueue(modelNameOperations);

Aspire.Hosting.Testing.Tests (2)

tests\Shared\Logging\TestSink.cs (2)

40_writes.Enqueue(context); 49_scopes.Enqueue(context);

Aspire.Hosting.Tests (4)

Dcp\TestKubernetesService.cs (2)

83CreatedResources.Enqueue(res); 111DeletedResources.Enqueue(name);

tests\Shared\Logging\TestSink.cs (2)

40_writes.Enqueue(context); 49_scopes.Enqueue(context);

Aspire.Playground.Tests (2)

tests\Shared\Logging\TestSink.cs (2)

40_writes.Enqueue(context); 49_scopes.Enqueue(context);

dotnet (1)

Commands\Test\MTP\MSBuildUtility.cs (1)

483gracefulExceptions.Enqueue(ex);

dotnet-svcutil-lib (1)

FrameworkFork\System.ServiceModel\Internals\System\Runtime\Diagnostics\EtwDiagnosticTrace.cs (1)

473s_freeStringBuilders.Enqueue(sb);

ILCompiler.ReadyToRun (3)

Compiler\DependencyAnalysis\ReadyToRun\TypeValidationChecker.cs (3)

59_tasksThatMustFinish.Enqueue(ValidateType(this, ecmaType)); 61_tasksThatMustFinish.Enqueue(ValidateType(this, module.GetGlobalModuleType())); 618_tasksThatMustFinish.Enqueue(ValidateType(this, ecmaType));

Infrastructure.Common (1)

xunit\WcfTestCase.cs (1)

52 s_testListener.EventWritten = events.Enqueue;

Microsoft.AspNetCore.App.Analyzers (2)

Mvc\MvcAnalyzer.cs (1)

85concurrentQueue.Enqueue(pooledItems);

RouteHandlers\RouteHandlerAnalyzer.cs (1)

64concurrentQueue.Enqueue(mapOperations);

Microsoft.AspNetCore.Components.Endpoints (1)

FormMapping\Converters\CollectionAdapters\ConcurrentQueueBufferAdapter.cs (1)

14buffer.Enqueue(element);

Microsoft.AspNetCore.Components.Server (1)

Circuits\RemoteRenderer.cs (1)

179_unacknowledgedRenderBatches.Enqueue(pendingRender);

Microsoft.AspNetCore.Diagnostics.Middleware (1)

Buffering\IncomingRequestLogBuffer.cs (1)

89_activeBuffer.Enqueue(serializedLogRecord);

Microsoft.AspNetCore.Http (1)

src\aspnetcore\src\Shared\CancellationTokenSourcePool.cs (1)

33_queue.Enqueue(cts);

Microsoft.AspNetCore.Http.Extensions (1)

src\aspnetcore\src\Components\Endpoints\src\FormMapping\Converters\CollectionAdapters\ConcurrentQueueBufferAdapter.cs (1)

14buffer.Enqueue(element);

Microsoft.AspNetCore.InternalTesting (3)

Logging\TestSink.cs (2)

41_writes.Enqueue(context); 50_scopes.Enqueue(context);

Tracing\CollectingEventListener.cs (1)

59_events.Enqueue(eventData);

Microsoft.AspNetCore.OutputCaching (1)

RecyclableReadOnlySequenceSegment.cs (1)

53s_Spares.Enqueue(obj);

Microsoft.AspNetCore.Server.HttpSys (1)

src\aspnetcore\src\Shared\Buffers.MemoryPool\PinnedBlockMemoryPool.cs (1)

145_blocks.Enqueue(block);

Microsoft.AspNetCore.Server.IIS (1)

src\aspnetcore\src\Shared\Buffers.MemoryPool\PinnedBlockMemoryPool.cs (1)

145_blocks.Enqueue(block);

Microsoft.AspNetCore.Server.Kestrel.Core (5)

Internal\Http2\Http2Connection.cs (3)

1443_completedStreams.Enqueue(stream); 1458_completedStreams.Enqueue(stream); 1485_completedStreams.Enqueue(stream);

src\aspnetcore\src\Shared\Buffers.MemoryPool\PinnedBlockMemoryPool.cs (1)

145_blocks.Enqueue(block);

src\aspnetcore\src\Shared\CancellationTokenSourcePool.cs (1)

33_queue.Enqueue(cts);

Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)

src\aspnetcore\src\Shared\Buffers.MemoryPool\PinnedBlockMemoryPool.cs (1)

145_blocks.Enqueue(block);

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)

src\aspnetcore\src\Shared\Buffers.MemoryPool\PinnedBlockMemoryPool.cs (1)

145_blocks.Enqueue(block);

Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (2)

Internal\IOQueue.cs (1)

20_workItems.Enqueue(new Work(action, state));

Internal\SocketSenderPool.cs (1)

46_queue.Enqueue(sender);

Microsoft.Build (15)

BackEnd\Client\MSBuildClientPacketPump.cs (1)

158ReceivedPacketsQueue.Enqueue(packet);

BackEnd\Components\Communications\NodeEndpointInProc.cs (1)

346_packetQueue.Enqueue(packet);

BackEnd\Components\Communications\NodeProviderOutOfProcBase.cs (3)

306exceptions.Enqueue(ex); 444nodeContexts.Enqueue(nodeContext); 1196_packetWriteQueue.Enqueue(packet);

BackEnd\Components\Logging\LoggingService.cs (1)

1378eventQueue.Enqueue(buildEvent);

BackEnd\Components\RequestBuilder\RequestBuilder.cs (1)

504_pendingResourceRequests.Enqueue((response) =>

BackEnd\Node\InProcNode.cs (1)

242_receivedPackets.Enqueue(packet);

BackEnd\Node\OutOfProcNode.cs (1)

380_receivedPackets.Enqueue(packet);

BackEnd\Node\OutOfProcServerNode.cs (1)

277_receivedPackets.Enqueue(packet);

Graph\ParallelWorkSet.cs (1)

125_queue.Enqueue(workItem);

Instance\TaskFactories\TaskHostTask.cs (1)

523_receivedPackets.Enqueue(packet);

Logging\ProfilerLogger.cs (1)

107_profiledResults.Enqueue(projectFinishedEvent.ProfilerResult.Value);

src\msbuild\src\Shared\NodeEndpointOutOfProcBase.cs (1)

356_packetQueue.Enqueue(packet);

Utilities\AwaitExtensions.cs (1)

173_queuedTasks.Enqueue(task);

Microsoft.Build.Tasks.Core (6)

Copy.cs (1)

642_copyActionQueue.Enqueue(ProcessPartition);

GetSDKReferenceFiles.cs (5)

943_exceptionMessages.Enqueue(ResourceUtilities.FormatResourceStringStripCodeAndKeyword("GetSDKReferenceFiles.ProblemReadingCacheFile", cacheFile, e.ToString())); 973_exceptionMessages.Enqueue(ResourceUtilities.FormatResourceStringStripCodeAndKeyword("GetSDKReferenceFiles.ProblemDeletingCacheFile", existingCacheFile, e.Message)); 986_exceptionMessages.Enqueue(ResourceUtilities.FormatResourceStringStripCodeAndKeyword("GetSDKReferenceFiles.ProblemWritingCacheFile", referencesCacheFile, e.Message)); 1108_exceptionMessages.Enqueue(ResourceUtilities.FormatResourceStringStripCodeAndKeyword("GetSDKReferenceFiles.ProblemGeneratingHash", currentAssembly, ex.Message)); 1142_exceptionMessages.Enqueue(ResourceUtilities.FormatResourceStringStripCodeAndKeyword("GetSDKReferenceFiles.ProblemGettingAssemblyMetadata", referencePath, e.Message));

Microsoft.CodeAnalysis (8)

Diagnostic\DiagnosticBag.cs (3)

118bag.Enqueue(diag); 131bag.Enqueue(diagnostics[i]); 143this.Bag.Enqueue(diagnostic);

Emit\CommonPEModuleBuilder.cs (5)

906NestedTypes.Enqueue(nestedType); 998defs.Methods.Enqueue(method); 1011defs.Properties.Enqueue(property); 1024defs.Fields.Enqueue(field); 1043_lazySynthesizedNamespaceMembers.GetOrAdd(container, _ => new ConcurrentQueue<INamespaceOrTypeSymbolInternal>()).Enqueue(typeOrNamespace);

Microsoft.CodeAnalysis.Features (3)

AddImport\AbstractAddImportFeatureService.cs (1)

479allSymbolReferences.Enqueue(reference);

AddImport\SymbolReferenceFinder_PackageAssemblySearch.cs (2)

171allReferences.Enqueue(new PackageReference( 204allReferences.Enqueue(new AssemblyReference(

Microsoft.CodeAnalysis.NetAnalyzers (2)

Microsoft.NetFramework.Analyzers\DoNotUseInsecureDtdProcessingInApiDesign.cs (2)

332locations.Enqueue(assignment.Syntax.GetLocation()); 358locations.Enqueue(assignment.Syntax.GetLocation());

Microsoft.Extensions.Diagnostics.Testing.Tests (5)

Logging\FakeLogCollectorTests.LogEnumeration.cs (5)

167eventTracker?.Enqueue("New sequence awaiter started at " + DateTime.Now + $", waiting for items: {string.Join(", ", sequence)} from index {fromIndex}."); 186eventTracker?.Enqueue($"Sequence awaiter checks log: \"{msg}\"."); 197eventTracker?.Enqueue($"Sequence awaiter satisfied at {DateTime.Now}"); 204eventTracker?.Enqueue($"Sequence awaiter cancelled at {DateTime.Now}"); 226eventTracker?.Enqueue($"Emitting log: \"{log}\" at {DateTime.Now}, current log count: {logger.Collector.Count}");

Microsoft.Extensions.Http (2)

DefaultHttpClientFactory.cs (2)

210_expiredHandlers.Enqueue(expired); 298_expiredHandlers.Enqueue(entry);

Microsoft.Extensions.ObjectPool (1)

DefaultObjectPool.cs (1)

88_items.Enqueue(obj);

Microsoft.ML.Core (3)

Data\ProgressReporter.cs (3)

395_pendingEvents.Enqueue(new ProgressEvent(newInfo.Index, newInfo.Name, newInfo.StartTime, ProgressEvent.EventKind.Start)); 413_pendingEvents.Enqueue(new ProgressEvent(info.Index, info.Name, info.StartTime, ProgressEvent.EventKind.Stop)); 419_pendingEvents.Enqueue(new ProgressEvent(info.Index, info.Name, info.StartTime, entry));

Microsoft.ML.Data (1)

DataLoadSave\Text\BlockingQueue.cs (1)

74_queue.Enqueue(item);

Microsoft.ML.FastTree (1)

Training\Applications\ObjectiveFunction.cs (1)

75queue.Enqueue(threadIndex);

Microsoft.TestPlatform.Extensions.BlameDataCollector (1)

BlameCollector.cs (1)

471_testSequence.Enqueue(blameTestObject.Id);

Microsoft.VisualStudio.TestPlatform.Extensions.Trx.TestLogger (4)

TrxLogger.cs (4)

296_runLevelErrorsAndWarnings.Enqueue(runMessage); 305_runLevelErrorsAndWarnings.Enqueue(runMessage); 456_runLevelErrorsAndWarnings.Enqueue(runMessage); 517_runLevelStdOut.Enqueue(message);

MSBuild (1)

src\msbuild\src\Shared\NodeEndpointOutOfProcBase.cs (1)

356_packetQueue.Enqueue(packet);

NuGet.Commands (5)

PackCollectorLogger.cs (2)

48_errors.Enqueue(message); 68_errors.Enqueue(message);

RestoreCommand\Logging\RestoreCollectorLogger.cs (3)

155_errors.Enqueue(message); 185_errors.Enqueue(message); 250_suppressedWarnings.Enqueue(message);

NuGet.DependencyResolver.Core (1)

Remote\RemoteDependencyWalker.cs (1)

637_toBeProcessedTransitiveCentralPackageVersions.Enqueue(centralPackageVersionDependency);

NuGet.Protocol (1)

Utility\DedicatedAsynchronousProcessingThread.cs (1)

54_taskQueue.Enqueue(task);

System.Data.Odbc (1)

Common\System\Data\ProviderBase\DbConnectionPool.cs (1)

702_pendingOpens.Enqueue(pendingGetConnection);

System.Data.OleDb (1)

System\Data\ProviderBase\DbConnectionPool.cs (1)

1070_pendingOpens.Enqueue(pendingGetConnection);

System.Net.Sockets (1)

System\Net\Sockets\SocketAsyncEngine.Unix.cs (1)

420_pool.Enqueue(this);

System.Private.CoreLib (7)

src\runtime\src\libraries\Common\src\System\Collections\Concurrent\MultiProducerMultiConsumerQueue.cs (1)

18void IProducerConsumerQueue<T>.Enqueue(T item) { Enqueue(item); }

src\runtime\src\libraries\System.Private.CoreLib\src\System\Collections\Concurrent\ConcurrentQueue.cs (2)

105Enqueue(item); 186Enqueue(item);

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\ThreadPoolWorkQueue.cs (4)

564workItems.Enqueue(workItem); 636queue.Enqueue(callback); 686highPriorityWorkItems.Enqueue(workItem); 717queue.highPriorityWorkItems.Enqueue(workItem);

System.ServiceModel.Primitives (1)

Internals\System\Runtime\Diagnostics\EtwDiagnosticTrace.cs (1)

370s_freeStringBuilders.Enqueue(sb);

System.Text.Json (1)

System\Text\Json\Serialization\Converters\Collection\ConcurrentQueueOfTConverter.cs (1)

17((TCollection)state.Current.ReturnValue!).Enqueue(value);

System.Threading.Channels (2)

src\runtime\src\libraries\Common\src\System\Collections\Concurrent\MultiProducerMultiConsumerQueue.cs (1)

18void IProducerConsumerQueue<T>.Enqueue(T item) { Enqueue(item); }

System\Threading\Channels\UnboundedChannel.cs (1)

269parent._items.Enqueue(item);

System.Threading.Tasks.Dataflow (1)

src\runtime\src\libraries\Common\src\System\Collections\Concurrent\MultiProducerMultiConsumerQueue.cs (1)

18void IProducerConsumerQueue<T>.Enqueue(T item) { Enqueue(item); }

System.Threading.Tasks.Parallel (5)

System\Threading\Tasks\Parallel.cs (3)

280exceptionQ.Enqueue(e); 311foreach (Exception exc in ae.InnerExceptions) exceptionQ.Enqueue(exc); 315exceptionQ.Enqueue(e);

System\Threading\Tasks\TaskReplicator.cs (2)

39_replicator._pendingReplicas.Enqueue(this); 91LazyInitializer.EnsureInitialized(ref _replicator._exceptions).Enqueue(ex);

System.Transactions.Local (4)

System\Transactions\DtcProxyShim\DtcProxyShimFactory.cs (4)

161_notifications.Enqueue(notification); 354=> _cachedOptions.Enqueue(options); 376_cachedTransmitters.Enqueue(transmitter); 400_cachedReceivers.Enqueue(receiver);