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
157 references to INodePacket
Microsoft.Build (121)
BackEnd\BuildManager\BuildManager.cs (4)
1265void INodePacketHandler.PacketReceived(int node, INodePacket packet) 1671private void ProcessPacket(int node, INodePacket packet) 3186private 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) 651private 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; 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)
144public void SendData(int nodeId, INodePacket packet) 281public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 293public 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) 619private readonly ConcurrentQueue<INodePacket> _packetWriteQueue; 679_packetWriteQueue = new ConcurrentQueue<INodePacket>(); 787public void SendData(INodePacket packet) 811while (context._packetWriteQueue.TryDequeue(out INodePacket packet)) 874private static bool IsExitPacket(INodePacket packet)
BackEnd\Components\Communications\NodeProviderOutOfProcTaskHost.cs (4)
170public void SendData(int nodeId, INodePacket packet) 276public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 286public void RoutePacket(int nodeId, INodePacket packet) 308public 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\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)
978public 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)
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)
101public static INodePacket FactoryForDeserialization(ITranslator translator)
BackEnd\Node\InProcNode.cs (6)
54private readonly ConcurrentQueue<INodePacket> _receivedPackets; 116_receivedPackets = new ConcurrentQueue<INodePacket>(); 167while (_receivedPackets.TryDequeue(out INodePacket packet)) 233public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 245public void RoutePacket(int nodeId, INodePacket packet) 383private 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)
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)
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)
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)
76private ConcurrentQueue<INodePacket> _receivedPackets; 185_receivedPackets = new ConcurrentQueue<INodePacket>(); 352INodePacket packet = null; 442public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator) 452public void RoutePacket(int nodeId, INodePacket packet) 463public void PacketReceived(int node, INodePacket packet) 481private 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; 607ConcurrentQueue<INodePacket> localPacketQueue, 743INodePacket 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)
477internal 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) 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)
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());