[jboss-cvs] JBoss Messaging SVN: r4415 - trunk/tests/src/org/jboss/messaging/tests/integration/core/asyncio/impl.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2008-06-09 15:18:32 -0400 (Mon, 09 Jun 2008)
New Revision: 4415

Modified:
   trunk/tests/src/org/jboss/messaging/tests/integration/core/asyncio/impl/SingleThreadWriteNativeTest.java
Log:
Tweaks (fixing timeouts)

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/core/asyncio/impl/SingleThreadWriteNativeTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/core/asyncio/impl/SingleThreadWriteNativeTest.java	2008-06-09 19:15:42 UTC (rev 4414)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/core/asyncio/impl/SingleThreadWriteNativeTest.java	2008-06-09 19:18:32 UTC (rev 4415)
@@ -58,7 +58,7 @@
       final AsynchronousFileImpl controller = new AsynchronousFileImpl();
       for (int i = 0; i < 1000; i++)
       {
-         controller.open(FILE_NAME, 10000, 120);
+         controller.open(FILE_NAME, 10000, 1200);
          controller.close();
          
       }
@@ -73,8 +73,8 @@
    {
       final AsynchronousFileImpl controller = new AsynchronousFileImpl();
       final AsynchronousFileImpl controller2 = new AsynchronousFileImpl();
-      controller.open(FILE_NAME + ".1", 10000, 120);
-      controller2.open(FILE_NAME + ".2", 10000, 120);
+      controller.open(FILE_NAME + ".1", 10000, 1200);
+      controller2.open(FILE_NAME + ".2", 10000, 1200);
       
       int numberOfLines = 1000;
       int size = 1024;
@@ -206,12 +206,12 @@
          
          final int SIZE = 512;
          
-         controller.open(FILE_NAME, 10, 120);
+         controller.open(FILE_NAME, 10, 1200);
          controller.close();
          
          controller = new AsynchronousFileImpl();
          
-         controller.open(FILE_NAME, 10, 120);
+         controller.open(FILE_NAME, 10, 1200);
          
          controller.fill(0, 1, 512, (byte) 'j');
          
@@ -296,7 +296,7 @@
          final int NUMBER_LINES = 1000;
          final int SIZE = 1024;
          
-         controller.open(FILE_NAME, 10, 120);
+         controller.open(FILE_NAME, 10, 1200);
          
          log.info("Filling file");
          
@@ -328,7 +328,7 @@
          log.info("Closing file");
          controller.close();
          log.info("Reading file");
-         controller.open(FILE_NAME, 10, 120);
+         controller.open(FILE_NAME, 10, 1200);
          
          ByteBuffer newBuffer = ByteBuffer.allocateDirect(SIZE);
          
@@ -427,7 +427,7 @@
          assertEquals(0, readLatch.getCount());
          readLatch.await();
          log.info("Reading file");
-         controller.open(FILE_NAME, 10, 120);
+         controller.open(FILE_NAME, 10, 1200);
          
          ByteBuffer newBuffer = ByteBuffer.allocateDirect(SIZE);
          
@@ -483,7 +483,7 @@
          throws Exception
    {
       final AsynchronousFileImpl controller = new AsynchronousFileImpl();
-      controller.open(FILE_NAME, aioLimit, 120);
+      controller.open(FILE_NAME, aioLimit, 1200);
       
       try
       {
@@ -563,7 +563,7 @@
          final int SIZE = 1024;
          
          final AsynchronousFileImpl controller = new AsynchronousFileImpl();
-         controller.open(FILE_NAME, 2000, 120);
+         controller.open(FILE_NAME, 2000, 1200);
          
          ByteBuffer block = ByteBuffer.allocateDirect(SIZE);
          encodeBufer(block);
@@ -594,7 +594,8 @@
       }
       
    }
-   
+ 
+//   disabled until http://jira.jboss.com/jira/browse/JBMESSAGING-1334 is done
 //   public void testInvalidWrite() throws Exception
 //   {
 //      final AsynchronousFileImpl controller = new AsynchronousFileImpl();