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)
2622IEnumerable<ScheduleResponse> responses = _scheduler!.ReportRequestBlocked(node, blocker); 2647IEnumerable<ScheduleResponse> response = _scheduler!.ReleaseCores(request.GlobalRequestId, request.NumCores); 2732IEnumerable<ScheduleResponse> response = _scheduler!.ReportResult(node, result); 2880private void PerformSchedulingActions(IEnumerable<ScheduleResponse> responses) 2884foreach (ScheduleResponse response in responses) 2923IEnumerable<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)
284internal delegate void AssignUnscheduledRequestsDelegate(List<ScheduleResponse> responses, HashSet<int> idleNodes); 348public IEnumerable<ScheduleResponse> ReportRequestBlocked(int nodeId, BuildRequestBlocker blocker) 351List<ScheduleResponse> responses = new List<ScheduleResponse>(); 395responses.Add(ScheduleResponse.CreateCircularDependencyResponse(nodeId, parentRequest.BuildRequest, ex.Request)); 408responses.Add(ScheduleResponse.CreateCircularDependencyResponse(nodeId, parentRequest.BuildRequest, ex.Request)); 421public IEnumerable<ScheduleResponse> ReportResult(int nodeId, BuildResult result) 424List<ScheduleResponse> responses = new List<ScheduleResponse>(); 433ScheduleResponse response = ScheduleResponse.CreateReportResultResponse(config.ResultsNodeId, result); 455ScheduleResponse response = TrySatisfyRequestFromCache(request.Parent.AssignedNode, request.BuildRequest, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss()); 462response = ScheduleResponse.CreateReportResultResponse(request.Parent.AssignedNode, result.Clone()); 471responses.Add(ScheduleResponse.CreateSubmissionCompleteResponse(result)); 499ScheduleResponse response = TrySatisfyRequestFromCache(parentNode, unscheduledRequest.BuildRequest, skippedResultsDoNotCauseCacheMiss: true); 544public IEnumerable<ScheduleResponse> ReportNodesCreated(IEnumerable<NodeInfo> nodeInfos) 569List<ScheduleResponse> responses = new List<ScheduleResponse>(); 669public List<ScheduleResponse> ReleaseCores(int requestId, int coresToRelease) 674List<ScheduleResponse> responses = new List<ScheduleResponse>(); 735private void ScheduleUnassignedRequests(List<ScheduleResponse> responses) 854private void AssignUnscheduledRequestsToNodes(List<ScheduleResponse> responses, HashSet<int> idleNodes) 980private void AssignUnscheduledRequestsWithPlanByMostImmediateReferences(List<ScheduleResponse> responses, HashSet<int> idleNodes) 988private void AssignUnscheduledRequestsWithPlanByGreatestPlanTime(List<ScheduleResponse> responses, HashSet<int> idleNodes) 993private void AssignUnscheduledRequestsWithPlan(List<ScheduleResponse> responses, HashSet<int> idleNodes, Func<SchedulingPlan.PlanConfigData, SchedulingPlan.PlanConfigData, bool> comparisonFunction) 1036private void AssignUnscheduledRequestsByTraversalsFirst(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1045private void AssignUnscheduledProxyBuildRequestsToInProcNode(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1050private void AssignUnscheduledRequestsToInProcNode(List<ScheduleResponse> responses, HashSet<int> idleNodes, Func<SchedulableRequest, bool> shouldBeScheduled) 1089private void AssignUnscheduledRequestsWithConfigurationCountLevelling(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1128private void AssignUnscheduledRequestsWithSmallestFileSize(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1170private void AssignUnscheduledRequestsWithLargestFileSize(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1212private void AssignUnscheduledRequestsWithMaxWaitingRequests(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1289private void AssignUnscheduledRequestsWithMaxWaitingRequests2(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1317private void AssignUnscheduledRequestsFIFO(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1349private void AssignUnscheduledRequestsUsingCustomSchedulerForSQL(List<ScheduleResponse> responses, HashSet<int> idleNodes) 1422private void AssignUnscheduledRequestToNode(SchedulableRequest request, int nodeId, List<ScheduleResponse> responses) 1443responses.Add(ScheduleResponse.CreateScheduleResponse(nodeId, request.BuildRequest, mustSendConfigurationToNode)); 1541private bool CreateNewNodeIfPossible(List<ScheduleResponse> responses, IEnumerable<SchedulableRequest> requests) 1636responses.Add(ScheduleResponse.CreateNewNodeResponse(NodeAffinity.InProc, inProcNodesToCreate)); 1667responses.Add(ScheduleResponse.CreateNewNodeResponse(NodeAffinity.OutOfProc, outOfProcNodesToCreate)); 1727private void HandleRequestBlockedOnResultsTransfer(SchedulableRequest parentRequest, List<ScheduleResponse> responses) 1743responses.Add(ScheduleResponse.CreateScheduleResponse(configuration.ResultsNodeId, newRequest, false)); 1755private void HandleRequestBlockedByNewRequests(SchedulableRequest parentRequest, BuildRequestBlocker blocker, List<ScheduleResponse> responses) 1777ScheduleResponse response = TrySatisfyRequestFromCache(nodeForResults, request, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss()); 1876responses.Add(ScheduleResponse.CreateResumeExecutionResponse(parentRequest.AssignedNode, parentRequest.BuildRequest.GlobalRequestId)); 1895private void ResumeReadyRequestIfAny(int nodeId, List<ScheduleResponse> responses) 1904ScheduleResponse response = ScheduleResponse.CreateResumeExecutionResponse(nodeId, request.BuildRequest.GlobalRequestId); 1916private void ResolveRequestFromCacheAndResumeIfPossible(SchedulableRequest request, List<ScheduleResponse> responses) 1921ScheduleResponse response = TrySatisfyRequestFromCache(nodeForResults, request.BuildRequest, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss()); 1930responses.Add(ScheduleResponse.CreateSubmissionCompleteResponse(response.BuildResult)); 1984private void ResumeRequiredWork(List<ScheduleResponse> responses) 2024private ScheduleResponse TrySatisfyRequestFromCache(int nodeForResults, BuildRequest request, bool skippedResultsDoNotCauseCacheMiss) 2038private bool CheckIfCacheMissOnReferencedProjectIsAllowedAndErrorIfNot(int nodeForResults, BuildRequest request, List<ScheduleResponse> responses, bool emitNonErrorLogs) 2094var response = GetResponseForResult(nodeForResults, request, result); 2190private ScheduleResponse GetResponseForResult(int parentRequestNode, BuildRequest requestWhichGeneratedResult, BuildResult result) 2196return ScheduleResponse.CreateSubmissionCompleteResponse(result); 2204return 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)