Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

reduce test duration to match existing fork timeouts

This commit is contained in:
gtully 2014-12-16 11:41:37 +00:00
parent 13c207292f
commit 30d3fae323
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-unit-tests/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java
View File

@ -476,9 +476,9 @@ public class PListTest {
// with overlapping seeks from the iterators so that we are likely to // with overlapping seeks from the iterators so that we are likely to
// seek into // seek into
// some bad area in the page file. // some bad area in the page file.
executor = Executors.newFixedThreadPool(400); executor = Executors.newFixedThreadPool(100);
final int numProducer = 300; final int numProducer = 30;
final int numConsumer = 100; final int numConsumer = 10;
for (int i = 0; i < numLists; i++) { for (int i = 0; i < numLists; i++) {
for (int j = 0; j < numProducer; j++) { for (int j = 0; j < numProducer; j++) {
executor.execute(new Job(i, PListTest.TaskType.ADD, iterations)); executor.execute(new Job(i, PListTest.TaskType.ADD, iterations));
@ -490,7 +490,7 @@ public class PListTest {
executor.shutdown(); executor.shutdown();
LOG.info("wait for parallel work to complete"); 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("no exceptions: " + exceptions, exceptions.isEmpty());
assertTrue("test did not timeout ", shutdown); assertTrue("test did not timeout ", shutdown);
LOG.info("Num dataFiles:" + store.getJournal().getFiles().size()); LOG.info("Num dataFiles:" + store.getJournal().getFiles().size());