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

Comparing jsr166/src/test/tck/SubmissionPublisherTest.java (file contents):
Revision 1.6 by jsr166, Mon Sep 7 20:53:10 2015 UTC vs.
Revision 1.7 by jsr166, Mon Sep 7 21:25:50 2015 UTC

# Line 806 | Line 806 | public class SubmissionPublisherTest ext
806       */
807      public void testEmptyTimedOffer() {
808          SubmissionPublisher<Integer> p = basicPublisher();
809 +        long startTime = System.nanoTime();
810          assertEquals(0, p.offer(1, LONG_DELAY_MS, MILLISECONDS, null));
811 +        assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS / 2);
812      }
813  
814      /**
# Line 814 | Line 816 | public class SubmissionPublisherTest ext
816       */
817      public void testNullTimedOffer() {
818          SubmissionPublisher<Integer> p = basicPublisher();
819 +        long startTime = System.nanoTime();
820          try {
821 <            p.offer(null, SHORT_DELAY_MS, MILLISECONDS, null);
821 >            p.offer(null, LONG_DELAY_MS, MILLISECONDS, null);
822              shouldThrow();
823          } catch (NullPointerException success) {}
824          try {
825 <            p.offer(1, SHORT_DELAY_MS, null, null);
825 >            p.offer(1, LONG_DELAY_MS, null, null);
826              shouldThrow();
827          } catch (NullPointerException success) {}
828 +        assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS / 2);
829      }
830  
831      /**
# Line 837 | Line 841 | public class SubmissionPublisherTest ext
841          p.subscribe(s2);
842          s2.awaitSubscribe();
843          s1.awaitSubscribe();
844 <        assertTrue(p.offer(1, SHORT_DELAY_MS, MILLISECONDS, null) >= 1);
845 <        assertTrue(p.offer(2, SHORT_DELAY_MS, MILLISECONDS, null) >= 2);
844 >        long startTime = System.nanoTime();
845 >        assertTrue(p.offer(1, LONG_DELAY_MS, MILLISECONDS, null) >= 1);
846 >        assertTrue(p.offer(2, LONG_DELAY_MS, MILLISECONDS, null) >= 2);
847          s1.sn.request(4);
848 <        assertTrue(p.offer(3, SHORT_DELAY_MS, MILLISECONDS, null) >= 3);
848 >        assertTrue(p.offer(3, LONG_DELAY_MS, MILLISECONDS, null) >= 3);
849          s2.sn.request(4);
850 <        p.offer(4, SHORT_DELAY_MS, MILLISECONDS, null);
850 >        p.offer(4, LONG_DELAY_MS, MILLISECONDS, null);
851          p.close();
852          s2.awaitComplete();
853          assertEquals(4, s2.nexts);
854          s1.awaitComplete();
855          assertEquals(4, s2.nexts);
856 +        assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS / 2);
857      }
858  
859      /**

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines