Home
last modified time | relevance | path

Searched refs:atMost (Results 1 – 25 of 304) sorted by relevance

12345678910>>...13

/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/codec/test/
H A DQuicIntegerTest.cpp37 for (int atMost = 0; atMost <= GetParam().encodedLength; atMost++) { in TEST_P() local
41 (unsigned long)(GetParam().encodedLength - atMost))); in TEST_P()
45 if (GetParam().error || atMost != GetParam().encodedLength) { in TEST_P()
60 for (int atMost = 0; atMost <= GetParam().encodedLength; atMost++) { in TEST_P() local
63 auto decodedValue = decodeQuicInteger(cursor, atMost); in TEST_P()
64 if (GetParam().error || atMost != GetParam().encodedLength) { in TEST_P()
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/
H A DFutureAction.scala54 override def ready(atMost: Duration)(implicit permit: CanAwait): FutureAction.this.type
65 override def result(atMost: Duration)(implicit permit: CanAwait): T
124 override def ready(atMost: Duration)(implicit permit: CanAwait): SimpleFutureAction.this.type = {
125 jobWaiter.completionFuture.ready(atMost)
130 override def result(atMost: Duration)(implicit permit: CanAwait): T = {
131 jobWaiter.completionFuture.ready(atMost)
221 override def ready(atMost: Duration)(implicit permit: CanAwait): this.type = {
222 p.future.ready(atMost)(permit)
227 override def result(atMost: Duration)(implicit permit: CanAwait): T = {
228 p.future.result(atMost)(permit)
/dports/net-im/psi/psi-1.5/3rdparty/qhttp/src/private/
H A Dhttpreader.hxx32 void collectData(int atMost) { in collectData() argument
34 icollectCapacity = atMost; in collectData()
36 if ( atMost > 0 ) in collectData()
37 icollectedData.reserve(atMost); in collectData()
/dports/editors/cpeditor/cpeditor-6.8.2/third_party/qhttp/src/private/
H A Dhttpreader.hxx32 void collectData(int atMost) { in collectData() argument
34 icollectCapacity = atMost; in collectData()
36 if ( atMost > 0 ) in collectData()
37 icollectedData.reserve(atMost); in collectData()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/
H A DTestResourceRetention.java65 verify(pubTracker, atMost(2)) in testRsrcUnused()
67 verify(trackerA, atMost(4)) in testRsrcUnused()
69 verify(trackerB, atMost(1)) in testRsrcUnused()
71 verify(trackerC, atMost(3)) in testRsrcUnused()
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/util/
H A DThreadUtils.scala188 def awaitResult[T](awaitable: Awaitable[T], atMost: Duration): T = {
190 Await.result(awaitable, atMost)
207 def awaitResultInForkJoinSafely[T](awaitable: Awaitable[T], atMost: Duration): T = {
212 awaitable.result(atMost)(awaitPermission)
/dports/www/moodle311/moodle/mod/scorm/tests/
H A Dcustom_completion_test.php195 $DB->expects($this->atMost(1))
207 $DB->expects($this->atMost(1))
221 $DB->expects($this->atMost(1))
225 $DB->expects($this->atMost(1))
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/codec/
H A DQuicInteger.cpp49 uint64_t atMost) { in decodeQuicInteger() argument
54 if (atMost < 1 || !cursor.canAdvance(1)) { in decodeQuicInteger()
81 if (atMost < (numBytes + 1) || !cursor.canAdvance(numBytes + 1)) { in decodeQuicInteger()
/dports/net-im/psi/psi-1.5/3rdparty/qhttp/src/
H A Dqhttpclientresponse.cpp49 QHttpResponse::collectData(int atMost) { in collectData() argument
50 d_func()->collectData(atMost); in collectData()
H A Dqhttpserverrequest.cpp64 QHttpRequest::collectData(int atMost) { in collectData() argument
65 d_func()->collectData(atMost); in collectData()
/dports/editors/cpeditor/cpeditor-6.8.2/third_party/qhttp/src/
H A Dqhttpclientresponse.cpp49 QHttpResponse::collectData(int atMost) { in collectData() argument
50 d_func()->collectData(atMost); in collectData()
H A Dqhttpserverrequest.cpp64 QHttpRequest::collectData(int atMost) { in collectData() argument
65 d_func()->collectData(atMost); in collectData()
/dports/lang/spidermonkey60/firefox-60.9.0/mobile/android/base/java/org/mozilla/gecko/widget/
H A DSplashScreen.java63 atMost(MAX_DISPLAY_TIME - MIN_DISPLAY_TIME); in atLeast()
70 private void atMost(long millis) { in atMost() method in SplashScreen
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/
H A DTestDelegationTokenRenewer.java78 verify(token, atMost(3)).renew(eq(conf)); in testAddRemoveRenewAction()
140 verify(token1, atMost(2)).renew(eq(conf)); in testGetNewTokenOnRenewFailure()
172 verify(token, atMost(2)).renew(eq(conf)); in testStopRenewalWhenFsGone()
179 verify(token, atMost(2)).renew(eq(conf)); in testStopRenewalWhenFsGone()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/
H A DTestIOUtils.java83 Mockito.verify(inputStream, Mockito.atMost(0)).close(); in testCopyBytesShouldNotCloseStreamsWhenCloseIsFalse()
84 Mockito.verify(outputStream, Mockito.atMost(0)).close(); in testCopyBytesShouldNotCloseStreamsWhenCloseIsFalse()
105 Mockito.verify(inputStream, Mockito.atMost(0)).close(); in testCopyBytesWithCountShouldNotCloseStreamsWhenCloseIsFalse()
106 Mockito.verify(outputStream, Mockito.atMost(0)).close(); in testCopyBytesWithCountShouldNotCloseStreamsWhenCloseIsFalse()
/dports/lang/spidermonkey60/firefox-60.9.0/mobile/android/app/src/test/java/org/mozilla/gecko/cleanup/
H A DTestFileCleanupController.java22 import static org.mockito.Mockito.atMost;
68 verify(context, atMost(1)).startService(any(Intent.class)); in testStartIfReadyDoesNotRunTwiceInSuccession()
/dports/www/firefox-legacy/firefox-52.8.0esr/mobile/android/tests/background/junit4/src/org/mozilla/gecko/cleanup/
H A DTestFileCleanupController.java22 import static org.mockito.Mockito.atMost;
68 verify(context, atMost(1)).startService(any(Intent.class)); in testStartIfReadyDoesNotRunTwiceInSuccession()
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/jdk/jfr/event/runtime/
H A DTestNetworkUtilizationEvent.java85 Events.assertField(event, "writeRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE); in main()
86 Events.assertField(event, "readRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE); in main()
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/jdk/jfr/event/runtime/
H A DTestNetworkUtilizationEvent.java85 Events.assertField(event, "writeRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE); in main()
86 Events.assertField(event, "readRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE); in main()
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/jdk/jfr/event/runtime/
H A DTestNetworkUtilizationEvent.java85 Events.assertField(event, "writeRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE); in main()
86 Events.assertField(event, "readRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE); in main()
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/jdk/jfr/event/runtime/
H A DTestNetworkUtilizationEvent.java85 Events.assertField(event, "writeRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE); in main()
86 Events.assertField(event, "readRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE); in main()
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/jdk/jfr/event/runtime/
H A DTestNetworkUtilizationEvent.java85 Events.assertField(event, "writeRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE);
86 Events.assertField(event, "readRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE);
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/jdk/jfr/event/runtime/
H A DTestNetworkUtilizationEvent.java85 Events.assertField(event, "writeRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE); in main()
86 Events.assertField(event, "readRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE); in main()
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/jdk/jfr/event/runtime/
H A DTestNetworkUtilizationEvent.java85 Events.assertField(event, "writeRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE); in main()
86 Events.assertField(event, "readRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE); in main()
/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/test/jdk/jfr/event/runtime/
H A DTestNetworkUtilizationEvent.java85 Events.assertField(event, "writeRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE); in main()
86 Events.assertField(event, "readRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE); in main()

12345678910>>...13