1 interface inheriting from INodePacket
Microsoft.Build (1)
ITaskHostCallbackPacket.cs (1)
11internal interface ITaskHostCallbackPacket : INodePacket
29 implementations of INodePacket
Microsoft.Build (27)
BackEnd\Components\BuildRequestEngine\BuildRequestConfigurationResponse.cs (1)
12internal 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)
18internal 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)
30INodePacket
BackEnd\Shared\BuildRequestUnblocker.cs (1)
21internal class BuildRequestUnblocker : ITranslatable, INodePacket
BackEnd\Shared\BuildResult.cs (1)
39public class BuildResult : BuildResultBase, INodePacket, IBuildResults
BackEnd\Shared\ResourceRequest.cs (1)
9internal sealed class ResourceRequest : INodePacket
BackEnd\Shared\ResourceResponse.cs (1)
9internal sealed class ResourceResponse : INodePacket
LogMessagePacketBase.cs (1)
255internal class LogMessagePacketBase : INodePacket
NodeBuildComplete.cs (1)
13internal class NodeBuildComplete : INodePacket
NodeShutdown.cs (1)
36internal class NodeShutdown : INodePacket
TaskHostConfiguration.cs (1)
19internal class TaskHostConfiguration : INodePacket
TaskHostCoresRequest.cs (1)
11internal class TaskHostCoresRequest : INodePacket, ITaskHostCallbackPacket
TaskHostCoresResponse.cs (1)
11internal class TaskHostCoresResponse : INodePacket, ITaskHostCallbackPacket
TaskHostIsRunningMultipleNodesRequest.cs (1)
9internal class TaskHostIsRunningMultipleNodesRequest : INodePacket, ITaskHostCallbackPacket
TaskHostIsRunningMultipleNodesResponse.cs (1)
9internal class TaskHostIsRunningMultipleNodesResponse : INodePacket, ITaskHostCallbackPacket
TaskHostTaskCancelled.cs (1)
11internal class TaskHostTaskCancelled : INodePacket
TaskHostTaskComplete.cs (1)
53internal class TaskHostTaskComplete : INodePacket
Microsoft.Build.Engine.UnitTests (2)
BackEnd\LoggingService_Tests.cs (1)
1503internal sealed class NonLoggingPacket : INodePacket
BackEnd\NodeEndpointInProc_Tests.cs (1)
131private sealed class TestPacket : INodePacket
165 references to INodePacket
Microsoft.Build (129)
BackEnd\BuildManager\BuildManager.cs (4)
1370void INodePacketHandler.PacketReceived(int node, INodePacket packet) 1776private void ProcessPacket(int node, INodePacket packet) 3300private static I ExpectPacketType<I>(INodePacket packet, NodePacketType expectedType) where I : class, INodePacket
BackEnd\Client\MSBuildClient.cs (5)
339while (packetPump.ReceivedPacketsQueue.TryDequeue(out INodePacket? packet) && 405private bool TrySendPacket(Func<INodePacket> packetResolver) 407INodePacket? packet = null; 554private void HandlePacket(INodePacket packet) 636private void WritePacket(Stream nodeStream, INodePacket packet)
BackEnd\Client\MSBuildClientPacketPump.cs (5)
24public ConcurrentQueue<INodePacket> ReceivedPacketsQueue { get; } 86ReceivedPacketsQueue = new ConcurrentQueue<INodePacket>(); 133public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 143public void RoutePacket(int nodeId, INodePacket packet) 157public void PacketReceived(int node, INodePacket packet)
BackEnd\Components\BuildRequestEngine\BuildRequestConfigurationResponse.cs (1)
85internal 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)
52internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Components\Communications\NodeEndpointInProc.cs (5)
93private ConcurrentQueue<INodePacket> _packetQueue; 218public void SendData(INodePacket packet) 340private void EnqueuePacket(INodePacket packet) 379_packetQueue = new ConcurrentQueue<INodePacket>(); 444INodePacket packet;
BackEnd\Components\Communications\NodeManager.cs (3)
122public void SendData(int node, INodePacket packet) 263public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 273public void RoutePacket(int nodeId, INodePacket packet)
BackEnd\Components\Communications\NodeProviderInProc.cs (3)
156public void SendData(int nodeId, INodePacket packet) 293public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 305public void RoutePacket(int nodeId, INodePacket packet)
BackEnd\Components\Communications\NodeProviderOutOfProc.cs (1)
136public void SendData(int nodeId, INodePacket packet)
BackEnd\Components\Communications\NodeProviderOutOfProcBase.cs (6)
97protected void SendData(NodeContext context, INodePacket packet) 883private readonly ConcurrentQueue<INodePacket> _packetWriteQueue; 951_packetWriteQueue = new ConcurrentQueue<INodePacket>(); 1060public void SendData(INodePacket packet) 1084while (context._packetWriteQueue.TryDequeue(out INodePacket packet)) 1156private static bool IsExitPacket(INodePacket packet)
BackEnd\Components\Communications\NodeProviderOutOfProcTaskHost.cs (5)
192public void SendData(int nodeId, INodePacket packet) 202internal void SendData(TaskHostNodeKey nodeKey, INodePacket packet) 310public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 320public void RoutePacket(int nodeId, INodePacket packet) 342public void PacketReceived(int node, INodePacket packet)
BackEnd\Components\Communications\TaskHostNodeManager.cs (3)
57public void SendData(int node, INodePacket packet) 157public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 167public void RoutePacket(int nodeId, INodePacket packet)
BackEnd\Components\FileAccesses\FileAccessReport.cs (1)
25internal static INodePacket FactoryForDeserialization(ITranslator translator) => new FileAccessReport(translator);
BackEnd\Components\FileAccesses\OutOfProcNodeFileAccessManager.cs (3)
22private readonly Action<INodePacket> _sendPacket; 24private OutOfProcNodeFileAccessManager(Action<INodePacket> sendPacket) => _sendPacket = sendPacket; 26public static IBuildComponent CreateComponent(BuildComponentType type, Action<INodePacket> sendPacket)
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)
993public void PacketReceived(int node, INodePacket packet)
BackEnd\Components\SdkResolution\HostedSdkResolverServiceBase.cs (2)
31public Action<INodePacket> SendPacket { get; set; } 53public 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) 129INodePacket packet = SdkResolverRequest.Create(submissionId, sdk, loggingContext.BuildEventContext, sdkReferenceLocation, solutionPath, projectPath, interactive, isRunningInVisualStudio);
BackEnd\Components\SdkResolution\OutOfProcNodeSdkResolverServiceFactory.cs (2)
17private readonly Action<INodePacket> _sendPacket; 19public 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)
101public static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Node\InProcNode.cs (6)
55private readonly ConcurrentQueue<INodePacket> _receivedPackets; 117_receivedPackets = new ConcurrentQueue<INodePacket>(); 168while (_receivedPackets.TryDequeue(out INodePacket packet)) 234public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 246public void RoutePacket(int nodeId, INodePacket packet) 384private void HandlePacket(INodePacket packet)
BackEnd\Node\NodeConfiguration.cs (1)
186internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Node\OutOfProcNode.cs (8)
106private readonly ConcurrentQueue<INodePacket> _receivedPackets; 145_receivedPackets = new ConcurrentQueue<INodePacket>(); 271while (_receivedPackets.TryDequeue(out INodePacket packet)) 353INodePacket INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator) 363void INodePacketFactory.RoutePacket(int nodeId, INodePacket packet) 377void INodePacketHandler.PacketReceived(int node, INodePacket packet) 599private void SendPacket(INodePacket packet) 630private void HandlePacket(INodePacket packet)
BackEnd\Node\OutOfProcServerNode.cs (8)
45private readonly ConcurrentQueue<INodePacket> _receivedPackets; 77_receivedPackets = new ConcurrentQueue<INodePacket>(); 149while (_receivedPackets.TryDequeue(out INodePacket? packet)) 213INodePacket INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator) 223void INodePacketFactory.RoutePacket(int nodeId, INodePacket packet) 237void INodePacketHandler.PacketReceived(int node, INodePacket packet) 288private void SendPacket(INodePacket packet) 299private void HandlePacket(INodePacket packet)
BackEnd\Node\ServerNodeBuildCancel.cs (1)
14internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Node\ServerNodeBuildCommand.cs (1)
110internal 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)
446internal 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)
432NodePacketType INodePacket.Type
BackEnd\Shared\ResourceRequest.cs (1)
106internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Shared\ResourceResponse.cs (1)
69internal static INodePacket FactoryForDeserialization(ITranslator translator)
INodeEndpoint.cs (2)
21internal delegate void DataReceivedDelegate(INodeEndpoint endpoint, INodePacket packet); 104void SendData(INodePacket packet);
INodePacketFactory.cs (3)
13internal delegate INodePacket NodePacketFactoryMethod(ITranslator translator); 50INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator); 57void RoutePacket(int nodeId, INodePacket packet);
INodePacketHandler.cs (1)
19void PacketReceived(int node, INodePacket packet);
Instance\TaskFactories\TaskHostTask.cs (7)
73private ConcurrentQueue<INodePacket> _receivedPackets; 206_receivedPackets = new ConcurrentQueue<INodePacket>(); 377INodePacket packet = null; 451public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 461public void RoutePacket(int nodeId, INodePacket packet) 472public void PacketReceived(int node, INodePacket packet) 490private void HandlePacket(INodePacket packet, out bool taskFinished)
NodeEndpointOutOfProcBase.cs (7)
104private ConcurrentQueue<INodePacket> _packetQueue; 200public void SendData(INodePacket packet) 330private void EnqueuePacket(INodePacket packet) 352_packetQueue = new ConcurrentQueue<INodePacket>(); 368ConcurrentQueue<INodePacket> localPacketQueue = _packetQueue; 614ConcurrentQueue<INodePacket> localPacketQueue, 754INodePacket packet;
NodePacketFactory.cs (5)
58INodePacket packet = record.DeserializePacket(translator); 65public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 79public void RoutePacket(int nodeId, INodePacket packet) 119public INodePacket DeserializePacket(ITranslator translator) => _factoryMethod(translator); 124public void RoutePacket(int nodeId, INodePacket packet) => _handler.PacketReceived(nodeId, packet);
TaskHostConfiguration.cs (1)
532internal static INodePacket FactoryForDeserialization(ITranslator translator)
TaskHostCoresRequest.cs (1)
52internal static INodePacket FactoryForDeserialization(ITranslator translator)
TaskHostCoresResponse.cs (1)
46internal static INodePacket FactoryForDeserialization(ITranslator translator)
TaskHostIsRunningMultipleNodesRequest.cs (1)
30internal static INodePacket FactoryForDeserialization(ITranslator translator)
TaskHostIsRunningMultipleNodesResponse.cs (1)
40internal static INodePacket FactoryForDeserialization(ITranslator translator)
TaskHostTaskCancelled.cs (1)
40internal static INodePacket FactoryForDeserialization(ITranslator translator)
TaskHostTaskComplete.cs (1)
258internal static INodePacket FactoryForDeserialization(ITranslator translator)
Microsoft.Build.Engine.UnitTests (36)
BackEnd\BuildEventArgTransportSink_Tests.cs (4)
66void TransportDelegate(INodePacket packet) 89void TransportDelegate(INodePacket packet) 110void TransportDelegate(INodePacket packet) 153private static void PacketProcessor(INodePacket packet)
BackEnd\BuildRequest_Tests.cs (2)
124INodePacket packet = BuildRequest.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 245INodePacket 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)
118Assert.Equal(NodePacketType.BuildResult, ((INodePacket)result).Type); 325Assert.Equal(NodePacketType.BuildResult, (result as INodePacket).Type); 327INodePacket packet = BuildResult.FactoryForDeserialization(TranslationHelpers.GetReadTranslator());
BackEnd\MockHost.cs (1)
231public INodePacket DeserializePacket(NodePacketType type, byte[] serializedPacket)
BackEnd\MockSdkResolverService.cs (1)
17public Action<INodePacket> SendPacket { get; }
BackEnd\NodeEndpointInProc_Tests.cs (8)
108public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 113public void RoutePacket(int nodeId, INodePacket packet) 163public readonly INodePacket packet; 165public DataReceivedContext(Thread thread, INodePacket packet) 301INodePacket managerPacket = new TestPacket(); 302INodePacket nodePacket = new TestPacket(); 330INodePacket managerPacket = new TestPacket(); 331INodePacket nodePacket = new TestPacket();
BackEnd\NodePackets_Tests.cs (1)
330INodePacket tempPacket = LogMessagePacket.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()) as LogMessagePacket;
BackEnd\TaskHostConfiguration_Tests.cs (7)
355INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 460INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 510INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 558INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 605INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 659INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 708INodePacket 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());