Enqueue

138 references to Enqueue

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 (3)

Dcp\TestKubernetesService.cs (1)

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-svcutil-lib (1)

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

473s_freeStringBuilders.Enqueue(sb);

Infrastructure.Common (1)

xunit\WcfTestCase.cs (1)

52 s_testListener.EventWritten = events.Enqueue;

InMemory.FunctionalTests (5)

EventSourceTests.cs (1)

468_events.Enqueue(new EventSnapshot(eventData));

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)

1241_testBase._streamContextPool.Enqueue(this);

src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (2)

54Scopes.Enqueue(state); 105Messages.Enqueue(logMessage);

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

87_blocks.Enqueue(block);

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)

178_unacknowledgedRenderBatches.Enqueue(pendingRender);

Microsoft.AspNetCore.Components.Tests (1)

RendererTest.cs (1)

5794Log?.Enqueue(entry);

Microsoft.AspNetCore.ConcurrencyLimiter (3)

QueuePolicies\BasePolicy.cs (3)

51_leases.Enqueue(lease); 61_leases.Enqueue(lease); 92_leases.Enqueue(lease);

Microsoft.AspNetCore.Http (1)

src\Shared\CancellationTokenSourcePool.cs (1)

33_queue.Enqueue(cts);

Microsoft.AspNetCore.Http.Extensions (1)

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\Shared\Buffers.MemoryPool\PinnedBlockMemoryPool.cs (1)

87_blocks.Enqueue(block);

Microsoft.AspNetCore.Server.IIS (1)

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

87_blocks.Enqueue(block);

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

Internal\Http2\Http2Connection.cs (3)

1409_completedStreams.Enqueue(stream); 1424_completedStreams.Enqueue(stream); 1451_completedStreams.Enqueue(stream);

src\Shared\CancellationTokenSourcePool.cs (1)

33_queue.Enqueue(cts);

Microsoft.AspNetCore.Server.Kestrel.Core.Tests (3)

src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (2)

54Scopes.Enqueue(state); 105Messages.Enqueue(logMessage);

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

87_blocks.Enqueue(block);

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

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)

1241_testBase._streamContextPool.Enqueue(this);

src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (2)

54Scopes.Enqueue(state); 105Messages.Enqueue(logMessage);

src\Servers\Kestrel\Transport.Sockets\src\Internal\IOQueue.cs (1)

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

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

87_blocks.Enqueue(block);

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

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

87_blocks.Enqueue(block);

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

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

87_blocks.Enqueue(block);

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (2)

src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (2)

54Scopes.Enqueue(state); 105Messages.Enqueue(logMessage);

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

Internal\IOQueue.cs (1)

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

Internal\SocketSenderPool.cs (1)

46_queue.Enqueue(sender);

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

87_blocks.Enqueue(block);

Microsoft.AspNetCore.SignalR.StackExchangeRedis.Tests (2)

Docker.cs (2)

215lines.Enqueue(a.Data); 220lines.Enqueue(a.Data);

Microsoft.AspNetCore.SignalR.Tests.Utils (1)

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

45_logs.Enqueue(record);

Microsoft.AspNetCore.Tests (2)

WebApplicationTests.cs (1)

3061_events.Enqueue(eventData);

WebHostTests.cs (1)

147_events.Enqueue(eventData);

Microsoft.AspNetCore.WebSockets.Tests (1)

BufferStream.cs (1)

233_bufferedData.Enqueue(internalBuffer);

Microsoft.Build (15)

AwaitExtensions.cs (1)

173_queuedTasks.Enqueue(task);

BackEnd\Client\MSBuildClientPacketPump.cs (1)

159ReceivedPacketsQueue.Enqueue(packet);

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

339_packetQueue.Enqueue(packet);

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

254exceptions.Enqueue(ex); 383nodeContexts.Enqueue(nodeContext); 719_packetWriteQueue.Enqueue(packet);

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

1273_eventQueue.Enqueue(buildEvent);

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

