6 instantiations of ScheduleResponse
Microsoft.Build (6)
BackEnd\Components\Scheduler\ScheduleResponse.cs (6)
171
return new
ScheduleResponse
(node, requestToSchedule, sendConfiguration);
182
return new
ScheduleResponse
(node, new BuildRequestUnblocker(resultToReport));
193
return new
ScheduleResponse
(node, new BuildRequestUnblocker(globalRequestIdToResume));
205
return new
ScheduleResponse
(node, parentRequest, requestCausingCircularDependency);
215
return new
ScheduleResponse
(rootRequestResult);
226
return new
ScheduleResponse
(typeOfNodeToCreate, count);
75 references to ScheduleResponse
Microsoft.Build (75)
BackEnd\BuildManager\BuildManager.cs (6)
2615
IEnumerable<
ScheduleResponse
> responses = _scheduler!.ReportRequestBlocked(node, blocker);
2640
IEnumerable<
ScheduleResponse
> response = _scheduler!.ReleaseCores(request.GlobalRequestId, request.NumCores);
2725
IEnumerable<
ScheduleResponse
> response = _scheduler!.ReportResult(node, result);
2873
private void PerformSchedulingActions(IEnumerable<
ScheduleResponse
> responses)
2877
foreach (
ScheduleResponse
response in responses)
2916
IEnumerable<
ScheduleResponse
> newResponses = _scheduler!.ReportNodesCreated(newNodes);
BackEnd\Components\Scheduler\IScheduler.cs (4)
47
IEnumerable<
ScheduleResponse
> ReportRequestBlocked(int nodeId, BuildRequestBlocker blocker);
55
IEnumerable<
ScheduleResponse
> ReportResult(int nodeId, BuildResult result);
62
IEnumerable<
ScheduleResponse
> ReportNodesCreated(IEnumerable<NodeInfo> nodeInfo);
88
List<
ScheduleResponse
> ReleaseCores(int requestId, int coresToRelease);
BackEnd\Components\Scheduler\Scheduler.cs (59)
284
internal delegate void AssignUnscheduledRequestsDelegate(List<
ScheduleResponse
> responses, HashSet<int> idleNodes);
348
public IEnumerable<
ScheduleResponse
> ReportRequestBlocked(int nodeId, BuildRequestBlocker blocker)
351
List<
ScheduleResponse
> responses = new List<
ScheduleResponse
>();
395
responses.Add(
ScheduleResponse
.CreateCircularDependencyResponse(nodeId, parentRequest.BuildRequest, ex.Request));
408
responses.Add(
ScheduleResponse
.CreateCircularDependencyResponse(nodeId, parentRequest.BuildRequest, ex.Request));
421
public IEnumerable<
ScheduleResponse
> ReportResult(int nodeId, BuildResult result)
424
List<
ScheduleResponse
> responses = new List<
ScheduleResponse
>();
433
ScheduleResponse
response =
ScheduleResponse
.CreateReportResultResponse(config.ResultsNodeId, result);
455
ScheduleResponse
response = TrySatisfyRequestFromCache(request.Parent.AssignedNode, request.BuildRequest, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss());
462
response =
ScheduleResponse
.CreateReportResultResponse(request.Parent.AssignedNode, result.Clone());
471
responses.Add(
ScheduleResponse
.CreateSubmissionCompleteResponse(result));
499
ScheduleResponse
response = TrySatisfyRequestFromCache(parentNode, unscheduledRequest.BuildRequest, skippedResultsDoNotCauseCacheMiss: true);
544
public IEnumerable<
ScheduleResponse
> ReportNodesCreated(IEnumerable<NodeInfo> nodeInfos)
569
List<
ScheduleResponse
> responses = new List<
ScheduleResponse
>();
669
public List<
ScheduleResponse
> ReleaseCores(int requestId, int coresToRelease)
674
List<
ScheduleResponse
> responses = new List<
ScheduleResponse
>();
735
private void ScheduleUnassignedRequests(List<
ScheduleResponse
> responses)
854
private void AssignUnscheduledRequestsToNodes(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
980
private void AssignUnscheduledRequestsWithPlanByMostImmediateReferences(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
988
private void AssignUnscheduledRequestsWithPlanByGreatestPlanTime(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
993
private void AssignUnscheduledRequestsWithPlan(List<
ScheduleResponse
> responses, HashSet<int> idleNodes, Func<SchedulingPlan.PlanConfigData, SchedulingPlan.PlanConfigData, bool> comparisonFunction)
1036
private void AssignUnscheduledRequestsByTraversalsFirst(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1045
private void AssignUnscheduledProxyBuildRequestsToInProcNode(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1050
private void AssignUnscheduledRequestsToInProcNode(List<
ScheduleResponse
> responses, HashSet<int> idleNodes, Func<SchedulableRequest, bool> shouldBeScheduled)
1089
private void AssignUnscheduledRequestsWithConfigurationCountLevelling(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1128
private void AssignUnscheduledRequestsWithSmallestFileSize(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1170
private void AssignUnscheduledRequestsWithLargestFileSize(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1212
private void AssignUnscheduledRequestsWithMaxWaitingRequests(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1289
private void AssignUnscheduledRequestsWithMaxWaitingRequests2(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1317
private void AssignUnscheduledRequestsFIFO(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1349
private void AssignUnscheduledRequestsUsingCustomSchedulerForSQL(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1422
private void AssignUnscheduledRequestToNode(SchedulableRequest request, int nodeId, List<
ScheduleResponse
> responses)
1443
responses.Add(
ScheduleResponse
.CreateScheduleResponse(nodeId, request.BuildRequest, mustSendConfigurationToNode));
1539
private bool CreateNewNodeIfPossible(List<
ScheduleResponse
> responses, IEnumerable<SchedulableRequest> requests)
1634
responses.Add(
ScheduleResponse
.CreateNewNodeResponse(NodeAffinity.InProc, inProcNodesToCreate));
1665
responses.Add(
ScheduleResponse
.CreateNewNodeResponse(NodeAffinity.OutOfProc, outOfProcNodesToCreate));
1725
private void HandleRequestBlockedOnResultsTransfer(SchedulableRequest parentRequest, List<
ScheduleResponse
> responses)
1741
responses.Add(
ScheduleResponse
.CreateScheduleResponse(configuration.ResultsNodeId, newRequest, false));
1753
private void HandleRequestBlockedByNewRequests(SchedulableRequest parentRequest, BuildRequestBlocker blocker, List<
ScheduleResponse
> responses)
1775
ScheduleResponse
response = TrySatisfyRequestFromCache(nodeForResults, request, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss());
1872
responses.Add(
ScheduleResponse
.CreateResumeExecutionResponse(parentRequest.AssignedNode, parentRequest.BuildRequest.GlobalRequestId));
1891
private void ResumeReadyRequestIfAny(int nodeId, List<
ScheduleResponse
> responses)
1900
ScheduleResponse
response =
ScheduleResponse
.CreateResumeExecutionResponse(nodeId, request.BuildRequest.GlobalRequestId);
1912
private void ResolveRequestFromCacheAndResumeIfPossible(SchedulableRequest request, List<
ScheduleResponse
> responses)
1917
ScheduleResponse
response = TrySatisfyRequestFromCache(nodeForResults, request.BuildRequest, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss());
1926
responses.Add(
ScheduleResponse
.CreateSubmissionCompleteResponse(response.BuildResult));
1980
private void ResumeRequiredWork(List<
ScheduleResponse
> responses)
2020
private
ScheduleResponse
TrySatisfyRequestFromCache(int nodeForResults, BuildRequest request, bool skippedResultsDoNotCauseCacheMiss)
2034
private bool CheckIfCacheMissOnReferencedProjectIsAllowedAndErrorIfNot(int nodeForResults, BuildRequest request, List<
ScheduleResponse
> responses, bool emitNonErrorLogs)
2090
var
response = GetResponseForResult(nodeForResults, request, result);
2184
private
ScheduleResponse
GetResponseForResult(int parentRequestNode, BuildRequest requestWhichGeneratedResult, BuildResult result)
2190
return
ScheduleResponse
.CreateSubmissionCompleteResponse(result);
2198
return
ScheduleResponse
.CreateReportResultResponse(parentRequestNode, result);
BackEnd\Components\Scheduler\ScheduleResponse.cs (6)
169
public static
ScheduleResponse
CreateScheduleResponse(int node, BuildRequest requestToSchedule, bool sendConfiguration)
180
public static
ScheduleResponse
CreateReportResultResponse(int node, BuildResult resultToReport)
191
public static
ScheduleResponse
CreateResumeExecutionResponse(int node, int globalRequestIdToResume)
203
public static
ScheduleResponse
CreateCircularDependencyResponse(int node, BuildRequest parentRequest, BuildRequest requestCausingCircularDependency)
213
public static
ScheduleResponse
CreateSubmissionCompleteResponse(BuildResult rootRequestResult)
224
public static
ScheduleResponse
CreateNewNodeResponse(NodeAffinity typeOfNodeToCreate, int count)