BackEnd\BuildManager\BuildManager.cs (31)
760_nodeManager!.RegisterPacketHandler(NodePacketType.BuildRequestBlocker, BuildRequestBlocker.FactoryForDeserialization, this);
761_nodeManager.RegisterPacketHandler(NodePacketType.BuildRequestConfiguration, BuildRequestConfiguration.FactoryForDeserialization, this);
762_nodeManager.RegisterPacketHandler(NodePacketType.BuildRequestConfigurationResponse, BuildRequestConfigurationResponse.FactoryForDeserialization, this);
763_nodeManager.RegisterPacketHandler(NodePacketType.BuildResult, BuildResult.FactoryForDeserialization, this);
764_nodeManager.RegisterPacketHandler(NodePacketType.FileAccessReport, FileAccessReport.FactoryForDeserialization, this);
765_nodeManager.RegisterPacketHandler(NodePacketType.NodeShutdown, NodeShutdown.FactoryForDeserialization, this);
766_nodeManager.RegisterPacketHandler(NodePacketType.ProcessReport, ProcessReport.FactoryForDeserialization, this);
767_nodeManager.RegisterPacketHandler(NodePacketType.ResolveSdkRequest, SdkResolverRequest.FactoryForDeserialization, SdkResolverService as INodePacketHandler);
768_nodeManager.RegisterPacketHandler(NodePacketType.ResourceRequest, ResourceRequest.FactoryForDeserialization, this);
839_nodeManager!.RegisterPacketHandler(NodePacketType.LogMessage, LogMessagePacket.FactoryForDeserialization, loggingService as INodePacketHandler);
2118if (_shuttingDown && packet.Type != NodePacketType.NodeShutdown)
2126case NodePacketType.BuildRequestBlocker:
2127BuildRequestBlocker blocker = ExpectPacketType<BuildRequestBlocker>(packet, NodePacketType.BuildRequestBlocker);
2131case NodePacketType.BuildRequestConfiguration:
2132BuildRequestConfiguration requestConfiguration = ExpectPacketType<BuildRequestConfiguration>(packet, NodePacketType.BuildRequestConfiguration);
2136case NodePacketType.BuildResult:
2137BuildResult result = ExpectPacketType<BuildResult>(packet, NodePacketType.BuildResult);
2141case NodePacketType.ResourceRequest:
2142ResourceRequest request = ExpectPacketType<ResourceRequest>(packet, NodePacketType.ResourceRequest);
2146case NodePacketType.NodeShutdown:
2148NodeShutdown shutdownPacket = ExpectPacketType<NodeShutdown>(packet, NodePacketType.NodeShutdown);
2152case NodePacketType.FileAccessReport:
2153FileAccessReport fileAccessReport = ExpectPacketType<FileAccessReport>(packet, NodePacketType.FileAccessReport);
2157case NodePacketType.ProcessReport:
2158ProcessReport processReport = ExpectPacketType<ProcessReport>(packet, NodePacketType.ProcessReport);
2664_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildRequestBlocker);
2665_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildRequestConfiguration);
2666_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildRequestConfigurationResponse);
2667_nodeManager?.UnregisterPacketHandler(NodePacketType.BuildResult);
2668_nodeManager?.UnregisterPacketHandler(NodePacketType.NodeShutdown);
3657private 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)
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)
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: