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)
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)
29INodePacket
BackEnd\Shared\BuildRequestUnblocker.cs (1)
21internal class BuildRequestUnblocker : ITranslatable, INodePacket
BackEnd\Shared\BuildResult.cs (1)
38public 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)
262internal abstract class LogMessagePacketBase : INodePacket
NodeBuildComplete.cs (1)
14internal class NodeBuildComplete : INodePacket
NodeShutdown.cs (1)
36internal class NodeShutdown : INodePacket
TaskHostConfiguration.cs (1)
18internal 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)
1503internal sealed class NonLoggingPacket : INodePacket
BackEnd\NodeEndpointInProc_Tests.cs (1)
131private sealed class TestPacket : INodePacket
161 references to INodePacket
Microsoft.Build (125)
BackEnd\BuildManager\BuildManager.cs (4)
1259void INodePacketHandler.PacketReceived(int node, INodePacket packet) 1665private void ProcessPacket(int node, INodePacket packet) 3169private 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 (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)
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 (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)
158public void SendData(int nodeId, INodePacket packet) 298public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 310public void RoutePacket(int nodeId, INodePacket packet)
BackEnd\Components\Communications\NodeProviderOutOfProc.cs (1)
132public void SendData(int nodeId, INodePacket packet)
BackEnd\Components\Communications\NodeProviderOutOfProcBase.cs (6)
96protected void SendData(NodeContext context, INodePacket packet) 589private readonly ConcurrentQueue<INodePacket> _packetWriteQueue; 635_packetWriteQueue = new ConcurrentQueue<INodePacket>(); 742public void SendData(INodePacket packet) 766while (context._packetWriteQueue.TryDequeue(out INodePacket packet)) 816private static bool IsExitPacket(INodePacket packet)
BackEnd\Components\Communications\NodeProviderOutOfProcTaskHost.cs (5)
179public void SendData(int nodeId, INodePacket packet) 189public void SendData(HandshakeOptions hostContext, INodePacket packet) 300public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 310public void RoutePacket(int nodeId, INodePacket packet) 332public 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)
968public 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 (6)
54private readonly ConcurrentQueue<INodePacket> _receivedPackets; 113_receivedPackets = new ConcurrentQueue<INodePacket>(); 162while (_receivedPackets.TryDequeue(out INodePacket packet)) 228public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 240public void RoutePacket(int nodeId, INodePacket packet) 378private void HandlePacket(INodePacket packet)
BackEnd\Node\NodeConfiguration.cs (1)
186internal static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Node\OutOfProcNode.cs (8)
104private readonly ConcurrentQueue<INodePacket> _receivedPackets; 143_receivedPackets = new ConcurrentQueue<INodePacket>(); 269while (_receivedPackets.TryDequeue(out INodePacket packet)) 351INodePacket INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator) 361void INodePacketFactory.RoutePacket(int nodeId, INodePacket packet) 375void INodePacketHandler.PacketReceived(int node, INodePacket packet) 590private void SendPacket(INodePacket packet) 621private void HandlePacket(INodePacket packet)
BackEnd\Node\OutOfProcServerNode.cs (8)
50private readonly ConcurrentQueue<INodePacket> _receivedPackets; 82_receivedPackets = new ConcurrentQueue<INodePacket>(); 154while (_receivedPackets.TryDequeue(out INodePacket? packet)) 218INodePacket INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator) 228void INodePacketFactory.RoutePacket(int nodeId, INodePacket packet) 242void INodePacketHandler.PacketReceived(int node, INodePacket packet) 293private void SendPacket(INodePacket packet) 304private 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)
431NodePacketType 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 (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)
70private ConcurrentQueue<INodePacket> _receivedPackets; 162_receivedPackets = new ConcurrentQueue<INodePacket>(); 309INodePacket packet = null; 383public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 393public void RoutePacket(int nodeId, INodePacket packet) 404public void PacketReceived(int node, INodePacket packet) 422private void HandlePacket(INodePacket packet, out bool taskFinished)
NodeEndpointOutOfProcBase.cs (7)
107private ConcurrentQueue<INodePacket> _packetQueue; 198public void SendData(INodePacket packet) 331private void EnqueuePacket(INodePacket packet) 353_packetQueue = new ConcurrentQueue<INodePacket>(); 369ConcurrentQueue<INodePacket> localPacketQueue = _packetQueue; 601ConcurrentQueue<INodePacket> localPacketQueue, 725INodePacket 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)
486internal 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 (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)
122INodePacket packet = BuildRequest.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 168INodePacket 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) 302INodePacket managerPacket = new TestPacket(); 303INodePacket nodePacket = new TestPacket(); 331INodePacket managerPacket = new TestPacket(); 332INodePacket nodePacket = new TestPacket();
BackEnd\NodePackets_Tests.cs (1)
330INodePacket tempPacket = LogMessagePacket.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()) as LogMessagePacket;
BackEnd\TaskHostConfiguration_Tests.cs (7)
375INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 474INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 526INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 576INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 625INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 681INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 732INodePacket 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());