565_schedulingData = new SchedulingData();

282return _schedulingData.GetRequestsAssignedToConfigurationCount(configurationId) > 0; 305if (!_schedulingData.IsNodeWorking(nodeId)) 310SchedulableRequest request = _schedulingData.GetExecutingRequestByNode(nodeId); 319_schedulingData.EventTime = DateTime.UtcNow; 328parentRequest = _schedulingData.GetYieldingRequest(blocker.BlockedRequestId); 332parentRequest = _schedulingData.GetExecutingRequest(blocker.BlockedRequestId); 392_schedulingData.EventTime = DateTime.UtcNow; 408SchedulableRequest request = _schedulingData.GetExecutingRequest(result.GlobalRequestId); 448List<SchedulableRequest> unscheduledRequests = new List<SchedulableRequest>(_schedulingData.UnscheduledRequests); 512_schedulingData.EventTime = DateTime.UtcNow; 546_schedulingData.EventTime = DateTime.UtcNow; 551foreach (SchedulableRequest request in _schedulingData.GetScheduledRequestsByNode(nodeId)) 585foreach (SchedulableRequest request in _schedulingData.GetRequestsByHierarchy(null)) 612_schedulingData.GrantCoresToRequest(requestId, grantedCores); 636_schedulingData.RemoveCoresFromRequest(requestId, coresToRelease); 705if (_schedulingData.UnscheduledRequestsCount == 0 && 706_schedulingData.ReadyRequestsCount == 0 && 707_schedulingData.BlockedRequestsCount == 0) 709if (_schedulingData.ExecutingRequestsCount == 0 && _schedulingData.YieldingRequestsCount == 0) 729if (!_schedulingData.IsNodeWorking(availableNodeId)) 738if (idleNodes.Count > 0 && _schedulingData.UnscheduledRequestsCount > 0) 747if (_schedulingData.UnscheduledRequestsCount > 0 || responses.Count == 0) 749createNodePending = CreateNewNodeIfPossible(responses, _schedulingData.UnscheduledRequests); 755if (_schedulingData.ExecutingRequestsCount > 0 || _schedulingData.YieldingRequestsCount > 0) 759else if (_schedulingData.UnscheduledRequestsCount == 0 && 760_schedulingData.ReadyRequestsCount == 0 && 761_schedulingData.BlockedRequestsCount == 0) 766else if (_schedulingData.BlockedRequestsCount != 0) 777foreach (SchedulableRequest request in _schedulingData.BlockedRequests) 782ErrorUtilities.ThrowInternalError("Somehow no requests are currently executing, and at least one of the {0} requests blocked by in-progress requests is servicable by a currently existing node, but no circular dependency was detected ...", _schedulingData.BlockedRequestsCount); 789ErrorUtilities.ThrowInternalError("None of the {0} blocked requests can be serviced by currently existing nodes, but we aren't requesting a new one.", _schedulingData.BlockedRequestsCount); 792else if (_schedulingData.ReadyRequestsCount != 0) 795ErrorUtilities.ThrowInternalError("Somehow we have {0} requests which are ready to go but we didn't tell the nodes to continue.", _schedulingData.ReadyRequestsCount); 797else if (_schedulingData.UnscheduledRequestsCount != 0 && !createNodePending) 800ErrorUtilities.ThrowInternalError("Somehow we have {0} unassigned build requests but {1} of our nodes are free and we aren't requesting a new one...", _schedulingData.UnscheduledRequestsCount, idleNodes.Count); 808TraceScheduler("Requests scheduled: {0} Unassigned Requests: {1} Blocked Requests: {2} Unblockable Requests: {3} Free Nodes: {4}/{5} Responses: {6}", nodesFreeToDoWorkPriorToScheduling - idleNodes.Count, _schedulingData.UnscheduledRequestsCount, _schedulingData.BlockedRequestsCount, _schedulingData.ReadyRequestsCount, idleNodes.Count, _availableNodes.Count, responses.Count); 874_schedulingPlan = new SchedulingPlan(_configCache, _schedulingData); 875ReadSchedulingPlan(_schedulingData.GetRequestsByHierarchy(null).First().BuildRequest.SubmissionId); 966foreach (SchedulableRequest request in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1019foreach (SchedulableRequest request in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1046IEnumerable<int> nodesByConfigurationCountAscending = _availableNodes.Keys.OrderBy(x => _schedulingData.GetConfigurationsCountByNode(x, excludeTraversals: true, _configCache)); 1058TraceScheduler("System load limit reached, cannot schedule new work. Executing: {0} Yielding: {1} Max Count: {2}", _schedulingData.ExecutingRequestsCount, _schedulingData.YieldingRequestsCount, _componentHost.BuildParameters.MaxNodeCount); 1062foreach (SchedulableRequest request in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1084while (idleNodes.Count > 0 && _schedulingData.UnscheduledRequestsCount > 0) 1090foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1092int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(unscheduledRequest.BuildRequest.ConfigurationId); 1126while (idleNodes.Count > 0 && _schedulingData.UnscheduledRequestsCount > 0) 1132foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1134int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(unscheduledRequest.BuildRequest.ConfigurationId); 1174foreach (SchedulableRequest currentSchedulableRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1177int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(currentRequest.ConfigurationId); 1249foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1278TraceScheduler("System load limit reached, cannot schedule new work. Executing: {0} Yielding: {1} Max Count: {2}", _schedulingData.ExecutingRequestsCount, _schedulingData.YieldingRequestsCount, _componentHost.BuildParameters.MaxNodeCount); 1282foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1319configurationCountsByNode[availableNodeId] = _schedulingData.GetConfigurationsCountByNode(availableNodeId, true /* excludeTraversals */, _configCache); 1342TraceScheduler("System load limit reached, cannot schedule new work. Executing: {0} Yielding: {1} Max Count: {2}", _schedulingData.ExecutingRequestsCount, _schedulingData.YieldingRequestsCount, _componentHost.BuildParameters.MaxNodeCount); 1346foreach (SchedulableRequest request in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1350int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(request.BuildRequest.ConfigurationId); 1405if (request.IsProxyBuildRequest() && nodeId != InProcNodeId && _schedulingData.CanScheduleRequestToNode(request, InProcNodeId)) 1428int implicitlyGrantedCores = Math.Max(1, (_schedulingData.ExecutingRequestsCount * _nodeCoreAllocationWeight) / 100); 1431int explicitlyGrantedCores = _schedulingData.ExplicitlyGrantedCores; 1448if (_schedulingData.ExecutingRequestsCount >= _componentHost.BuildParameters.MaxNodeCount) 1462return _schedulingData.ExecutingRequestsCount + 1463_schedulingData.YieldingRequestsCount + 1464_schedulingData.ExplicitlyGrantedCores >= limit; 1472if (_schedulingData.CanScheduleRequestToNode(request, nodeId)) 1506int assignedNodeForConfiguration = _schedulingData.GetAssignedNodeForRequestConfiguration(request.BuildRequest.ConfigurationId); 1646SchedulableRequest blockingRequest = _schedulingData.GetScheduledRequest(blocker.BlockingRequestId); 1746int assignedNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(request.ConfigurationId); 1752if (_schedulingData.GetRequestsAssignedToConfigurationCount(request.ConfigurationId) == 0) 1755_schedulingData.UnassignNodeForRequestConfiguration(request.ConfigurationId); 1764else if (_schedulingData.GetRequestsAssignedToConfigurationCount(request.ConfigurationId) > 0) 1767foreach (SchedulableRequest existingRequest in _schedulingData.GetRequestsAssignedToConfiguration(request.ConfigurationId)) 1828SchedulableRequest blockingRequest = _schedulingData.CreateRequest(requestToAdd, parentRequest); 1843foreach (SchedulableRequest request in _schedulingData.GetReadyRequestsByNode(nodeId)) 1892if (!_schedulingData.IsNodeWorking(response.NodeId)) 1939TraceScheduler("System load limit reached, cannot resume any more work. Executing: {0} Yielding: {1} Max Count: {2}", _schedulingData.ExecutingRequestsCount, _schedulingData.YieldingRequestsCount, _componentHost.BuildParameters.MaxNodeCount); 1944if (_schedulingData.IsNodeWorking(nodeId)) 1955List<SchedulableRequest> unscheduledRequests = new List<SchedulableRequest>(_schedulingData.UnscheduledRequests); 1993string parentProjectFullPath = GetParentConfigurationId(request, _configCache, _schedulingData).ProjectFullPath; 2012BuildRequestConfiguration parentConfig = GetParentConfigurationId(request, _configCache, _schedulingData); 2156int nodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(request.ConfigurationId); 2207if (_schedulingData.CanScheduleConfigurationToNode(request.ConfigurationId, InProcNodeId) && request.IsProxyBuildRequest()) 2280|| _schedulingData.GetRequestsAssignedToConfigurationCount(request.ConfigurationId) == 0) 2289foreach (SchedulableRequest existingRequest in _schedulingData.GetRequestsAssignedToConfiguration(request.ConfigurationId)) 2364foreach (SchedulingData.SchedulingEvent buildEvent in _schedulingData.BuildEvents) 2569List<SchedulableRequest> childRequests = new List<SchedulableRequest>(_schedulingData.GetRequestsByHierarchy(request)); 2605file.Write("{0}({1})-{2}: ", Thread.CurrentThread.Name, Environment.CurrentManagedThreadId, _schedulingData.EventTime.Ticks); 2623if (_schedulingData != null) 2630file.WriteLine("Scheduler state at timestamp {0}:", _schedulingData.EventTime.Ticks); 2638_schedulingData.IsNodeWorking(nodeId) 2642_schedulingData.GetExecutingRequestByNode(nodeId) 2645_schedulingData.GetScheduledRequestsCountByNode(nodeId), 2646_schedulingData.GetConfigurationsCountByNode(nodeId, false, null)); 2648List<SchedulableRequest> scheduledRequestsByNode = new List<SchedulableRequest>(_schedulingData.GetScheduledRequestsByNode(nodeId)); 2657if (!_schedulingData.IsNodeWorking(nodeId)) 2707if (_schedulingData.UnscheduledRequestsCount == 0) 2715foreach (SchedulableRequest request in _schedulingData.UnscheduledRequests) 2738if (_schedulingData != null) 2747List<int> configurations = new List<int>(_schedulingData.Configurations); 2752file.WriteLine("Config {0} Node {1} TV: {2} File {3}", config, _schedulingData.GetAssignedNodeForRequestConfiguration(config), _configCache[config].ToolsVersion, _configCache[config].ProjectFullPath); 2778if (_schedulingData != null) 2803foreach (SchedulableRequest child in _schedulingData.GetRequestsByHierarchy(root)) 2845_schedulingData.GetAssignedNodeForRequestConfiguration(buildRequest.ConfigurationId), 2846_schedulingData.IsRequestScheduled(request) 2860SchedulingPlan plan = new SchedulingPlan(_configCache, _schedulingData); 2869_schedulingPlan = new SchedulingPlan(_configCache, _schedulingData);