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)
2915
IEnumerable<
ScheduleResponse
> responses = _scheduler!.ReportRequestBlocked(node, blocker);
2940
IEnumerable<
ScheduleResponse
> response = _scheduler!.ReleaseCores(request.GlobalRequestId, request.NumCores);
3025
IEnumerable<
ScheduleResponse
> response = _scheduler!.ReportResult(node, result);
3185
private void PerformSchedulingActions(IEnumerable<
ScheduleResponse
> responses)
3189
foreach (
ScheduleResponse
response in responses)
3232
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)
285
internal delegate void AssignUnscheduledRequestsDelegate(List<
ScheduleResponse
> responses, HashSet<int> idleNodes);
349
public IEnumerable<
ScheduleResponse
> ReportRequestBlocked(int nodeId, BuildRequestBlocker blocker)
352
List<
ScheduleResponse
> responses = new List<
ScheduleResponse
>();
396
responses.Add(
ScheduleResponse
.CreateCircularDependencyResponse(nodeId, parentRequest.BuildRequest, ex.Request));
409
responses.Add(
ScheduleResponse
.CreateCircularDependencyResponse(nodeId, parentRequest.BuildRequest, ex.Request));
422
public IEnumerable<
ScheduleResponse
> ReportResult(int nodeId, BuildResult result)
425
List<
ScheduleResponse
> responses = new List<
ScheduleResponse
>();
434
ScheduleResponse
response =
ScheduleResponse
.CreateReportResultResponse(config.ResultsNodeId, result);
456
ScheduleResponse
response = TrySatisfyRequestFromCache(request.Parent.AssignedNode, request.BuildRequest, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss());
463
response =
ScheduleResponse
.CreateReportResultResponse(request.Parent.AssignedNode, result.Clone());
472
responses.Add(
ScheduleResponse
.CreateSubmissionCompleteResponse(result));
500
ScheduleResponse
response = TrySatisfyRequestFromCache(parentNode, unscheduledRequest.BuildRequest, skippedResultsDoNotCauseCacheMiss: true);
545
public IEnumerable<
ScheduleResponse
> ReportNodesCreated(IEnumerable<NodeInfo> nodeInfos)
570
List<
ScheduleResponse
> responses = new List<
ScheduleResponse
>();
670
public List<
ScheduleResponse
> ReleaseCores(int requestId, int coresToRelease)
675
List<
ScheduleResponse
> responses = new List<
ScheduleResponse
>();
736
private void ScheduleUnassignedRequests(List<
ScheduleResponse
> responses)
855
private void AssignUnscheduledRequestsToNodes(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
981
private void AssignUnscheduledRequestsWithPlanByMostImmediateReferences(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
989
private void AssignUnscheduledRequestsWithPlanByGreatestPlanTime(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
994
private void AssignUnscheduledRequestsWithPlan(List<
ScheduleResponse
> responses, HashSet<int> idleNodes, Func<SchedulingPlan.PlanConfigData, SchedulingPlan.PlanConfigData, bool> comparisonFunction)
1037
private void AssignUnscheduledRequestsByTraversalsFirst(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1046
private void AssignUnscheduledProxyBuildRequestsToInProcNode(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1051
private void AssignUnscheduledRequestsToInProcNode(List<
ScheduleResponse
> responses, HashSet<int> idleNodes, Func<SchedulableRequest, bool> shouldBeScheduled)
1090
private void AssignUnscheduledRequestsWithConfigurationCountLevelling(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1129
private void AssignUnscheduledRequestsWithSmallestFileSize(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1171
private void AssignUnscheduledRequestsWithLargestFileSize(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1213
private void AssignUnscheduledRequestsWithMaxWaitingRequests(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1290
private void AssignUnscheduledRequestsWithMaxWaitingRequests2(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1318
private void AssignUnscheduledRequestsFIFO(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1350
private void AssignUnscheduledRequestsUsingCustomSchedulerForSQL(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1423
private void AssignUnscheduledRequestToNode(SchedulableRequest request, int nodeId, List<
ScheduleResponse
> responses)
1444
responses.Add(
ScheduleResponse
.CreateScheduleResponse(nodeId, request.BuildRequest, mustSendConfigurationToNode));
1540
private bool CreateNewNodeIfPossible(List<
ScheduleResponse
> responses, IEnumerable<SchedulableRequest> requests)
1635
responses.Add(
ScheduleResponse
.CreateNewNodeResponse(NodeAffinity.InProc, inProcNodesToCreate));
1666
responses.Add(
ScheduleResponse
.CreateNewNodeResponse(NodeAffinity.OutOfProc, outOfProcNodesToCreate));
1726
private void HandleRequestBlockedOnResultsTransfer(SchedulableRequest parentRequest, List<
ScheduleResponse
> responses)
1742
responses.Add(
ScheduleResponse
.CreateScheduleResponse(configuration.ResultsNodeId, newRequest, false));
1754
private void HandleRequestBlockedByNewRequests(SchedulableRequest parentRequest, BuildRequestBlocker blocker, List<
ScheduleResponse
> responses)
1776
ScheduleResponse
response = TrySatisfyRequestFromCache(nodeForResults, request, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss(), allowedTopLevelTargets: GetIsolationAllowedTopLevelTargets(parentRequest, request));
1873
responses.Add(
ScheduleResponse
.CreateResumeExecutionResponse(parentRequest.AssignedNode, parentRequest.BuildRequest.GlobalRequestId));
1892
private void ResumeReadyRequestIfAny(int nodeId, List<
ScheduleResponse
> responses)
1901
ScheduleResponse
response =
ScheduleResponse
.CreateResumeExecutionResponse(nodeId, request.BuildRequest.GlobalRequestId);
1913
private void ResolveRequestFromCacheAndResumeIfPossible(SchedulableRequest request, List<
ScheduleResponse
> responses)
1918
ScheduleResponse
response = TrySatisfyRequestFromCache(nodeForResults, request.BuildRequest, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss(), allowedTopLevelTargets: GetIsolationAllowedTopLevelTargets(request.Parent, request.BuildRequest));
1927
responses.Add(
ScheduleResponse
.CreateSubmissionCompleteResponse(response.BuildResult));
1981
private void ResumeRequiredWork(List<
ScheduleResponse
> responses)
2021
private
ScheduleResponse
TrySatisfyRequestFromCache(int nodeForResults, BuildRequest request, bool skippedResultsDoNotCauseCacheMiss, IReadOnlyCollection<string> allowedTopLevelTargets = null)
2063
private bool CheckIfCacheMissOnReferencedProjectIsAllowedAndErrorIfNot(int nodeForResults, BuildRequest request, List<
ScheduleResponse
> responses, bool emitNonErrorLogs)
2119
var
response = GetResponseForResult(nodeForResults, request, result);
2213
private
ScheduleResponse
GetResponseForResult(int parentRequestNode, BuildRequest requestWhichGeneratedResult, BuildResult result)
2219
return
ScheduleResponse
.CreateSubmissionCompleteResponse(result);
2227
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)