|
@@ -39,7 +39,7 @@ var (
|
|
|
)
|
|
|
|
|
|
func customScoreFn(si scorerInput) float64 {
|
|
|
- return si.metrics["ipc"] / (si.metrics["mem_read"] + si.metrics["mem_write"])
|
|
|
+ return si.metrics["ipc"] * / (si.metrics["mem_read"] + si.metrics["mem_write"])
|
|
|
}
|
|
|
|
|
|
func onlyIPC(metrics map[string]float64) float64 {
|
|
@@ -166,6 +166,12 @@ func customResourceScorer(nodeName string) (float64, error) {
|
|
|
} else {
|
|
|
res = res * 1
|
|
|
}
|
|
|
+
|
|
|
+
|
|
|
+ //Apply heterogeneity
|
|
|
+ speed := links[nodes[nodeName]][0] * links[nodes[nodeName]][1]
|
|
|
+ res = res*speed
|
|
|
+
|
|
|
// Select Node
|
|
|
|
|
|
klog.Infof("Node name %s, has score %v\n", nodeName, res)
|