Output csv from stress test run

SignalR · Jan 23, 2012 · 232ae60 · 232ae60
1 parent 47ae6c8
commit 232ae60
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/SignalR.Stress/Program.cs b/SignalR.Stress/Program.cs
@@ -4,6 +4,7 @@
 using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
+using System.IO;
 
 namespace SignalR.Stress
 {
@@ -60,7 +61,7 @@ static void Main(string[] args)
                             bus.Send("a", payload).ContinueWith(task =>
                             {
                                 Interlocked.Exchange(ref _exception, task.Exception);
-                            }, 
+                            },
                             TaskContinuationOptions.OnlyOnFaulted);
 
                             Thread.Sleep(interval);
@@ -74,7 +75,7 @@ static void Main(string[] args)
             },
             TaskCreationOptions.LongRunning);
 
-            MeasureStats();            
+            MeasureStats();
 
             Console.ReadLine();
         }
@@ -126,6 +127,8 @@ public static void MeasureStats()
         {
             _sw.Start();
             _avgCalcStart = DateTime.UtcNow;
+            var resultsPath = Guid.NewGuid().ToString() + ".csv";
+            File.WriteAllText(resultsPath, "Target Rate, RPS, Peak RPS, Avg RPS\n");
 
             _rateTimer = new Timer(_ =>
             {
@@ -172,6 +175,9 @@ public static void MeasureStats()
                     var d3 = Math.Max(0, TotalRate - _avgReceivesPerSecond);
                     Console.WriteLine("Avg RPS: {0:0.000} (diff: {1:0.000} {2:0.00}%)", Math.Min(TotalRate, _avgReceivesPerSecond), d3, d3 * 100.0 / TotalRate);
 
+                    File.AppendAllText(resultsPath, String.Format("{0}, {1}, {2}, {3}\n", TotalRate, _receivesPerSecond, _peakReceivesPerSecond, _avgReceivesPerSecond));
+
+
                     if (recvPerSec < long.MaxValue && recvPerSec > _peakReceivesPerSecond)
                     {
                         Interlocked.Exchange(ref _peakReceivesPerSecond, recvPerSec);