500_pendingResourceRequests.Enqueue((response) =>

BackEnd\Node\InProcNode.cs (1)

242_receivedPackets.Enqueue(packet);

BackEnd\Node\OutOfProcNode.cs (1)

377_receivedPackets.Enqueue(packet);

BackEnd\Node\OutOfProcServerNode.cs (1)

244_receivedPackets.Enqueue(packet);

Graph\ParallelWorkSet.cs (1)

125_queue.Enqueue(workItem);

Instance\TaskFactories\TaskHostTask.cs (1)

405_receivedPackets.Enqueue(packet);

Logging\ProfilerLogger.cs (1)

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

NodeEndpointOutOfProcBase.cs (1)

321_packetQueue.Enqueue(packet);

Microsoft.Build.Engine.UnitTests (3)

ProjectCache\ProjectCacheTests.cs (3)

296Requests.Enqueue(buildRequest); 297QueryStartStops.Enqueue(queryId); 308QueryStartStops.Enqueue(queryId);

Microsoft.Build.Tasks.Core (6)

Copy.cs (1)

611_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.Build.UnitTests.Shared (2)

MockEngine.cs (2)

80_errorEvents.Enqueue(eventArgs); 110_warningEvents.Enqueue(eventArgs);

Microsoft.CodeAnalysis (8)

Diagnostic\DiagnosticBag.cs (3)

117bag.Enqueue(diag); 130bag.Enqueue(diagnostics[i]); 142this.Bag.Enqueue(diagnostic);

Emit\CommonPEModuleBuilder.cs (5)

826NestedTypes.Enqueue(nestedType); 918defs.Methods.Enqueue(method); 931defs.Properties.Enqueue(property); 944defs.Fields.Enqueue(field); 963_lazySynthesizedNamespaceMembers.GetOrAdd(container, _ => new ConcurrentQueue<INamespaceOrTypeSymbolInternal>()).Enqueue(typeOrNamespace);

Microsoft.CodeAnalysis.CSharp.Scripting.UnitTests (3)

ObjectFormatterTests.cs (3)

700obj.Enqueue(1); 701obj.Enqueue(2); 702obj.Enqueue(3);

Microsoft.CodeAnalysis.CSharp.Symbol.UnitTests (6)

Compilation\CompilationAPITests.cs (6)

546queue.Enqueue(ref1); 547queue.Enqueue(ref2); 548queue.Enqueue(ref3); 873queue.Enqueue(t4); 874queue.Enqueue(t5); 875queue.Enqueue(t6);

Microsoft.CodeAnalysis.Test.Utilities (1)

Diagnostics\TrackingDiagnosticAnalyzer.cs (1)

54_callLog.Enqueue(new Entry(abstractMemberName, callerName, node, symbol));

Microsoft.DotNet.Arcade.Sdk.Tests (1)

Utilities\TestProjectFixture.cs (1)

45_disposables.Enqueue(app);

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.Extensions.Telemetry (1)

Buffering\GlobalBuffer.cs (1)

109_activeBuffer.Enqueue(serializedLogRecord);

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);

MSBuild (1)

NodeEndpointOutOfProcBase.cs (1)

321_packetQueue.Enqueue(packet);

Sockets.BindTests (2)

src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (2)

54Scopes.Enqueue(state); 105Messages.Enqueue(logMessage);

Sockets.FunctionalTests (2)

src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (2)

54Scopes.Enqueue(state); 105Messages.Enqueue(logMessage);

System.Data.Odbc (1)

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

702_pendingOpens.Enqueue(pendingGetConnection);

System.Net.Sockets (1)

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

390_eventQueue.Enqueue(new SocketIOEvent(context, events));

System.Private.CoreLib (8)

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

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

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

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

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

576workItems.Enqueue(workItem); 657queue.Enqueue(callback); 696queue.Enqueue(callback); 707highPriorityWorkItems.Enqueue(workItem); 735queue.highPriorityWorkItems.Enqueue(workItem);

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\libraries\Common\src\System\Collections\Concurrent\MultiProducerMultiConsumerQueue.cs (1)

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

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

265parent._items.Enqueue(item);

System.Threading.Tasks.Dataflow (1)

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)

283exceptionQ.Enqueue(e); 314foreach (Exception exc in ae.InnerExceptions) exceptionQ.Enqueue(exc); 318exceptionQ.Enqueue(e);

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

38_replicator._pendingReplicas.Enqueue(this); 90LazyInitializer.EnsureInitialized(ref _replicator._exceptions).Enqueue(ex);