600_schedulingData = new SchedulingData();

314return _schedulingData.GetRequestsAssignedToConfigurationCount(configurationId) > 0; 342SchedulableRequest request = _schedulingData.GetExecutingRequestByNode(nodeId); 351_schedulingData.EventTime = DateTime.UtcNow; 360parentRequest = _schedulingData.GetYieldingRequest(blocker.BlockedRequestId); 364parentRequest = _schedulingData.GetExecutingRequest(blocker.BlockedRequestId); 424_schedulingData.EventTime = DateTime.UtcNow; 440SchedulableRequest request = _schedulingData.GetExecutingRequest(result.GlobalRequestId); 481_schedulingData.UnscheduledRequests, _schedulingData.UnscheduledRequestsCount, out int numRead); 547_schedulingData.EventTime = DateTime.UtcNow; 581_schedulingData.EventTime = DateTime.UtcNow; 586foreach (SchedulableRequest request in _schedulingData.GetScheduledRequestsByNode(nodeId)) 621foreach (SchedulableRequest request in _schedulingData.GetRequestsByHierarchy(null)) 648_schedulingData.GrantCoresToRequest(requestId, grantedCores); 672_schedulingData.RemoveCoresFromRequest(requestId, coresToRelease); 741if (_schedulingData.UnscheduledRequestsCount == 0 && 742_schedulingData.ReadyRequestsCount == 0 && 743_schedulingData.BlockedRequestsCount == 0) 745if (_schedulingData.ExecutingRequestsCount == 0 && _schedulingData.YieldingRequestsCount == 0) 765if (!_schedulingData.IsNodeWorking(availableNodeId)) 774if (idleNodes.Count > 0 && _schedulingData.UnscheduledRequestsCount > 0) 783if (_schedulingData.UnscheduledRequestsCount > 0 || responses.Count == 0) 785createNodePending = CreateNewNodeIfPossible(responses, _schedulingData.UnscheduledRequests); 791if (_schedulingData.ExecutingRequestsCount > 0 || _schedulingData.YieldingRequestsCount > 0) 795else if (_schedulingData.UnscheduledRequestsCount == 0 && 796_schedulingData.ReadyRequestsCount == 0 && 797_schedulingData.BlockedRequestsCount == 0) 802else if (_schedulingData.BlockedRequestsCount != 0) 813foreach (SchedulableRequest request in _schedulingData.BlockedRequests) 818Assumed.Unreachable($"Somehow no requests are currently executing, and at least one of the {_schedulingData.BlockedRequestsCount} requests blocked by in-progress requests is servicable by a currently existing node, but no circular dependency was detected ..."); 825Assumed.Unreachable($"None of the {_schedulingData.BlockedRequestsCount} blocked requests can be serviced by currently existing nodes, but we aren't requesting a new one."); 828else if (_schedulingData.ReadyRequestsCount != 0) 831Assumed.Unreachable($"Somehow we have {_schedulingData.ReadyRequestsCount} requests which are ready to go but we didn't tell the nodes to continue."); 833else if (_schedulingData.UnscheduledRequestsCount != 0 && !createNodePending) 836Assumed.Unreachable($"Somehow we have {_schedulingData.UnscheduledRequestsCount} unassigned build requests but {idleNodes.Count} of our nodes are free and we aren't requesting a new one..."); 844TraceScheduler($"Requests scheduled: {nodesFreeToDoWorkPriorToScheduling - idleNodes.Count} Unassigned Requests: {_schedulingData.UnscheduledRequestsCount} Blocked Requests: {_schedulingData.BlockedRequestsCount} Unblockable Requests: {_schedulingData.ReadyRequestsCount} Free Nodes: {idleNodes.Count}/{_availableNodes.Count} Responses: {responses.Count}"); 910_schedulingPlan = new SchedulingPlan(_configCache, _schedulingData); 911ReadSchedulingPlan(_schedulingData.GetRequestsByHierarchy(null).First().BuildRequest.SubmissionId); 1002foreach (SchedulableRequest request in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1055SchedulableRequest[] unscheduledRequests = _requestBufferPool.Rent(_schedulingData.UnscheduledRequestsCount); 1058SchedulingData.UnscheduledRequestsWhichCanBeScheduledEnumerator unscheduledRequestsRead = _schedulingData.UnscheduledRequestsWhichCanBeScheduled.GetEnumerator(); 1059while (numRead < _schedulingData.UnscheduledRequestsCount && unscheduledRequestsRead.MoveNext()) 1094IEnumerable<int> nodesByConfigurationCountAscending = _availableNodes.Keys.OrderBy(x => _schedulingData.GetConfigurationsCountByNode(x, excludeTraversals: true, _configCache)); 1106TraceScheduler($"System load limit reached, cannot schedule new work. Executing: {_schedulingData.ExecutingRequestsCount} Yielding: {_schedulingData.YieldingRequestsCount} Max Count: {_componentHost.BuildParameters.MaxNodeCount}"); 1110foreach (SchedulableRequest request in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1132while (idleNodes.Count > 0 && _schedulingData.UnscheduledRequestsCount > 0) 1138foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1140int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(unscheduledRequest.BuildRequest.ConfigurationId); 1174while (idleNodes.Count > 0 && _schedulingData.UnscheduledRequestsCount > 0) 1180foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1182int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(unscheduledRequest.BuildRequest.ConfigurationId); 1222foreach (SchedulableRequest currentSchedulableRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1225int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(currentRequest.ConfigurationId); 1297foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1326TraceScheduler($"System load limit reached, cannot schedule new work. Executing: {_schedulingData.ExecutingRequestsCount} Yielding: {_schedulingData.YieldingRequestsCount} Max Count: {_componentHost.BuildParameters.MaxNodeCount}"); 1330foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1367configurationCountsByNode[availableNodeId] = _schedulingData.GetConfigurationsCountByNode(availableNodeId, true /* excludeTraversals */, _configCache); 1390TraceScheduler($"System load limit reached, cannot schedule new work. Executing: {_schedulingData.ExecutingRequestsCount} Yielding: {_schedulingData.YieldingRequestsCount} Max Count: {_componentHost.BuildParameters.MaxNodeCount}"); 1394foreach (SchedulableRequest request in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1398int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(request.BuildRequest.ConfigurationId); 1453if (request.IsProxyBuildRequest() && nodeId != InProcNodeId && _schedulingData.CanScheduleRequestToNode(request, InProcNodeId)) 1474int implicitlyGrantedCores = Math.Max(1, (_schedulingData.ExecutingRequestsCount * _nodeCoreAllocationWeight) / 100); 1477int explicitlyGrantedCores = _schedulingData.ExplicitlyGrantedCores; 1494if (_schedulingData.ExecutingRequestsCount >= _componentHost.BuildParameters.MaxNodeCount) 1508return _schedulingData.ExecutingRequestsCount + 1509_schedulingData.YieldingRequestsCount + 1510_schedulingData.ExplicitlyGrantedCores >= limit; 1518if (_schedulingData.CanScheduleRequestToNode(request, nodeId)) 1557int assignedNodeForConfiguration = _schedulingData.GetAssignedNodeForRequestConfiguration(request.BuildRequest.ConfigurationId); 1701SchedulableRequest blockingRequest = _schedulingData.GetScheduledRequest(blocker.BlockingRequestId); 1801int assignedNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(request.ConfigurationId); 1807if (_schedulingData.GetRequestsAssignedToConfigurationCount(request.ConfigurationId) == 0) 1810_schedulingData.UnassignNodeForRequestConfiguration(request.ConfigurationId); 1819else if (_schedulingData.GetRequestsAssignedToConfigurationCount(request.ConfigurationId) > 0) 1822foreach (SchedulableRequest existingRequest in _schedulingData.GetRequestsAssignedToConfiguration(request.ConfigurationId)) 1881SchedulableRequest blockingRequest = _schedulingData.CreateRequest(requestToAdd, parentRequest); 1896foreach (SchedulableRequest request in _schedulingData.GetReadyRequestsByNode(nodeId)) 1945if (!_schedulingData.IsNodeWorking(response.NodeId)) 1992TraceScheduler($"System load limit reached, cannot resume any more work. Executing: {_schedulingData.ExecutingRequestsCount} Yielding: {_schedulingData.YieldingRequestsCount} Max Count: {_componentHost.BuildParameters.MaxNodeCount}"); 1997if (_schedulingData.IsNodeWorking(nodeId)) 2009_schedulingData.UnscheduledRequests, _schedulingData.UnscheduledRequestsCount, out int numRead); 2077string parentProjectFullPath = GetParentConfigurationId(request, _configCache, _schedulingData).ProjectFullPath; 2096BuildRequestConfiguration parentConfig = GetParentConfigurationId(request, _configCache, _schedulingData); 2238int nodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(request.ConfigurationId); 2288if (_schedulingData.CanScheduleConfigurationToNode(request.ConfigurationId, InProcNodeId) && request.IsProxyBuildRequest()) 2361|| _schedulingData.GetRequestsAssignedToConfigurationCount(request.ConfigurationId) == 0) 2370foreach (SchedulableRequest existingRequest in _schedulingData.GetRequestsAssignedToConfiguration(request.ConfigurationId)) 2475foreach (SchedulingData.SchedulingEvent buildEvent in _schedulingData.BuildEvents) 2680List<SchedulableRequest> childRequests = new List<SchedulableRequest>(_schedulingData.GetRequestsByHierarchy(request)); 2716file.Write("{0}({1})-{2}: ", Thread.CurrentThread.Name, Environment.CurrentManagedThreadId, _schedulingData.EventTime.Ticks); 2771if (_schedulingData != null) 2796file.WriteLine("Scheduler state at timestamp {0}:", _schedulingData.EventTime.Ticks); 2801SchedulableRequest executingRequest = _schedulingData.GetExecutingRequestByNode(nodeId); 2811_schedulingData.GetScheduledRequestsCountByNode(nodeId), 2812_schedulingData.GetConfigurationsCountByNode(nodeId, false, null)); 2814List<SchedulableRequest> scheduledRequestsByNode = new List<SchedulableRequest>(_schedulingData.GetScheduledRequestsByNode(nodeId)); 2873if (_schedulingData.UnscheduledRequestsCount == 0) 2881foreach (SchedulableRequest request in _schedulingData.UnscheduledRequests) 2904if (_schedulingData != null) 2913List<int> configurations = new List<int>(_schedulingData.Configurations); 2918file.WriteLine("Config {0} Node {1} TV: {2} File {3}", config, _schedulingData.GetAssignedNodeForRequestConfiguration(config), _configCache[config].ToolsVersion, _configCache[config].ProjectFullPath); 2944if (_schedulingData != null) 2969foreach (SchedulableRequest child in _schedulingData.GetRequestsByHierarchy(root)) 3011_schedulingData.GetAssignedNodeForRequestConfiguration(buildRequest.ConfigurationId), 3012_schedulingData.IsRequestScheduled(request) 3026SchedulingPlan plan = new SchedulingPlan(_configCache, _schedulingData); 3035_schedulingPlan = new SchedulingPlan(_configCache, _schedulingData);