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

[jbosscache-commits at lists.jboss.org]

Author: mircea.markus
Date: 2008-01-06 11:54:29 -0500 (Sun, 06 Jan 2008)
New Revision: 5010

Modified:
   cache-bench-fwk/trunk/src/org/cachebench/smartfrog/CacheBenchmarkPrim.java
Log:
we can run tests on multiple cluster configs now

Modified: cache-bench-fwk/trunk/src/org/cachebench/smartfrog/CacheBenchmarkPrim.java
===================================================================
--- cache-bench-fwk/trunk/src/org/cachebench/smartfrog/CacheBenchmarkPrim.java	2008-01-06 16:11:03 UTC (rev 5009)
+++ cache-bench-fwk/trunk/src/org/cachebench/smartfrog/CacheBenchmarkPrim.java	2008-01-06 16:54:29 UTC (rev 5010)
@@ -82,9 +82,16 @@
          log.trace("Entered sfStart...");
          if (clusterSize <= nodeIndex)
          {
-            log.info("Not processing this node" + getNodeDescription());
+            log.info("Not processing this node as compund is smaller than " + nodeIndex + getNodeDescription());
             return;
          }
+         if (clusterSize < minClusterSize || clusterSize > maxClusterSize)
+         {
+            log.info("Only clusters with size in range (" + minClusterSize + ", " + maxClusterSize + ") are " +
+                  "processed, skiping this one" + getNodeDescription());
+            correctTerminationOfTestsIfNeeded();
+            return;
+         }
          String command = scriptToExec + " " + nodeIndex + " " + cacheDistribution + " -DclusterSize=" + clusterSize;
          log.info("Executing command: " + command);
          Process process = Runtime.getRuntime().exec(command, null, toRunIn);