spdf/elektron
Archived
1
0
Fork 0
Code Issues 4 Pull requests 1 Projects Releases Packages Wiki Activity

Minor fixes. Updated the README.

Browse source
This commit is contained in:
Renan DelValle 2017-01-03 18:10:05 -05:00
parent 312728a2f6
commit 3f04e4cc4c
2 changed files with 23 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

20
README.md
View file

@ -13,8 +13,9 @@ To Do:
Possible to setup the constants at runtime based on the environment? Possible to setup the constants at runtime based on the environment?
**Requires Performance-Copilot tool pmdumptext to be installed on the **Requires [Performance Co-Pilot](http://pcp.io/) tool pmdumptext to be installed on the
machine on which electron is launched for logging to work** machine on which electron is launched for logging to work and PCP collector agents installed
on the Mesos Agents**
How to run (Use the --help option to get information about other command-line options): How to run (Use the --help option to get information about other command-line options):
@ -37,7 +38,13 @@ Workload schema:
"watts": 50, "watts": 50,
"image": "gouravr/minife:v5", "image": "gouravr/minife:v5",
"cmd": "cd src && mpirun -np 1 miniFE.x -nx 100 -ny 100 -nz 100", "cmd": "cd src && mpirun -np 1 miniFE.x -nx 100 -ny 100 -nz 100",
"inst": 9 "inst": 9,
"class_to_watts" : {
"A": 30.2475289996,
"B": 35.6491229228,
"C": 24.0476734352
}
}, },
{ {
"name": "dgemm", "name": "dgemm",
@ -46,7 +53,12 @@ Workload schema:
"watts": 50, "watts": 50,
"image": "gouravr/dgemm:v2", "image": "gouravr/dgemm:v2",
"cmd": "/./mt-dgemm 1024", "cmd": "/./mt-dgemm 1024",
"inst": 9 "inst": 9,
"class_to_watts" : {
"A": 35.2475289996,
"B": 25.6491229228,
"C": 29.0476734352
}
} }
] ]
``` ```

12
schedulers/bpswClassMapWatts.go
View file

@ -144,7 +144,7 @@ func (s *BPSWClassMapWatts) ResourceOffers(driver sched.SchedulerDriver, offers
tasks := []*mesos.TaskInfo{} tasks := []*mesos.TaskInfo{}
offer_cpu, offer_ram, offer_watts := OfferAgg(offer) offerCPU, offerRAM, offerWatts := OfferAgg(offer)
taken := false taken := false
totalWatts := 0.0 totalWatts := 0.0
@ -168,9 +168,11 @@ func (s *BPSWClassMapWatts) ResourceOffers(driver sched.SchedulerDriver, offers
} }
} }
// Does the task fit // Does the task fit
if (s.ignoreWatts || offer_watts >= (totalWatts+task.ClassToWatts[nodeClass])) && // OR lazy evaluation. If ignore watts is set to true, second statement won't
(offer_cpu >= (totalCPU + task.CPU)) && // be evaluated.
(offer_ram >= (totalRAM + task.RAM)) { if (s.ignoreWatts || (offerWatts >= (totalWatts+task.ClassToWatts[nodeClass]))) &&
(offerCPU >= (totalCPU + task.CPU)) &&
(offerRAM >= (totalRAM + task.RAM)) {
fmt.Println("Watts being used: ", task.ClassToWatts[nodeClass]) fmt.Println("Watts being used: ", task.ClassToWatts[nodeClass])
taken = true taken = true
@ -194,7 +196,7 @@ func (s *BPSWClassMapWatts) ResourceOffers(driver sched.SchedulerDriver, offers
} }
} }
} else { } else {
break // Continue on to next offer break // Continue on to next task
} }
} }
} }