forked from powerapi-ng/powerapi-scala
-
Notifications
You must be signed in to change notification settings - Fork 4
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request powerapi-ng#49 from Spirals-Team/develop
feat: version 3.0 of PowerAPI
- Loading branch information
Showing
241 changed files
with
43,541 additions
and
13 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,17 +1,40 @@ | ||
| *.class | ||
| *.log | ||
| *~ | ||
|
|
||
| # activator specific | ||
| activator* | ||
|
|
||
| # sbt specific | ||
| .cache/ | ||
| .history/ | ||
| .lib/ | ||
| dist/* | ||
| target/ | ||
| lib_managed/ | ||
| src_managed/ | ||
| project/boot/ | ||
| project/plugins/project/ | ||
| *# | ||
| *.iml | ||
| *.ipr | ||
| *.iws | ||
| *.pyc | ||
| *.tm.epoch | ||
| *.vim | ||
| *-shim.sbt | ||
| .idea/ | ||
| /project/plugins/project | ||
| project/boot | ||
| target/ | ||
| /logs | ||
| .cache | ||
| .classpath | ||
| .project | ||
| .settings | ||
|
|
||
| # Scala-IDE specific | ||
| .scala_dependencies | ||
| .worksheet | ||
|
|
||
| #bluecove | ||
| */*/bluecove* | ||
|
|
||
| #tokens | ||
| secrets.tar |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,13 @@ | ||
| language: scala | ||
| scala: | ||
| - 2.11.4 | ||
| script: | ||
| - sbt clean coverage test | ||
| before_install: | ||
| - openssl aes-256-cbc -K $encrypted_48ebb0d1c0b9_key -iv $encrypted_48ebb0d1c0b9_iv | ||
| -in secrets.tar.enc -out secrets.tar -d | ||
| - tar xvf secrets.tar | ||
| after_success: | ||
| - sbt coverageReport | ||
| - sbt coverageAggregate | ||
| - sbt codacyCoverage |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,22 @@ | ||
| name := "powerapi" | ||
|
|
||
| version in ThisBuild := "3.0" | ||
|
|
||
| scalaVersion in ThisBuild := "2.11.4" | ||
|
|
||
| scalacOptions in ThisBuild ++= Seq( | ||
| "-language:reflectiveCalls", | ||
| "-language:implicitConversions", | ||
| "-feature", | ||
| "-deprecation" | ||
| ) | ||
|
|
||
| // Logging | ||
| libraryDependencies in ThisBuild ++= Seq( | ||
| "org.apache.logging.log4j" % "log4j-api" % "2.1", | ||
| "org.apache.logging.log4j" % "log4j-core" % "2.1" | ||
| ) | ||
|
|
||
| parallelExecution in (ThisBuild, Test) := false | ||
|
|
||
| codacyProjectTokenFile := Some("./codacy-token.txt") |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,37 @@ | ||
| name := "powerapi-cli" | ||
|
|
||
| lazy val downloadBluecoveApp = taskKey[File]("download-bluecove-app") | ||
| lazy val downloadBluecoveGplApp = taskKey[File]("download-bluecove-gpl-app") | ||
|
|
||
| downloadBluecoveApp := { | ||
| val locationBluecove = baseDirectory.value / "lib" / "bluecove-2.1.0.jar" | ||
| if(!locationBluecove.getParentFile.exists()) locationBluecove.getParentFile.mkdirs() | ||
| if(!locationBluecove.exists()) IO.download(url("https://bluecove.googlecode.com/files/bluecove-2.1.0.jar"), locationBluecove) | ||
| locationBluecove | ||
| } | ||
|
|
||
| downloadBluecoveGplApp := { | ||
| val locationBluecoveGpl = baseDirectory.value / "lib" / "bluecove-gpl-2.1.0.jar" | ||
| if(!locationBluecoveGpl.getParentFile.exists()) locationBluecoveGpl.getParentFile.mkdirs() | ||
| if(!locationBluecoveGpl.exists()) IO.download(url("https://bluecove.googlecode.com/files/bluecove-gpl-2.1.0.jar"), locationBluecoveGpl) | ||
| locationBluecoveGpl | ||
| } | ||
|
|
||
| mappings in Universal += downloadBluecoveApp.value -> s"lib/${downloadBluecoveApp.value.name}" | ||
|
|
||
| mappings in Universal += downloadBluecoveGplApp.value -> s"lib/${downloadBluecoveGplApp.value.name}" | ||
|
|
||
| mappings in Universal ++= { | ||
| ((file("../") * "README*").get map { | ||
| readmeFile: File => | ||
| readmeFile -> readmeFile.getName | ||
| }) ++ | ||
| ((file("../") * "LICENSE*").get map { | ||
| licenseFile: File => | ||
| licenseFile -> licenseFile.getName | ||
| }) | ||
| } | ||
|
|
||
| scriptClasspath ++= Seq("../conf", "../scripts") | ||
|
|
||
| NativePackagerKeys.executableScriptName := "powerapi" |
216 changes: 216 additions & 0 deletions
216
powerapi-cli/src/main/scala/org/powerapi/app/Application.scala
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,216 @@ | ||
| /* | ||
| * This software is licensed under the GNU Affero General Public License, quoted below. | ||
| * | ||
| * This file is a part of PowerAPI. | ||
| * | ||
| * Copyright (C) 2011-2015 Inria, University of Lille 1. | ||
| * | ||
| * PowerAPI is free software: you can redistribute it and/or modify | ||
| * it under the terms of the GNU Affero General Public License as | ||
| * published by the Free Software Foundation, either version 3 of | ||
| * the License, or (at your option) any later version. | ||
| * | ||
| * PowerAPI is distributed in the hope that it will be useful, | ||
| * but WITHOUT ANY WARRANTY; without even the implied warranty of | ||
| * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | ||
| * GNU Affero General Public License for more details. | ||
| * | ||
| * You should have received a copy of the GNU Affero General Public License | ||
| * along with PowerAPI. | ||
| * | ||
| * If not, please consult http://www.gnu.org/licenses/agpl-3.0.html. | ||
| */ | ||
| package org.powerapi.app | ||
|
|
||
| import java.lang.management.ManagementFactory | ||
|
|
||
| import org.powerapi.core.target.{Application, All, Process, Target} | ||
| import org.powerapi.reporter.{FileDisplay, JFreeChartDisplay, ConsoleDisplay} | ||
| import org.powerapi.{PowerMonitoring, PowerMeter, PowerModule} | ||
| import org.powerapi.core.power._ | ||
| import org.powerapi.module.cpu.dvfs.CpuDvfsModule | ||
| import org.powerapi.module.cpu.simple.CpuSimpleModule | ||
| import org.powerapi.module.libpfm.{LibpfmHelper, LibpfmCoreProcessModule, LibpfmCoreModule} | ||
| import org.powerapi.module.powerspy.PowerSpyModule | ||
| import scala.concurrent.duration.DurationInt | ||
| import scala.sys | ||
| import scala.sys.process.stringSeqToProcess | ||
|
|
||
| /** | ||
| * PowerAPI CLI. | ||
| * | ||
| * @author <a href="mailto:[email protected]">Maxime Colmant</a> | ||
| * @author <a href="mailto:[email protected]">Loïc Huertas</a> | ||
| */ | ||
| object PowerAPI extends App { | ||
| val modulesR = """(cpu-simple|cpu-dvfs|libpfm-core|libpfm-core-process|powerspy)(,(cpu-simple|cpu-dvfs|libpfm-core|libpfm-core-process|powerspy))*""".r | ||
| val aggR = """max|min|geomean|logsum|mean|median|stdev|sum|variance""".r | ||
| val durationR = """\d+""".r | ||
| val pidR = """(\d+)""".r | ||
| val appR = """(.+)""".r | ||
|
|
||
| @volatile var powerMeters = Seq[PowerMeter]() | ||
| @volatile var monitors = Seq[PowerMonitoring]() | ||
|
|
||
| val shutdownHookThread = scala.sys.ShutdownHookThread { | ||
| monitors.foreach(monitor => monitor.cancel()) | ||
| monitors = Seq() | ||
| powerMeters.foreach(powerMeter => powerMeter.shutdown()) | ||
| powerMeters = Seq() | ||
| } | ||
|
|
||
| def validateModules(str: String) = str match { | ||
| case modulesR(_*) => true | ||
| case _ => false | ||
| } | ||
|
|
||
| implicit def modulesStrToPowerModules(str: String): Seq[PowerModule] = { | ||
| (for(module <- str.split(",")) yield { | ||
| module match { | ||
| case "cpu-simple" => CpuSimpleModule() | ||
| case "cpu-dvfs" => CpuDvfsModule() | ||
| case "libpfm-core" => LibpfmCoreModule() | ||
| case "libpfm-core-process" => LibpfmCoreProcessModule() | ||
| case "powerspy" => PowerSpyModule() | ||
| } | ||
| }).toSeq | ||
| } | ||
|
|
||
| def validateAgg(str: String): Boolean = str match { | ||
| case aggR(_*) => true | ||
| case _ => false | ||
| } | ||
|
|
||
| implicit def aggStrToAggFunction(str: String): Seq[Power] => Power = { | ||
| str match { | ||
| case "max" => MAX | ||
| case "min" => MIN | ||
| case "geomean" => GEOMEAN | ||
| case "logsum" => LOGSUM | ||
| case "mean" => MEAN | ||
| case "median" => MEDIAN | ||
| case "stdev" => STDEV | ||
| case "sum" => SUM | ||
| case "variance" => VARIANCE | ||
| } | ||
| } | ||
|
|
||
| def validateDuration(str: String): Boolean = str match { | ||
| case durationR(_*) => true | ||
| case _ => false | ||
| } | ||
|
|
||
| implicit def targetsStrToTargets(str: String): Seq[Target] = { | ||
| val strTargets = if(str.split(",").contains("all")) { | ||
| "all" | ||
| } | ||
| else str | ||
|
|
||
| (for(target <- strTargets.split(",")) yield { | ||
| target match { | ||
| case "" => Process(ManagementFactory.getRuntimeMXBean.getName.split("@")(0).toInt) | ||
| case "all" => All | ||
| case pidR(pid) => Process(pid.toInt) | ||
| case appR(app) => Application(app) | ||
| } | ||
| }).toSeq | ||
| } | ||
|
|
||
| def printHelp(): Unit = { | ||
| val str = | ||
| """ | ||
| |PowerAPI, Spirals Team" | ||
| | | ||
| |Build a software-defined power meter. Do not forget to configure correctly the modules (see the documentation). | ||
| | | ||
| |usage: ./powerapi modules [cpu-simple|cpu-dvfs|libpfm-core|libpfm-core-proces|powerspy, ...] \ | ||
| | monitor --frequency [ms] --targets [pid, ..., app, ...)|all] --agg [max|min|geomean|logsum|mean|median|stdev|sum|variance] --[console,file [filepath],chart] \ | ||
| | duration [s] | ||
| | | ||
| |example: ./powerapi modules cpu-simple monitor --frequency 1000 --targets firefox --agg max --console monitor --targets chrome --agg max --console \ | ||
| | modules powerspy monitor --frequency 1000 --targets all --agg max --console \ | ||
| | duration 30 | ||
| """.stripMargin | ||
|
|
||
| println(str) | ||
| } | ||
|
|
||
| def cli(options: List[Map[Symbol, Any]], duration: String, args: List[String]): (List[Map[Symbol, Any]], String) = args match { | ||
| case Nil => (options, duration) | ||
| case "modules" :: value :: "monitor" :: tail if validateModules(value) => { | ||
| val (remainingArgs, monitors) = cliMonitorsSubcommand(List(), Map(), tail.map(_.toString)) | ||
| cli(options :+ Map('modules -> value, 'monitors -> monitors), duration, remainingArgs) | ||
| } | ||
| case "duration" :: value :: tail if validateDuration(value) => cli(options, value, tail) | ||
| case option :: tail => println(s"unknown cli option $option"); sys.exit(1) | ||
| } | ||
|
|
||
| def cliMonitorsSubcommand(options: List[Map[Symbol, Any]], currentMonitor: Map[Symbol, Any], args: List[String]): (List[String], List[Map[Symbol, Any]]) = args match { | ||
| case Nil => (List(), options :+ currentMonitor) | ||
| case "modules" :: value :: "monitor" :: tail if validateModules(value) => (List("modules", value, "monitor") ++ tail, options :+ currentMonitor) | ||
| case "duration" :: value :: tail if validateDuration(value) => (List("duration", value) ++ tail, options :+ currentMonitor) | ||
| case "monitor" :: tail => cliMonitorsSubcommand(options :+ currentMonitor, Map(), tail) | ||
| case "--frequency" :: value :: tail if validateDuration(value) => cliMonitorsSubcommand(options, currentMonitor ++ Map('frequency -> value), tail) | ||
| case "--targets" :: value :: tail => cliMonitorsSubcommand(options, currentMonitor ++ Map('targets -> value), tail) | ||
| case "--agg" :: value :: tail if validateAgg(value) => cliMonitorsSubcommand(options, currentMonitor ++ Map('agg -> value), tail) | ||
| case "--console" :: tail => cliMonitorsSubcommand(options, currentMonitor ++ Map('console -> "true"), tail) | ||
| case "--file" :: value :: tail => cliMonitorsSubcommand(options, currentMonitor ++ Map('file -> value), tail) | ||
| case "--chart" :: tail => cliMonitorsSubcommand(options, currentMonitor ++ Map('chart -> "true"), tail) | ||
| case option :: tail => println(s"unknown monitor option $option"); sys.exit(1) | ||
| } | ||
|
|
||
| if(args.size == 0) { | ||
| printHelp() | ||
| sys.exit(1) | ||
| } | ||
|
|
||
| else { | ||
| Seq("bash", "scripts/system.bash").! | ||
| val (configuration, duration) = cli(List(), "3600", args.toList) | ||
|
|
||
| for(powerMeterConf <- configuration) { | ||
| val modules = powerMeterConf('modules).toString | ||
| if(modules.contains("libpfm-core") || modules.contains("libpfm-core-process")) LibpfmHelper.init() | ||
|
|
||
| val powerMeter = PowerMeter.loadModule(powerMeterConf('modules).toString: _*) | ||
| powerMeters :+= powerMeter | ||
|
|
||
| for(monitorConf <- powerMeterConf('monitors).asInstanceOf[List[Map[Symbol, Any]]]) { | ||
| val frequency = monitorConf.getOrElse('frequency, "1000").toString.toInt.milliseconds | ||
| val targets: Seq[Target] = monitorConf.getOrElse('targets, "").toString.toLowerCase | ||
| val agg: Seq[Power] => Power = aggStrToAggFunction(monitorConf.getOrElse('agg, "max").toString.toLowerCase) | ||
| val console = monitorConf.getOrElse('console, "").toString | ||
| val file = monitorConf.getOrElse('file, "").toString | ||
| val chart = monitorConf.getOrElse('chart, "").toString | ||
|
|
||
| val monitor = powerMeter.monitor(frequency)(targets: _*)(agg) | ||
| monitors :+= monitor | ||
|
|
||
| if(console != "") { | ||
| val consoleDisplay = new ConsoleDisplay() | ||
| monitor.to(consoleDisplay) | ||
| } | ||
|
|
||
| if(file != "") { | ||
| val fileDisplay = new FileDisplay(file) | ||
| monitor.to(fileDisplay) | ||
| } | ||
|
|
||
| if(chart != "") { | ||
| val chartDisplay = new JFreeChartDisplay() | ||
| monitor.to(chartDisplay) | ||
| } | ||
| } | ||
| } | ||
|
|
||
| Thread.sleep(duration.toInt.seconds.toMillis) | ||
|
|
||
| val isLibpfmInit = configuration.count(powerMeterConf => powerMeterConf('modules).toString.contains("libpfm-core") || powerMeterConf('modules).toString.contains("libpfm-core-process")) != 0 | ||
| if(isLibpfmInit) LibpfmHelper.deinit() | ||
| } | ||
|
|
||
| shutdownHookThread.start() | ||
| shutdownHookThread.join() | ||
| shutdownHookThread.remove() | ||
| sys.exit(0) | ||
| } |
Oops, something went wrong.