6 instantiations of ScheduleResponse
Microsoft.Build (6)
BackEnd\Components\Scheduler\ScheduleResponse.cs (6)
171return new ScheduleResponse(node, requestToSchedule, sendConfiguration); 182return new ScheduleResponse(node, new BuildRequestUnblocker(resultToReport)); 193return new ScheduleResponse(node, new BuildRequestUnblocker(globalRequestIdToResume)); 205return new ScheduleResponse(node, parentRequest, requestCausingCircularDependency); 215return new ScheduleResponse(rootRequestResult); 226return new ScheduleResponse(typeOfNodeToCreate, count);
75 references to ScheduleResponse
Microsoft.Build (75)
BackEnd\BuildManager\BuildManager.cs (6)
2915IEnumerable<ScheduleResponse> responses = _scheduler!.ReportRequestBlocked(node, blocker); 2940IEnumerable<ScheduleResponse> response = _scheduler!.ReleaseCores(request.GlobalRequestId, request.NumCores); 3025IEnumerable<ScheduleResponse> response = _scheduler!.ReportResult(node, result); 3185private void PerformSchedulingActions(IEnumerable<ScheduleResponse> responses) 3189foreach (ScheduleResponse response in responses) 3232IEnumerable<ScheduleResponse> newResponses = _scheduler!.ReportNodesCreated(newNodes);
BackEnd\Components\Scheduler\IScheduler.cs (4)
47IEnumerable<ScheduleResponse> ReportRequestBlocked(int nodeId, BuildRequestBlocker blocker); 55IEnumerable<ScheduleResponse> ReportResult(int nodeId, BuildResult result); 62IEnumerable<ScheduleResponse> ReportNodesCreated(IEnumerable<NodeInfo> nodeInfo); 88List<ScheduleResponse> ReleaseCores(int requestId, int coresToRelease);
BackEnd\Components\Scheduler\Scheduler.cs (59)
285internal delegate void AssignUnscheduledRequestsDelegate(List<ScheduleResponse> responses, HashSet<int> idleNodes); 349public IEnumerable<ScheduleResponse> ReportRequestBlocked(int nodeId, BuildRequestBlocker blocker) 352List<ScheduleResponse> responses = new List<ScheduleResponse>(); 396responses.Add(ScheduleResponse.CreateCircularDependencyResponse(nodeId, parentRequest.BuildRequest, ex.Request)); 409responses.Add(ScheduleResponse.CreateCircularDependencyResponse(nodeId, parentRequest.BuildRequest, ex.Request)); 422public IEnumerable<ScheduleResponse> ReportResult(int nodeId, BuildResult result) 425List<ScheduleResponse> responses = new List<ScheduleResponse>(); 434ScheduleResponse response = ScheduleResponse.CreateReportResultResponse(config.ResultsNodeId, result); 456ScheduleResponse response = TrySatisfyRequestFromCache(request.Parent.AssignedNode, request.BuildRequest, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss()); 463response = ScheduleResponse.CreateReportResultResponse(request.Parent.AssignedNode, result.Clone()); 472responses.Add(ScheduleResponse.CreateSubmissionCompleteResponse(result)); 500ScheduleResponse response = TrySatisfyRequestFromCache(parentNode, unscheduledRequest.BuildRequest, skippedResultsDoNotCauseCacheMiss: true); 545public IEnumerable<ScheduleResponse> ReportNodesCreated(IEnumerable<NodeInfo> nodeInfos) 570List<ScheduleResponse> responses = new List<ScheduleResponse>(); 670public List<ScheduleResponse> ReleaseCores(int requestId, int coresToRelease) 675List<ScheduleResponse> responses = new List<ScheduleResponse>(); 736private void ScheduleUnassignedRequests(List<ScheduleResponse> responses) 855private void AssignUnscheduledRequestsToNodes(List<ScheduleResponse> responses, HashSet<int> idleNodes) 981private void AssignUnscheduledRequestsWithPlanByMostImmediateReferences(List<ScheduleResponse> responses, HashSet<int> idleNodes) 989private void AssignUnscheduledRequestsWithPlanByGreatestPlanTime(List<ScheduleResponse> responses, HashSet<int> idleNodes) 994private void AssignUnscheduledRequestsWithPlan(List<ScheduleResponse> responses, HashSet<int> idleNodes, Func<SchedulingPlan.PlanConfigData, SchedulingPlan.PlanConfigData, bool> comparisonFunction) 1037private void AssignUnscheduledRequestsByTraversalsFirst(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1046private void AssignUnscheduledProxyBuildRequestsToInProcNode(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1051private void AssignUnscheduledRequestsToInProcNode(List<ScheduleResponse> responses, HashSet<int> idleNodes, Func<SchedulableRequest, bool> shouldBeScheduled) 1090private void AssignUnscheduledRequestsWithConfigurationCountLevelling(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1129private void AssignUnscheduledRequestsWithSmallestFileSize(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1171private void AssignUnscheduledRequestsWithLargestFileSize(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1213private void AssignUnscheduledRequestsWithMaxWaitingRequests(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1290private void AssignUnscheduledRequestsWithMaxWaitingRequests2(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1318private void AssignUnscheduledRequestsFIFO(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1350private void AssignUnscheduledRequestsUsingCustomSchedulerForSQL(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1423private void AssignUnscheduledRequestToNode(SchedulableRequest request, int nodeId, List<ScheduleResponse> responses) 1444responses.Add(ScheduleResponse.CreateScheduleResponse(nodeId, request.BuildRequest, mustSendConfigurationToNode)); 1540private bool CreateNewNodeIfPossible(List<ScheduleResponse> responses, IEnumerable<SchedulableRequest> requests) 1635responses.Add(ScheduleResponse.CreateNewNodeResponse(NodeAffinity.InProc, inProcNodesToCreate)); 1666responses.Add(ScheduleResponse.CreateNewNodeResponse(NodeAffinity.OutOfProc, outOfProcNodesToCreate)); 1726private void HandleRequestBlockedOnResultsTransfer(SchedulableRequest parentRequest, List<ScheduleResponse> responses) 1742responses.Add(ScheduleResponse.CreateScheduleResponse(configuration.ResultsNodeId, newRequest, false)); 1754private void HandleRequestBlockedByNewRequests(SchedulableRequest parentRequest, BuildRequestBlocker blocker, List<ScheduleResponse> responses) 1776ScheduleResponse response = TrySatisfyRequestFromCache(nodeForResults, request, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss(), allowedTopLevelTargets: GetIsolationAllowedTopLevelTargets(parentRequest, request)); 1873responses.Add(ScheduleResponse.CreateResumeExecutionResponse(parentRequest.AssignedNode, parentRequest.BuildRequest.GlobalRequestId)); 1892private void ResumeReadyRequestIfAny(int nodeId, List<ScheduleResponse> responses) 1901ScheduleResponse response = ScheduleResponse.CreateResumeExecutionResponse(nodeId, request.BuildRequest.GlobalRequestId); 1913private void ResolveRequestFromCacheAndResumeIfPossible(SchedulableRequest request, List<ScheduleResponse> responses) 1918ScheduleResponse response = TrySatisfyRequestFromCache(nodeForResults, request.BuildRequest, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss(), allowedTopLevelTargets: GetIsolationAllowedTopLevelTargets(request.Parent, request.BuildRequest)); 1927responses.Add(ScheduleResponse.CreateSubmissionCompleteResponse(response.BuildResult)); 1981private void ResumeRequiredWork(List<ScheduleResponse> responses) 2021private ScheduleResponse TrySatisfyRequestFromCache(int nodeForResults, BuildRequest request, bool skippedResultsDoNotCauseCacheMiss, IReadOnlyCollection<string> allowedTopLevelTargets = null) 2063private bool CheckIfCacheMissOnReferencedProjectIsAllowedAndErrorIfNot(int nodeForResults, BuildRequest request, List<ScheduleResponse> responses, bool emitNonErrorLogs) 2119var response = GetResponseForResult(nodeForResults, request, result); 2213private ScheduleResponse GetResponseForResult(int parentRequestNode, BuildRequest requestWhichGeneratedResult, BuildResult result) 2219return ScheduleResponse.CreateSubmissionCompleteResponse(result); 2227return ScheduleResponse.CreateReportResultResponse(parentRequestNode, result);
BackEnd\Components\Scheduler\ScheduleResponse.cs (6)
169public static ScheduleResponse CreateScheduleResponse(int node, BuildRequest requestToSchedule, bool sendConfiguration) 180public static ScheduleResponse CreateReportResultResponse(int node, BuildResult resultToReport) 191public static ScheduleResponse CreateResumeExecutionResponse(int node, int globalRequestIdToResume) 203public static ScheduleResponse CreateCircularDependencyResponse(int node, BuildRequest parentRequest, BuildRequest requestCausingCircularDependency) 213public static ScheduleResponse CreateSubmissionCompleteResponse(BuildResult rootRequestResult) 224public static ScheduleResponse CreateNewNodeResponse(NodeAffinity typeOfNodeToCreate, int count)