27 references to AssignedNode
Microsoft.Build (27)
BackEnd\Components\Scheduler\Scheduler.cs (11)
455ScheduleResponse response = TrySatisfyRequestFromCache(request.Parent.AssignedNode, request.BuildRequest, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss()); 462response = ScheduleResponse.CreateReportResultResponse(request.Parent.AssignedNode, result.Clone()); 489int parentNode = (unscheduledRequest.Parent == null) ? InvalidNodeId : unscheduledRequest.Parent.AssignedNode; 1401if (request.AssignedNode == nodeId || requiredNodeId == nodeId || configurationCountsByNode[nodeId] <= configurationCountLimit) 1745TraceScheduler($"Created request {newRequest.GlobalRequestId} (node request {newRequest.NodeRequestId}) for transfer of configuration {configuration.ConfigurationId}'s results from node {configuration.ResultsNodeId} to node {parentRequest.AssignedNode}"); 1749configuration.ResultsNodeId = parentRequest.AssignedNode; 1771int nodeForResults = (parentRequest == null) ? InvalidNodeId : parentRequest.AssignedNode; 1876responses.Add(ScheduleResponse.CreateResumeExecutionResponse(parentRequest.AssignedNode, parentRequest.BuildRequest.GlobalRequestId)); 1918int nodeForResults = (request.Parent != null) ? request.Parent.AssignedNode : InvalidNodeId; 2480if (buildEvent.Request.AssignedNode != InvalidNodeId) 2482int 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 {request.BuildRequest.GlobalRequestId} is already scheduled to node {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 {request.AssignedNode} is currently executing a request."); 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 {request.BuildRequest.GlobalRequestId} is already marked as ready on node {request.AssignedNode}");