/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/codec/test/ |
H A D | QuicIntegerTest.cpp | 37 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 D | FutureAction.scala | 54 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 D | httpreader.hxx | 32 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 D | httpreader.hxx | 32 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 D | TestResourceRetention.java | 65 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 D | ThreadUtils.scala | 188 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 D | custom_completion_test.php | 195 $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 D | QuicInteger.cpp | 49 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 D | qhttpclientresponse.cpp | 49 QHttpResponse::collectData(int atMost) { in collectData() argument 50 d_func()->collectData(atMost); in collectData()
|
H A D | qhttpserverrequest.cpp | 64 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 D | qhttpclientresponse.cpp | 49 QHttpResponse::collectData(int atMost) { in collectData() argument 50 d_func()->collectData(atMost); in collectData()
|
H A D | qhttpserverrequest.cpp | 64 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 D | SplashScreen.java | 63 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 D | TestDelegationTokenRenewer.java | 78 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 D | TestIOUtils.java | 83 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 D | TestFileCleanupController.java | 22 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 D | TestFileCleanupController.java | 22 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 D | TestNetworkUtilizationEvent.java | 85 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 D | TestNetworkUtilizationEvent.java | 85 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 D | TestNetworkUtilizationEvent.java | 85 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 D | TestNetworkUtilizationEvent.java | 85 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 D | TestNetworkUtilizationEvent.java | 85 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 D | TestNetworkUtilizationEvent.java | 85 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 D | TestNetworkUtilizationEvent.java | 85 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 D | TestNetworkUtilizationEvent.java | 85 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()
|