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

Style and naming fixes.

Browse source
This commit is contained in:
Renan DelValle 2017-02-05 14:54:15 -05:00
parent 610c006834
commit 12efaedaa9
1 changed files with 12 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

23
pcp/loganddynamiccap.go
View file

@ -17,7 +17,7 @@ import (
var RAPLUnits = math.Pow(2, -32)
func meanPKG(history *ring.Ring) float64 {
func averageNodePowerHistory(history *ring.Ring) float64 {
total := 0.0
count := 0.0
@ -38,7 +38,8 @@ func meanPKG(history *ring.Ring) float64 {
return (total / count)
}
func meanCluster(history *ring.Ring) float64 {
// TODO: Figure a way to merge this and avgpower
func averageClusterPowerHistory(history *ring.Ring) float64 {
total := 0.0
count := 0.0
@ -95,18 +96,18 @@ func StartPCPLogAndExtremaDynamicCap(quit chan struct{}, logging *bool, prefix s
indexToHost := make(map[int]string)
for i, hostMetric := range headers {
split := strings.Split(hostMetric, ":")
metricSplit := strings.Split(hostMetric, ":")
//log.Printf("%d Host %s: Metric: %s\n", i, split[0], split[1])
if strings.Contains(split[1], "RAPL_ENERGY_PKG") ||
strings.Contains(split[1], "RAPL_ENERGY_DRAM"){
if strings.Contains(metricSplit[1], "RAPL_ENERGY_PKG") ||
strings.Contains(metricSplit[1], "RAPL_ENERGY_DRAM") {
//fmt.Println("Index: ", i)
powerIndexes = append(powerIndexes, i)
indexToHost[i] = split[0]
indexToHost[i] = metricSplit[0]
// Only create one ring per host
if _, ok := powerHistories[split[0]]; !ok{
powerHistories[split[0]] = ring.New(20) // Two PKGS, two DRAM per node, 20 = 5 seconds of tracking
if _, ok := powerHistories[metricSplit[0]]; !ok {
powerHistories[metricSplit[0]] = ring.New(20) // Two PKGS, two DRAM per node, 20 = 5 seconds of tracking
}
}
}
@ -144,7 +145,7 @@ func StartPCPLogAndExtremaDynamicCap(quit chan struct{}, logging *bool, prefix s
clusterPowerHist.Value = clusterPower
clusterPowerHist = clusterPowerHist.Next()
clusterMean := meanCluster(clusterPowerHist)
clusterMean := averageClusterPowerHistory(clusterPowerHist)
log.Printf("Total power: %f, %d Sec Avg: %f", clusterPower, clusterPowerHist.Len(), clusterMean)
@ -156,10 +157,10 @@ func StartPCPLogAndExtremaDynamicCap(quit chan struct{}, logging *bool, prefix s
// TODO: Just keep track of the largest to reduce fron nlogn to n
for name, history := range powerHistories {
histMean := meanPKG(history)
histMean := averageNodePowerHistory(history)
// Consider doing mean calculations using go routines if we need to speed up
victims = append(victims, Victim{Watts: histMean, Host: name})
//log.Printf("host: %s, Avg: %f", name, histMean * RAPLUnits)
}
sort.Sort(VictimSorter(victims)) // Sort by average wattage