BackEnd\BuildManager\BuildManager.cs (31)
662_nodeManager!.RegisterPacketHandler(NodePacketType.BuildRequestBlocker, BuildRequestBlocker.FactoryForDeserialization, this);
663_nodeManager.RegisterPacketHandler(NodePacketType.BuildRequestConfiguration, BuildRequestConfiguration.FactoryForDeserialization, this);
664_nodeManager.RegisterPacketHandler(NodePacketType.BuildRequestConfigurationResponse, BuildRequestConfigurationResponse.FactoryForDeserialization, this);
665_nodeManager.RegisterPacketHandler(NodePacketType.BuildResult, BuildResult.FactoryForDeserialization, this);
666_nodeManager.RegisterPacketHandler(NodePacketType.FileAccessReport, FileAccessReport.FactoryForDeserialization, this);
667_nodeManager.RegisterPacketHandler(NodePacketType.NodeShutdown, NodeShutdown.FactoryForDeserialization, this);
668_nodeManager.RegisterPacketHandler(NodePacketType.ProcessReport, ProcessReport.FactoryForDeserialization, this);
669_nodeManager.RegisterPacketHandler(NodePacketType.ResolveSdkRequest, SdkResolverRequest.FactoryForDeserialization, SdkResolverService as INodePacketHandler);
670_nodeManager.RegisterPacketHandler(NodePacketType.ResourceRequest, ResourceRequest.FactoryForDeserialization, this);
699_nodeManager!.RegisterPacketHandler(NodePacketType.LogMessage, LogMessagePacket.FactoryForDeserialization, loggingService as INodePacketHandler);
1855if (_shuttingDown && packet.Type != NodePacketType.NodeShutdown)
1863case NodePacketType.BuildRequestBlocker:
1864BuildRequestBlocker blocker = ExpectPacketType<BuildRequestBlocker>(packet, NodePacketType.BuildRequestBlocker);
1868case NodePacketType.BuildRequestConfiguration:
1869BuildRequestConfiguration requestConfiguration = ExpectPacketType<BuildRequestConfiguration>(packet, NodePacketType.BuildRequestConfiguration);
1873case NodePacketType.BuildResult:
1874BuildResult result = ExpectPacketType<BuildResult>(packet, NodePacketType.BuildResult);
1878case NodePacketType.ResourceRequest:
1879ResourceRequest request = ExpectPacketType<ResourceRequest>(packet, NodePacketType.ResourceRequest);
1883case NodePacketType.NodeShutdown:
1885NodeShutdown shutdownPacket = ExpectPacketType<NodeShutdown>(packet, NodePacketType.NodeShutdown);
1889case NodePacketType.FileAccessReport:
1890FileAccessReport fileAccessReport = ExpectPacketType<FileAccessReport>(packet, NodePacketType.FileAccessReport);
1894case NodePacketType.ProcessReport:
1895ProcessReport processReport = ExpectPacketType<ProcessReport>(packet, NodePacketType.ProcessReport);
2398_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildRequestBlocker);
2399_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildRequestConfiguration);
2400_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildRequestConfigurationResponse);
2401_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildResult);
2402_nodeManager?.UnregisterPacketHandler(NodePacketType.NodeShutdown);
3377private static I ExpectPacketType<I>(INodePacket packet, NodePacketType expectedType)
BackEnd\Components\Communications\NodeProviderOutOfProcTaskHost.cs (11)
255(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.LogMessage, LogMessagePacket.FactoryForDeserialization, this);
256(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostTaskComplete, TaskHostTaskComplete.FactoryForDeserialization, this);
257(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeShutdown, NodeShutdown.FactoryForDeserialization, this);
262(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostIsRunningMultipleNodesRequest, TaskHostIsRunningMultipleNodesRequest.FactoryForDeserialization, this);
263(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostCoresRequest, TaskHostCoresRequest.FactoryForDeserialization, this);
264(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostBuildRequest, TaskHostBuildRequest.FactoryForDeserialization, this);
284public void RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
293public void UnregisterPacketHandler(NodePacketType packetType)
306public void DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
318public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator)
361case NodePacketType.NodeShutdown:
BackEnd\Node\OutOfProcNode.cs (19)
181(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequest, BuildRequest.FactoryForDeserialization, this);
182(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequestConfiguration, BuildRequestConfiguration.FactoryForDeserialization, this);
183(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequestConfigurationResponse, BuildRequestConfigurationResponse.FactoryForDeserialization, this);
184(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequestUnblocker, BuildRequestUnblocker.FactoryForDeserialization, this);
185(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeConfiguration, NodeConfiguration.FactoryForDeserialization, this);
186(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeBuildComplete, NodeBuildComplete.FactoryForDeserialization, this);
187(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ResourceResponse, ResourceResponse.FactoryForDeserialization, this);
188(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ResolveSdkResponse, SdkResult.FactoryForDeserialization, _sdkResolverService as INodePacketHandler);
323void INodePacketFactory.RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
332void INodePacketFactory.UnregisterPacketHandler(NodePacketType packetType)
343void INodePacketFactory.DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
353INodePacket INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator)
635case NodePacketType.BuildRequest:
639case NodePacketType.BuildRequestConfiguration:
643case NodePacketType.BuildRequestConfigurationResponse:
647case NodePacketType.BuildRequestUnblocker:
651case NodePacketType.ResourceResponse:
655case NodePacketType.NodeConfiguration:
659case NodePacketType.NodeBuildComplete:
BackEnd\Node\OutOfProcServerNode.cs (10)
82(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ServerNodeBuildCommand, ServerNodeBuildCommand.FactoryForDeserialization, this);
83(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeBuildComplete, NodeBuildComplete.FactoryForDeserialization, this);
84(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ServerNodeBuildCancel, ServerNodeBuildCancel.FactoryForDeserialization, this);
190void INodePacketFactory.RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
199void INodePacketFactory.UnregisterPacketHandler(NodePacketType packetType)
210void INodePacketFactory.DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
220INodePacket INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator)
310case NodePacketType.ServerNodeBuildCommand:
313case NodePacketType.NodeBuildComplete:
316case NodePacketType.ServerNodeBuildCancel:
Instance\TaskFactories\TaskHostTask.cs (16)
198(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.LogMessage, LogMessagePacket.FactoryForDeserialization, this);
199(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostTaskComplete, TaskHostTaskComplete.FactoryForDeserialization, this);
200(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeShutdown, NodeShutdown.FactoryForDeserialization, this);
201(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostIsRunningMultipleNodesRequest, TaskHostIsRunningMultipleNodesRequest.FactoryForDeserialization, this);
202(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostCoresRequest, TaskHostCoresRequest.FactoryForDeserialization, this);
203(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostBuildRequest, TaskHostBuildRequest.FactoryForDeserialization, this);
475public void RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
484public void UnregisterPacketHandler(NodePacketType packetType)
495public void DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
505public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator)
551case NodePacketType.TaskHostTaskComplete:
555case NodePacketType.NodeShutdown:
559case NodePacketType.LogMessage:
562case NodePacketType.TaskHostIsRunningMultipleNodesRequest:
565case NodePacketType.TaskHostCoresRequest:
568case NodePacketType.TaskHostBuildRequest: