6 instantiations of ScheduleResponse
Microsoft.Build (6)
BackEnd\Components\Scheduler\ScheduleResponse.cs (6)
173
return new
ScheduleResponse
(node, requestToSchedule, sendConfiguration);
184
return new
ScheduleResponse
(node, new BuildRequestUnblocker(resultToReport));
195
return new
ScheduleResponse
(node, new BuildRequestUnblocker(globalRequestIdToResume));
207
return new
ScheduleResponse
(node, parentRequest, requestCausingCircularDependency);
217
return new
ScheduleResponse
(rootRequestResult);
228
return new
ScheduleResponse
(typeOfNodeToCreate, count);
127 references to ScheduleResponse
Microsoft.Build (75)
BackEnd\BuildManager\BuildManager.cs (6)
2351
IEnumerable<
ScheduleResponse
> response = _scheduler!.ReportRequestBlocked(node, blocker);
2376
IEnumerable<
ScheduleResponse
> response = _scheduler!.ReleaseCores(request.GlobalRequestId, request.NumCores);
2454
IEnumerable<
ScheduleResponse
> response = _scheduler!.ReportResult(node, result);
2602
private void PerformSchedulingActions(IEnumerable<
ScheduleResponse
> responses)
2606
foreach (
ScheduleResponse
response in responses)
2645
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)
239
internal delegate void AssignUnscheduledRequestsDelegate(List<
ScheduleResponse
> responses, HashSet<int> idleNodes);
303
public IEnumerable<
ScheduleResponse
> ReportRequestBlocked(int nodeId, BuildRequestBlocker blocker)
306
List<
ScheduleResponse
> responses = new List<
ScheduleResponse
>();
350
responses.Add(
ScheduleResponse
.CreateCircularDependencyResponse(nodeId, parentRequest.BuildRequest, ex.Request));
363
responses.Add(
ScheduleResponse
.CreateCircularDependencyResponse(nodeId, parentRequest.BuildRequest, ex.Request));
376
public IEnumerable<
ScheduleResponse
> ReportResult(int nodeId, BuildResult result)
379
List<
ScheduleResponse
> responses = new List<
ScheduleResponse
>();
388
ScheduleResponse
response =
ScheduleResponse
.CreateReportResultResponse(config.ResultsNodeId, result);
410
ScheduleResponse
response = TrySatisfyRequestFromCache(request.Parent.AssignedNode, request.BuildRequest, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss());
417
response =
ScheduleResponse
.CreateReportResultResponse(request.Parent.AssignedNode, result.Clone());
426
responses.Add(
ScheduleResponse
.CreateSubmissionCompleteResponse(result));
453
ScheduleResponse
response = TrySatisfyRequestFromCache(parentNode, unscheduledRequest.BuildRequest, skippedResultsDoNotCauseCacheMiss: true);
486
public IEnumerable<
ScheduleResponse
> ReportNodesCreated(IEnumerable<NodeInfo> nodeInfos)
511
List<
ScheduleResponse
> responses = new List<
ScheduleResponse
>();
610
public List<
ScheduleResponse
> ReleaseCores(int requestId, int coresToRelease)
615
List<
ScheduleResponse
> responses = new List<
ScheduleResponse
>();
676
private void ScheduleUnassignedRequests(List<
ScheduleResponse
> responses)
795
private void AssignUnscheduledRequestsToNodes(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
921
private void AssignUnscheduledRequestsWithPlanByMostImmediateReferences(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
929
private void AssignUnscheduledRequestsWithPlanByGreatestPlanTime(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
934
private void AssignUnscheduledRequestsWithPlan(List<
ScheduleResponse
> responses, HashSet<int> idleNodes, Func<SchedulingPlan.PlanConfigData, SchedulingPlan.PlanConfigData, bool> comparisonFunction)
977
private void AssignUnscheduledRequestsByTraversalsFirst(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
986
private void AssignUnscheduledProxyBuildRequestsToInProcNode(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
991
private void AssignUnscheduledRequestsToInProcNode(List<
ScheduleResponse
> responses, HashSet<int> idleNodes, Func<SchedulableRequest, bool> shouldBeScheduled)
1019
private void AssignUnscheduledRequestsWithConfigurationCountLevelling(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1061
private void AssignUnscheduledRequestsWithSmallestFileSize(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1103
private void AssignUnscheduledRequestsWithLargestFileSize(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1145
private void AssignUnscheduledRequestsWithMaxWaitingRequests(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1222
private void AssignUnscheduledRequestsWithMaxWaitingRequests2(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1250
private void AssignUnscheduledRequestsFIFO(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1282
private void AssignUnscheduledRequestsUsingCustomSchedulerForSQL(List<
ScheduleResponse
> responses, HashSet<int> idleNodes)
1355
private void AssignUnscheduledRequestToNode(SchedulableRequest request, int nodeId, List<
ScheduleResponse
> responses)
1376
responses.Add(
ScheduleResponse
.CreateScheduleResponse(nodeId, request.BuildRequest, mustSendConfigurationToNode));
1474
private bool CreateNewNodeIfPossible(List<
ScheduleResponse
> responses, IEnumerable<SchedulableRequest> requests)
1560
responses.Add(
ScheduleResponse
.CreateNewNodeResponse(NodeAffinity.InProc, 1));
1591
responses.Add(
ScheduleResponse
.CreateNewNodeResponse(NodeAffinity.OutOfProc, outOfProcNodesToCreate));
1651
private void HandleRequestBlockedOnResultsTransfer(SchedulableRequest parentRequest, List<
ScheduleResponse
> responses)
1667
responses.Add(
ScheduleResponse
.CreateScheduleResponse(configuration.ResultsNodeId, newRequest, false));
1679
private void HandleRequestBlockedByNewRequests(SchedulableRequest parentRequest, BuildRequestBlocker blocker, List<
ScheduleResponse
> responses)
1701
ScheduleResponse
response = TrySatisfyRequestFromCache(nodeForResults, request, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss());
1802
responses.Add(
ScheduleResponse
.CreateResumeExecutionResponse(parentRequest.AssignedNode, parentRequest.BuildRequest.GlobalRequestId));
1821
private void ResumeReadyRequestIfAny(int nodeId, List<
ScheduleResponse
> responses)
1830
ScheduleResponse
response =
ScheduleResponse
.CreateResumeExecutionResponse(nodeId, request.BuildRequest.GlobalRequestId);
1842
private void ResolveRequestFromCacheAndResumeIfPossible(SchedulableRequest request, List<
ScheduleResponse
> responses)
1847
ScheduleResponse
response = TrySatisfyRequestFromCache(nodeForResults, request.BuildRequest, skippedResultsDoNotCauseCacheMiss: _componentHost.BuildParameters.SkippedResultsDoNotCauseCacheMiss());
1856
responses.Add(
ScheduleResponse
.CreateSubmissionCompleteResponse(response.BuildResult));
1910
private void ResumeRequiredWork(List<
ScheduleResponse
> responses)
1947
private
ScheduleResponse
TrySatisfyRequestFromCache(int nodeForResults, BuildRequest request, bool skippedResultsDoNotCauseCacheMiss)
1961
private bool CheckIfCacheMissOnReferencedProjectIsAllowedAndErrorIfNot(int nodeForResults, BuildRequest request, List<
ScheduleResponse
> responses, out Action<ILoggingService> emitNonErrorLogs)
2012
var
response = GetResponseForResult(nodeForResults, request, result);
2105
private
ScheduleResponse
GetResponseForResult(int parentRequestNode, BuildRequest requestWhichGeneratedResult, BuildResult result)
2111
return
ScheduleResponse
.CreateSubmissionCompleteResponse(result);
2119
return
ScheduleResponse
.CreateReportResultResponse(parentRequestNode, result);
BackEnd\Components\Scheduler\ScheduleResponse.cs (6)
171
public static
ScheduleResponse
CreateScheduleResponse(int node, BuildRequest requestToSchedule, bool sendConfiguration)
182
public static
ScheduleResponse
CreateReportResultResponse(int node, BuildResult resultToReport)
193
public static
ScheduleResponse
CreateResumeExecutionResponse(int node, int globalRequestIdToResume)
205
public static
ScheduleResponse
CreateCircularDependencyResponse(int node, BuildRequest parentRequest, BuildRequest requestCausingCircularDependency)
215
public static
ScheduleResponse
CreateSubmissionCompleteResponse(BuildResult rootRequestResult)
226
public static
ScheduleResponse
CreateNewNodeResponse(NodeAffinity typeOfNodeToCreate, int count)
Microsoft.Build.Engine.UnitTests (52)
BackEnd\Scheduler_Tests.cs (52)
111
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
129
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
153
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
176
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
183
response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
207
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
227
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
250
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
278
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
302
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
329
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
355
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
398
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, new BuildRequestBlocker(-1, Array.Empty<string>(), new BuildRequest[] { _defaultParentRequest, request1, request2, request3 })));
405
List<
ScheduleResponse
> moreResponses = new List<
ScheduleResponse
>(_scheduler.ReportNodesCreated(nodeInfos));
433
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
463
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
493
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
526
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
550
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
592
List<
ScheduleResponse
> responses = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, new BuildRequestBlocker(-1, Array.Empty<string>(), new BuildRequest[] { _defaultParentRequest, request1, request2, request3 })));
628
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
647
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
667
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
683
List<
ScheduleResponse
> response = new List<
ScheduleResponse
>(_scheduler.ReportRequestBlocked(1, blocker));
686
response = new List<
ScheduleResponse
>(_scheduler.ReportResult(1, result));
855
private void MockPerformSchedulingActions(IEnumerable<
ScheduleResponse
> responses, ref int nodeId, ref bool inProcNodeExists)
858
foreach (
ScheduleResponse
response in responses)
883
List<
ScheduleResponse
> moreResponses = new List<
ScheduleResponse
>(_scheduler.ReportNodesCreated(nodeInfos));