diff --git a/pcp/pcp.go b/pcp/pcp.go index c5e3e04..2d8f51f 100644 --- a/pcp/pcp.go +++ b/pcp/pcp.go @@ -11,8 +11,6 @@ import ( "syscall" "time" "github.com/montanaflynn/stats" - "github.com/mesos/mesos-go/api/v0/mesosproto" - "path/filepath" ) func Start(quit chan struct{}, logging *bool, logMType chan elecLogDef.LogMessageType, logMsg chan string, s scheduler.Scheduler) { @@ -38,7 +36,7 @@ func Start(quit chan struct{}, logging *bool, logMType chan elecLogDef.LogMessag logMsg <- scanner.Text() logMType <- elecLogDef.DEG_COL - logMsg <- fmt.Sprintf("CPU Variance, CPU Task Share Variance, Memory Variance, Memory Task Share Variance") + logMsg <- "CPU Variance, CPU Task Share Variance, Memory Variance, Memory Task Share Variance" // Throw away first set of results scanner.Scan() diff --git a/pcp/utils.go b/pcp/utils.go index 866a8bf..1ef9928 100644 --- a/pcp/utils.go +++ b/pcp/utils.go @@ -50,15 +50,6 @@ func AverageClusterPowerHistory(history *ring.Ring) float64 { return (total / count) } -func sumAndNormalize(tokenSlice []string, normalizer float64) float64 { - sum := 0.0 - for _, value := range tokenSlice { - i, _ := strconv.ParseFloat(value, 64) - sum += i - } - return sum / normalizer -} - func utilization(used string, free string) float64 { u, _ := strconv.ParseFloat(used, 64) f, _ := strconv.ParseFloat(free, 64)