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)
2622
IEnumerable<
ScheduleResponse
> responses = _scheduler!.ReportRequestBlocked(node, blocker);
2647
IEnumerable<
ScheduleResponse
> response = _scheduler!.ReleaseCores(request.GlobalRequestId, request.NumCores);
2732
IEnumerable<
ScheduleResponse
> response = _scheduler!.ReportResult(node, result);
2880
private void PerformSchedulingActions(IEnumerable<
ScheduleResponse
> responses)
2884
foreach (
ScheduleResponse
response in responses)
2923
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));
1541
private bool CreateNewNodeIfPossible(List<
ScheduleResponse
> responses, IEnumerable<SchedulableRequest> requests)
1636
responses.Add(
ScheduleResponse
.CreateNewNodeResponse(NodeAffinity.InProc, inProcNodesToCreate));
1667
responses.Add(
ScheduleResponse
.CreateNewNodeResponse(NodeAffinity.OutOfProc, outOfProcNodesToCreate));
1727
private void HandleRequestBlockedOnResultsTransfer(SchedulableRequest parentRequest, List<
ScheduleResponse
> responses)
1743
responses.Add(
ScheduleResponse
.CreateScheduleResponse(configuration.ResultsNodeId, newRequest, false));
1755
private void HandleRequestBlockedByNewRequests(SchedulableRequest parentRequest, BuildRequestBlocker blocker, List<
ScheduleResponse
> responses)
1777
ScheduleResponse
response = TrySatisfyRequestFromCache(nodeForResults, request, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss());
1876
responses.Add(
ScheduleResponse
.CreateResumeExecutionResponse(parentRequest.AssignedNode, parentRequest.BuildRequest.GlobalRequestId));
1895
private void ResumeReadyRequestIfAny(int nodeId, List<
ScheduleResponse
> responses)
1904
ScheduleResponse
response =
ScheduleResponse
.CreateResumeExecutionResponse(nodeId, request.BuildRequest.GlobalRequestId);
1916
private void ResolveRequestFromCacheAndResumeIfPossible(SchedulableRequest request, List<
ScheduleResponse
> responses)
1921
ScheduleResponse
response = TrySatisfyRequestFromCache(nodeForResults, request.BuildRequest, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss());
1930
responses.Add(
ScheduleResponse
.CreateSubmissionCompleteResponse(response.BuildResult));
1984
private void ResumeRequiredWork(List<
ScheduleResponse
> responses)
2024
private
ScheduleResponse
TrySatisfyRequestFromCache(int nodeForResults, BuildRequest request, bool skippedResultsDoNotCauseCacheMiss)
2038
private bool CheckIfCacheMissOnReferencedProjectIsAllowedAndErrorIfNot(int nodeForResults, BuildRequest request, List<
ScheduleResponse
> responses, bool emitNonErrorLogs)
2094
var
response = GetResponseForResult(nodeForResults, request, result);
2190
private
ScheduleResponse
GetResponseForResult(int parentRequestNode, BuildRequest requestWhichGeneratedResult, BuildResult result)
2196
return
ScheduleResponse
.CreateSubmissionCompleteResponse(result);
2204
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)