BackEnd\BuildManager\BuildManager.cs (31)
731_nodeManager!.RegisterPacketHandler(NodePacketType.BuildRequestBlocker, BuildRequestBlocker.FactoryForDeserialization, this);
732_nodeManager.RegisterPacketHandler(NodePacketType.BuildRequestConfiguration, BuildRequestConfiguration.FactoryForDeserialization, this);
733_nodeManager.RegisterPacketHandler(NodePacketType.BuildRequestConfigurationResponse, BuildRequestConfigurationResponse.FactoryForDeserialization, this);
734_nodeManager.RegisterPacketHandler(NodePacketType.BuildResult, BuildResult.FactoryForDeserialization, this);
735_nodeManager.RegisterPacketHandler(NodePacketType.FileAccessReport, FileAccessReport.FactoryForDeserialization, this);
736_nodeManager.RegisterPacketHandler(NodePacketType.NodeShutdown, NodeShutdown.FactoryForDeserialization, this);
737_nodeManager.RegisterPacketHandler(NodePacketType.ProcessReport, ProcessReport.FactoryForDeserialization, this);
738_nodeManager.RegisterPacketHandler(NodePacketType.ResolveSdkRequest, SdkResolverRequest.FactoryForDeserialization, SdkResolverService as INodePacketHandler);
739_nodeManager.RegisterPacketHandler(NodePacketType.ResourceRequest, ResourceRequest.FactoryForDeserialization, this);
768_nodeManager!.RegisterPacketHandler(NodePacketType.LogMessage, LogMessagePacket.FactoryForDeserialization, loggingService as INodePacketHandler);
1971if (_shuttingDown && packet.Type != NodePacketType.NodeShutdown)
1979case NodePacketType.BuildRequestBlocker:
1980BuildRequestBlocker blocker = ExpectPacketType<BuildRequestBlocker>(packet, NodePacketType.BuildRequestBlocker);
1984case NodePacketType.BuildRequestConfiguration:
1985BuildRequestConfiguration requestConfiguration = ExpectPacketType<BuildRequestConfiguration>(packet, NodePacketType.BuildRequestConfiguration);
1989case NodePacketType.BuildResult:
1990BuildResult result = ExpectPacketType<BuildResult>(packet, NodePacketType.BuildResult);
1994case NodePacketType.ResourceRequest:
1995ResourceRequest request = ExpectPacketType<ResourceRequest>(packet, NodePacketType.ResourceRequest);
1999case NodePacketType.NodeShutdown:
2001NodeShutdown shutdownPacket = ExpectPacketType<NodeShutdown>(packet, NodePacketType.NodeShutdown);
2005case NodePacketType.FileAccessReport:
2006FileAccessReport fileAccessReport = ExpectPacketType<FileAccessReport>(packet, NodePacketType.FileAccessReport);
2010case NodePacketType.ProcessReport:
2011ProcessReport processReport = ExpectPacketType<ProcessReport>(packet, NodePacketType.ProcessReport);
2517_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildRequestBlocker);
2518_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildRequestConfiguration);
2519_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildRequestConfigurationResponse);
2520_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildResult);
2521_nodeManager?.UnregisterPacketHandler(NodePacketType.NodeShutdown);
3509private static I ExpectPacketType<I>(INodePacket packet, NodePacketType expectedType)
BackEnd\Components\Communications\NodeProviderOutOfProcTaskHost.cs (12)
401(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.LogMessage, LogMessagePacket.FactoryForDeserialization, this);
402(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostTaskComplete, TaskHostTaskComplete.FactoryForDeserialization, this);
403(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeShutdown, NodeShutdown.FactoryForDeserialization, this);
404(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeBuildComplete, NodeBuildComplete.FactoryForDeserialization, this);
409(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostIsRunningMultipleNodesRequest, TaskHostIsRunningMultipleNodesRequest.FactoryForDeserialization, this);
410(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostCoresRequest, TaskHostCoresRequest.FactoryForDeserialization, this);
411(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostBuildRequest, TaskHostBuildRequest.FactoryForDeserialization, this);
435public void RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
444public void UnregisterPacketHandler(NodePacketType packetType)
457public void DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
469public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator)
511if (packet.Type == NodePacketType.NodeShutdown)
BackEnd\Node\OutOfProcNode.cs (19)
195(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequest, BuildRequest.FactoryForDeserialization, this);
196(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequestConfiguration, BuildRequestConfiguration.FactoryForDeserialization, this);
197(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequestConfigurationResponse, BuildRequestConfigurationResponse.FactoryForDeserialization, this);
198(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequestUnblocker, BuildRequestUnblocker.FactoryForDeserialization, this);
199(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeConfiguration, NodeConfiguration.FactoryForDeserialization, this);
200(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeBuildComplete, NodeBuildComplete.FactoryForDeserialization, this);
201(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ResourceResponse, ResourceResponse.FactoryForDeserialization, this);
202(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ResolveSdkResponse, SdkResult.FactoryForDeserialization, _sdkResolverService as INodePacketHandler);
337void INodePacketFactory.RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
346void INodePacketFactory.UnregisterPacketHandler(NodePacketType packetType)
357void INodePacketFactory.DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
367INodePacket INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator)
651case NodePacketType.BuildRequest:
655case NodePacketType.BuildRequestConfiguration:
659case NodePacketType.BuildRequestConfigurationResponse:
663case NodePacketType.BuildRequestUnblocker:
667case NodePacketType.ResourceResponse:
671case NodePacketType.NodeConfiguration:
675case NodePacketType.NodeBuildComplete:
BackEnd\Node\OutOfProcServerNode.cs (10)
112(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ServerNodeBuildCommand, ServerNodeBuildCommand.FactoryForDeserialization, this);
113(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeBuildComplete, NodeBuildComplete.FactoryForDeserialization, this);
114(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ServerNodeBuildCancel, ServerNodeBuildCancel.FactoryForDeserialization, this);
221void INodePacketFactory.RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
230void INodePacketFactory.UnregisterPacketHandler(NodePacketType packetType)
241void INodePacketFactory.DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
251INodePacket INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator)
341case NodePacketType.ServerNodeBuildCommand:
344case NodePacketType.NodeBuildComplete:
347case NodePacketType.ServerNodeBuildCancel:
Instance\TaskFactories\TaskHostTask.cs (16)
203(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.LogMessage, LogMessagePacket.FactoryForDeserialization, this);
204(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostTaskComplete, TaskHostTaskComplete.FactoryForDeserialization, this);
205(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeShutdown, NodeShutdown.FactoryForDeserialization, this);
206(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostIsRunningMultipleNodesRequest, TaskHostIsRunningMultipleNodesRequest.FactoryForDeserialization, this);
207(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostCoresRequest, TaskHostCoresRequest.FactoryForDeserialization, this);
208(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostBuildRequest, TaskHostBuildRequest.FactoryForDeserialization, this);
477public void RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
486public void UnregisterPacketHandler(NodePacketType packetType)
497public void DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
507public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator)
553case NodePacketType.TaskHostTaskComplete:
557case NodePacketType.NodeShutdown:
561case NodePacketType.LogMessage:
564case NodePacketType.TaskHostIsRunningMultipleNodesRequest:
567case NodePacketType.TaskHostCoresRequest:
570case NodePacketType.TaskHostBuildRequest: