[jbosscache-commits] JBoss Cache SVN: r5035 - cache-bench-fwk/trunk/src/org/cachebench/reportgenerators.

[jbosscache-commits at lists.jboss.org]

Author: mircea.markus
Date: 2008-01-07 09:18:23 -0500 (Mon, 07 Jan 2008)
New Revision: 5035

Added:
   cache-bench-fwk/trunk/src/org/cachebench/reportgenerators/CsvStatisticReportGenerator.java
Log:
added session simulator test + refactoring

Added: cache-bench-fwk/trunk/src/org/cachebench/reportgenerators/CsvStatisticReportGenerator.java
===================================================================
--- cache-bench-fwk/trunk/src/org/cachebench/reportgenerators/CsvStatisticReportGenerator.java	                        (rev 0)
+++ cache-bench-fwk/trunk/src/org/cachebench/reportgenerators/CsvStatisticReportGenerator.java	2008-01-07 14:18:23 UTC (rev 5035)
@@ -0,0 +1,106 @@
+package org.cachebench.reportgenerators;
+
+import org.apache.commons.logging.LogFactory;
+import org.apache.commons.math.stat.descriptive.DescriptiveStatistics;
+import org.cachebench.tests.results.StatisticTestResult;
+import org.cachebench.tests.results.TestResult;
+
+import java.io.BufferedWriter;
+import java.io.FileWriter;
+import java.io.IOException;
+
+
+/**
+ * @author Manik Surtani (manik at surtani.org)
+ * @version $Id: CsvStatisticReportGenerator.java,v 1.5 2007/04/18 19:09:31 msurtani Exp $
+ */
+public class CsvStatisticReportGenerator extends CsvBaseReportGenerator
+{
+   public CsvStatisticReportGenerator()
+   {
+      log = LogFactory.getLog(this.getClass());
+   }
+
+   /**
+    * Writes out the report.
+    * The method checkes whether the result is passed or failed. And based on the status would generate the report with
+    * appropriate content. The method also checks whether the report has any foot notes attached to the test case. If
+    * any foot note is found, then its added to the <code>footNotes</code> ArrayList for later processing.
+    */
+   protected void writeTestResult(TestResult results, BufferedWriter writer) throws IOException
+   {
+      StatisticTestResult stResults = (StatisticTestResult) results;
+      log.debug("Writing the Result to the Report");
+      StringBuffer buf = new StringBuffer();
+      if (stResults.isTestPassed())
+      {
+         // This test has pased. Lets add this test results to the report.
+         DescriptiveStatistics putData = stResults.getPutData();
+         DescriptiveStatistics getData = stResults.getGetData();
+
+         buf.append(stResults.getTestName());
+         buf.append(",");
+         buf.append(stResults.getTestTime());
+         buf.append(",");
+         buf.append(stResults.getTestType());
+         buf.append(",");
+         buf.append(stResults.getNumMembers());
+         buf.append(",");
+         buf.append(stResults.getNumThreads());
+         buf.append(",");
+         buf.append(putData.getSum()/1000);
+         buf.append(",");
+         buf.append(getData.getSum()/1000);
+         buf.append(",");
+         buf.append(putData.getMean());
+         buf.append(",");
+         buf.append(getData.getMean());
+         buf.append(",");
+         // medians are the 50th percentile...
+         buf.append(putData.getPercentile(50));
+         buf.append(",");
+         buf.append(getData.getPercentile(50));
+         buf.append(",");
+         buf.append(putData.getStandardDeviation());
+         buf.append(",");
+         buf.append(getData.getStandardDeviation());
+         buf.append(",");
+         buf.append(putData.getMax());
+         buf.append(",");
+         buf.append(getData.getMax());
+         buf.append(",");
+         buf.append(putData.getMin());
+         buf.append(",");
+         buf.append(getData.getMin());
+         buf.append(",");
+         buf.append(stResults.getThroughputTransactionsPerSecond());
+         buf.append(",");
+         buf.append(stResults.getThroughputBytesPerSecond());
+      }
+      else
+      {
+         // This test has failed. Need to add this to the report.
+         buf.append(stResults.getTestName());
+         buf.append(",");
+         buf.append(stResults.getTestTime());
+         buf.append(",");
+         buf.append(stResults.getTestType());
+         buf.append(",");
+         buf.append(stResults.getErrorMsg());
+      }
+
+      // write details of this test to file.
+      writer.write(buf.toString());
+      writer.newLine();
+   }
+
+   protected void writeHeaderLine(BufferedWriter writer) throws IOException
+   {
+      log.debug("Write the Report Header");
+      writer.write("TEST NAME, TEST DATE, TEST TYPE, NUM MEMBERS, NUM THREADS, TOTAL PUT TIME (secs), TOTAL GET TIME (secs), MEAN PUT TIME, MEAN GET TIME, MEDIAN PUT TIME, MEDIAN GET TIME, STANDARD DEVIATION PUT TIME, STANDARD DEVIATION GET TIME, MAX PUT TIME, MAX GET TIME, MIN PUT TIME, MIN GET TIME, THROUGHPUT TRANSACTIONS PER SEC, THROUGHPUT BYTES PER SEC");
+      writer.newLine();
+      log.debug("Complted the Report Header");
+   }
+
+
+}