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 <[email protected]> Authored: Tue Dec 16 11:41:37 2014 +0000 Committer: gtully <[email protected]> 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());
