27 references to AssignedNode
Microsoft.Build (27)
BackEnd\Components\Scheduler\Scheduler.cs (11)
441ScheduleResponse response = TrySatisfyRequestFromCache(request.Parent.AssignedNode, request.BuildRequest, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss()); 448response = ScheduleResponse.CreateReportResultResponse(request.Parent.AssignedNode, result.Clone()); 475int parentNode = (unscheduledRequest.Parent == null) ? InvalidNodeId : unscheduledRequest.Parent.AssignedNode; 1387if (request.AssignedNode == nodeId || requiredNodeId == nodeId || configurationCountsByNode[nodeId] <= configurationCountLimit) 1731TraceScheduler("Created request {0} (node request {1}) for transfer of configuration {2}'s results from node {3} to node {4}", newRequest.GlobalRequestId, newRequest.NodeRequestId, configuration.ConfigurationId, configuration.ResultsNodeId, parentRequest.AssignedNode); 1735configuration.ResultsNodeId = parentRequest.AssignedNode; 1757int nodeForResults = (parentRequest == null) ? InvalidNodeId : parentRequest.AssignedNode; 1862responses.Add(ScheduleResponse.CreateResumeExecutionResponse(parentRequest.AssignedNode, parentRequest.BuildRequest.GlobalRequestId)); 1904int nodeForResults = (request.Parent != null) ? request.Parent.AssignedNode : InvalidNodeId; 2470if (buildEvent.Request.AssignedNode != InvalidNodeId) 2472int nodeForEvent = availableNodeIdsToIndex[buildEvent.Request.AssignedNode];
BackEnd\Components\Scheduler\SchedulingData.cs (16)
310_executingRequestByNode[request.AssignedNode] = null; 315_readyRequestsByNode[request.AssignedNode].Remove(request); 327if (!_scheduledRequestsByNode.TryGetValue(request.AssignedNode, out requestsAssignedToNode)) 330_scheduledRequestsByNode[request.AssignedNode] = requestsAssignedToNode; 333ErrorUtilities.VerifyThrow(!requestsAssignedToNode.Contains(request), "Request {0} is already scheduled to node {1}", request.BuildRequest.GlobalRequestId, request.AssignedNode); 338if (!_configurationsByNode.TryGetValue(request.AssignedNode, out configurationsAssignedToNode)) 341_configurationsByNode[request.AssignedNode] = configurationsAssignedToNode; 370if (_scheduledRequestsByNode.TryGetValue(request.AssignedNode, out var requests)) 380ErrorUtilities.VerifyThrow(!_executingRequestByNode.ContainsKey(request.AssignedNode) || _executingRequestByNode[request.AssignedNode] == null, "Node {0} is currently executing a request.", request.AssignedNode); 383_executingRequestByNode[request.AssignedNode] = request; 384_configurationToNode[request.BuildRequest.ConfigurationId] = request.AssignedNode; 396if (!_readyRequestsByNode.TryGetValue(request.AssignedNode, out readyRequestsOnNode)) 399_readyRequestsByNode[request.AssignedNode] = readyRequestsOnNode; 402ErrorUtilities.VerifyThrow(!readyRequestsOnNode.Contains(request), "Request with global id {0} is already marked as ready on node {1}", request.BuildRequest.GlobalRequestId, request.AssignedNode);