BackEnd\BuildManager\BuildManager.cs (31)
621_nodeManager!.RegisterPacketHandler(NodePacketType.BuildRequestBlocker, BuildRequestBlocker.FactoryForDeserialization, this);
622_nodeManager.RegisterPacketHandler(NodePacketType.BuildRequestConfiguration, BuildRequestConfiguration.FactoryForDeserialization, this);
623_nodeManager.RegisterPacketHandler(NodePacketType.BuildRequestConfigurationResponse, BuildRequestConfigurationResponse.FactoryForDeserialization, this);
624_nodeManager.RegisterPacketHandler(NodePacketType.BuildResult, BuildResult.FactoryForDeserialization, this);
625_nodeManager.RegisterPacketHandler(NodePacketType.FileAccessReport, FileAccessReport.FactoryForDeserialization, this);
626_nodeManager.RegisterPacketHandler(NodePacketType.NodeShutdown, NodeShutdown.FactoryForDeserialization, this);
627_nodeManager.RegisterPacketHandler(NodePacketType.ProcessReport, ProcessReport.FactoryForDeserialization, this);
628_nodeManager.RegisterPacketHandler(NodePacketType.ResolveSdkRequest, SdkResolverRequest.FactoryForDeserialization, SdkResolverService as INodePacketHandler);
629_nodeManager.RegisterPacketHandler(NodePacketType.ResourceRequest, ResourceRequest.FactoryForDeserialization, this);
658_nodeManager!.RegisterPacketHandler(NodePacketType.LogMessage, LogMessagePacket.FactoryForDeserialization, loggingService as INodePacketHandler);
1669if (_shuttingDown && packet.Type != NodePacketType.NodeShutdown)
1677case NodePacketType.BuildRequestBlocker:
1678BuildRequestBlocker blocker = ExpectPacketType<BuildRequestBlocker>(packet, NodePacketType.BuildRequestBlocker);
1682case NodePacketType.BuildRequestConfiguration:
1683BuildRequestConfiguration requestConfiguration = ExpectPacketType<BuildRequestConfiguration>(packet, NodePacketType.BuildRequestConfiguration);
1687case NodePacketType.BuildResult:
1688BuildResult result = ExpectPacketType<BuildResult>(packet, NodePacketType.BuildResult);
1692case NodePacketType.ResourceRequest:
1693ResourceRequest request = ExpectPacketType<ResourceRequest>(packet, NodePacketType.ResourceRequest);
1697case NodePacketType.NodeShutdown:
1699NodeShutdown shutdownPacket = ExpectPacketType<NodeShutdown>(packet, NodePacketType.NodeShutdown);
1703case NodePacketType.FileAccessReport:
1704FileAccessReport fileAccessReport = ExpectPacketType<FileAccessReport>(packet, NodePacketType.FileAccessReport);
1708case NodePacketType.ProcessReport:
1709ProcessReport processReport = ExpectPacketType<ProcessReport>(packet, NodePacketType.ProcessReport);
2217_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildRequestBlocker);
2218_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildRequestConfiguration);
2219_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildRequestConfigurationResponse);
2220_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildResult);
2221_nodeManager?.UnregisterPacketHandler(NodePacketType.NodeShutdown);
3173private static I ExpectPacketType<I>(INodePacket packet, NodePacketType expectedType) where I : class, INodePacket
BackEnd\Components\Communications\NodeProviderOutOfProcTaskHost.cs (8)
241(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.LogMessage, LogMessagePacket.FactoryForDeserialization, this);
242(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostTaskComplete, TaskHostTaskComplete.FactoryForDeserialization, this);
243(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeShutdown, NodeShutdown.FactoryForDeserialization, this);
263public void RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
272public void UnregisterPacketHandler(NodePacketType packetType)
283public void DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
300public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator)
340ErrorUtilities.VerifyThrow(packet.Type == NodePacketType.NodeShutdown, "We should only ever handle packets of type NodeShutdown -- everything else should only come in when there's an active task");
BackEnd\Node\OutOfProcNode.cs (19)
179(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequest, BuildRequest.FactoryForDeserialization, this);
180(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequestConfiguration, BuildRequestConfiguration.FactoryForDeserialization, this);
181(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequestConfigurationResponse, BuildRequestConfigurationResponse.FactoryForDeserialization, this);
182(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequestUnblocker, BuildRequestUnblocker.FactoryForDeserialization, this);
183(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeConfiguration, NodeConfiguration.FactoryForDeserialization, this);
184(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeBuildComplete, NodeBuildComplete.FactoryForDeserialization, this);
185(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ResourceResponse, ResourceResponse.FactoryForDeserialization, this);
186(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ResolveSdkResponse, SdkResult.FactoryForDeserialization, _sdkResolverService as INodePacketHandler);
321void INodePacketFactory.RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
330void INodePacketFactory.UnregisterPacketHandler(NodePacketType packetType)
341void INodePacketFactory.DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
351INodePacket INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator)
626case NodePacketType.BuildRequest:
630case NodePacketType.BuildRequestConfiguration:
634case NodePacketType.BuildRequestConfigurationResponse:
638case NodePacketType.BuildRequestUnblocker:
642case NodePacketType.ResourceResponse:
646case NodePacketType.NodeConfiguration:
650case NodePacketType.NodeBuildComplete:
BackEnd\Node\OutOfProcServerNode.cs (10)
87(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ServerNodeBuildCommand, ServerNodeBuildCommand.FactoryForDeserialization, this);
88(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeBuildComplete, NodeBuildComplete.FactoryForDeserialization, this);
89(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ServerNodeBuildCancel, ServerNodeBuildCancel.FactoryForDeserialization, this);
188void INodePacketFactory.RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
197void INodePacketFactory.UnregisterPacketHandler(NodePacketType packetType)
208void INodePacketFactory.DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
218INodePacket INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator)
308case NodePacketType.ServerNodeBuildCommand:
311case NodePacketType.NodeBuildComplete:
314case NodePacketType.ServerNodeBuildCancel:
Instance\TaskFactories\TaskHostTask.cs (10)
157(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.LogMessage, LogMessagePacket.FactoryForDeserialization, this);
158(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostTaskComplete, TaskHostTaskComplete.FactoryForDeserialization, this);
159(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeShutdown, NodeShutdown.FactoryForDeserialization, this);
353public void RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
362public void UnregisterPacketHandler(NodePacketType packetType)
373public void DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
383public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator)
429case NodePacketType.TaskHostTaskComplete:
433case NodePacketType.NodeShutdown:
437case NodePacketType.LogMessage: