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)
28INodePacket
BackEnd\Shared\BuildRequestUnblocker.cs (1)
21internal class BuildRequestUnblocker : ITranslatable, INodePacket
BackEnd\Shared\BuildResult.cs (1)
37public 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)
1222void INodePacketHandler.PacketReceived(int node, INodePacket packet) 1628private void ProcessPacket(int node, INodePacket packet) 3132private 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) 584private ConcurrentQueue<INodePacket> _packetWriteQueue = new ConcurrentQueue<INodePacket>(); 713public void SendData(INodePacket packet) 749while (context._packetWriteQueue.TryDequeue(out var packet)) 800private static bool IsExitPacket(INodePacket packet)
BackEnd\Components\Communications\NodeProviderOutOfProcTaskHost.cs (5)
174public void SendData(int nodeId, INodePacket packet) 184public void SendData(HandshakeOptions hostContext, INodePacket packet) 295public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 305public void RoutePacket(int nodeId, INodePacket packet) 327public 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) 594private void SendPacket(INodePacket packet) 625private 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)
430NodePacketType 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>(); 308INodePacket packet = null; 382public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 392public void RoutePacket(int nodeId, INodePacket packet) 403public void PacketReceived(int node, INodePacket packet) 421private void HandlePacket(INodePacket packet, out bool taskFinished)
NodeEndpointOutOfProcBase.cs (7)
103private ConcurrentQueue<INodePacket> _packetQueue; 183public void SendData(INodePacket packet) 316private void EnqueuePacket(INodePacket packet) 338_packetQueue = new ConcurrentQueue<INodePacket>(); 354ConcurrentQueue<INodePacket> localPacketQueue = _packetQueue; 516ConcurrentQueue<INodePacket> localPacketQueue, AutoResetEvent localPacketAvailable, AutoResetEvent localTerminatePacketPump) 638INodePacket 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)
470internal 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)
365INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 462INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 513INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 562INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 610INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 665INodePacket packet = TaskHostConfiguration.FactoryForDeserialization(TranslationHelpers.GetReadTranslator()); 715INodePacket 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());