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 |
|
/** |
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 |
|
/** |
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 |
|
/** |