27 references to AssignedNode
Microsoft.Build (27)
BackEnd\Components\Scheduler\Scheduler.cs (11)
410ScheduleResponse response = TrySatisfyRequestFromCache(request.Parent.AssignedNode, request.BuildRequest, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss()); 417response = ScheduleResponse.CreateReportResultResponse(request.Parent.AssignedNode, result.Clone()); 443int parentNode = (unscheduledRequest.Parent == null) ? InvalidNodeId : unscheduledRequest.Parent.AssignedNode; 1334if (request.AssignedNode == nodeId || requiredNodeId == nodeId || configurationCountsByNode[nodeId] <= configurationCountLimit) 1669TraceScheduler("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); 1673configuration.ResultsNodeId = parentRequest.AssignedNode; 1695int nodeForResults = (parentRequest == null) ? InvalidNodeId : parentRequest.AssignedNode; 1802responses.Add(ScheduleResponse.CreateResumeExecutionResponse(parentRequest.AssignedNode, parentRequest.BuildRequest.GlobalRequestId)); 1844int nodeForResults = (request.Parent != null) ? request.Parent.AssignedNode : InvalidNodeId; 2363if (buildEvent.Request.AssignedNode != InvalidNodeId) 2365int nodeForEvent = availableNodeIdsToIndex[buildEvent.Request.AssignedNode];
BackEnd\Components\Scheduler\SchedulingData.cs (16)
322_executingRequestByNode[request.AssignedNode] = null; 327_readyRequestsByNode[request.AssignedNode].Remove(request); 339if (!_scheduledRequestsByNode.TryGetValue(request.AssignedNode, out requestsAssignedToNode)) 342_scheduledRequestsByNode[request.AssignedNode] = requestsAssignedToNode; 345ErrorUtilities.VerifyThrow(!requestsAssignedToNode.Contains(request), "Request {0} is already scheduled to node {1}", request.BuildRequest.GlobalRequestId, request.AssignedNode); 350if (!_configurationsByNode.TryGetValue(request.AssignedNode, out configurationsAssignedToNode)) 353_configurationsByNode[request.AssignedNode] = configurationsAssignedToNode; 382if (_scheduledRequestsByNode.TryGetValue(request.AssignedNode, out var requests)) 392ErrorUtilities.VerifyThrow(!_executingRequestByNode.ContainsKey(request.AssignedNode) || _executingRequestByNode[request.AssignedNode] == null, "Node {0} is currently executing a request.", request.AssignedNode); 395_executingRequestByNode[request.AssignedNode] = request; 396_configurationToNode[request.BuildRequest.ConfigurationId] = request.AssignedNode; 408if (!_readyRequestsByNode.TryGetValue(request.AssignedNode, out readyRequestsOnNode)) 411_readyRequestsByNode[request.AssignedNode] = readyRequestsOnNode; 414ErrorUtilities.VerifyThrow(!readyRequestsOnNode.Contains(request), "Request with global id {0} is already marked as ready on node {1}", request.BuildRequest.GlobalRequestId, request.AssignedNode);