YAO/YAO-scheduler
1
0
Fork 0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-06-07 22:31:55 +00:00
Code Issues Releases Wiki Activity

update

Browse Source
This commit is contained in:
Newnius 2020-06-05 15:35:56 +08:00
parent 6f0a9617e4
commit c879cf0461
1 changed files with 24 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
src/optimizer.go
View File

@ -46,25 +46,31 @@ func (optimizer *Optimizer) init(conf Configuration) {
} }
func (optimizer *Optimizer) feedStats(job string, stats [][]TaskStatus) { func (optimizer *Optimizer) feedStats(job string, stats [][]TaskStatus) {
var UtilsCPU []float64 go func() {
var Mems []float64 var UtilsCPU []float64
var BwRxs []float64 var Mems []float64
var BwTxs []float64 var BwRxs []float64
for _, stat := range stats { var BwTxs []float64
for _, task := range stat { str := strings.Split(job, "-")
UtilsCPU = append(UtilsCPU, task.UtilCPU) if len(str) == 2 {
Mems = append(Mems, task.Mem) jobName := str[0]
BwRxs = append(BwRxs, task.BwRX) for _, stat := range stats {
BwTxs = append(BwTxs, task.BWTx) for _, task := range stat {
UtilsCPU = append(UtilsCPU, task.UtilCPU)
Mems = append(Mems, task.Mem)
BwRxs = append(BwRxs, task.BwRX)
BwTxs = append(BwTxs, task.BWTx)
}
}
optimizer.stats[jobName] = map[string]float64{
"cpu": optimizer.mean(UtilsCPU),
"cpu_std": optimizer.std(UtilsCPU),
"mem": optimizer.max(Mems),
"bw_rx": optimizer.mean(BwRxs),
"bw_tx": optimizer.mean(BwTxs),
}
} }
} }()
optimizer.stats[job] = map[string]float64{
"cpu": optimizer.mean(UtilsCPU),
"cpu_std": optimizer.std(UtilsCPU),
"mem": optimizer.max(Mems),
"bw_rx": optimizer.mean(BwRxs),
"bw_tx": optimizer.mean(BwTxs),
}
} }
func (optimizer *Optimizer) max(values []float64) float64 { func (optimizer *Optimizer) max(values []float64) float64 {