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

[jbosscache-commits at lists.jboss.org]

Author: mircea.markus
Date: 2008-01-06 18:49:55 -0500 (Sun, 06 Jan 2008)
New Revision: 5018

Modified:
   cache-bench-fwk/trunk/src/org/cachebench/reportgenerators/ClusterReportGenerator.java
Log:


Modified: cache-bench-fwk/trunk/src/org/cachebench/reportgenerators/ClusterReportGenerator.java
===================================================================
--- cache-bench-fwk/trunk/src/org/cachebench/reportgenerators/ClusterReportGenerator.java	2008-01-06 23:05:50 UTC (rev 5017)
+++ cache-bench-fwk/trunk/src/org/cachebench/reportgenerators/ClusterReportGenerator.java	2008-01-06 23:49:55 UTC (rev 5018)
@@ -41,13 +41,22 @@
             log.trace("Received following results: " + results);
             generateReport(barrier.getReceivedMessages());
          }
+         barrierUntilReportIsGenerated();
       } catch (Exception e)
       {
          log.error("Error while generating report!", e);
       }
    }
 
+   private void barrierUntilReportIsGenerated() throws Exception
+   {
+      ClusterBarrier barrier = new ClusterBarrier();
+      barrier.setConfig(this.clusterConfig);
+      barrier.setAcknowledge(true);
+      barrier.barrier("AFTER_REPORT_GENERATED_BARRIER");
+   }
 
+
    private void generateReport(Map<SocketAddress, Object> receivedMessages) throws Exception
    {
       log.trace("Received " + receivedMessages.size() + " results!");