Author: mircea.markus Date: 2008-10-06 06:45:52 -0400 (Mon, 06 Oct 2008) New Revision: 6839 Modified: benchmarks/benchmark-fwk/trunk/src/org/cachebench/tests/SessionSimulatorTest.java Log: Modified: benchmarks/benchmark-fwk/trunk/src/org/cachebench/tests/SessionSimulatorTest.java =================================================================== --- benchmarks/benchmark-fwk/trunk/src/org/cachebench/tests/SessionSimulatorTest.java 2008-10-06 10:16:34 UTC (rev 6838) +++ benchmarks/benchmark-fwk/trunk/src/org/cachebench/tests/SessionSimulatorTest.java 2008-10-06 10:45:52 UTC (rev 6839) @@ -146,11 +146,11 @@ log.info("Gathering replication delay"); String key = "registerReplicationDelay"; List<String> path = Arrays.asList(key); - cacheWrapper.put(path, key + getNodeIndex(), "value" + getNodeIndex()); Set received = new HashSet(); int clusterSize = configuration.getClusterConfig().getClusterSize(); while (received.size() < clusterSize) { + cacheWrapper.put(path, key + getNodeIndex(), "value" + getNodeIndex()); for (int i = 0; i < clusterSize; i++) { Object replicatedValue = cacheWrapper.get(path, key + i);