601_schedulingData = new SchedulingData();

315return _schedulingData.GetRequestsAssignedToConfigurationCount(configurationId) > 0; 343SchedulableRequest request = _schedulingData.GetExecutingRequestByNode(nodeId); 352_schedulingData.EventTime = DateTime.UtcNow; 361parentRequest = _schedulingData.GetYieldingRequest(blocker.BlockedRequestId); 365parentRequest = _schedulingData.GetExecutingRequest(blocker.BlockedRequestId); 425_schedulingData.EventTime = DateTime.UtcNow; 441SchedulableRequest request = _schedulingData.GetExecutingRequest(result.GlobalRequestId); 482_schedulingData.UnscheduledRequests, _schedulingData.UnscheduledRequestsCount, out int numRead); 548_schedulingData.EventTime = DateTime.UtcNow; 582_schedulingData.EventTime = DateTime.UtcNow; 587foreach (SchedulableRequest request in _schedulingData.GetScheduledRequestsByNode(nodeId)) 622foreach (SchedulableRequest request in _schedulingData.GetRequestsByHierarchy(null)) 649_schedulingData.GrantCoresToRequest(requestId, grantedCores); 673_schedulingData.RemoveCoresFromRequest(requestId, coresToRelease); 742if (_schedulingData.UnscheduledRequestsCount == 0 && 743_schedulingData.ReadyRequestsCount == 0 && 744_schedulingData.BlockedRequestsCount == 0) 746if (_schedulingData.ExecutingRequestsCount == 0 && _schedulingData.YieldingRequestsCount == 0) 766if (!_schedulingData.IsNodeWorking(availableNodeId)) 775if (idleNodes.Count > 0 && _schedulingData.UnscheduledRequestsCount > 0) 784if (_schedulingData.UnscheduledRequestsCount > 0 || responses.Count == 0) 786createNodePending = CreateNewNodeIfPossible(responses, _schedulingData.UnscheduledRequests); 792if (_schedulingData.ExecutingRequestsCount > 0 || _schedulingData.YieldingRequestsCount > 0) 796else if (_schedulingData.UnscheduledRequestsCount == 0 && 797_schedulingData.ReadyRequestsCount == 0 && 798_schedulingData.BlockedRequestsCount == 0) 803else if (_schedulingData.BlockedRequestsCount != 0) 814foreach (SchedulableRequest request in _schedulingData.BlockedRequests) 819Assumed.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 ..."); 826Assumed.Unreachable($"None of the {_schedulingData.BlockedRequestsCount} blocked requests can be serviced by currently existing nodes, but we aren't requesting a new one."); 829else if (_schedulingData.ReadyRequestsCount != 0) 832Assumed.Unreachable($"Somehow we have {_schedulingData.ReadyRequestsCount} requests which are ready to go but we didn't tell the nodes to continue."); 834else if (_schedulingData.UnscheduledRequestsCount != 0 && !createNodePending) 837Assumed.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..."); 845TraceScheduler($"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}"); 911_schedulingPlan = new SchedulingPlan(_configCache, _schedulingData); 912ReadSchedulingPlan(_schedulingData.GetRequestsByHierarchy(null).First().BuildRequest.SubmissionId); 1003foreach (SchedulableRequest request in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1056SchedulableRequest[] unscheduledRequests = _requestBufferPool.Rent(_schedulingData.UnscheduledRequestsCount); 1059SchedulingData.UnscheduledRequestsWhichCanBeScheduledEnumerator unscheduledRequestsRead = _schedulingData.UnscheduledRequestsWhichCanBeScheduled.GetEnumerator(); 1060while (numRead < _schedulingData.UnscheduledRequestsCount && unscheduledRequestsRead.MoveNext()) 1095IEnumerable<int> nodesByConfigurationCountAscending = _availableNodes.Keys.OrderBy(x => _schedulingData.GetConfigurationsCountByNode(x, excludeTraversals: true, _configCache)); 1107TraceScheduler($"System load limit reached, cannot schedule new work. Executing: {_schedulingData.ExecutingRequestsCount} Yielding: {_schedulingData.YieldingRequestsCount} Max Count: {_componentHost.BuildParameters.MaxNodeCount}"); 1111foreach (SchedulableRequest request in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1133while (idleNodes.Count > 0 && _schedulingData.UnscheduledRequestsCount > 0) 1139foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1141int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(unscheduledRequest.BuildRequest.ConfigurationId); 1175while (idleNodes.Count > 0 && _schedulingData.UnscheduledRequestsCount > 0) 1181foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1183int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(unscheduledRequest.BuildRequest.ConfigurationId); 1223foreach (SchedulableRequest currentSchedulableRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1226int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(currentRequest.ConfigurationId); 1298foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1327TraceScheduler($"System load limit reached, cannot schedule new work. Executing: {_schedulingData.ExecutingRequestsCount} Yielding: {_schedulingData.YieldingRequestsCount} Max Count: {_componentHost.BuildParameters.MaxNodeCount}"); 1331foreach (SchedulableRequest unscheduledRequest in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1368configurationCountsByNode[availableNodeId] = _schedulingData.GetConfigurationsCountByNode(availableNodeId, true /* excludeTraversals */, _configCache); 1391TraceScheduler($"System load limit reached, cannot schedule new work. Executing: {_schedulingData.ExecutingRequestsCount} Yielding: {_schedulingData.YieldingRequestsCount} Max Count: {_componentHost.BuildParameters.MaxNodeCount}"); 1395foreach (SchedulableRequest request in _schedulingData.UnscheduledRequestsWhichCanBeScheduled) 1399int requiredNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(request.BuildRequest.ConfigurationId); 1454if (request.IsProxyBuildRequest() && nodeId != InProcNodeId && _schedulingData.CanScheduleRequestToNode(request, InProcNodeId)) 1475int implicitlyGrantedCores = Math.Max(1, (_schedulingData.ExecutingRequestsCount * _nodeCoreAllocationWeight) / 100); 1478int explicitlyGrantedCores = _schedulingData.ExplicitlyGrantedCores; 1495if (_schedulingData.ExecutingRequestsCount >= _componentHost.BuildParameters.MaxNodeCount) 1509return _schedulingData.ExecutingRequestsCount + 1510_schedulingData.YieldingRequestsCount + 1511_schedulingData.ExplicitlyGrantedCores >= limit; 1519if (_schedulingData.CanScheduleRequestToNode(request, nodeId)) 1558int assignedNodeForConfiguration = _schedulingData.GetAssignedNodeForRequestConfiguration(request.BuildRequest.ConfigurationId); 1702SchedulableRequest blockingRequest = _schedulingData.GetScheduledRequest(blocker.BlockingRequestId); 1802int assignedNodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(request.ConfigurationId); 1808if (_schedulingData.GetRequestsAssignedToConfigurationCount(request.ConfigurationId) == 0) 1811_schedulingData.UnassignNodeForRequestConfiguration(request.ConfigurationId); 1820else if (_schedulingData.GetRequestsAssignedToConfigurationCount(request.ConfigurationId) > 0) 1823foreach (SchedulableRequest existingRequest in _schedulingData.GetRequestsAssignedToConfiguration(request.ConfigurationId)) 1882SchedulableRequest blockingRequest = _schedulingData.CreateRequest(requestToAdd, parentRequest); 1897foreach (SchedulableRequest request in _schedulingData.GetReadyRequestsByNode(nodeId)) 1946if (!_schedulingData.IsNodeWorking(response.NodeId)) 1993TraceScheduler($"System load limit reached, cannot resume any more work. Executing: {_schedulingData.ExecutingRequestsCount} Yielding: {_schedulingData.YieldingRequestsCount} Max Count: {_componentHost.BuildParameters.MaxNodeCount}"); 1998if (_schedulingData.IsNodeWorking(nodeId)) 2010_schedulingData.UnscheduledRequests, _schedulingData.UnscheduledRequestsCount, out int numRead); 2078string parentProjectFullPath = GetParentConfigurationId(request, _configCache, _schedulingData).ProjectFullPath; 2097BuildRequestConfiguration parentConfig = GetParentConfigurationId(request, _configCache, _schedulingData); 2239int nodeId = _schedulingData.GetAssignedNodeForRequestConfiguration(request.ConfigurationId); 2289if (_schedulingData.CanScheduleConfigurationToNode(request.ConfigurationId, InProcNodeId) && request.IsProxyBuildRequest()) 2362|| _schedulingData.GetRequestsAssignedToConfigurationCount(request.ConfigurationId) == 0) 2371foreach (SchedulableRequest existingRequest in _schedulingData.GetRequestsAssignedToConfiguration(request.ConfigurationId)) 2476foreach (SchedulingData.SchedulingEvent buildEvent in _schedulingData.BuildEvents) 2681List<SchedulableRequest> childRequests = new List<SchedulableRequest>(_schedulingData.GetRequestsByHierarchy(request)); 2717file.Write("{0}({1})-{2}: ", Thread.CurrentThread.Name, Environment.CurrentManagedThreadId, _schedulingData.EventTime.Ticks); 2772if (_schedulingData != null) 2797file.WriteLine("Scheduler state at timestamp {0}:", _schedulingData.EventTime.Ticks); 2802SchedulableRequest executingRequest = _schedulingData.GetExecutingRequestByNode(nodeId); 2812_schedulingData.GetScheduledRequestsCountByNode(nodeId), 2813_schedulingData.GetConfigurationsCountByNode(nodeId, false, null)); 2815List<SchedulableRequest> scheduledRequestsByNode = new List<SchedulableRequest>(_schedulingData.GetScheduledRequestsByNode(nodeId)); 2874if (_schedulingData.UnscheduledRequestsCount == 0) 2882foreach (SchedulableRequest request in _schedulingData.UnscheduledRequests) 2905if (_schedulingData != null) 2914List<int> configurations = new List<int>(_schedulingData.Configurations); 2919file.WriteLine("Config {0} Node {1} TV: {2} File {3}", config, _schedulingData.GetAssignedNodeForRequestConfiguration(config), _configCache[config].ToolsVersion, _configCache[config].ProjectFullPath); 2945if (_schedulingData != null) 2970foreach (SchedulableRequest child in _schedulingData.GetRequestsByHierarchy(root)) 3012_schedulingData.GetAssignedNodeForRequestConfiguration(buildRequest.ConfigurationId), 3013_schedulingData.IsRequestScheduled(request) 3027SchedulingPlan plan = new SchedulingPlan(_configCache, _schedulingData); 3036_schedulingPlan = new SchedulingPlan(_configCache, _schedulingData);