--- jsr166/src/test/tck/LinkedTransferQueueTest.java	2010/10/28 22:42:05	1.31
+++ jsr166/src/test/tck/LinkedTransferQueueTest.java	2010/11/03 07:54:52	1.36
@@ -354,13 +354,16 @@ public class LinkedTransferQueueTest ext
                 for (int i = 0; i < SIZE; ++i) {
                     long t0 = System.nanoTime();
                     assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
-                    assertTrue(millisElapsedSince(t0) < SHORT_DELAY_MS);
+                    assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS);
                 }
+                long t0 = System.nanoTime();
                 aboutToWait.countDown();
                 try {
                     q.poll(MEDIUM_DELAY_MS, MILLISECONDS);
                     shouldThrow();
-                } catch (InterruptedException success) {}
+                } catch (InterruptedException success) {
+                    assertTrue(millisElapsedSince(t0) < MEDIUM_DELAY_MS);
+                }
             }});
 
         aboutToWait.await();
@@ -382,7 +385,7 @@ public class LinkedTransferQueueTest ext
                 for (int i = 0; i < SIZE; ++i) {
                     long t0 = System.nanoTime();
                     assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
-                    assertTrue(millisElapsedSince(t0) < SHORT_DELAY_MS);
+                    assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS);
                 }
                 try {
                     q.poll(MEDIUM_DELAY_MS, MILLISECONDS);
@@ -581,12 +584,12 @@ public class LinkedTransferQueueTest ext
     }
 
     /**
-     * toArray(incompatible array type) throws CCE
+     * toArray(incompatible array type) throws ArrayStoreException
      */
     public void testToArray1_BadArg() {
         LinkedTransferQueue q = populatedQueue(SIZE);
         try {
-            Object o[] = q.toArray(new String[10]);
+            q.toArray(new String[10]);
             shouldThrow();
         } catch (ArrayStoreException success) {}
     }
@@ -739,6 +742,8 @@ public class LinkedTransferQueueTest ext
         LinkedTransferQueue r = (LinkedTransferQueue) in.readObject();
 
         assertEquals(q.size(), r.size());
+        assertEquals(q.toString(), r.toString());
+        assertTrue(Arrays.equals(q.toArray(), r.toArray()));
         while (!q.isEmpty()) {
             assertEquals(q.remove(), r.remove());
         }
@@ -908,15 +913,14 @@ public class LinkedTransferQueueTest ext
         Thread t = newStartedThread(new CheckedRunnable() {
             public void realRun() throws InterruptedException {
                 threadStarted.countDown();
-                q.transfer(SIZE);
+                q.transfer(five);
                 checkEmpty(q);
             }});
 
         threadStarted.await();
         waitForThreadToEnterWaitState(t, SMALL_DELAY_MS);
-        assertTrue(t.isAlive());
         assertEquals(1, q.size());
-        assertEquals(SIZE, (int) q.poll());
+        assertSame(five, q.poll());
         checkEmpty(q);
         awaitTermination(t, MEDIUM_DELAY_MS);
     }
@@ -930,24 +934,23 @@ public class LinkedTransferQueueTest ext
 
         Thread first = newStartedThread(new CheckedRunnable() {
             public void realRun() throws InterruptedException {
-                Integer i = SIZE + 1;
-                q.transfer(i);
-                assertTrue(!q.contains(i));
+                q.transfer(four);
+                assertTrue(!q.contains(four));
                 assertEquals(1, q.size());
             }});
 
         Thread interruptedThread = newStartedThread(
             new CheckedInterruptedRunnable() {
                 public void realRun() throws InterruptedException {
-                    while (q.size() == 0)
+                    while (q.isEmpty())
                         Thread.yield();
-                    q.transfer(SIZE);
+                    q.transfer(five);
                 }});
 
         while (q.size() < 2)
             Thread.yield();
         assertEquals(2, q.size());
-        assertEquals(SIZE + 1, (int) q.poll());
+        assertSame(four, q.poll());
         first.join();
         assertEquals(1, q.size());
         interruptedThread.interrupt();
@@ -1094,7 +1097,7 @@ public class LinkedTransferQueueTest ext
     }
 
     /**
-     * tryTransfer gives up after the timeout and return false
+     * tryTransfer gives up after the timeout and returns false
      */
     public void testTryTransfer6() throws InterruptedException {
         final LinkedTransferQueue q = new LinkedTransferQueue();
@@ -1105,9 +1108,9 @@ public class LinkedTransferQueueTest ext
                 assertFalse(q.tryTransfer(new Object(),
                                           SHORT_DELAY_MS, MILLISECONDS));
                 assertTrue(millisElapsedSince(t0) >= SHORT_DELAY_MS);
+                checkEmpty(q);
             }});
 
-        checkEmpty(q);
         awaitTermination(t, MEDIUM_DELAY_MS);
         checkEmpty(q);
     }
@@ -1126,7 +1129,8 @@ public class LinkedTransferQueueTest ext
                 checkEmpty(q);
             }});
 
-        Thread.sleep(SHORT_DELAY_MS);
+        while (q.size() != 2)
+            Thread.yield();
         assertEquals(2, q.size());
         assertSame(four, q.poll());
         assertSame(five, q.poll());
@@ -1142,7 +1146,9 @@ public class LinkedTransferQueueTest ext
         final LinkedTransferQueue q = new LinkedTransferQueue();
         assertTrue(q.offer(four));
         assertEquals(1, q.size());
+        long t0 = System.nanoTime();
         assertFalse(q.tryTransfer(five, SHORT_DELAY_MS, MILLISECONDS));
+        assertTrue(millisElapsedSince(t0) >= SHORT_DELAY_MS);
         assertEquals(1, q.size());
         assertSame(four, q.poll());
         assertNull(q.poll());