BackEnd\BuildManager\BuildManager.cs (31)
766_nodeManager!.RegisterPacketHandler(NodePacketType.BuildRequestBlocker, BuildRequestBlocker.FactoryForDeserialization, this);
767_nodeManager.RegisterPacketHandler(NodePacketType.BuildRequestConfiguration, BuildRequestConfiguration.FactoryForDeserialization, this);
768_nodeManager.RegisterPacketHandler(NodePacketType.BuildRequestConfigurationResponse, BuildRequestConfigurationResponse.FactoryForDeserialization, this);
769_nodeManager.RegisterPacketHandler(NodePacketType.BuildResult, BuildResult.FactoryForDeserialization, this);
770_nodeManager.RegisterPacketHandler(NodePacketType.FileAccessReport, FileAccessReport.FactoryForDeserialization, this);
771_nodeManager.RegisterPacketHandler(NodePacketType.NodeShutdown, NodeShutdown.FactoryForDeserialization, this);
772_nodeManager.RegisterPacketHandler(NodePacketType.ProcessReport, ProcessReport.FactoryForDeserialization, this);
773_nodeManager.RegisterPacketHandler(NodePacketType.ResolveSdkRequest, SdkResolverRequest.FactoryForDeserialization, SdkResolverService as INodePacketHandler);
774_nodeManager.RegisterPacketHandler(NodePacketType.ResourceRequest, ResourceRequest.FactoryForDeserialization, this);
845_nodeManager!.RegisterPacketHandler(NodePacketType.LogMessage, LogMessagePacket.FactoryForDeserialization, loggingService as INodePacketHandler);
2146if (_shuttingDown && packet.Type != NodePacketType.NodeShutdown)
2154case NodePacketType.BuildRequestBlocker:
2155BuildRequestBlocker blocker = ExpectPacketType<BuildRequestBlocker>(packet, NodePacketType.BuildRequestBlocker);
2159case NodePacketType.BuildRequestConfiguration:
2160BuildRequestConfiguration requestConfiguration = ExpectPacketType<BuildRequestConfiguration>(packet, NodePacketType.BuildRequestConfiguration);
2164case NodePacketType.BuildResult:
2165BuildResult result = ExpectPacketType<BuildResult>(packet, NodePacketType.BuildResult);
2169case NodePacketType.ResourceRequest:
2170ResourceRequest request = ExpectPacketType<ResourceRequest>(packet, NodePacketType.ResourceRequest);
2174case NodePacketType.NodeShutdown:
2176NodeShutdown shutdownPacket = ExpectPacketType<NodeShutdown>(packet, NodePacketType.NodeShutdown);
2180case NodePacketType.FileAccessReport:
2181FileAccessReport fileAccessReport = ExpectPacketType<FileAccessReport>(packet, NodePacketType.FileAccessReport);
2185case NodePacketType.ProcessReport:
2186ProcessReport processReport = ExpectPacketType<ProcessReport>(packet, NodePacketType.ProcessReport);
2695_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildRequestBlocker);
2696_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildRequestConfiguration);
2697_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildRequestConfigurationResponse);
2698_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildResult);
2699_nodeManager?.UnregisterPacketHandler(NodePacketType.NodeShutdown);
3704private static I ExpectPacketType<I>(INodePacket packet, NodePacketType expectedType)
BackEnd\Components\Communications\NodeProviderOutOfProcTaskHost.cs (13)
439(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.LogMessage, LogMessagePacket.FactoryForDeserialization, this);
440(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostTaskComplete, TaskHostTaskComplete.FactoryForDeserialization, this);
441(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeShutdown, NodeShutdown.FactoryForDeserialization, this);
442(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeBuildComplete, NodeBuildComplete.FactoryForDeserialization, this);
443(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ConsoleWrite, ConsoleWritePacket.FactoryForDeserialization, this);
448(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostIsRunningMultipleNodesRequest, TaskHostIsRunningMultipleNodesRequest.FactoryForDeserialization, this);
449(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostCoresRequest, TaskHostCoresRequest.FactoryForDeserialization, this);
450(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostBuildRequest, TaskHostBuildRequest.FactoryForDeserialization, this);
492public void RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
501public void UnregisterPacketHandler(NodePacketType packetType)
514public void DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
526public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator)
568if (packet.Type == NodePacketType.NodeShutdown)
BackEnd\Node\OutOfProcNode.cs (19)
196(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequest, BuildRequest.FactoryForDeserialization, this);
197(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequestConfiguration, BuildRequestConfiguration.FactoryForDeserialization, this);
198(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequestConfigurationResponse, BuildRequestConfigurationResponse.FactoryForDeserialization, this);
199(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.BuildRequestUnblocker, BuildRequestUnblocker.FactoryForDeserialization, this);
200(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeConfiguration, NodeConfiguration.FactoryForDeserialization, this);
201(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeBuildComplete, NodeBuildComplete.FactoryForDeserialization, this);
202(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ResourceResponse, ResourceResponse.FactoryForDeserialization, this);
203(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ResolveSdkResponse, SdkResult.FactoryForDeserialization, _sdkResolverService as INodePacketHandler);
338void INodePacketFactory.RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
347void INodePacketFactory.UnregisterPacketHandler(NodePacketType packetType)
358void INodePacketFactory.DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
368INodePacket INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator)
654case NodePacketType.BuildRequest:
658case NodePacketType.BuildRequestConfiguration:
662case NodePacketType.BuildRequestConfigurationResponse:
666case NodePacketType.BuildRequestUnblocker:
670case NodePacketType.ResourceResponse:
674case NodePacketType.NodeConfiguration:
678case NodePacketType.NodeBuildComplete:
BackEnd\Node\OutOfProcServerNode.cs (10)
111(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ServerNodeBuildCommand, ServerNodeBuildCommand.FactoryForDeserialization, this);
112(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeBuildComplete, NodeBuildComplete.FactoryForDeserialization, this);
113(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.ServerNodeBuildCancel, ServerNodeBuildCancel.FactoryForDeserialization, this);
220void INodePacketFactory.RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
229void INodePacketFactory.UnregisterPacketHandler(NodePacketType packetType)
240void INodePacketFactory.DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
250INodePacket INodePacketFactory.DeserializePacket(NodePacketType packetType, ITranslator translator)
340case NodePacketType.ServerNodeBuildCommand:
343case NodePacketType.NodeBuildComplete:
346case NodePacketType.ServerNodeBuildCancel:
Instance\TaskFactories\TaskHostTask.cs (16)
223(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.LogMessage, LogMessagePacket.FactoryForDeserialization, this);
224(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostTaskComplete, TaskHostTaskComplete.FactoryForDeserialization, this);
225(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.NodeShutdown, NodeShutdown.FactoryForDeserialization, this);
226(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostIsRunningMultipleNodesRequest, TaskHostIsRunningMultipleNodesRequest.FactoryForDeserialization, this);
227(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostCoresRequest, TaskHostCoresRequest.FactoryForDeserialization, this);
228(this as INodePacketFactory).RegisterPacketHandler(NodePacketType.TaskHostBuildRequest, TaskHostBuildRequest.FactoryForDeserialization, this);
535public void RegisterPacketHandler(NodePacketType packetType, NodePacketFactoryMethod factory, INodePacketHandler handler)
544public void UnregisterPacketHandler(NodePacketType packetType)
555public void DeserializeAndRoutePacket(int nodeId, NodePacketType packetType, ITranslator translator)
565public INodePacket DeserializePacket(NodePacketType packetType, ITranslator translator)
622case NodePacketType.TaskHostTaskComplete:
626case NodePacketType.NodeShutdown:
630case NodePacketType.LogMessage:
633case NodePacketType.TaskHostIsRunningMultipleNodesRequest:
636case NodePacketType.TaskHostCoresRequest:
639case NodePacketType.TaskHostBuildRequest: