activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject activemq git commit: reduce test duration to match existing fork timeouts
Date Tue, 16 Dec 2014 11:47:24 GMT
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 <gary.tully@gmail.com>
Authored: Tue Dec 16 11:41:37 2014 +0000
Committer: gtully <gary.tully@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());


Mime
View raw message