| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/java/net/httpclient/reactivestreams-tck/org/reactivestreams/tck/ |
| H A D | TestEnvironment.java | 333 subscribe(pub, sub, timeoutMillis); in newManualSubscriber()
468 return nextElement(timeoutMillis, errorMsg); in requestNextElement()
485 return nextElementOrEndOfStream(timeoutMillis, errorMsg); in requestNextElementOrEndOfStream()
502 expectCompletion(timeoutMillis, errorMsg); in requestEndOfStream()
517 return nextElements(elements, timeoutMillis, errorMsg); in requestNextElements()
533 return received.next(timeoutMillis, errorMsg); in nextElement()
561 return received.nextN(elements, timeoutMillis, errorMsg); in nextElements()
588 received.expectCompletion(timeoutMillis, errorMsg); in expectCompletion()
604 … expectErrorWithMessage(expected, requiredMessagePartAlternatives, timeoutMillis, timeoutMillis); in expectErrorWithMessage()
884 long requested = expectRequest(timeoutMillis); in expectExactRequest()
[all …]
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/java/net/httpclient/reactivestreams-tck/org/reactivestreams/tck/ |
| H A D | TestEnvironment.java | 333 subscribe(pub, sub, timeoutMillis); in newManualSubscriber()
468 return nextElement(timeoutMillis, errorMsg); in requestNextElement()
485 return nextElementOrEndOfStream(timeoutMillis, errorMsg); in requestNextElementOrEndOfStream()
502 expectCompletion(timeoutMillis, errorMsg); in requestEndOfStream()
517 return nextElements(elements, timeoutMillis, errorMsg); in requestNextElements()
533 return received.next(timeoutMillis, errorMsg); in nextElement()
561 return received.nextN(elements, timeoutMillis, errorMsg); in nextElements()
588 received.expectCompletion(timeoutMillis, errorMsg); in expectCompletion()
604 … expectErrorWithMessage(expected, requiredMessagePartAlternatives, timeoutMillis, timeoutMillis); in expectErrorWithMessage()
884 long requested = expectRequest(timeoutMillis); in expectExactRequest()
[all …]
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/java/net/httpclient/reactivestreams-tck/org/reactivestreams/tck/ |
| H A D | TestEnvironment.java | 333 subscribe(pub, sub, timeoutMillis); in newManualSubscriber()
468 return nextElement(timeoutMillis, errorMsg); in requestNextElement()
485 return nextElementOrEndOfStream(timeoutMillis, errorMsg); in requestNextElementOrEndOfStream()
502 expectCompletion(timeoutMillis, errorMsg); in requestEndOfStream()
517 return nextElements(elements, timeoutMillis, errorMsg); in requestNextElements()
533 return received.next(timeoutMillis, errorMsg); in nextElement()
561 return received.nextN(elements, timeoutMillis, errorMsg); in nextElements()
588 received.expectCompletion(timeoutMillis, errorMsg); in expectCompletion()
604 … expectErrorWithMessage(expected, requiredMessagePartAlternatives, timeoutMillis, timeoutMillis); in expectErrorWithMessage()
884 long requested = expectRequest(timeoutMillis); in expectExactRequest()
[all …]
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/java/net/httpclient/reactivestreams-tck/org/reactivestreams/tck/ |
| H A D | TestEnvironment.java | 333 subscribe(pub, sub, timeoutMillis); in newManualSubscriber()
468 return nextElement(timeoutMillis, errorMsg); in requestNextElement()
485 return nextElementOrEndOfStream(timeoutMillis, errorMsg); in requestNextElementOrEndOfStream()
502 expectCompletion(timeoutMillis, errorMsg); in requestEndOfStream()
517 return nextElements(elements, timeoutMillis, errorMsg); in requestNextElements()
533 return received.next(timeoutMillis, errorMsg); in nextElement()
561 return received.nextN(elements, timeoutMillis, errorMsg); in nextElements()
588 received.expectCompletion(timeoutMillis, errorMsg); in expectCompletion()
604 … expectErrorWithMessage(expected, requiredMessagePartAlternatives, timeoutMillis, timeoutMillis); in expectErrorWithMessage()
884 long requested = expectRequest(timeoutMillis); in expectExactRequest()
[all …]
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/java/net/httpclient/reactivestreams-tck/org/reactivestreams/tck/ |
| H A D | TestEnvironment.java | 333 subscribe(pub, sub, timeoutMillis); in newManualSubscriber()
468 return nextElement(timeoutMillis, errorMsg); in requestNextElement()
485 return nextElementOrEndOfStream(timeoutMillis, errorMsg); in requestNextElementOrEndOfStream()
502 expectCompletion(timeoutMillis, errorMsg); in requestEndOfStream()
517 return nextElements(elements, timeoutMillis, errorMsg); in requestNextElements()
533 return received.next(timeoutMillis, errorMsg); in nextElement()
561 return received.nextN(elements, timeoutMillis, errorMsg); in nextElements()
588 received.expectCompletion(timeoutMillis, errorMsg); in expectCompletion()
604 … expectErrorWithMessage(expected, requiredMessagePartAlternatives, timeoutMillis, timeoutMillis); in expectErrorWithMessage()
884 long requested = expectRequest(timeoutMillis); in expectExactRequest()
[all …]
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/java/net/httpclient/reactivestreams-tck/org/reactivestreams/tck/ |
| H A D | TestEnvironment.java | 333 subscribe(pub, sub, timeoutMillis); in newManualSubscriber()
468 return nextElement(timeoutMillis, errorMsg); in requestNextElement()
485 return nextElementOrEndOfStream(timeoutMillis, errorMsg); in requestNextElementOrEndOfStream()
502 expectCompletion(timeoutMillis, errorMsg); in requestEndOfStream()
517 return nextElements(elements, timeoutMillis, errorMsg); in requestNextElements()
533 return received.next(timeoutMillis, errorMsg); in nextElement()
561 return received.nextN(elements, timeoutMillis, errorMsg); in nextElements()
588 received.expectCompletion(timeoutMillis, errorMsg); in expectCompletion()
604 … expectErrorWithMessage(expected, requiredMessagePartAlternatives, timeoutMillis, timeoutMillis); in expectErrorWithMessage()
884 long requested = expectRequest(timeoutMillis); in expectExactRequest()
[all …]
|
| /dports/java/bouncycastle15/crypto-169/tls/src/main/java/org/bouncycastle/tls/ |
| H A D | DefaultTlsHeartbeat.java | 8 private final int idleMillis, timeoutMillis; field in DefaultTlsHeartbeat
12 public DefaultTlsHeartbeat(int idleMillis, int timeoutMillis) in DefaultTlsHeartbeat() argument
18 if (timeoutMillis <= 0) in DefaultTlsHeartbeat()
24 this.timeoutMillis = timeoutMillis; in DefaultTlsHeartbeat()
40 return timeoutMillis; in getTimeoutMillis()
|
| H A D | Timeout.java | 57 int timeoutMillis = getWaitMillis(timeout, currentTimeMillis); in constrainWaitMillis() local
58 if (timeoutMillis < 0) in constrainWaitMillis()
65 return timeoutMillis; in constrainWaitMillis()
67 if (timeoutMillis == 0) in constrainWaitMillis()
72 return Math.min(waitMillis, timeoutMillis); in constrainWaitMillis()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/libaddressinput/src/android/src/androidTest/java/com/android/i18n/addressinput/testing/ |
| H A D | AsyncTestCase.java | 43 protected void delayTestFinish(int timeoutMillis) { in delayTestFinish() argument
44 testTimeoutMillis = System.currentTimeMillis() + timeoutMillis; in delayTestFinish()
64 long timeoutMillis = testTimeoutMillis - System.currentTimeMillis(); in runTest() local
65 if (timeoutMillis > 0) { in runTest()
67 wait(timeoutMillis); in runTest()
71 throw new TimeoutException("Waited " + timeoutMillis + " ms!"); in runTest()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/libaddressinput/src/android/src/androidTest/java/com/android/i18n/addressinput/testing/ |
| H A D | AsyncTestCase.java | 43 protected void delayTestFinish(int timeoutMillis) { in delayTestFinish() argument
44 testTimeoutMillis = System.currentTimeMillis() + timeoutMillis; in delayTestFinish()
64 long timeoutMillis = testTimeoutMillis - System.currentTimeMillis(); in runTest() local
65 if (timeoutMillis > 0) { in runTest()
67 wait(timeoutMillis); in runTest()
71 throw new TimeoutException("Waited " + timeoutMillis + " ms!"); in runTest()
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/src/java.base/share/classes/java/lang/ |
| H A D | Object.java | 345 public final native void wait(long timeoutMillis) throws InterruptedException; in wait() argument
441 public final void wait(long timeoutMillis, int nanos) throws InterruptedException { in wait() argument
442 if (timeoutMillis < 0) { in wait()
451 if (nanos > 0 && timeoutMillis < Long.MAX_VALUE) { in wait()
452 timeoutMillis++; in wait()
455 wait(timeoutMillis); in wait()
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/src/java.base/share/classes/java/lang/ |
| H A D | Object.java | 345 public final native void wait(long timeoutMillis) throws InterruptedException; in wait() argument
441 public final void wait(long timeoutMillis, int nanos) throws InterruptedException { in wait() argument
442 if (timeoutMillis < 0) { in wait()
451 if (nanos > 0 && timeoutMillis < Long.MAX_VALUE) { in wait()
452 timeoutMillis++; in wait()
455 wait(timeoutMillis); in wait()
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/java.base/share/classes/java/lang/ |
| H A D | Object.java | 350 public final native void wait(long timeoutMillis) throws InterruptedException; in wait() argument
446 public final void wait(long timeoutMillis, int nanos) throws InterruptedException { in wait() argument
447 if (timeoutMillis < 0) { in wait()
456 if (nanos > 0 && timeoutMillis < Long.MAX_VALUE) { in wait()
457 timeoutMillis++; in wait()
460 wait(timeoutMillis); in wait()
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.base/share/classes/java/lang/ |
| H A D | Object.java | 344 public final native void wait(long timeoutMillis) throws InterruptedException; in wait() argument
440 public final void wait(long timeoutMillis, int nanos) throws InterruptedException { in wait() argument
441 if (timeoutMillis < 0) { in wait()
450 if (nanos > 0 && timeoutMillis < Long.MAX_VALUE) { in wait()
451 timeoutMillis++; in wait()
454 wait(timeoutMillis); in wait()
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/java.base/share/classes/java/lang/ |
| H A D | Object.java | 362 public final native void wait(long timeoutMillis) throws InterruptedException; in wait() argument
458 public final void wait(long timeoutMillis, int nanos) throws InterruptedException { in wait() argument
459 if (timeoutMillis < 0) { in wait()
468 if (nanos > 0 && timeoutMillis < Long.MAX_VALUE) { in wait()
469 timeoutMillis++; in wait()
472 wait(timeoutMillis); in wait()
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/java.base/share/classes/java/lang/ |
| H A D | Object.java | 350 public final native void wait(long timeoutMillis) throws InterruptedException; in wait() argument
446 public final void wait(long timeoutMillis, int nanos) throws InterruptedException { in wait() argument
447 if (timeoutMillis < 0) { in wait()
456 if (nanos > 0 && timeoutMillis < Long.MAX_VALUE) { in wait()
457 timeoutMillis++; in wait()
460 wait(timeoutMillis); in wait()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/libaddressinput/src/android/src/main/java/com/android/i18n/addressinput/ |
| H A D | AndroidAsyncRequestApi.java | 48 private final int timeoutMillis; field in AndroidAsyncRequestApi.AsyncHttp
50 protected AsyncHttp(URL requestUrl, AsyncCallback callback, int timeoutMillis) { in AsyncHttp() argument
53 this.timeoutMillis = timeoutMillis; in AsyncHttp()
64 connection.setConnectTimeout(timeoutMillis); in run()
65 connection.setReadTimeout(timeoutMillis); in run()
100 @Override public void requestObject(String url, AsyncCallback callback, int timeoutMillis) { in requestObject() argument
102 (new AsyncHttp(stringToUrl(url), callback, timeoutMillis)).start(); in requestObject()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/libaddressinput/src/android/src/main/java/com/android/i18n/addressinput/ |
| H A D | AndroidAsyncRequestApi.java | 48 private final int timeoutMillis; field in AndroidAsyncRequestApi.AsyncHttp
50 protected AsyncHttp(URL requestUrl, AsyncCallback callback, int timeoutMillis) { in AsyncHttp() argument
53 this.timeoutMillis = timeoutMillis; in AsyncHttp()
64 connection.setConnectTimeout(timeoutMillis); in run()
65 connection.setReadTimeout(timeoutMillis); in run()
100 @Override public void requestObject(String url, AsyncCallback callback, int timeoutMillis) { in requestObject() argument
102 (new AsyncHttp(stringToUrl(url), callback, timeoutMillis)).start(); in requestObject()
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/java.base/share/classes/java/lang/ |
| H A D | Object.java | 352 public final native void wait(long timeoutMillis) throws InterruptedException; in wait() argument
448 public final void wait(long timeoutMillis, int nanos) throws InterruptedException { in wait() argument
449 if (timeoutMillis < 0) { in wait()
459 timeoutMillis++; in wait()
462 wait(timeoutMillis); in wait()
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/src/java.base/share/classes/java/lang/ |
| H A D | Object.java | 352 public final native void wait(long timeoutMillis) throws InterruptedException; in wait() argument
448 public final void wait(long timeoutMillis, int nanos) throws InterruptedException { in wait() argument
449 if (timeoutMillis < 0) { in wait()
459 timeoutMillis++; in wait()
462 wait(timeoutMillis); in wait()
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/ |
| H A D | LockConflictException.java | 120 private long timeoutMillis; field in LockConflictException
199 public void setTimeoutMillis(long timeoutMillis) { in setTimeoutMillis() argument
200 this.timeoutMillis = timeoutMillis; in setTimeoutMillis()
208 return timeoutMillis; in getTimeoutMillis()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/executor/ |
| H A D | network_interface_asio_integration_fixture.cpp | 121 Milliseconds timeoutMillis) { in assertCommandOK() argument
123 fixture().getServers()[0], db.toString(), cmd, BSONObj(), nullptr, timeoutMillis}; in assertCommandOK()
131 StringData db, const BSONObj& cmd, ErrorCodes::Error reason, Milliseconds timeoutMillis) { in assertCommandFailsOnClient() argument
133 fixture().getServers()[0], db.toString(), cmd, BSONObj(), nullptr, timeoutMillis}; in assertCommandFailsOnClient()
139 StringData db, const BSONObj& cmd, ErrorCodes::Error reason, Milliseconds timeoutMillis) { in assertCommandFailsOnServer() argument
141 fixture().getServers()[0], db.toString(), cmd, BSONObj(), nullptr, timeoutMillis}; in assertCommandFailsOnServer()
151 Milliseconds timeoutMillis) { in assertWriteError() argument
153 fixture().getServers()[0], db.toString(), cmd, BSONObj(), nullptr, timeoutMillis}; in assertWriteError()
|
| /dports/devel/android-tools-adb/platform_system_core-android-9.0.0_r3/libutils/ |
| H A D | Looper.cpp | 210 result = pollInner(timeoutMillis); in pollOnce()
214 int Looper::pollInner(int timeoutMillis) { in pollInner() argument
220 if (timeoutMillis != 0 && mNextMessageUptime != LLONG_MAX) { in pollInner()
224 && (timeoutMillis < 0 || messageTimeoutMillis < timeoutMillis)) { in pollInner()
225 timeoutMillis = messageTimeoutMillis; in pollInner()
229 this, mNextMessageUptime - now, timeoutMillis); in pollInner()
373 if (timeoutMillis <= 0) { in pollAll()
376 result = pollOnce(timeoutMillis, outFd, outEvents, outData); in pollAll()
381 + milliseconds_to_nanoseconds(timeoutMillis); in pollAll()
390 timeoutMillis = toMillisecondTimeoutDelay(now, endTime); in pollAll()
[all …]
|
| /dports/devel/android-tools-fastboot/platform_system_core-platform-tools-29.0.5/libutils/ |
| H A D | Looper.cpp | 207 result = pollInner(timeoutMillis); in pollOnce()
211 int Looper::pollInner(int timeoutMillis) { in pollInner() argument
217 if (timeoutMillis != 0 && mNextMessageUptime != LLONG_MAX) { in pollInner()
221 && (timeoutMillis < 0 || messageTimeoutMillis < timeoutMillis)) { in pollInner()
222 timeoutMillis = messageTimeoutMillis; in pollInner()
226 this, mNextMessageUptime - now, timeoutMillis); in pollInner()
370 if (timeoutMillis <= 0) { in pollAll()
373 result = pollOnce(timeoutMillis, outFd, outEvents, outData); in pollAll()
378 + milliseconds_to_nanoseconds(timeoutMillis); in pollAll()
387 timeoutMillis = toMillisecondTimeoutDelay(now, endTime); in pollAll()
[all …]
|
| /dports/devel/android-tools-adb/platform_system_core-android-9.0.0_r3/libutils/include/utils/ |
| H A D | Looper.h | 263 int pollOnce(int timeoutMillis, int* outFd, int* outEvents, void** outData);
264 inline int pollOnce(int timeoutMillis) { in pollOnce() argument
265 return pollOnce(timeoutMillis, NULL, NULL, NULL); in pollOnce()
273 int pollAll(int timeoutMillis, int* outFd, int* outEvents, void** outData);
274 inline int pollAll(int timeoutMillis) { in pollAll() argument
275 return pollAll(timeoutMillis, NULL, NULL, NULL); in pollAll()
473 int pollInner(int timeoutMillis);
|