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) 1743TraceScheduler($"Created request {newRequest.GlobalRequestId} (node request {newRequest.NodeRequestId}) for transfer of configuration {configuration.ConfigurationId}'s results from node {configuration.ResultsNodeId} to node {parentRequest.AssignedNode}"); 1747configuration.ResultsNodeId = parentRequest.AssignedNode; 1769int nodeForResults = (parentRequest == null) ? InvalidNodeId : parentRequest.AssignedNode; 1872responses.Add(ScheduleResponse.CreateResumeExecutionResponse(parentRequest.AssignedNode, parentRequest.BuildRequest.GlobalRequestId)); 1914int nodeForResults = (request.Parent != null) ? request.Parent.AssignedNode : InvalidNodeId; 2474if (buildEvent.Request.AssignedNode != InvalidNodeId) 2476int nodeForEvent = availableNodeIdsToIndex[buildEvent.Request.AssignedNode];
BackEnd\Components\Scheduler\SchedulingData.cs (16)
309_executingRequestByNode[request.AssignedNode] = null; 314_readyRequestsByNode[request.AssignedNode].Remove(request); 326if (!_scheduledRequestsByNode.TryGetValue(request.AssignedNode, out requestsAssignedToNode)) 329_scheduledRequestsByNode[request.AssignedNode] = requestsAssignedToNode; 332Assumed.False(requestsAssignedToNode.Contains(request), $"Request {request.BuildRequest.GlobalRequestId} is already scheduled to node {request.AssignedNode}"); 337if (!_configurationsByNode.TryGetValue(request.AssignedNode, out configurationsAssignedToNode)) 340_configurationsByNode[request.AssignedNode] = configurationsAssignedToNode; 369if (_scheduledRequestsByNode.TryGetValue(request.AssignedNode, out var requests)) 379Assumed.True(!_executingRequestByNode.ContainsKey(request.AssignedNode) || _executingRequestByNode[request.AssignedNode] == null, $"Node {request.AssignedNode} is currently executing a request."); 382_executingRequestByNode[request.AssignedNode] = request; 383_configurationToNode[request.BuildRequest.ConfigurationId] = request.AssignedNode; 395if (!_readyRequestsByNode.TryGetValue(request.AssignedNode, out readyRequestsOnNode)) 398_readyRequestsByNode[request.AssignedNode] = readyRequestsOnNode; 401Assumed.False(readyRequestsOnNode.Contains(request), $"Request with global id {request.BuildRequest.GlobalRequestId} is already marked as ready on node {request.AssignedNode}");