[jboss-cvs] JBoss Messaging SVN: r1675 - branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Fri Dec 1 18:08:08 EST 2006


Author: timfox
Date: 2006-12-01 18:08:04 -0500 (Fri, 01 Dec 2006)
New Revision: 1675

Modified:
   branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_NP_2PCTest.java
   branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_NP_NTTest.java
   branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_NP_TTest.java
   branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_P_2PCTest.java
   branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_P_NTTest.java
   branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_P_TTest.java
Log:
few more tweaks



Modified: branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_NP_2PCTest.java
===================================================================
--- branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_NP_2PCTest.java	2006-12-01 20:55:27 UTC (rev 1674)
+++ branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_NP_2PCTest.java	2006-12-01 23:08:04 UTC (rev 1675)
@@ -829,6 +829,9 @@
          dels[i].cancel();   
       }
       
+      //Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);
+      
       //This should cause the refs corresponding to the deliveries to go the front of the in memory quuee
       //and the oldest refs in memory evicted off the end into the down cache
       
@@ -862,6 +865,9 @@
          dels[i].cancel();
       }
       
+//    Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);
+      
       //This should cause the down cache to be flushed
       
       //verify 10 ref in storage
@@ -896,6 +902,8 @@
          dels[i].cancel();
       }
       
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);      
       
       //This should cause the down cache to be flushed
       

Modified: branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_NP_NTTest.java
===================================================================
--- branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_NP_NTTest.java	2006-12-01 20:55:27 UTC (rev 1674)
+++ branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_NP_NTTest.java	2006-12-01 23:08:04 UTC (rev 1675)
@@ -781,6 +781,9 @@
          dels[i].cancel();  
       }
       
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);       
+      
       //This should cause the refs corresponding to the deliveries to go the front of the in memory quuee
       //and the oldest refs in memory evicted off the end into the down cache
       
@@ -814,6 +817,9 @@
          dels[i].cancel();
       }
       
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);       
+      
       //This should cause the down cache to be flushed
       
       //verify 10 ref in storage
@@ -847,6 +853,8 @@
       {
          dels[i].cancel();
       }
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);       
       
       //consumeCount += 20;
       

Modified: branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_NP_TTest.java
===================================================================
--- branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_NP_TTest.java	2006-12-01 20:55:27 UTC (rev 1674)
+++ branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_NP_TTest.java	2006-12-01 23:08:04 UTC (rev 1675)
@@ -819,6 +819,9 @@
          dels[i].cancel();  
       }
       
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);       
+      
       //This should cause the refs corresponding to the deliveries to go the front of the in memory quuee
       //and the oldest refs in memory evicted off the end into the down cache
       
@@ -852,6 +855,9 @@
          dels[i].cancel();
       }
       
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);       
+      
       //This should cause the down cache to be flushed
       
       //verify 10 ref in storage
@@ -887,6 +893,9 @@
       }
       
       
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);       
+      
       //This should cause the down cache to be flushed
       
       //verify 20 ref in storage

Modified: branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_P_2PCTest.java
===================================================================
--- branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_P_2PCTest.java	2006-12-01 20:55:27 UTC (rev 1674)
+++ branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_P_2PCTest.java	2006-12-01 23:08:04 UTC (rev 1675)
@@ -926,6 +926,9 @@
          dels[i].cancel(); 
       }
       
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);       
+      
       //This should cause the refs corresponding to the deliveries to go the front of the in memory quuee
       //and the oldest refs in memory evicted off the end into the down cache
       
@@ -965,6 +968,9 @@
          dels[i].cancel();
       }
       
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);       
+      
       //This should cause the down cache to be flushed
       
       //verify 10 ref in storage
@@ -1004,6 +1010,9 @@
          dels[i].cancel();
       }
       
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);       
+      
       //consumeCount += 20;
       
       //This should cause the down cache to be flushed

Modified: branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_P_NTTest.java
===================================================================
--- branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_P_NTTest.java	2006-12-01 20:55:27 UTC (rev 1674)
+++ branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_P_NTTest.java	2006-12-01 23:08:04 UTC (rev 1675)
@@ -880,6 +880,9 @@
          dels[i].cancel();
       }
       
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);       
+      
       //This should cause the refs corresponding to the deliveries to go the front of the in memory quuee
       //and the oldest refs in memory evicted off the end into the down cache
       
@@ -918,6 +921,8 @@
       {
          dels[i].cancel();
       }
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);       
       
       //This should cause the down cache to be flushed
       
@@ -957,6 +962,9 @@
       {
          dels[i].cancel();
       }
+           
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);     
       
       //consumeCount += 20;
       

Modified: branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_P_TTest.java
===================================================================
--- branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_P_TTest.java	2006-12-01 20:55:27 UTC (rev 1674)
+++ branches/Branch_1_0_1_SP/tests/src/org/jboss/test/messaging/core/paging/SingleChannel_P_TTest.java	2006-12-01 23:08:04 UTC (rev 1675)
@@ -913,6 +913,9 @@
          dels[i].cancel();   
       }
       
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250); 
+      
       //This should cause the refs corresponding to the deliveries to go the front of the in memory quuee
       //and the oldest refs in memory evicted off the end into the down cache
       
@@ -952,6 +955,9 @@
          dels[i].cancel();
       }
       
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);       
+      
       //This should cause the down cache to be flushed
       
       //verify 10 ref in storage
@@ -991,6 +997,9 @@
          dels[i].cancel();
       }
       
+      // Cancel is asynch, so need to wait a bit
+      Thread.sleep(250);       
+      
       //consumeCount += 20;
       
       //This should cause the down cache to be flushed




More information about the jboss-cvs-commits mailing list