- Sort Score
- Result 10 results
- Languages All
Results 231 - 240 of 365 for timeouts (0.14 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractChainedListenableFutureTest.java
resultFuture = buildChainingFuture(inputFuture); listener = new MockFutureListener(resultFuture); } public void testFutureGetBeforeCallback() throws Exception { // Verify that get throws a timeout exception before the callback is called. assertThrows(TimeoutException.class, () -> resultFuture.get(1L, MILLISECONDS)); } public void testFutureGetThrowsWrappedException() throws Exception {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 3.4K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/NetShareEnum.java
name = new String( "\\PIPE\\LANMAN" ); maxParameterCount = 8; // maxDataCount = 4096; why was this set? maxSetupCount = (byte)0x00; setupCount = 0; timeout = 5000; } int writeSetupWireFormat( byte[] dst, int dstIndex ) { return 0; } int writeParametersWireFormat( byte[] dst, int dstIndex ) { int start = dstIndex; byte[] descr;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 2.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java
public boolean isShutdown() { return false; } @Override public boolean isTerminated() { return false; } @Override public boolean awaitTermination(long timeout, TimeUnit unit) { return false; } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 3.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java
public boolean isShutdown() { return false; } @Override public boolean isTerminated() { return false; } @Override public boolean awaitTermination(long timeout, TimeUnit unit) { return false; } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 3.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FuturesGetChecked.java
Future<V> future, Class<X> exceptionClass, long timeout, TimeUnit unit) throws X { // TODO(cpovirk): benchmark a version of this method that accepts a GetCheckedTypeValidator bestGetCheckedTypeValidator().validateClass(exceptionClass); try { return future.get(timeout, unit); } catch (InterruptedException e) { currentThread().interrupt();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 11.9K bytes - Viewed (0) -
cmd/bucket-quota.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 00:34:56 UTC 2024 - 4.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
private final AbstractFuture<?> future; private final long timeout; private final TimeUnit unit; private Exception exception; private volatile long startTime; private long timeSpentBlocked; TimedWaiterThread(AbstractFuture<?> future, long timeout, TimeUnit unit) { this.future = future; this.timeout = timeout; this.unit = unit; } @Override
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 47.1K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental.cc
"Coordination service is not enabled."); return; } absl::Duration timeout; if (timeout_in_ms > 0) { timeout = absl::Milliseconds(timeout_in_ms); } else { // Block until the key-value is set or the worker shuts down. timeout = absl::InfiniteDuration(); } auto status_or_value = coord_agent->GetKeyValue(key, timeout); status->status = status_or_value.status(); if (!status_or_value.ok()) return;
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Sat Oct 12 05:11:17 UTC 2024 - 35.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Futures.java
return applyTransformation(input.get()); } @Override public O get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { return applyTransformation(input.get(timeout, unit)); } private O applyTransformation(I input) throws ExecutionException { try {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.4K bytes - Viewed (0) -
buildscripts/verify-healing-empty-erasure-set.sh
"${MINIO[@]}" --address ":$((start_port + 3))" $args >"${WORK_DIR}/dist-minio-server3.log" 2>&1 & pid3=$! disown $pid3 export MC_HOST_myminio="http://minio:minio123@127.0.0.1:$((start_port + 1))" timeout 15m /tmp/mc ready myminio || fail # Wait for all drives to be online and formatted while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].state | select(. != "ok")' | wc -l) -gt 0 ]; do sleep 1; done
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 3.7K bytes - Viewed (0)