JBoss Cache SVN: r8266 - in core/trunk/src/test/java/org/jboss/cache/profiling: testinternals and 1 other directory.
by jbosscache-commits＠lists.jboss.org
Author: manik.surtani(a)jboss.com
Date: 2009-10-21 11:33:44 -0400 (Wed, 21 Oct 2009)
New Revision: 8266
Modified:
core/trunk/src/test/java/org/jboss/cache/profiling/AbstractProfileTest.java
core/trunk/src/test/java/org/jboss/cache/profiling/ProfileSlaveTest.java
core/trunk/src/test/java/org/jboss/cache/profiling/ProfileTest.java
core/trunk/src/test/java/org/jboss/cache/profiling/testinternals/TaskRunner.java
Log:
Updated perf test internals
Modified: core/trunk/src/test/java/org/jboss/cache/profiling/AbstractProfileTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/profiling/AbstractProfileTest.java 2009-10-21 09:54:32 UTC (rev 8265)
+++ core/trunk/src/test/java/org/jboss/cache/profiling/AbstractProfileTest.java 2009-10-21 15:33:44 UTC (rev 8266)
@@ -33,6 +33,15 @@
cache = null;
}
+ boolean startedInCmdLine = false;
+ String clusterNameOverride = null;
+ protected void initTest() {
+ System.out.println("Setting up test params!");
+ if (startedInCmdLine) {
+ setUp();
+ }
+ }
+
public abstract void testReplSync() throws Exception;
public abstract void testReplAsync() throws Exception;
Modified: core/trunk/src/test/java/org/jboss/cache/profiling/ProfileSlaveTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/profiling/ProfileSlaveTest.java 2009-10-21 09:54:32 UTC (rev 8265)
+++ core/trunk/src/test/java/org/jboss/cache/profiling/ProfileSlaveTest.java 2009-10-21 15:33:44 UTC (rev 8266)
@@ -8,44 +8,66 @@
/**
* Slave to go with ProfileTest. Should be done in a different VM. Can be profiled as well to profile receiving
- * messages.
- * Importnat - make sure you inly enable these tests locally!
+ * messages. Importnat - make sure you inly enable these tests locally!
*
* @author Manik Surtani (<a href="mailto:manik AT jboss DOT org">manik AT jboss DOT org</a>)
* @since 2.1.0
*/
@Test(groups = "profiling", testName = "profiling.ProfileSlaveTest", enabled = false)
-public class ProfileSlaveTest extends AbstractProfileTest
-{
- private void waitForTest() throws Exception
- {
+public class ProfileSlaveTest extends AbstractProfileTest {
+
+ public static void main(String[] args) throws Exception {
+ ProfileSlaveTest pst = new ProfileSlaveTest();
+ pst.startedInCmdLine = true;
+
+ String mode = args[0];
+ try {
+ if (args.length > 1) pst.clusterNameOverride = args[1];
+ if (mode.equals("replsync")) {
+ pst.testReplSync();
+ } else if (mode.equals("replasync")) {
+ pst.testReplAsync();
+ }
+ } finally {
+ pst.tearDown();
+ }
+
+ }
+
+ private void waitForTest() throws Exception {
System.out.println("Slave listening for remote connections. Hit Enter when done.");
System.in.read();
+ if (clusterNameOverride != null) cache.getConfiguration().setClusterName(clusterNameOverride);
}
@Test(enabled = false)
- public void testReplSync() throws Exception
- {
+ public void testReplSync() throws Exception {
+ initTest();
cache.getConfiguration().setNodeLockingScheme(Configuration.NodeLockingScheme.MVCC);
- cache.getConfiguration().setExposeManagementStatistics(true);
+ cache.getConfiguration().setConcurrencyLevel(5000);
cache.start();
+ System.out.println("My Address is " + cache.getLocalAddress());
+ doTest();
waitForTest();
}
+ private void doTest() {
+ // this is here to act as a JProfiler trigger
+ }
+
@Test(enabled = false)
- public void testReplAsync() throws Exception
- {
+ public void testReplAsync() throws Exception {
+ initTest();
cache.getConfiguration().setNodeLockingScheme(Configuration.NodeLockingScheme.MVCC);
cache.getConfiguration().setCacheMode(Configuration.CacheMode.REPL_ASYNC);
cache.getConfiguration().setConcurrencyLevel(5000);
- cache.getConfiguration().setClusterConfig(getJGroupsConfig());
+// cache.getConfiguration().setClusterConfig(getJGroupsConfig());
cache.start();
waitForTest();
}
@Test(enabled = false)
- public void testReplSyncOptimistic() throws Exception
- {
+ public void testReplSyncOptimistic() throws Exception {
cache.getConfiguration().setNodeLockingScheme(Configuration.NodeLockingScheme.OPTIMISTIC);
cache.getConfiguration().setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
cache.start();
@@ -53,8 +75,7 @@
}
@Test(enabled = false)
- public void testReplAsyncOptimistic() throws Exception
- {
+ public void testReplAsyncOptimistic() throws Exception {
cache.getConfiguration().setCacheMode(Configuration.CacheMode.REPL_ASYNC);
cache.getConfiguration().setNodeLockingScheme(Configuration.NodeLockingScheme.OPTIMISTIC);
cache.getConfiguration().setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
@@ -63,8 +84,7 @@
}
@Test(enabled = false)
- public void testReplSyncBR() throws Exception
- {
+ public void testReplSyncBR() throws Exception {
BuddyReplicationConfig brc = new BuddyReplicationConfig();
brc.setEnabled(true);
cache.getConfiguration().setBuddyReplicationConfig(brc);
@@ -72,8 +92,7 @@
}
@Test(enabled = false)
- public void testReplAsyncBR() throws Exception
- {
+ public void testReplAsyncBR() throws Exception {
BuddyReplicationConfig brc = new BuddyReplicationConfig();
brc.setEnabled(true);
cache.getConfiguration().setBuddyReplicationConfig(brc);
@@ -85,8 +104,7 @@
}
@Test(enabled = false)
- public void testReplSyncOptBR() throws Exception
- {
+ public void testReplSyncOptBR() throws Exception {
BuddyReplicationConfig brc = new BuddyReplicationConfig();
brc.setEnabled(true);
cache.getConfiguration().setBuddyReplicationConfig(brc);
@@ -94,8 +112,7 @@
}
@Test(enabled = false)
- public void testReplAsyncOptBR() throws Exception
- {
+ public void testReplAsyncOptBR() throws Exception {
BuddyReplicationConfig brc = new BuddyReplicationConfig();
brc.setEnabled(true);
cache.getConfiguration().setBuddyReplicationConfig(brc);
@@ -103,26 +120,22 @@
}
@Test(enabled = false)
- public void testStateTransfer() throws Exception
- {
+ public void testStateTransfer() throws Exception {
throw new Exception("Implement me");
}
@Test(enabled = false)
- public void testStartup() throws Exception
- {
+ public void testStartup() throws Exception {
throw new Exception("Implement me");
}
@Test(enabled = false)
- public void testCacheLoading() throws Exception
- {
+ public void testCacheLoading() throws Exception {
throw new Exception("Implement me");
}
@Test(enabled = false)
- public void testPassivation() throws Exception
- {
+ public void testPassivation() throws Exception {
throw new Exception("Implement me");
}
}
Modified: core/trunk/src/test/java/org/jboss/cache/profiling/ProfileTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/profiling/ProfileTest.java 2009-10-21 09:54:32 UTC (rev 8265)
+++ core/trunk/src/test/java/org/jboss/cache/profiling/ProfileTest.java 2009-10-21 15:33:44 UTC (rev 8266)
@@ -22,18 +22,17 @@
* <p/>
* Typical usage pattern:
* <p/>
- * 1. Start a single test method in ProfileSlaveTest. This will block until you kill it.
- * 2. Start the corresponding test in this class, with the same name, in a different JVM, and attached to a profiler.
- * 3. Profile away!
+ * 1. Start a single test method in ProfileSlaveTest. This will block until you kill it. 2. Start the corresponding
+ * test in this class, with the same name, in a different JVM, and attached to a profiler. 3. Profile away!
* <p/>
- *
+ * <p/>
* Importnat - make sure you inly enable these tests locally!
+ *
* @author Manik Surtani (<a href="mailto:manik AT jboss DOT org">manik AT jboss DOT org</a>)
* @since 2.1.0
*/
@Test(groups = "profiling", testName = "profiling.ProfileTest", enabled = false)
-public class ProfileTest extends AbstractProfileTest
-{
+public class ProfileTest extends AbstractProfileTest {
/*
Test configuration options
*/
@@ -45,14 +44,32 @@
protected static final int WARMUP_LOOPS = 20000;
protected static final boolean USE_SLEEP = false; // throttle generation a bit
+ protected static final boolean SKIP_WARMUP = true;
+
private List<Fqn> fqns = new ArrayList<Fqn>(MAX_OVERALL_NODES);
Log log = LogFactory.getLog(ProfileTest.class);
+ public static void main(String[] args) throws Exception {
+ ProfileTest pst = new ProfileTest();
+ pst.startedInCmdLine = true;
+
+ String mode = args[0];
+ try {
+ if (args.length > 1) pst.clusterNameOverride = args[1];
+ if (mode.equals("replsync")) {
+ pst.testReplSync();
+ } else if (mode.equals("replasync")) {
+ pst.testReplAsync();
+ }
+ } finally {
+ pst.tearDown();
+ }
+ }
+
@Test(enabled = false)
- public void testLocalModePess() throws Exception
- {
+ public void testLocalModePess() throws Exception {
Configuration cfg = cache.getConfiguration();
cfg.setCacheMode(Configuration.CacheMode.LOCAL);
cfg.setConcurrencyLevel(2000);
@@ -64,42 +81,42 @@
}
@Test(enabled = false)
- public void testLocalModeOpt() throws Exception
- {
+ public void testLocalModeOpt() throws Exception {
cache.getConfiguration().setCacheMode(Configuration.CacheMode.LOCAL);
cache.getConfiguration().setNodeLockingScheme(Configuration.NodeLockingScheme.OPTIMISTIC);
runCompleteTest();
}
@Test(enabled = false)
- public void testReplSync() throws Exception
- {
+ public void testReplSync() throws Exception {
+ initTest();
cache.getConfiguration().setNodeLockingScheme(Configuration.NodeLockingScheme.MVCC);
+ cache.getConfiguration().setSerializationExecutorPoolSize(0);
+ cache.getConfiguration().setConcurrencyLevel(5000);
+
runCompleteTest();
}
@Test(enabled = false)
- public void testReplAsync() throws Exception
- {
+ public void testReplAsync() throws Exception {
+ initTest();
cache.getConfiguration().setNodeLockingScheme(Configuration.NodeLockingScheme.MVCC);
cache.getConfiguration().setCacheMode(Configuration.CacheMode.REPL_ASYNC);
cache.getConfiguration().setSerializationExecutorPoolSize(0);
cache.getConfiguration().setConcurrencyLevel(5000);
- cache.getConfiguration().setClusterConfig(getJGroupsConfig());
+
runCompleteTest();
}
@Test(enabled = false)
- public void testReplSyncOptimistic() throws Exception
- {
+ public void testReplSyncOptimistic() throws Exception {
cache.getConfiguration().setNodeLockingScheme(Configuration.NodeLockingScheme.OPTIMISTIC);
cache.getConfiguration().setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
runCompleteTest();
}
@Test(enabled = false)
- public void testReplAsyncOptimistic() throws Exception
- {
+ public void testReplAsyncOptimistic() throws Exception {
cache.getConfiguration().setCacheMode(Configuration.CacheMode.REPL_ASYNC);
cache.getConfiguration().setNodeLockingScheme(Configuration.NodeLockingScheme.OPTIMISTIC);
cache.getConfiguration().setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
@@ -107,8 +124,7 @@
}
@Test(enabled = false)
- public void testReplSyncBR() throws Exception
- {
+ public void testReplSyncBR() throws Exception {
BuddyReplicationConfig brc = new BuddyReplicationConfig();
brc.setEnabled(true);
cache.getConfiguration().setBuddyReplicationConfig(brc);
@@ -116,8 +132,7 @@
}
@Test(enabled = false)
- public void testReplAsyncBR() throws Exception
- {
+ public void testReplAsyncBR() throws Exception {
BuddyReplicationConfig brc = new BuddyReplicationConfig();
brc.setEnabled(true);
cache.getConfiguration().setBuddyReplicationConfig(brc);
@@ -129,8 +144,7 @@
}
@Test(enabled = false)
- public void testReplSyncOptBR() throws Exception
- {
+ public void testReplSyncOptBR() throws Exception {
BuddyReplicationConfig brc = new BuddyReplicationConfig();
brc.setEnabled(true);
cache.getConfiguration().setBuddyReplicationConfig(brc);
@@ -138,21 +152,19 @@
}
@Test(enabled = false)
- public void testReplAsyncOptBR() throws Exception
- {
+ public void testReplAsyncOptBR() throws Exception {
BuddyReplicationConfig brc = new BuddyReplicationConfig();
brc.setEnabled(true);
cache.getConfiguration().setBuddyReplicationConfig(brc);
testReplAsyncOptimistic();
}
- private void runCompleteTest() throws Exception
- {
+ private void runCompleteTest() throws Exception {
init();
startup();
warmup();
doTest();
-
+ testFinishedMarker();
// wait for user exit
System.in.read();
}
@@ -161,18 +173,15 @@
* Thr following test phases can be profiled individually using triggers in JProfiler.
*/
- protected void init()
- {
+ protected void init() {
long startTime = System.currentTimeMillis();
log.warn("Starting init() phase");
fqns.clear();
- for (int i = 0; i < MAX_OVERALL_NODES; i++)
- {
+ for (int i = 0; i < MAX_OVERALL_NODES; i++) {
Fqn fqn = Generator.createRandomFqn(MAX_DEPTH);
while (fqns.contains(fqn)) fqn = Generator.createRandomFqn(MAX_DEPTH);
- if (i % 10 == 0)
- {
- log.warn("Generated " + i + " fqns");
+ if (i % 10 == 0) {
+ log.trace("Generated " + i + " fqns");
}
fqns.add(fqn);
}
@@ -181,8 +190,7 @@
log.warn("Finished init() phase. " + printDuration(duration));
}
- protected void startup()
- {
+ protected void startup() {
long startTime = System.currentTimeMillis();
log.warn("Starting cache");
cache.start();
@@ -190,18 +198,20 @@
log.warn("Started cache. " + printDuration(duration));
}
- private void warmup() throws InterruptedException
- {
+ private void warmup() throws InterruptedException {
+ if (SKIP_WARMUP) {
+ log.info("Skipping warmup; taking a nap.");
+ Thread.sleep(5000);
+ log.info("Waking up");
+ return;
+ }
long startTime = System.currentTimeMillis();
TaskRunner exec = new TaskRunner(NUM_THREADS);
log.warn("Starting warmup");
// creates all the Fqns since this can be expensive and we don't really want to measure this (for now)
- for (final Fqn f : fqns)
- {
- exec.execute(new Runnable()
- {
- public void run()
- {
+ for (final Fqn f : fqns) {
+ exec.execute(new Runnable() {
+ public void run() {
// this will create the necessary nodes.
cache.put(f, Collections.emptyMap());
}
@@ -209,12 +219,9 @@
}
// loop through WARMUP_LOOPS gets and puts for JVM optimisation
- for (int i = 0; i < WARMUP_LOOPS; i++)
- {
- exec.execute(new Runnable()
- {
- public void run()
- {
+ for (int i = 0; i < WARMUP_LOOPS; i++) {
+ exec.execute(new Runnable() {
+ public void run() {
Fqn f = Generator.getRandomElement(fqns);
cache.get(f, "");
cache.put(f, "k", "v");
@@ -233,8 +240,11 @@
startup();
}
- private void doTest() throws Exception
- {
+ private void testFinishedMarker() {
+ System.out.println("Test finished");
+ }
+
+ private void doTest() throws Exception {
TaskRunner exec = new TaskRunner(NUM_THREADS);
log.warn("Starting test");
int i;
@@ -245,11 +255,9 @@
AtomicLong durationRemoves = new AtomicLong();
long stElapsed = System.nanoTime();
- for (i = 0; i < NUM_OPERATIONS; i++)
- {
+ for (i = 0; i < NUM_OPERATIONS; i++) {
MyRunnable r = null;
- switch (i % 3)
- {
+ switch (i % 3) {
case 0:
r = new Putter(i, durationPuts);
break;
@@ -280,121 +288,105 @@
log.warn("Average REMOVE time: " + printAvg(durationRemoves.get()));
}
- private String printAvg(long totalNanos)
- {
+ private String printAvg(long totalNanos) {
double nOps = (double) (NUM_OPERATIONS / 3);
double avg = ((double) totalNanos) / nOps;
double avgMicros = avg / 1000;
- return avgMicros + " �s";
+ return avgMicros + " �s";
}
- private double toMillis(long nanos)
- {
+ private double toMillis(long nanos) {
return ((double) nanos / (double) 1000000);
}
- enum Mode
- {
+ enum Mode {
PUT, GET, REMOVE
}
- private abstract class MyRunnable implements Runnable
- {
+ private abstract class MyRunnable implements Runnable {
int id;
Mode mode;
AtomicLong duration;
- public void run()
- {
- String k = Generator.getRandomString();
- Fqn f = Generator.getRandomElement(fqns);
- long d = 0, st = 0;
- switch (mode)
- {
- case PUT:
- st = System.nanoTime();
- cache.put(f, k, Generator.getRandomString());
- d = System.nanoTime() - st;
- break;
- case GET:
- st = System.nanoTime();
- cache.get(f, k);
- d = System.nanoTime() - st;
- break;
- case REMOVE:
- st = System.nanoTime();
- cache.remove(f, k);
- d = System.nanoTime() - st;
- break;
+ public void run() {
+ try {
+ String k = Generator.getRandomString();
+ Fqn f = Generator.getRandomElement(fqns);
+ long d = 0, st = 0;
+ switch (mode) {
+ case PUT:
+ st = System.nanoTime();
+ cache.put(f, k, Generator.getRandomString());
+ d = System.nanoTime() - st;
+ break;
+ case GET:
+ st = System.nanoTime();
+ cache.get(f, k);
+ d = System.nanoTime() - st;
+ break;
+ case REMOVE:
+ st = System.nanoTime();
+ cache.remove(f, k);
+ d = System.nanoTime() - st;
+ break;
+ }
+ duration.getAndAdd(d);
+ } catch (Exception e) {
+ log.warn("Caught ", e);
}
- duration.getAndAdd(d);
}
}
- private class Putter extends MyRunnable
- {
- private Putter(int id, AtomicLong duration)
- {
+ private class Putter extends MyRunnable {
+ private Putter(int id, AtomicLong duration) {
this.id = id;
this.duration = duration;
mode = Mode.PUT;
}
}
- private class Getter extends MyRunnable
- {
- private Getter(int id, AtomicLong duration)
- {
+ private class Getter extends MyRunnable {
+ private Getter(int id, AtomicLong duration) {
this.id = id;
this.duration = duration;
mode = Mode.GET;
}
}
- private class Remover extends MyRunnable
- {
- private Remover(int id, AtomicLong duration)
- {
+ private class Remover extends MyRunnable {
+ private Remover(int id, AtomicLong duration) {
this.id = id;
this.duration = duration;
mode = Mode.REMOVE;
}
}
- protected String printDuration(long duration)
- {
- if (duration > 2000)
- {
+ protected String printDuration(long duration) {
+ if (duration > 2000) {
double dSecs = ((double) duration / (double) 1000);
return "Duration: " + dSecs + " seconds";
- }
- else
- {
+ } else {
return "Duration: " + duration + " millis";
}
}
@Test(enabled = false)
- public void testStateTransfer() throws Exception
- {
+ public void testStateTransfer() throws Exception {
throw new Exception("Implement me");
}
@Test(enabled = false)
- public void testStartup() throws Exception
- {
+ public void testStartup() throws Exception {
throw new Exception("Implement me");
}
@Test(enabled = false)
- public void testCacheLoading() throws Exception
- {
+ public void testCacheLoading() throws Exception {
throw new Exception("Implement me");
}
@Test(enabled = false)
- public void testPassivation() throws Exception
- {
+ public void testPassivation() throws Exception {
throw new Exception("Implement me");
}
}
Modified: core/trunk/src/test/java/org/jboss/cache/profiling/testinternals/TaskRunner.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/profiling/testinternals/TaskRunner.java 2009-10-21 09:54:32 UTC (rev 8265)
+++ core/trunk/src/test/java/org/jboss/cache/profiling/testinternals/TaskRunner.java 2009-10-21 15:33:44 UTC (rev 8266)
@@ -2,7 +2,9 @@
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
+import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicInteger;
/**
* Essentially a delegate to an ExecutorService, but a special one that is only used by perf tests so it can be ignored
@@ -14,7 +16,13 @@
public TaskRunner(int numThreads)
{
- this.exec = Executors.newFixedThreadPool(numThreads);
+ final ThreadGroup tg = new ThreadGroup(Thread.currentThread().getThreadGroup(), "LoadGenerators");
+ final AtomicInteger ai = new AtomicInteger(1);
+ this.exec = Executors.newFixedThreadPool(numThreads, new ThreadFactory() {
+ public Thread newThread(Runnable r) {
+ return new Thread(tg, r, "LoadGenerator-" + ai.getAndIncrement());
+ }
+ });
}
public void execute(Runnable r)
15 years, 2 months
JBoss Cache SVN: r8265 - benchmarks/benchmark-fwk/trunk/src/org/cachebench/tests.
by jbosscache-commits＠lists.jboss.org
Author: mircea.markus
Date: 2009-10-21 05:54:32 -0400 (Wed, 21 Oct 2009)
New Revision: 8265
Modified:
benchmarks/benchmark-fwk/trunk/src/org/cachebench/tests/SessionSimulatorTest.java
Log:
more accurate progress logging
Modified: benchmarks/benchmark-fwk/trunk/src/org/cachebench/tests/SessionSimulatorTest.java
===================================================================
--- benchmarks/benchmark-fwk/trunk/src/org/cachebench/tests/SessionSimulatorTest.java 2009-10-21 09:42:24 UTC (rev 8264)
+++ benchmarks/benchmark-fwk/trunk/src/org/cachebench/tests/SessionSimulatorTest.java 2009-10-21 09:54:32 UTC (rev 8265)
@@ -91,7 +91,6 @@
AtomicLong durationNanos = new AtomicLong(0);
for (int i = 0; i < numberOfRequests; i++)
{
- logRunCount(i);
randomAction = r.nextInt(100);
randomAttribute = r.nextInt(numberOfAttributes - 1);
byte[] buf;
@@ -102,13 +101,13 @@
if (randomAction < readPercentage)
{
// read
- ex.execute(new ReadTask(path, durationNanos, sessionEntry));
+ ex.execute(new ReadTask(path, durationNanos, sessionEntry, i));
reads++;
}
else
{
// write
- ex.execute(new WriteTask(path, durationNanos, sessionEntry));
+ ex.execute(new WriteTask(path, durationNanos, sessionEntry, i));
writes++;
}
}
@@ -242,20 +241,22 @@
List<String> path;
AtomicLong durationNanos;
Object sessionEntry;
+ int taskNumber;
- protected Task(List<String> path, AtomicLong durationNanos, Object sessionEntry)
+ protected Task(List<String> path, AtomicLong durationNanos, Object sessionEntry, int taskNumber)
{
this.path = path;
this.durationNanos = durationNanos;
this.sessionEntry = sessionEntry;
+ this.taskNumber = taskNumber;
}
}
private class WriteTask extends Task
{
- protected WriteTask(List<String> path, AtomicLong durationNanos, Object sessionEntry)
+ protected WriteTask(List<String> path, AtomicLong durationNanos, Object sessionEntry, int i)
{
- super(path, durationNanos, sessionEntry);
+ super(path, durationNanos, sessionEntry, i);
}
public void run()
@@ -271,15 +272,17 @@
catch (Throwable e)
{
log.warn("Error appeared whilst writing to cache:" + e.getMessage(), e);
+ } finally {
+ logRunCount(taskNumber);
}
}
}
private class ReadTask extends Task
{
- protected ReadTask(List<String> path, AtomicLong durationNanos, Object sessionEntry)
+ protected ReadTask(List<String> path, AtomicLong durationNanos, Object sessionEntry, int i)
{
- super(path, durationNanos, sessionEntry);
+ super(path, durationNanos, sessionEntry, i);
}
public void run()
@@ -294,6 +297,8 @@
catch (Throwable e)
{
log.warn("Error appeared whilst reading from cache:" + e.getMessage(), e);
+ } finally {
+ logRunCount(taskNumber);
}
}
}
15 years, 2 months
JBoss Cache SVN: r8264 - in benchmarks/benchmark-fwk/trunk/cache-products: jbosscache-3.1.0/conf and 1 other directory.
by jbosscache-commits＠lists.jboss.org
Author: mircea.markus
Date: 2009-10-21 05:42:24 -0400 (Wed, 21 Oct 2009)
New Revision: 8264
Added:
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/async_tcp_ispn.xml
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/async_udp_ispn.xml
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-async-l1.xml
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-async-nol1.xml
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-async-l1.xml
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-async-nol1.xml
Removed:
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp_mping_ispn.xml
Modified:
benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-3.1.0/conf/pess-repl-async.xml
Log:
added async configs
Added: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/async_tcp_ispn.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/async_tcp_ispn.xml (rev 0)
+++ benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/async_tcp_ispn.xml 2009-10-21 09:42:24 UTC (rev 8264)
@@ -0,0 +1,71 @@
+<!--
+ TCP based stack, with flow control and message bundling. This is usually used when IP
+ multicasting cannot be used in a network, e.g. because it is disabled (routers discard multicast).
+ Note that TCP.bind_addr and TCPPING.initial_hosts should be set, possibly via system properties, e.g.
+ -Djgroups.bind_addr=192.168.5.2 and -Djgroups.tcpping.initial_hosts=192.168.5.2[7800]
+ author: Bela Ban
+ version: $Id: tcp.xml,v 1.32 2009/07/20 12:28:22 belaban Exp $
+-->
+<config xmlns="urn:org:jgroups"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="urn:org:jgroups file:schema/JGroups-2.8.xsd">
+ <TCP bind_port="7800"
+ loopback="true"
+ recv_buf_size="${tcp.recv_buf_size:20000000}"
+ send_buf_size="${tcp.send_buf_size:640000}"
+ discard_incompatible_packets="true"
+ max_bundle_size="64000"
+ max_bundle_timeout="30"
+ enable_bundling="true"
+ use_send_queues="false"
+ sock_conn_timeout="300"
+ skip_suspected_members="true"
+
+ thread_pool.enabled="true"
+ thread_pool.min_threads="1"
+ thread_pool.max_threads="10"
+ thread_pool.keep_alive_time="5000"
+ thread_pool.queue_enabled="false"
+ thread_pool.queue_max_size="100"
+ thread_pool.rejection_policy="run"
+
+ oob_thread_pool.enabled="true"
+ oob_thread_pool.min_threads="1"
+ oob_thread_pool.max_threads="8"
+ oob_thread_pool.keep_alive_time="5000"
+ oob_thread_pool.queue_enabled="false"
+ oob_thread_pool.queue_max_size="100"
+ oob_thread_pool.rejection_policy="run"/>
+
+ <!--<MPING timeout="4000"-->
+ <!--receive_on_all_interfaces="true"-->
+ <!--mcast_addr="228.8.8.8"-->
+ <!--mcast_port="7500"-->
+ <!--ip_ttl="8"-->
+ <!--num_initial_members="2"-->
+ <!--num_ping_requests="1"/>-->
+ <!---->
+
+ <FILE_PING location="file_ping_dir"/>
+ <MERGE2 max_interval="30000"
+ min_interval="10000"/>
+ <FD_SOCK/>
+ <FD timeout="10000" max_tries="5" />
+ <VERIFY_SUSPECT timeout="1500" />
+ <BARRIER />
+ <pbcast.NAKACK
+ use_mcast_xmit="false" gc_lag="0"
+ retransmit_timeout="300,600,1200,2400,4800"
+ discard_delivered_msgs="true"/>
+ <UNICAST timeout="300,600,1200" />
+ <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
+ max_bytes="400000"/>
+ <pbcast.GMS print_local_addr="true" join_timeout="3000"
+
+ view_bundling="true"/>
+ <FC max_credits="2000000"
+ min_threshold="0.10"/>
+ <FRAG2 frag_size="60000" />
+ <pbcast.STREAMING_STATE_TRANSFER/>
+ <pbcast.FLUSH timeout="0"/>
+</config>
\ No newline at end of file
Added: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/async_udp_ispn.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/async_udp_ispn.xml (rev 0)
+++ benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/async_udp_ispn.xml 2009-10-21 09:42:24 UTC (rev 8264)
@@ -0,0 +1,69 @@
+
+<!--
+ Default stack using IP multicasting. It is similar to the "udp"
+ stack in stacks.xml, but doesn't use streaming state transfer and flushing
+ author: Bela Ban
+ version: $Id: udp.xml,v 1.33 2009/08/28 09:04:07 belaban Exp $
+-->
+
+<config xmlns="urn:org:jgroups"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="urn:org:jgroups file:schema/JGroups-2.8.xsd">
+ <UDP
+ mcast_addr="${jgroups.udp.mcast_addr:232.10.10.10}"
+ mcast_port="${jgroups.udp.mcast_port:45588}"
+ tos="8"
+ ucast_recv_buf_size="20000000"
+ ucast_send_buf_size="640000"
+ mcast_recv_buf_size="25000000"
+ mcast_send_buf_size="640000"
+ loopback="false"
+ discard_incompatible_packets="true"
+ max_bundle_size="64000"
+ max_bundle_timeout="30"
+ ip_ttl="${jgroups.udp.ip_ttl:2}"
+ enable_bundling="true"
+ enable_diagnostics="false"
+ thread_naming_pattern="cl"
+
+ thread_pool.enabled="true"
+ thread_pool.min_threads="2"
+ thread_pool.max_threads="8"
+ thread_pool.keep_alive_time="5000"
+ thread_pool.queue_enabled="true"
+ thread_pool.queue_max_size="10000"
+ thread_pool.rejection_policy="discard"
+
+ oob_thread_pool.enabled="true"
+ oob_thread_pool.min_threads="1"
+ oob_thread_pool.max_threads="8"
+ oob_thread_pool.keep_alive_time="5000"
+ oob_thread_pool.queue_enabled="false"
+ oob_thread_pool.queue_max_size="100"
+ oob_thread_pool.rejection_policy="Run"/>
+
+ <FILE_PING location="file_ping_dir"/>
+ <MERGE2 max_interval="30000"
+ min_interval="10000"/>
+ <FD_SOCK/>
+ <FD_ALL/>
+ <VERIFY_SUSPECT timeout="1500" />
+ <BARRIER />
+ <pbcast.NAKACK use_stats_for_retransmission="false"
+ exponential_backoff="0"
+ use_mcast_xmit="true" gc_lag="0"
+ retransmit_timeout="50,300,600,1200"
+ discard_delivered_msgs="true"/>
+ <UNICAST timeout="300,600,1200"/>
+ <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
+ max_bytes="1000000"/>
+ <pbcast.GMS print_local_addr="true" join_timeout="3000"
+
+ view_bundling="true"/>
+ <FC max_credits="500000"
+ min_threshold="0.20"/>
+ <FRAG2 frag_size="60000" />
+ <!--pbcast.STREAMING_STATE_TRANSFER /-->
+ <pbcast.STATE_TRANSFER />
+ <pbcast.FLUSH />
+</config>
Added: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-async-l1.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-async-l1.xml (rev 0)
+++ benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-async-l1.xml 2009-10-21 09:42:24 UTC (rev 8264)
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<infinispan xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="urn:infinispan:config:4.0">
+
+ <global>
+
+ <transport clusterName="infinispan-cluster">
+ <properties>
+ <property name="configurationFile" value="async_tcp_ispn.xml"/>
+ </properties>
+ </transport>
+ </global>
+
+ <default>
+ <locking
+ lockAcquisitionTimeout="120000"
+ concurrencyLevel="10000"/>
+ <transaction
+ transactionManagerLookupClass="org.infinispan.transaction.lookup.GenericTransactionManagerLookup"
+ syncRollbackPhase="false"
+ syncCommitPhase="false"/>
+
+ <clustering mode="distribution">
+ <async/>
+ <hash numOwners="2" rehashWait="120000" rehashRpcTimeout="600000"/>
+ <l1 enabled="true" lifespan="600000"/>
+ </clustering>
+ </default>
+
+</infinispan>
Copied: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-async-nol1.xml (from rev 8262, benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-nol1.xml)
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-async-nol1.xml (rev 0)
+++ benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-async-nol1.xml 2009-10-21 09:42:24 UTC (rev 8264)
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<infinispan xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="urn:infinispan:config:4.0">
+
+ <global>
+
+ <transport clusterName="infinispan-cluster">
+ <properties>
+ <property name="configurationFile" value="async_tcp_ispn.xml"/>
+ </properties>
+ </transport>
+ </global>
+
+ <default>
+ <locking
+ lockAcquisitionTimeout="120000"
+ concurrencyLevel="10000"/>
+ <transaction
+ transactionManagerLookupClass="org.infinispan.transaction.lookup.GenericTransactionManagerLookup"
+ syncRollbackPhase="false"
+ syncCommitPhase="false"/>
+
+ <clustering mode="distribution">
+ <async/>
+ <hash numOwners="2" rehashWait="120000" rehashRpcTimeout="600000"/>
+ <l1 enabled="false" lifespan="600000"/>
+ </clustering>
+ </default>
+
+</infinispan>
Deleted: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp_mping_ispn.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp_mping_ispn.xml 2009-10-21 09:25:11 UTC (rev 8263)
+++ benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp_mping_ispn.xml 2009-10-21 09:42:24 UTC (rev 8264)
@@ -1,71 +0,0 @@
-<!--
- TCP based stack, with flow control and message bundling. This is usually used when IP
- multicasting cannot be used in a network, e.g. because it is disabled (routers discard multicast).
- Note that TCP.bind_addr and TCPPING.initial_hosts should be set, possibly via system properties, e.g.
- -Djgroups.bind_addr=192.168.5.2 and -Djgroups.tcpping.initial_hosts=192.168.5.2[7800]
- author: Bela Ban
- version: $Id: tcp.xml,v 1.32 2009/07/20 12:28:22 belaban Exp $
--->
-<config xmlns="urn:org:jgroups"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="urn:org:jgroups file:schema/JGroups-2.8.xsd">
- <TCP bind_port="7800"
- loopback="true"
- recv_buf_size="${tcp.recv_buf_size:20000000}"
- send_buf_size="${tcp.send_buf_size:640000}"
- discard_incompatible_packets="true"
- max_bundle_size="64000"
- max_bundle_timeout="30"
- enable_bundling="false"
- use_send_queues="false"
- sock_conn_timeout="300"
- skip_suspected_members="true"
-
- thread_pool.enabled="true"
- thread_pool.min_threads="1"
- thread_pool.max_threads="10"
- thread_pool.keep_alive_time="5000"
- thread_pool.queue_enabled="false"
- thread_pool.queue_max_size="100"
- thread_pool.rejection_policy="run"
-
- oob_thread_pool.enabled="true"
- oob_thread_pool.min_threads="1"
- oob_thread_pool.max_threads="8"
- oob_thread_pool.keep_alive_time="5000"
- oob_thread_pool.queue_enabled="false"
- oob_thread_pool.queue_max_size="100"
- oob_thread_pool.rejection_policy="run"/>
-
- <!--<MPING timeout="4000"-->
- <!--receive_on_all_interfaces="true"-->
- <!--mcast_addr="228.8.8.8"-->
- <!--mcast_port="7500"-->
- <!--ip_ttl="8"-->
- <!--num_initial_members="2"-->
- <!--num_ping_requests="1"/>-->
- <!---->
-
- <FILE_PING location="file_ping_dir"/>
- <MERGE2 max_interval="30000"
- min_interval="10000"/>
- <FD_SOCK/>
- <FD timeout="10000" max_tries="5" />
- <VERIFY_SUSPECT timeout="1500" />
- <BARRIER />
- <pbcast.NAKACK
- use_mcast_xmit="false" gc_lag="0"
- retransmit_timeout="300,600,1200,2400,4800"
- discard_delivered_msgs="true"/>
- <UNICAST timeout="300,600,1200" />
- <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
- max_bytes="400000"/>
- <pbcast.GMS print_local_addr="true" join_timeout="3000"
-
- view_bundling="true"/>
- <FC max_credits="2000000"
- min_threshold="0.10"/>
- <FRAG2 frag_size="60000" />
- <pbcast.STREAMING_STATE_TRANSFER/>
- <pbcast.FLUSH timeout="0"/>
-</config>
\ No newline at end of file
Added: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-async-l1.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-async-l1.xml (rev 0)
+++ benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-async-l1.xml 2009-10-21 09:42:24 UTC (rev 8264)
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<infinispan xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="urn:infinispan:config:4.0">
+
+ <global>
+
+ <transport clusterName="infinispan-cluster">
+ <properties>
+ <property name="configurationFile" value="async_udp_ispn.xml"/>
+ </properties>
+ </transport>
+ </global>
+
+ <default>
+ <locking
+ lockAcquisitionTimeout="120000"
+ concurrencyLevel="10000"/>
+ <transaction
+ transactionManagerLookupClass="org.infinispan.transaction.lookup.GenericTransactionManagerLookup"
+ syncRollbackPhase="false"
+ syncCommitPhase="false"/>
+
+ <clustering mode="distribution">
+ <async/>
+ <hash numOwners="2" rehashWait="120000" rehashRpcTimeout="600000"/>
+ <l1 enabled="true" lifespan="600000"/>
+ </clustering>
+ </default>
+
+</infinispan>
Added: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-async-nol1.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-async-nol1.xml (rev 0)
+++ benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-async-nol1.xml 2009-10-21 09:42:24 UTC (rev 8264)
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<infinispan xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="urn:infinispan:config:4.0">
+
+ <global>
+
+ <transport clusterName="infinispan-cluster">
+ <properties>
+ <property name="configurationFile" value="async_udp_ispn.xml"/>
+ </properties>
+ </transport>
+ </global>
+
+ <default>
+ <locking
+ lockAcquisitionTimeout="120000"
+ concurrencyLevel="10000"/>
+ <transaction
+ transactionManagerLookupClass="org.infinispan.transaction.lookup.GenericTransactionManagerLookup"
+ syncRollbackPhase="false"
+ syncCommitPhase="false"/>
+
+ <clustering mode="distribution">
+ <async/>
+ <hash numOwners="2" rehashWait="120000" rehashRpcTimeout="600000"/>
+ <l1 enabled="false"/>
+ </clustering>
+ </default>
+
+</infinispan>
Modified: benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-3.1.0/conf/pess-repl-async.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-3.1.0/conf/pess-repl-async.xml 2009-10-21 09:25:11 UTC (rev 8263)
+++ benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-3.1.0/conf/pess-repl-async.xml 2009-10-21 09:42:24 UTC (rev 8264)
@@ -1,5 +1,5 @@
<?xml version="1.0" encoding="UTF-8"?>
-<jbosscache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="urn:jboss:jbosscache-core:config:3.0">
+<jbosscache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="urn:jboss:jbosscache-core:config:3.1">
<locking isolationLevel="REPEATABLE_READ" lockAcquisitionTimeout="10000" nodeLockingScheme="pessimistic"/>
<transaction transactionManagerLookupClass="org.jboss.cache.transaction.GenericTransactionManagerLookup"/>
<clustering clusterName="JBossCache-Cluster">
15 years, 2 months
JBoss Cache SVN: r8263 - benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-3.1.0/conf.
by jbosscache-commits＠lists.jboss.org
Author: mircea.markus
Date: 2009-10-21 05:25:11 -0400 (Wed, 21 Oct 2009)
New Revision: 8263
Modified:
benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-3.1.0/conf/mvcc-repl-sync.xml
Log:
increased replication timeout
Modified: benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-3.1.0/conf/mvcc-repl-sync.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-3.1.0/conf/mvcc-repl-sync.xml 2009-10-21 09:16:01 UTC (rev 8262)
+++ benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-3.1.0/conf/mvcc-repl-sync.xml 2009-10-21 09:25:11 UTC (rev 8263)
@@ -1,40 +1,41 @@
<?xml version="1.0" encoding="UTF-8"?>
-<jbosscache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="urn:jboss:jbosscache-core:config:3.0">
- <locking isolationLevel="READ_COMMITTED" lockAcquisitionTimeout="10000" nodeLockingScheme="mvcc"
- concurrencyLevel="3000"/>
- <transaction transactionManagerLookupClass="org.jboss.cache.transaction.GenericTransactionManagerLookup"/>
+<jbosscache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="urn:jboss:jbosscache-core:config:3.1"
+ xsi:schemaLocation="urn:jboss:jbosscache-core:config:3.1 ">
+ <locking isolationLevel="READ_COMMITTED" lockAcquisitionTimeout="120000" nodeLockingScheme="mvcc"
+ concurrencyLevel="10000"/>
+ <transaction transactionManagerLookupClass="org.jboss.cache.transaction.GenericTransactionManagerLookup"/>
- <clustering clusterName="JBossCache-Cluster" mode="replication">
- <stateRetrieval timeout="20000" fetchInMemoryState="false"/>
- <jgroupsConfig>
- <UDP discard_incompatible_packets="true" enable_bundling="false" enable_diagnostics="false" ip_ttl="2"
- loopback="false" max_bundle_size="64000" max_bundle_timeout="30" mcast_addr="228.10.10.10"
- mcast_port="45588" mcast_recv_buf_size="25000000" mcast_send_buf_size="640000"
- oob_thread_pool.enabled="true" oob_thread_pool.keep_alive_time="10000" oob_thread_pool.max_threads="4"
- oob_thread_pool.min_threads="1" oob_thread_pool.queue_enabled="true"
- oob_thread_pool.queue_max_size="10"
- oob_thread_pool.rejection_policy="Run" thread_naming_pattern="pl" thread_pool.enabled="true"
- thread_pool.keep_alive_time="30000" thread_pool.max_threads="25" thread_pool.min_threads="1"
- thread_pool.queue_enabled="true" thread_pool.queue_max_size="10" thread_pool.rejection_policy="Run"
- tos="8" ucast_recv_buf_size="20000000" ucast_send_buf_size="640000" use_concurrent_stack="true"
- use_incoming_packet_handler="true"/>
- <PING num_initial_members="3" timeout="2000"/>
- <MERGE2 max_interval="30000" min_interval="10000"/>
- <FD_SOCK/>
- <FD max_tries="5" shun="true" timeout="10000"/>
- <VERIFY_SUSPECT timeout="1500"/>
- <pbcast.NAKACK discard_delivered_msgs="true" gc_lag="0" retransmit_timeout="300,600,1200,2400,4800"
- use_mcast_xmit="false"/>
- <UNICAST timeout="300,600,1200,2400,3600"/>
- <pbcast.STABLE desired_avg_gossip="50000" max_bytes="400000" stability_delay="1000"/>
- <pbcast.GMS join_timeout="5000" print_local_addr="true" shun="false" view_ack_collection_timeout="5000"
- view_bundling="true"/>
- <FRAG2 frag_size="60000"/>
- <pbcast.STREAMING_STATE_TRANSFER use_reading_thread="true"/>
- <pbcast.FLUSH timeout="0"/>
- </jgroupsConfig>
- <sync replTimeout="15000"/>
+ <clustering clusterName="JBossCache-Cluster" mode="replication">
+ <stateRetrieval timeout="20000" fetchInMemoryState="false"/>
+ <jgroupsConfig>
+ <UDP discard_incompatible_packets="true" enable_bundling="false" enable_diagnostics="false" ip_ttl="2"
+ loopback="false" max_bundle_size="64000" max_bundle_timeout="30" mcast_addr="228.10.10.10"
+ mcast_port="45588" mcast_recv_buf_size="25000000" mcast_send_buf_size="640000"
+ oob_thread_pool.enabled="true" oob_thread_pool.keep_alive_time="10000" oob_thread_pool.max_threads="4"
+ oob_thread_pool.min_threads="1" oob_thread_pool.queue_enabled="true"
+ oob_thread_pool.queue_max_size="10"
+ oob_thread_pool.rejection_policy="Run" thread_naming_pattern="pl" thread_pool.enabled="true"
+ thread_pool.keep_alive_time="30000" thread_pool.max_threads="25" thread_pool.min_threads="1"
+ thread_pool.queue_enabled="true" thread_pool.queue_max_size="10" thread_pool.rejection_policy="Run"
+ tos="8" ucast_recv_buf_size="20000000" ucast_send_buf_size="640000" use_concurrent_stack="true"
+ use_incoming_packet_handler="true"/>
+ <PING num_initial_members="3" timeout="2000"/>
+ <MERGE2 max_interval="30000" min_interval="10000"/>
+ <FD_SOCK/>
+ <FD max_tries="5" shun="true" timeout="10000"/>
+ <VERIFY_SUSPECT timeout="1500"/>
+ <pbcast.NAKACK discard_delivered_msgs="true" gc_lag="0" retransmit_timeout="300,600,1200,2400,4800"
+ use_mcast_xmit="false"/>
+ <UNICAST timeout="300,600,1200,2400,3600"/>
+ <pbcast.STABLE desired_avg_gossip="50000" max_bytes="400000" stability_delay="1000"/>
+ <pbcast.GMS join_timeout="5000" print_local_addr="true" shun="false" view_ack_collection_timeout="5000"
+ view_bundling="true"/>
+ <FRAG2 frag_size="60000"/>
+ <pbcast.STREAMING_STATE_TRANSFER use_reading_thread="true"/>
+ <pbcast.FLUSH timeout="0"/>
+ </jgroupsConfig>
+ <sync replTimeout="120000"/>
- </clustering>
+ </clustering>
</jbosscache>
15 years, 2 months
JBoss Cache SVN: r8262 - benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf.
by jbosscache-commits＠lists.jboss.org
Author: mircea.markus
Date: 2009-10-21 05:16:01 -0400 (Wed, 21 Oct 2009)
New Revision: 8262
Modified:
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-l1.xml
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-nol1.xml
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-l1.xml
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-nol1.xml
Log:
increased replication timeout
Modified: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-l1.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-l1.xml 2009-10-21 09:11:15 UTC (rev 8261)
+++ benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-l1.xml 2009-10-21 09:16:01 UTC (rev 8262)
@@ -21,7 +21,7 @@
syncCommitPhase="false"/>
<clustering mode="distribution">
- <sync/>
+ <sync replTimeout="120000"/>
<hash numOwners="2" rehashWait="120000" rehashRpcTimeout="600000"/>
<l1 enabled="true" lifespan="600000"/>
</clustering>
Modified: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-nol1.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-nol1.xml 2009-10-21 09:11:15 UTC (rev 8261)
+++ benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-nol1.xml 2009-10-21 09:16:01 UTC (rev 8262)
@@ -21,7 +21,7 @@
syncCommitPhase="false"/>
<clustering mode="distribution">
- <sync/>
+ <sync replTimeout="120000"/>
<hash numOwners="2" rehashWait="120000" rehashRpcTimeout="600000"/>
<l1 enabled="false" lifespan="600000"/>
</clustering>
Modified: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-l1.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-l1.xml 2009-10-21 09:11:15 UTC (rev 8261)
+++ benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-l1.xml 2009-10-21 09:16:01 UTC (rev 8262)
@@ -21,7 +21,7 @@
syncCommitPhase="false"/>
<clustering mode="distribution">
- <sync/>
+ <sync replTimeout="120000"/>
<hash numOwners="2" rehashWait="120000" rehashRpcTimeout="600000"/>
<l1 enabled="true" lifespan="600000"/>
</clustering>
Modified: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-nol1.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-nol1.xml 2009-10-21 09:11:15 UTC (rev 8261)
+++ benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-nol1.xml 2009-10-21 09:16:01 UTC (rev 8262)
@@ -21,7 +21,7 @@
syncCommitPhase="false"/>
<clustering mode="distribution">
- <sync/>
+ <sync replTimeout="120000"/>
<hash numOwners="2" rehashWait="120000" rehashRpcTimeout="600000"/>
<l1 enabled="false" lifespan="600000"/>
</clustering>
15 years, 2 months
JBoss Cache SVN: r8261 - benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf.
by jbosscache-commits＠lists.jboss.org
Author: mircea.markus
Date: 2009-10-21 05:11:15 -0400 (Wed, 21 Oct 2009)
New Revision: 8261
Modified:
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-l1.xml
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-nol1.xml
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-l1.xml
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-nol1.xml
Log:
increased replication timeout
Modified: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-l1.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-l1.xml 2009-10-20 19:48:15 UTC (rev 8260)
+++ benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-l1.xml 2009-10-21 09:11:15 UTC (rev 8261)
@@ -13,7 +13,7 @@
<default>
<locking
- lockAcquisitionTimeout="20000"
+ lockAcquisitionTimeout="120000"
concurrencyLevel="10000"/>
<transaction
transactionManagerLookupClass="org.infinispan.transaction.lookup.GenericTransactionManagerLookup"
Modified: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-nol1.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-nol1.xml 2009-10-20 19:48:15 UTC (rev 8260)
+++ benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/tcp-dist-sync-nol1.xml 2009-10-21 09:11:15 UTC (rev 8261)
@@ -13,7 +13,7 @@
<default>
<locking
- lockAcquisitionTimeout="20000"
+ lockAcquisitionTimeout="120000"
concurrencyLevel="10000"/>
<transaction
transactionManagerLookupClass="org.infinispan.transaction.lookup.GenericTransactionManagerLookup"
Modified: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-l1.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-l1.xml 2009-10-20 19:48:15 UTC (rev 8260)
+++ benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-l1.xml 2009-10-21 09:11:15 UTC (rev 8261)
@@ -13,7 +13,7 @@
<default>
<locking
- lockAcquisitionTimeout="20000"
+ lockAcquisitionTimeout="120000"
concurrencyLevel="10000"/>
<transaction
transactionManagerLookupClass="org.infinispan.transaction.lookup.GenericTransactionManagerLookup"
Modified: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-nol1.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-nol1.xml 2009-10-20 19:48:15 UTC (rev 8260)
+++ benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/conf/udp-dist-sync-nol1.xml 2009-10-21 09:11:15 UTC (rev 8261)
@@ -13,7 +13,7 @@
<default>
<locking
- lockAcquisitionTimeout="20000"
+ lockAcquisitionTimeout="120000"
concurrencyLevel="10000"/>
<transaction
transactionManagerLookupClass="org.infinispan.transaction.lookup.GenericTransactionManagerLookup"
15 years, 2 months
JBoss Cache SVN: r8260 - benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/lib.
by jbosscache-commits＠lists.jboss.org
Author: manik.surtani(a)jboss.com
Date: 2009-10-20 15:48:15 -0400 (Tue, 20 Oct 2009)
New Revision: 8260
Removed:
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/lib/commons-logging.jar
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/lib/jta.jar
Log:
Deleted: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/lib/commons-logging.jar
===================================================================
(Binary files differ)
Deleted: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/lib/jta.jar
===================================================================
(Binary files differ)
15 years, 2 months
JBoss Cache SVN: r8259 - benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/lib.
by jbosscache-commits＠lists.jboss.org
Author: manik.surtani(a)jboss.com
Date: 2009-10-20 15:47:48 -0400 (Tue, 20 Oct 2009)
New Revision: 8259
Added:
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/lib/jboss-transaction-api.jar
Modified:
benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/lib/infinispan-core.jar
Log:
Modified: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/lib/infinispan-core.jar
===================================================================
(Binary files differ)
Added: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/lib/jboss-transaction-api.jar
===================================================================
(Binary files differ)
Property changes on: benchmarks/benchmark-fwk/trunk/cache-products/infinispan-4.0.0/lib/jboss-transaction-api.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
15 years, 2 months