Author: mircea.markus
Date: 2008-01-06 06:13:52 -0500 (Sun, 06 Jan 2008)
New Revision: 5006
Modified:
cache-bench-fwk/trunk/src/org/cachebench/smartfrog/CacheBenchmarkPrim.java
cache-bench-fwk/trunk/src/org/cachebench/tests/SimpleTest.java
Log:
added some more logging
Modified: cache-bench-fwk/trunk/src/org/cachebench/smartfrog/CacheBenchmarkPrim.java
===================================================================
--- cache-bench-fwk/trunk/src/org/cachebench/smartfrog/CacheBenchmarkPrim.java 2008-01-06
00:37:11 UTC (rev 5005)
+++ cache-bench-fwk/trunk/src/org/cachebench/smartfrog/CacheBenchmarkPrim.java 2008-01-06
11:13:52 UTC (rev 5006)
@@ -106,7 +106,8 @@
int exitValue = process.waitFor();
if (exitValue != 0)
{
- sfTerminate(new TerminationRecord(TerminationRecord.ABNORMAL, "we have
an NOT zero exit code: " + exitValue, null));
+ sfTerminate(new TerminationRecord(TerminationRecord.ABNORMAL, "we have
an NOT zero exit code: " + exitValue
+ + ", originated from " + getNodeDescription(), null));
}
log.debug("Terminating the tests...");
TerminationRecord terminationRecord = new
TerminationRecord(TerminationRecord.NORMAL, "terminated the benchmark " +
Modified: cache-bench-fwk/trunk/src/org/cachebench/tests/SimpleTest.java
===================================================================
--- cache-bench-fwk/trunk/src/org/cachebench/tests/SimpleTest.java 2008-01-06 00:37:11 UTC
(rev 5005)
+++ cache-bench-fwk/trunk/src/org/cachebench/tests/SimpleTest.java 2008-01-06 11:13:52 UTC
(rev 5006)
@@ -30,6 +30,7 @@
protected ExecutorService executor;
private static final int EXECUTOR_SHUTDOWN_TIMEOUT_POLL_SECS = 60;
protected Configuration configuration;
+ protected final int LOG_FREQUENCY = 5000;
protected TestResult performTestWithObjectType(String testCaseName, CacheWrapper
cache, Class valueClass, String testName, int sampleSize, int numThreads) throws
Exception
{
@@ -101,6 +102,7 @@
for (int i = 0; i < sampleSize; i++)
{
+ logOperation(i, "GETS");
final int cycleNumber = i;
Runnable r = new Runnable()
{
@@ -147,6 +149,14 @@
return stats;
}
+ private void logOperation(int i, String s)
+ {
+ if ((i + 1) % LOG_FREQUENCY == 0)
+ {
+ log.info((i + 1) + " " + s + " were performed");
+ }
+ }
+
/**
* @param cache The Cachewrapper on which the bechmark is conducted.
* @param valueClass The value class instance which is going to be inserted into the
Cache.
@@ -165,6 +175,7 @@
for (int i = 0; i < sampleSize; i++)
{
+ logOperation(i,"PUTS");
final int cycleNumber = i;
Runnable r = new Runnable()
{
Show replies by date