ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/PhaserTest.java
(Generate patch)

Comparing jsr166/src/test/tck/PhaserTest.java (file contents):
Revision 1.23 by dl, Sat Nov 27 16:47:05 2010 UTC vs.
Revision 1.24 by dl, Mon Nov 29 15:47:29 2010 UTC

# Line 258 | Line 258 | public class PhaserTest extends JSR166Te
258          }
259          assertEquals(0, phaser.arriveAndDeregister());
260          assertTerminated(phaser);
261 +        assertEquals(1, phaser.getPhase() + Integer.MIN_VALUE);
262      }
263  
264      /**
# Line 289 | Line 290 | public class PhaserTest extends JSR166Te
290          Phaser phaser = new Phaser(1);
291          phaser.forceTermination();
292          assertTerminated(phaser, 1, 1);
293 +        assertEquals(0, phaser.getPhase() + Integer.MIN_VALUE);
294          assertTrue(phaser.arrive() < 0);
295          assertTrue(phaser.register() < 0);
296          assertTrue(phaser.arriveAndDeregister() < 0);
# Line 373 | Line 375 | public class PhaserTest extends JSR166Te
375          assertTerminated(child);
376          assertTerminated(parent);
377          assertTerminated(root);
378 +        assertEquals(1, root.getPhase() + Integer.MIN_VALUE);
379      }
380  
381      /**
# Line 391 | Line 394 | public class PhaserTest extends JSR166Te
394          assertState(phaser, 1, 1, 1);
395          assertEquals(1, phaser.arriveAndDeregister());
396          assertTerminated(phaser);
397 +        assertEquals(2, phaser.getPhase() + Integer.MIN_VALUE);
398          awaitTermination(t, SHORT_DELAY_MS);
399      }
400  
# Line 594 | Line 598 | public class PhaserTest extends JSR166Te
598                      assertTrue(phaser.awaitAdvance(0) < 0);
599                      assertTrue(phaser.isTerminated());
600                      assertTrue(phaser.getPhase() < 0);
601 +                    assertEquals(0, phaser.getPhase() + Integer.MIN_VALUE);
602                      assertEquals(3, phaser.getRegisteredParties());
603                  }};
604              threads.add(newStartedThread(r));
605          }
606          threadsStarted.await();
607          phaser.forceTermination();
608 +        assertEquals(0, phaser.getPhase() + Integer.MIN_VALUE);
609          for (Thread thread : threads)
610              awaitTermination(thread, SMALL_DELAY_MS);
611          assertTrue(phaser.isTerminated());

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines