ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/test/tck/SubmissionPublisherTest.java

Comparing jsr166/src/test/tck/SubmissionPublisherTest.java (file contents):
Revision 1.2 by jsr166, Mon Sep 7 20:20:40 2015 UTC vs.
Revision 1.5 by jsr166, Mon Sep 7 20:34:34 2015 UTC

#	Line 591 | Line 591 | public class SubmissionPublisherTest ext
591		}
592
593		/**
594	<	* Submit to a publisher with no subscribers returns lag 0
594	>	* submit to a publisher with no subscribers returns lag 0
595		*/
596		public void testEmptySubmit() {
597		SubmissionPublisher<Integer> p = basicPublisher();
#	Line 599 | Line 599 | public class SubmissionPublisherTest ext
599		}
600
601		/**
602	<	* Submit(null) throws NPE
602	>	* submit(null) throws NPE
603		*/
604		public void testNullSubmit() {
605		SubmissionPublisher<Integer> p = basicPublisher();
#	Line 610 | Line 610 | public class SubmissionPublisherTest ext
610		}
611
612		/**
613	<	* Submit returns number of lagged items, compatible with result
613	>	* submit returns number of lagged items, compatible with result
614		* of estimateMaximumLag.
615		*/
616		public void testLaggedSubmit() {
#	Line 674 | Line 674 | public class SubmissionPublisherTest ext
674		}
675
676		/**
677	<	* Offer to a publisher with no subscribers returns lag 0
677	>	* offer to a publisher with no subscribers returns lag 0
678		*/
679		public void testEmptyOffer() {
680		SubmissionPublisher<Integer> p = basicPublisher();
681	<	assertEquals(p.offer(1, null), 0);
681	>	assertEquals(0, p.offer(1, null));
682		}
683
684		/**
685	<	* Offer(null) throws NPE
685	>	* offer(null) throws NPE
686		*/
687		public void testNullOffer() {
688		SubmissionPublisher<Integer> p = basicPublisher();
#	Line 693 | Line 693 | public class SubmissionPublisherTest ext
693		}
694
695		/**
696	<	* Offer returns number of lagged items if not saturated
696	>	* offer returns number of lagged items if not saturated
697		*/
698		public void testLaggedOffer() {
699		SubmissionPublisher<Integer> p = basicPublisher();
#	Line 719 | Line 719 | public class SubmissionPublisherTest ext
719		}
720
721		/**
722	<	* Offer reports drops if saturated
722	>	* offer reports drops if saturated
723		*/
724		public void testDroppedOffer() {
725		SubmissionPublisher<Integer> p = new SubmissionPublisher<Integer>(
#	Line 747 | Line 747 | public class SubmissionPublisherTest ext
747		}
748
749		/**
750	<	* Offer invokes drop handler if saturated
750	>	* offer invokes drop handler if saturated
751		*/
752		public void testHandledDroppedOffer() {
753		AtomicInteger calls = new AtomicInteger();
#	Line 774 | Line 774 | public class SubmissionPublisherTest ext
774		assertTrue(calls.get() >= 4);
775		}
776
777	–
777		/**
778	<	* Offer succeeds if drop handler forces request
778	>	* offer succeeds if drop handler forces request
779		*/
780		public void testRecoveredHandledDroppedOffer() {
781		AtomicInteger calls = new AtomicInteger();
#	Line 802 | Line 801 | public class SubmissionPublisherTest ext
801		assertTrue(calls.get() >= 2);
802		}
803
805	–
804		/**
805	<	* TimedOffer to a publisher with no subscribers returns lag 0
805	>	* Timed offer to a publisher with no subscribers returns lag 0
806		*/
807		public void testEmptyTimedOffer() {
808		SubmissionPublisher<Integer> p = basicPublisher();
809	<	assertEquals(p.offer(1, null), 0);
809	>	assertEquals(0, p.offer(1, LONG_DELAY_MS, MILLISECONDS, null));
810		}
811
812		/**
813	<	* Timed Offer with null item or TimeUnit throws NPE
813	>	* Timed offer with null item or TimeUnit throws NPE
814		*/
815		public void testNullTimedOffer() {
816		SubmissionPublisher<Integer> p = basicPublisher();
#	Line 827 | Line 825 | public class SubmissionPublisherTest ext
825		}
826
827		/**
828	<	* Timed Offer returns number of lagged items if not saturated
828	>	* Timed offer returns number of lagged items if not saturated
829		*/
830		public void testLaggedTimedOffer() {
831		SubmissionPublisher<Integer> p = basicPublisher();
#	Line 853 | Line 851 | public class SubmissionPublisherTest ext
851		}
852
853		/**
854	<	* Timed Offer reports drops if saturated
854	>	* Timed offer reports drops if saturated
855		*/
856		public void testDroppedTimedOffer() {
857		SubmissionPublisher<Integer> p = new SubmissionPublisher<Integer>(
#	Line 881 | Line 879 | public class SubmissionPublisherTest ext
879		}
880
881		/**
882	<	* Timed Offer invokes drop handler if saturated
882	>	* Timed offer invokes drop handler if saturated
883		*/
884		public void testHandledDroppedTimedOffer() {
885		AtomicInteger calls = new AtomicInteger();
#	Line 909 | Line 907 | public class SubmissionPublisherTest ext
907		}
908
909		/**
910	<	* Timed Offer succeeds if drop handler forces request
910	>	* Timed offer succeeds if drop handler forces request
911		*/
912		public void testRecoveredHandledDroppedTimedOffer() {
913		AtomicInteger calls = new AtomicInteger();
#	Line 935 | Line 933 | public class SubmissionPublisherTest ext
933		assertTrue(calls.get() >= 2);
934		}
935
938	–
936		}

Diff Legend

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