25 implementations of INodePacket
Microsoft.Build (23)
BackEnd\Components\BuildRequestEngine\BuildRequestConfigurationResponse.cs (1)
14internal class BuildRequestConfigurationResponse : INodePacket
BackEnd\Components\FileAccesses\FileAccessReport.cs (1)
9internal sealed class FileAccessReport : INodePacket
BackEnd\Components\FileAccesses\ProcessReport.cs (1)
9internal sealed class ProcessReport : INodePacket
BackEnd\Components\SdkResolution\SdkResolverRequest.cs (1)
15internal sealed class SdkResolverRequest : INodePacket
BackEnd\Components\SdkResolution\SdkResult.cs (1)
18internal sealed class SdkResult : SdkResultBase, INodePacket
BackEnd\Node\NodeConfiguration.cs (1)
19internal class NodeConfiguration : INodePacket
BackEnd\Node\ServerNodeBuildCancel.cs (1)
6internal sealed class ServerNodeBuildCancel : INodePacket
BackEnd\Node\ServerNodeBuildCommand.cs (1)
15internal sealed class ServerNodeBuildCommand : INodePacket
BackEnd\Node\ServerNodeBuildResult.cs (1)
6internal sealed class ServerNodeBuildResult : INodePacket
BackEnd\Node\ServerNodeConsoleWrite.cs (1)
6internal sealed class ServerNodeConsoleWrite : INodePacket
BackEnd\Shared\BuildRequest.cs (1)
20internal class BuildRequest : INodePacket
BackEnd\Shared\BuildRequestBlocker.cs (1)
39internal class BuildRequestBlocker : INodePacket
BackEnd\Shared\BuildRequestConfiguration.cs (1)
28INodePacket
BackEnd\Shared\BuildRequestUnblocker.cs (1)
21internal class BuildRequestUnblocker : ITranslatable, INodePacket
BackEnd\Shared\BuildResult.cs (1)
36public class BuildResult : BuildResultBase, INodePacket, IBuildResults
BackEnd\Shared\ResourceRequest.cs (1)
11internal sealed class ResourceRequest : INodePacket
BackEnd\Shared\ResourceResponse.cs (1)
11internal sealed class ResourceResponse : INodePacket
LogMessagePacketBase.cs (1)
261internal abstract class LogMessagePacketBase : INodePacket
NodeBuildComplete.cs (1)
14internal class NodeBuildComplete : INodePacket
NodeShutdown.cs (1)
36internal class NodeShutdown : INodePacket
TaskHostConfiguration.cs (1)
19internal class TaskHostConfiguration : INodePacket
TaskHostTaskCancelled.cs (1)
12internal class TaskHostTaskCancelled : INodePacket
TaskHostTaskComplete.cs (1)
53internal class TaskHostTaskComplete : INodePacket
Microsoft.Build.Engine.UnitTests (2)
BackEnd\LoggingService_Tests.cs (1)
1504internal sealed class NonLoggingPacket : INodePacket
BackEnd\NodeEndpointInProc_Tests.cs (1)
127private sealed class TestPacket : INodePacket
146 references to INodePacket
Microsoft.Build (111)
BackEnd\BuildManager\BuildManager.cs (4)
1186void INodePacketHandler.PacketReceived(int node, INodePacket packet) 1592private void ProcessPacket(int node, INodePacket packet) 3078private static I ExpectPacketType<I>(INodePacket packet, NodePacketType expectedType) where I : class, INodePacket
BackEnd\Client\MSBuildClient.cs (5)
354while (packetPump.ReceivedPacketsQueue.TryDequeue(out INodePacket? packet) && 420private bool TrySendPacket(Func<INodePacket> packetResolver) 422INodePacket? packet = null; 569private void HandlePacket(INodePacket packet) 648private void WritePacket(Stream nodeStream, INodePacket packet)
BackEnd\Client\MSBuildClientPacketPump.cs (4)
22public ConcurrentQueue<INodePacket> ReceivedPacketsQueue { get; } 84ReceivedPacketsQueue = new ConcurrentQueue<INodePacket>(); 131public void RoutePacket(int nodeId, INodePacket packet) 145public void PacketReceived(int node, INodePacket packet)
BackEnd\Components\BuildRequestEngine\BuildRequestConfigurationResponse.cs (1)
87internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Components\Communications\INodeManager.cs (1)
36void SendData(int node, INodePacket packet);
BackEnd\Components\Communications\INodeProvider.cs (1)
78void SendData(int node, INodePacket packet);
BackEnd\Components\Communications\LogMessagePacket.cs (1)
41internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Components\Communications\NodeEndpointInProc.cs (5)
93private ConcurrentQueue<INodePacket> _packetQueue; 211public void SendData(INodePacket packet) 332private void EnqueuePacket(INodePacket packet) 371_packetQueue = new ConcurrentQueue<INodePacket>(); 436INodePacket packet;
BackEnd\Components\Communications\NodeManager.cs (2)
122public void SendData(int node, INodePacket packet) 263public void RoutePacket(int nodeId, INodePacket packet)
BackEnd\Components\Communications\NodeProviderInProc.cs (2)
157public void SendData(int nodeId, INodePacket packet) 299public void RoutePacket(int nodeId, INodePacket packet)
BackEnd\Components\Communications\NodeProviderOutOfProc.cs (1)
132public void SendData(int nodeId, INodePacket packet)
BackEnd\Components\Communications\NodeProviderOutOfProcBase.cs (7)
96protected void SendData(NodeContext context, INodePacket packet) 579private BlockingCollection<INodePacket> _packetWriteQueue = new BlockingCollection<INodePacket>(); 708public void SendData(INodePacket packet) 738while (_packetWriteQueue.TryTake(out var packet)) 752private void SendDataCore(INodePacket packet) 797private static bool IsExitPacket(INodePacket packet)
BackEnd\Components\Communications\NodeProviderOutOfProcTaskHost.cs (4)
174public void SendData(int nodeId, INodePacket packet) 184public void SendData(HandshakeOptions hostContext, INodePacket packet) 295public void RoutePacket(int nodeId, INodePacket packet) 317public void PacketReceived(int node, INodePacket packet)
BackEnd\Components\Communications\TaskHostNodeManager.cs (2)
57public void SendData(int node, INodePacket packet) 157public void RoutePacket(int nodeId, INodePacket packet)
BackEnd\Components\FileAccesses\FileAccessReport.cs (1)
25internal static INodePacket FactoryForDeserialization(ITranslator translator) => new FileAccessReport(translator);
BackEnd\Components\FileAccesses\ProcessReport.cs (1)
22internal static INodePacket FactoryForDeserialization(ITranslator translator) => new ProcessReport(translator);
BackEnd\Components\Logging\BuildEventArgTransportSink.cs (1)
16internal delegate void SendDataDelegate(INodePacket packetToSend);
BackEnd\Components\Logging\LoggingService.cs (1)
959public void PacketReceived(int node, INodePacket packet)
BackEnd\Components\SdkResolution\HostedSdkResolverServiceBase.cs (2)
30public Action<INodePacket> SendPacket { get; set; } 49public abstract void PacketReceived(int node, INodePacket packet);
BackEnd\Components\SdkResolution\ISdkResolverService.cs (1)
21Action<INodePacket> SendPacket { get; }
BackEnd\Components\SdkResolution\MainNodeSdkResolverService.cs (1)
59public override void PacketReceived(int node, INodePacket packet)
BackEnd\Components\SdkResolution\OutOfProcNodeSdkResolverService.cs (3)
48public OutOfProcNodeSdkResolverService(Action<INodePacket> sendPacket) 56public override void PacketReceived(int node, INodePacket packet) 124INodePacket packet = SdkResolverRequest.Create(submissionId, sdk, loggingContext.BuildEventContext, sdkReferenceLocation, solutionPath, projectPath, interactive, isRunningInVisualStudio);
BackEnd\Components\SdkResolution\OutOfProcNodeSdkResolverServiceFactory.cs (2)
19private readonly Action<INodePacket> _sendPacket; 21public OutOfProcNodeSdkResolverServiceFactory(Action<INodePacket> sendPacket)
BackEnd\Components\SdkResolution\SdkResolverRequest.cs (2)
13/// with an additional <see cref="INodePacket"/> implementation. 76public static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Components\SdkResolution\SdkResolverService.cs (1)
79public Action<INodePacket> SendPacket { get; }
BackEnd\Components\SdkResolution\SdkResult.cs (1)
99public static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Node\InProcNode.cs (5)
54private readonly ConcurrentQueue<INodePacket> _receivedPackets; 113_receivedPackets = new ConcurrentQueue<INodePacket>(); 162while (_receivedPackets.TryDequeue(out INodePacket packet)) 230public void RoutePacket(int nodeId, INodePacket packet) 368private void HandlePacket(INodePacket packet)
BackEnd\Node\NodeConfiguration.cs (1)
187internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Node\OutOfProcNode.cs (7)
102private readonly ConcurrentQueue<INodePacket> _receivedPackets; 141_receivedPackets = new ConcurrentQueue<INodePacket>(); 267while (_receivedPackets.TryDequeue(out INodePacket packet)) 349void INodePacketFactory.RoutePacket(int nodeId, INodePacket packet) 363void INodePacketHandler.PacketReceived(int node, INodePacket packet) 582private void SendPacket(INodePacket packet) 613private void HandlePacket(INodePacket packet)
BackEnd\Node\OutOfProcServerNode.cs (7)
52private readonly ConcurrentQueue<INodePacket> _receivedPackets; 84_receivedPackets = new ConcurrentQueue<INodePacket>(); 156while (_receivedPackets.TryDequeue(out INodePacket? packet)) 220void INodePacketFactory.RoutePacket(int nodeId, INodePacket packet) 234void INodePacketHandler.PacketReceived(int node, INodePacket packet) 285private void SendPacket(INodePacket packet) 296private void HandlePacket(INodePacket packet)
BackEnd\Node\ServerNodeBuildCancel.cs (1)
14internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Node\ServerNodeBuildCommand.cs (1)
122internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Node\ServerNodeBuildResult.cs (1)
41internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Node\ServerNodeConsoleWrite.cs (1)
40internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Shared\BuildRequest.cs (1)
443internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Shared\BuildRequestBlocker.cs (1)
244internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Shared\BuildRequestUnblocker.cs (1)
120internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Shared\BuildResult.cs (1)
429NodePacketType INodePacket.Type
BackEnd\Shared\ResourceRequest.cs (1)
108internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Shared\ResourceResponse.cs (1)
71internal static INodePacket FactoryForDeserialization(ITranslator translator)
INodeEndpoint.cs (2)
21internal delegate void DataReceivedDelegate(INodeEndpoint endpoint, INodePacket packet); 104void SendData(INodePacket packet);
INodePacketFactory.cs (2)
13internal delegate INodePacket NodePacketFactoryMethod(ITranslator translator); 50void RoutePacket(int nodeId, INodePacket packet);
INodePacketHandler.cs (1)
19void PacketReceived(int node, INodePacket packet);
Instance\TaskFactories\TaskHostTask.cs (6)
68private ConcurrentQueue<INodePacket> _receivedPackets; 160_receivedPackets = new ConcurrentQueue<INodePacket>(); 306INodePacket packet = null; 380public void RoutePacket(int nodeId, INodePacket packet) 391public void PacketReceived(int node, INodePacket packet) 409private void HandlePacket(INodePacket packet, out bool taskFinished)
NodeEndpointOutOfProcBase.cs (7)
102private ConcurrentQueue<INodePacket> _packetQueue; 182public void SendData(INodePacket packet) 315private void EnqueuePacket(INodePacket packet) 337_packetQueue = new ConcurrentQueue<INodePacket>(); 353ConcurrentQueue<INodePacket> localPacketQueue = _packetQueue; 515ConcurrentQueue<INodePacket> localPacketQueue, AutoResetEvent localPacketAvailable, AutoResetEvent localTerminatePacketPump) 626INodePacket packet;
NodePacketFactory.cs (3)
64public void RoutePacket(int nodeId, INodePacket packet) 101INodePacket packet = _factoryMethod(translator); 108public void RoutePacket(int nodeId, INodePacket packet)
TaskHostConfiguration.cs (1)
471internal static INodePacket FactoryForDeserialization(ITranslator translator)
TaskHostTaskCancelled.cs (1)
41internal static INodePacket FactoryForDeserialization(ITranslator translator)
TaskHostTaskComplete.cs (1)
258internal static INodePacket FactoryForDeserialization(ITranslator translator)
Microsoft.Build.Engine.UnitTests (35)
BackEnd\BuildEventArgTransportSink_Tests.cs (4)
68void TransportDelegate(INodePacket packet) 91void TransportDelegate(INodePacket packet) 112void TransportDelegate(INodePacket packet) 155private static void PacketProcessor(INodePacket packet)
BackEnd\BuildRequest_Tests.cs (2)
123INodePacket packet = BuildRequest.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 169INodePacket packet = BuildRequest.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
BackEnd\BuildRequestConfiguration_Tests.cs (2)
253INodePacket packet = BuildRequestConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 294INodePacket packet = BuildRequestConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
BackEnd\BuildRequestConfigurationResponse_Tests.cs (1)
84INodePacket deserializedPacket = BuildRequestConfigurationResponse.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
BackEnd\BuildResult_Tests.cs (3)
119Assert.Equal(NodePacketType.BuildResult, ((INodePacket)result).Type); 326Assert.Equal(NodePacketType.BuildResult, (result as INodePacket).Type); 328INodePacket packet = BuildResult.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
BackEnd\MockHost.cs (1)
224public INodePacket DeserializePacket(NodePacketType type, byte[] serializedPacket)
BackEnd\MockSdkResolverService.cs (1)
17public Action<INodePacket> SendPacket { get; }
BackEnd\NodeEndpointInProc_Tests.cs (7)
109public void RoutePacket(int nodeId, INodePacket packet) 159public readonly INodePacket packet; 161public DataReceivedContext(Thread thread, INodePacket packet) 298INodePacket managerPacket = new TestPacket(); 299INodePacket nodePacket = new TestPacket(); 327INodePacket managerPacket = new TestPacket(); 328INodePacket nodePacket = new TestPacket();
BackEnd\NodePackets_Tests.cs (1)
327INodePacket tempPacket = LogMessagePacket.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()) as LogMessagePacket;
BackEnd\TaskHostConfiguration_Tests.cs (7)
367INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 464INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 515INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 564INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 612INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 667INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 717INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
BackEnd\TaskHostTaskCancelled_Tests.cs (1)
35INodePacket packet = TaskHostTaskCancelled.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
BackEnd\TaskHostTaskComplete_Tests.cs (5)
120INodePacket packet = TaskHostTaskComplete.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 143INodePacket packet = TaskHostTaskComplete.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 169INodePacket packet = TaskHostTaskComplete.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 196INodePacket packet = TaskHostTaskComplete.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 222INodePacket packet = TaskHostTaskComplete.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());