Clean rps sample

samples/scala/comet-live-monitoring/README

@@ -0,0 +1,5 @@
+This app is designed to run on iPhone (but you can also load it in any modern browser).
+
+It display live application performance data. The simplest way to load the application is running:
+
+ab -k -c 100 -n 1000000 http://localhost:9000/load

samples/scala/rps/app/controllers/Application.scala → samples/scala/comet-live-monitoring/app/controllers/Application.scala

@@ -10,16 +10,16 @@ import scala.concurrent.stm._
 
 object Application extends Controller {
 
-  def index = Action {
+  def load = Action {
     SpeedOMeter.countRequest()
-    Ok("from your shell ab -k -c 100 -n 1000000 http://localhost:9000/")
+    Ok("from your shell ab -k -c 100 -n 1000000 http://localhost:9000/load")
   }
 
-  def monitor = Action {
+  def index = Action {
     Ok(views.html.monitor(Runtime.getRuntime().totalMemory()/(1024*1024)))
   }
 
-  def speedMeter = Action {
+  def monitoring = Action {
    Ok.stream(
      Streams.getRequestsPerSecond >-
      Streams.getCPU >-
@@ -29,7 +29,7 @@ object Application extends Controller {
 
   def gc = Action {
     Runtime.getRuntime().gc()
-    Ok("ok")
+    Ok("Done")
   }
 }
 
@@ -73,7 +73,6 @@ object SpeedOMeter {
     }
   }
 
-
   def getSpeed = {
     val current = java.lang.System.currentTimeMillis()
     val (precedent,(count,millis)) = counter.single()

samples/scala/comet-live-monitoring/app/models/CPU.java

@@ -0,0 +1,42 @@
+package models;
+
+import com.sun.management.OperatingSystemMXBean;
+import java.lang.management.*;
+
+public class CPU { 
+
+    private int  availableProcessors = ManagementFactory.getOperatingSystemMXBean().getAvailableProcessors();
+
+    private long lastSystemTime = 0;
+    private long lastProcessCpuTime = 0;
+
+    public synchronized double getCpuUsage() {
+        if(lastSystemTime == 0) {
+            baselineCounters();
+            return 0;
+        }
+
+        long systemTime = System.nanoTime();
+        long processCpuTime = 0;
+
+        if(ManagementFactory.getOperatingSystemMXBean() instanceof OperatingSystemMXBean) {
+            processCpuTime = ((OperatingSystemMXBean)ManagementFactory.getOperatingSystemMXBean()).getProcessCpuTime();
+        }
+
+        double cpuUsage = (double) (processCpuTime - lastProcessCpuTime) / (systemTime - lastSystemTime);
+
+        lastSystemTime = systemTime;
+        lastProcessCpuTime = processCpuTime;
+
+        return cpuUsage / availableProcessors;
+    }
+
+    private void baselineCounters() {
+        lastSystemTime = System.nanoTime();
+
+        if (ManagementFactory.getOperatingSystemMXBean() instanceof OperatingSystemMXBean) {
+            lastProcessCpuTime = ( (OperatingSystemMXBean) ManagementFactory.getOperatingSystemMXBean() ).getProcessCpuTime();
+        }
+    }
+
+}

samples/scala/rps/app/views/monitor.scala.html → samples/scala/comet-live-monitoring/app/views/monitor.scala.html

@@ -1,4 +1,5 @@
 @(totalMemory: Long)
+
 @main("RPS") {
     <script type="text/javascript">
         window.App = { };

samples/scala/rps/conf/routes → samples/scala/comet-live-monitoring/conf/routes

@@ -3,9 +3,9 @@
 # ~~~~
 
 # Home page
-GET     /                           controllers.Application.index()
-GET     /speed-meter                controllers.Application.speedMeter
-GET     /monitor                    controllers.Application.monitor
+GET     /                           controllers.Application.index
+GET     /load                       controllers.Application.load
+GET     /monitoring                 controllers.Application.monitoring
 POST    /gc!                        controllers.Application.gc
 
 # Map static resources from the /public folder to the /assets URL path

samples/scala/rps/project/Build.scala → samples/scala/comet-live-monitoring/project/Build.scala

@@ -4,7 +4,7 @@ import PlayProject._
 
 object ApplicationBuild extends Build {
 
-    val appName         = "cpu"
+    val appName         = "comet-live-monitoring"
     val appVersion      = "1.0"
 
     val appDependencies = Seq(

samples/scala/comet-live-monitoring/project/plugins.sbt

@@ -0,0 +1,8 @@
+// Comment to get more information during initialization
+logLevel := Level.Warn
+
+// The Typesafe repository contains all required dependencies
+resolvers += "Typesafe repository" at "http://repo.typesafe.com/typesafe/releases/"
+
+// Use the Play sbt plugin for Play projects
+addSbtPlugin("play" % "sbt-plugin" % Option(System.getProperty("play.version")).getOrElse("2.0"))

samples/scala/rps/public/javascripts/main.js → samples/scala/comet-live-monitoring/public/javascripts/main.js

@@ -87,7 +87,7 @@
 
         var button = $("button");
         button.className = "gc";
-        button.innerHTML = "GARBAGE RESET";
+        button.innerHTML = "GARBAGE COLLECT";
 
         button.addEventListener("click", function (evt){
             evt.target.className += " touch";
@@ -105,7 +105,7 @@
         document.body.appendChild(button);
 
         var iframe = $("iframe");
-        iframe.src = "/speed-meter";
+        iframe.src = "/monitoring";
         iframe.style.display = "none";
 
         window.message = function (msg) {