diff options
| author | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2020-02-20 23:28:34 +0100 |
|---|---|---|
| committer | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2020-02-24 17:22:41 +0100 |
| commit | e5345dc2192f88ba1d5949eca60ae505759038e0 (patch) | |
| tree | 8319c193fe960255a21fbda43a12abc6b0378904 /opendc/opendc-experiments-sc18/src | |
| parent | 8d05ee524981bacfe4af4fe0097c935309115481 (diff) | |
[ci skip] feat: Incorporate extensions to workflow scheduler
This change incorporate a number of extensions and improvements to the
workflow scheduler. These are a result of the Design Space Exploration
for Datacenter Schedulers work.
Diffstat (limited to 'opendc/opendc-experiments-sc18/src')
| -rw-r--r-- | opendc/opendc-experiments-sc18/src/main/kotlin/com/atlarge/opendc/experiments/sc18/TestExperiment.kt | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/opendc/opendc-experiments-sc18/src/main/kotlin/com/atlarge/opendc/experiments/sc18/TestExperiment.kt b/opendc/opendc-experiments-sc18/src/main/kotlin/com/atlarge/opendc/experiments/sc18/TestExperiment.kt index 3dc8be51..415221ca 100644 --- a/opendc/opendc-experiments-sc18/src/main/kotlin/com/atlarge/opendc/experiments/sc18/TestExperiment.kt +++ b/opendc/opendc-experiments-sc18/src/main/kotlin/com/atlarge/opendc/experiments/sc18/TestExperiment.kt @@ -31,7 +31,7 @@ import com.atlarge.opendc.format.trace.gwf.GwfTraceReader import com.atlarge.opendc.workflows.monitor.WorkflowMonitor import com.atlarge.opendc.workflows.service.StageWorkflowService import com.atlarge.opendc.workflows.service.WorkflowSchedulerMode -import com.atlarge.opendc.workflows.service.stage.job.FifoJobSortingPolicy +import com.atlarge.opendc.workflows.service.stage.job.SubmissionTimeJobOrderPolicy import com.atlarge.opendc.workflows.service.stage.job.NullJobAdmissionPolicy import com.atlarge.opendc.workflows.service.stage.resource.FirstFitResourceSelectionPolicy import com.atlarge.opendc.workflows.service.stage.resource.FunctionalResourceDynamicFilterPolicy @@ -92,7 +92,7 @@ fun main(args: Array<String>) { environment.platforms[0].zones[0].services[ProvisioningService.Key], mode = WorkflowSchedulerMode.Batch(100), jobAdmissionPolicy = NullJobAdmissionPolicy, - jobSortingPolicy = FifoJobSortingPolicy(), + jobSortingPolicy = SubmissionTimeJobOrderPolicy(), taskEligibilityPolicy = FunctionalTaskEligibilityPolicy(), taskSortingPolicy = FifoTaskSortingPolicy(), resourceDynamicFilterPolicy = FunctionalResourceDynamicFilterPolicy(), |