activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r1207713 - in /activemq/trunk/activemq-core/src/test/java/org/apache/activemq: broker/region/cursors/NegativeQueueTest.java bugs/DurableConsumerTest.java store/kahadb/plist/PListTest.java
Date Tue, 29 Nov 2011 00:07:25 GMT
Author: gtully
Date: Tue Nov 29 00:07:23 2011
New Revision: 1207713

URL: http://svn.apache.org/viewvc?rev=1207713&view=rev
Log:
reduce the duration of this tests

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/NegativeQueueTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/NegativeQueueTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/NegativeQueueTest.java?rev=1207713&r1=1207712&r2=1207713&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/NegativeQueueTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/NegativeQueueTest.java
Tue Nov 29 00:07:23 2011
@@ -90,7 +90,7 @@ public class NegativeQueueTest extends A
     private static final long MEMORY_USAGE = 400000000;
     private static final long TEMP_USAGE = 200000000;
     private static final long STORE_USAGE = 1000000000;
-    private static final int MESSAGE_COUNT = 2000;  
+    private static final int MESSAGE_COUNT = 1100;
     
     protected static final boolean TRANSACTED = true;
     protected static final boolean DEBUG = true;
@@ -106,13 +106,13 @@ public class NegativeQueueTest extends A
         blastAndConsume();
     }
     
-    public void testWithDefaultPrefetchFiveConsumers() throws Exception{
+    public void x_testWithDefaultPrefetchFiveConsumers() throws Exception{
         PREFETCH_SIZE = 1000;
         NUM_CONSUMERS = 5;
         blastAndConsume();
     }
     
-    public void testWithDefaultPrefetchTwoConsumers() throws Exception{
+    public void x_testWithDefaultPrefetchTwoConsumers() throws Exception{
         PREFETCH_SIZE = 1000;
         NUM_CONSUMERS = 2;
         blastAndConsume();
@@ -130,7 +130,7 @@ public class NegativeQueueTest extends A
         blastAndConsume();
     }   
     
-    public void testWithSmallPrefetch() throws Exception{
+    public void x_testWithSmallPrefetch() throws Exception{
         PREFETCH_SIZE = 10;
         NUM_CONSUMERS = 20;
         blastAndConsume();

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java?rev=1207713&r1=1207712&r2=1207713&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
Tue Nov 29 00:07:23 2011
@@ -64,7 +64,7 @@ import org.slf4j.LoggerFactory;
  */
 public class DurableConsumerTest extends CombinationTestSupport{
     private static final Logger LOG = LoggerFactory.getLogger(DurableConsumerTest.class);
-    private static int COUNT = 1024 * 10;
+    private static int COUNT = 1024;
     private static String CONSUMER_NAME = "DURABLE_TEST";
     protected BrokerService broker;
     

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java?rev=1207713&r1=1207712&r2=1207713&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/store/kahadb/plist/PListTest.java
Tue Nov 29 00:07:23 2011
@@ -187,7 +187,7 @@ public class PListTest {
 
 
         final Vector<Throwable> exceptions = new Vector<Throwable>();
-        final int iterations = 5000;
+        final int iterations = 1000;
         final int numLists = 10;
 
         final PList[] lists = new PList[numLists];
@@ -268,12 +268,11 @@ public class PListTest {
         IOHelper.deleteChildren(directory);
         store = new PListStore();
         store.setDirectory(directory);
-        //store.setJournalMaxFileLength(1024*5);
         store.start();
 
 
         final int numThreads = 20;
-        final int iterations = 2000;
+        final int iterations = 1000;
         executor = Executors.newFixedThreadPool(100);
         for (int i=0; i<numThreads; i++) {
             new Job(i, PListTest.TaskType.ADD, iterations).run();
@@ -322,7 +321,7 @@ public class PListTest {
         store.setCleanupInterval(5000);
         store.start();
 
-        final int iterations = 5000;
+        final int iterations = 500;
         final int numLists = 10;
 
         // prime the store
@@ -402,8 +401,8 @@ public class PListTest {
         store.setDirectory(directory);
         store.start();
 
-        final int iterations = 5000;
-        final int numLists = 50;
+        final int iterations = 500;
+        final int numLists = 10;
 
         LOG.info("create");
         for (int i=0; i<numLists;i++) {
@@ -418,7 +417,7 @@ public class PListTest {
         LOG.info("parallel add and remove");
         executor = Executors.newFixedThreadPool(400);
         final int numProducer = 5;
-        final int numConsumer = 50;
+        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*2));



Mime
View raw message