You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2014/12/16 12:47:24 UTC
activemq git commit: reduce test duration to match existing fork
timeouts
Repository: activemq
Updated Branches:
refs/heads/trunk 13c207292 -> 30d3fae32
reduce test duration to match existing fork timeouts
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/30d3fae3
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/30d3fae3
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/30d3fae3
Branch: refs/heads/trunk
Commit: 30d3fae323b53e2bd96c19cdcfd27e5e1bedd9c7
Parents: 13c2072
Author: gtully <ga...@gmail.com>
Authored: Tue Dec 16 11:41:37 2014 +0000
Committer: gtully <ga...@gmail.com>
Committed: Tue Dec 16 11:41:37 2014 +0000
----------------------------------------------------------------------
.../org/apache/activemq/store/kahadb/plist/PListTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/30d3fae3/activemq-unit-tests/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java
----------------------------------------------------------------------
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java
index 266aa94..555503e 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java
@@ -476,9 +476,9 @@ public class PListTest {
// with overlapping seeks from the iterators so that we are likely to
// seek into
// some bad area in the page file.
- executor = Executors.newFixedThreadPool(400);
- final int numProducer = 300;
- final int numConsumer = 100;
+ executor = Executors.newFixedThreadPool(100);
+ final int numProducer = 30;
+ final int numConsumer = 10;
for (int i = 0; i < numLists; i++) {
for (int j = 0; j < numProducer; j++) {
executor.execute(new Job(i, PListTest.TaskType.ADD, iterations));
@@ -490,7 +490,7 @@ public class PListTest {
executor.shutdown();
LOG.info("wait for parallel work to complete");
- boolean shutdown = executor.awaitTermination(60 * 60, TimeUnit.SECONDS);
+ boolean shutdown = executor.awaitTermination(5 * 60, TimeUnit.SECONDS);
assertTrue("no exceptions: " + exceptions, exceptions.isEmpty());
assertTrue("test did not timeout ", shutdown);
LOG.info("Num dataFiles:" + store.getJournal().getFiles().size());