[jbosscache-commits] JBoss Cache SVN: r5018 - cache-bench-fwk/trunk/src/org/cachebench/reportgenerators.
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!");