EOD checkin

samplescripts/.#test3.clj

@@ -0,0 +1 @@
+luke@new-host-2.home.57341

samplescripts/test3.clj

@@ -6,10 +6,9 @@
 
 (pp/pprint (first user/*samples*))
 
-
 (with-data samples
   (view (scatter-plot ($ :start-time) ($ :latency)))
-  (view (histogram ($ :latency))))
+  (view (histogram ($ :latency) :nbins 50)))
 
 
 

samplescripts/test4.clj

@@ -0,0 +1,37 @@
+(ns test4
+  (:use [incanter core stats charts])
+  (:require [clojure.pprint :as pp]))
+
+(pp/pprint (first user/*samples*))
+
+(def my-samples (map (fn [r] (assoc r :threadcount (Integer/parseInt (re-find #"^\d+" (:thread-name r))))) user/*samples*))
+(def samples (dataset (keys (first my-samples)) (drop 3 my-samples)))
+
+
+(println (distinct (map :group-threads my-samples)))
+
+
+(defn report-group [key group]
+  (with-data group
+    (println "key: " key)
+    (println "Count: " (count ($ :latency)))))
+
+(def trimmed-data ($where {:latency {:$lt (first  (quantile ($ :latency samples) :probs [0.99]))}} samples))
+
+(with-data trimmed-data
+
+  (view (scatter-plot ($ :latency) ($ :threadcount) ))
+
+  (let [groups ($group-by [:threadcount])]
+    (doseq [[k v] groups]
+      (report-group k v)))
+
+
+  (println "Groups" (count ($group-by [:group-threads])))
+  (println "Number of samples:" (count ($ :latency)))
+  (println "Quantile of latency:" (quantile ($ :latency) :probs [0.99 0.95 0.9]))
+  (println "Min Latency:" (reduce min ($ :latency)))
+  (println "Max latency:" (reduce max ($ :latency)))
+  (println "Mean latency:" (mean ($ :latency)))
+  (println "Standard deviation:" (sd ($ :latency))))
+

src/perfstats/PerfstatVisualizer.clj

@@ -37,13 +37,15 @@
 
 (extend-type SampleResult
   Sample
-  (to-map [sample] {:start-time (.getStartTime sample)
+  (to-map [sample] {
+                    :start-time (.getStartTime sample)
                     :end-time (.getEndTime sample)
                     :label (.getSampleLabel sample)
                     :successful (.isSuccessful sample)
                     :code (.getResponseCode sample)
                     :url (.getUrlAsString sample)
                     :monitor (.isMonitor sample)
+                    :size (.getBytes sample)
                     :group-threads (.getGroupThreads sample)
                     :thread-name (.getThreadName sample)
                     :latency (.getLatency sample)
@@ -80,7 +82,6 @@
   label)
 
 (defn -clearData [this]
-  (println "current state:" @(.state this))
   (println "clear"))
 
 (defn -init [this]