540_schedulingData = new SchedulingData();

267return _schedulingData.GetRequestsAssignedToConfigurationCount(configurationId) > 0; 290if (!_schedulingData.IsNodeWorking(nodeId)) 295SchedulableRequest request = _schedulingData.GetExecutingRequestByNode(nodeId); 304_schedulingData.EventTime = DateTime.UtcNow; 313parentRequest = _schedulingData.GetYieldingRequest(blocker.BlockedRequestId); 317parentRequest = _schedulingData.GetExecutingRequest(blocker.BlockedRequestId); 377_schedulingData.EventTime = DateTime.UtcNow; 393SchedulableRequest request = _schedulingData.GetExecutingRequest(result.GlobalRequestId); 433List<SchedulableRequest> unscheduledRequests = new List<SchedulableRequest>(_schedulingData.UnscheduledRequests); 487_schedulingData.EventTime = DateTime.UtcNow; 521_schedulingData.EventTime = DateTime.UtcNow; 526foreach (SchedulableRequest request in _schedulingData.GetScheduledRequestsByNode(nodeId)) 560foreach (SchedulableRequest request in _schedulingData.GetRequestsByHierarchy(null)) 587_schedulingData.GrantCoresToRequest(requestId, grantedCores); 611_schedulingData.RemoveCoresFromRequest(requestId, coresToRelease); 680if (_schedulingData.UnscheduledRequestsCount == 0 && 681_schedulingData.ReadyRequestsCount == 0 && 682_schedulingData.BlockedRequestsCount == 0) 684if (_schedulingData.ExecutingRequestsCount == 0 && _schedulingData.YieldingRequestsCount == 0) 704if (!_schedulingData.IsNodeWorking(availableNodeId)) 713if (idleNodes.Count > 0 && _schedulingData.UnscheduledRequestsCount > 0) 722if (_schedulingData.UnscheduledRequestsCount > 0 || responses.Count == 0) 724createNodePending = CreateNewNodeIfPossible(responses, _schedulingData.UnscheduledRequests); 730if (_schedulingData.ExecutingRequestsCount > 0 || _schedulingData.YieldingRequestsCount > 0) 734else if (_schedulingData.UnscheduledRequestsCount == 0 && 735_schedulingData.ReadyRequestsCount == 0 && 736_schedulingData.BlockedRequestsCount == 0) 741else if (_schedulingData.BlockedRequestsCount != 0) 752foreach (SchedulableRequest request in _schedulingData.BlockedRequests) 757ErrorUtilities.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); 764ErrorUtilities.ThrowInternalError("None of the {0} blocked requests can be serviced by currently existing nodes, but we aren't requesting a new one.", _schedulingData.BlockedRequestsCount); 767else if (_schedulingData.ReadyRequestsCount != 0) 770ErrorUtilities.ThrowInternalError("Somehow we have {0} requests which are ready to go but we didn't tell the nodes to continue.", _schedulingData.ReadyRequestsCount); 772else if (_schedulingData.UnscheduledRequestsCount != 0 && !createNodePending) 775ErrorUtilities.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); 783TraceScheduler("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); 849_schedulingPlan = new SchedulingPlan(_configCache, _schedulingData); 850ReadSchedulingPlan(_schedulingData.GetRequestsByHierarchy(null).First().BuildRequest.SubmissionId); 941foreach (SchedulableRequest request in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 994List<SchedulableRequest> unscheduledRequests = new List<SchedulableRequest>(_schedulingData.UnscheduledRequestsWhichCanBeScheduled); 1022IEnumerable<int> nodesByConfigurationCountAscending = _availableNodes.Keys.OrderBy(x => _schedulingData.GetConfigurationsCountByNode(x, excludeTraversals: true, _configCache)); 1034TraceScheduler("System load limit reached, cannot schedule new work. Executing: {0} Yielding: {1} Max Count: {2}", _schedulingData.ExecutingRequestsCount, _schedulingData.YieldingRequestsCount, _componentHost.BuildParameters.MaxNodeCount); 1038foreach (SchedulableRequest request in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1060while (idleNodes.Count > 0 && _schedulingData.UnscheduledRequestsCount > 0) 1066foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1068int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(unscheduledRequest.BuildRequest.ConfigurationId); 1102while (idleNodes.Count > 0 && _schedulingData.UnscheduledRequestsCount > 0) 1108foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1110int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(unscheduledRequest.BuildRequest.ConfigurationId); 1150foreach (SchedulableRequest currentSchedulableRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1153int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(currentRequest.ConfigurationId); 1225foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1254TraceScheduler("System load limit reached, cannot schedule new work. Executing: {0} Yielding: {1} Max Count: {2}", _schedulingData.ExecutingRequestsCount, _schedulingData.YieldingRequestsCount, _componentHost.BuildParameters.MaxNodeCount); 1258foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1295configurationCountsByNode[availableNodeId] = _schedulingData.GetConfigurationsCountByNode(availableNodeId, true /* excludeTraversals */, _configCache); 1318TraceScheduler("System load limit reached, cannot schedule new work. Executing: {0} Yielding: {1} Max Count: {2}", _schedulingData.ExecutingRequestsCount, _schedulingData.YieldingRequestsCount, _componentHost.BuildParameters.MaxNodeCount); 1322foreach (SchedulableRequest request in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1326int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(request.BuildRequest.ConfigurationId); 1381if (request.IsProxyBuildRequest() && nodeId != InProcNodeId && _schedulingData.CanScheduleRequestToNode(request, InProcNodeId)) 1404int implicitlyGrantedCores = Math.Max(1, (_schedulingData.ExecutingRequestsCount * _nodeCoreAllocationWeight) / 100); 1407int explicitlyGrantedCores = _schedulingData.ExplicitlyGrantedCores; 1424if (_schedulingData.ExecutingRequestsCount >= _componentHost.BuildParameters.MaxNodeCount) 1438return _schedulingData.ExecutingRequestsCount + 1439_schedulingData.YieldingRequestsCount + 1440_schedulingData.ExplicitlyGrantedCores >= limit; 1448if (_schedulingData.CanScheduleRequestToNode(request, nodeId)) 1482int assignedNodeForConfiguration = _schedulingData.GetAssignedNodeForRequestConfiguration(request.BuildRequest.ConfigurationId); 1622SchedulableRequest blockingRequest = _schedulingData.GetScheduledRequest(blocker.BlockingRequestId); 1724int assignedNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(request.ConfigurationId); 1730if (_schedulingData.GetRequestsAssignedToConfigurationCount(request.ConfigurationId) == 0) 1733_schedulingData.UnassignNodeForRequestConfiguration(request.ConfigurationId); 1742else if (_schedulingData.GetRequestsAssignedToConfigurationCount(request.ConfigurationId) > 0) 1745foreach (SchedulableRequest existingRequest in _schedulingData.GetRequestsAssignedToConfiguration(request.ConfigurationId)) 1806SchedulableRequest blockingRequest = _schedulingData.CreateRequest(requestToAdd, parentRequest); 1821foreach (SchedulableRequest request in _schedulingData.GetReadyRequestsByNode(nodeId)) 1870if (!_schedulingData.IsNodeWorking(response.NodeId)) 1917TraceScheduler("System load limit reached, cannot resume any more work. Executing: {0} Yielding: {1} Max Count: {2}", _schedulingData.ExecutingRequestsCount, _schedulingData.YieldingRequestsCount, _componentHost.BuildParameters.MaxNodeCount); 1922if (_schedulingData.IsNodeWorking(nodeId)) 1933List<SchedulableRequest> unscheduledRequests = new List<SchedulableRequest>(_schedulingData.UnscheduledRequests); 2029SchedulableRequest parentRequest = _schedulingData.BlockedRequests.FirstOrDefault(r => r.BuildRequest.GlobalRequestId == request.ParentGlobalRequestId) 2030?? _schedulingData.ExecutingRequests.FirstOrDefault(r => r.BuildRequest.GlobalRequestId == request.ParentGlobalRequestId); 2126int nodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(request.ConfigurationId); 2177if (_schedulingData.CanScheduleConfigurationToNode(request.ConfigurationId, InProcNodeId) && request.IsProxyBuildRequest()) 2254if (request.GlobalRequestId == BuildRequest.InvalidGlobalRequestId && _schedulingData.GetRequestsAssignedToConfigurationCount(request.ConfigurationId) > 0) 2256foreach (SchedulableRequest existingRequest in _schedulingData.GetRequestsAssignedToConfiguration(request.ConfigurationId)) 2328foreach (SchedulingData.SchedulingEvent buildEvent in _schedulingData.BuildEvents) 2533List<SchedulableRequest> childRequests = new List<SchedulableRequest>(_schedulingData.GetRequestsByHierarchy(request)); 2569file.Write("{0}({1})-{2}: ", Thread.CurrentThread.Name, Environment.CurrentManagedThreadId, _schedulingData.EventTime.Ticks); 2587if (_schedulingData != null) 2594file.WriteLine("Scheduler state at timestamp {0}:", _schedulingData.EventTime.Ticks); 2602_schedulingData.IsNodeWorking(nodeId) 2606_schedulingData.GetExecutingRequestByNode(nodeId) 2609_schedulingData.GetScheduledRequestsCountByNode(nodeId), 2610_schedulingData.GetConfigurationsCountByNode(nodeId, false, null)); 2612List<SchedulableRequest> scheduledRequestsByNode = new List<SchedulableRequest>(_schedulingData.GetScheduledRequestsByNode(nodeId)); 2621if (!_schedulingData.IsNodeWorking(nodeId)) 2671if (_schedulingData.UnscheduledRequestsCount == 0) 2679foreach (SchedulableRequest request in _schedulingData.UnscheduledRequests) 2702if (_schedulingData != null) 2711List<int> configurations = new List<int>(_schedulingData.Configurations); 2716file.WriteLine("Config {0} Node {1} TV: {2} File {3}", config, _schedulingData.GetAssignedNodeForRequestConfiguration(config), _configCache[config].ToolsVersion, _configCache[config].ProjectFullPath); 2742if (_schedulingData != null) 2767foreach (SchedulableRequest child in _schedulingData.GetRequestsByHierarchy(root)) 2809_schedulingData.GetAssignedNodeForRequestConfiguration(buildRequest.ConfigurationId), 2810_schedulingData.IsRequestScheduled(request) 2824SchedulingPlan plan = new SchedulingPlan(_configCache, _schedulingData); 2833_schedulingPlan = new SchedulingPlan(_configCache, _schedulingData);