- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 473 for _timeout (0.18 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/SpecificHostSocketFactory.kt
override fun connect( endpoint: SocketAddress?, timeout: Int, ) { val requested = (endpoint as InetSocketAddress) val inetSocketAddress = hostMapping[requested.address] ?: defaultAddress ?: requested Platform.get().log("Socket connection to: $inetSocketAddress was: $requested") super.connect(inetSocketAddress, timeout) } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 1.7K bytes - Viewed (0) -
tests/compose.yml
fi; echo "Waiting for database to be ready... ($$counter/12)"; sleep 5; counter=$$(($$counter + 1)); done; # timeout handling if [ $$counter -gt 20 ]; then echo "Error: Database failed to start within timeout"; exit 1; fi; # keep the container running: wait for the database process in the foreground wait
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Mon Aug 04 04:07:30 UTC 2025 - 1.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbComTransaction.java
+ ",maxParameterCount=" + maxParameterCount + ",maxDataCount=" + maxDataCount + ",maxSetupCount=" + (int) maxSetupCount + ",flags=0x" + Hexdump.toHexString(flags, 2) + ",timeout=" + timeout + ",parameterCount=" + parameterCount + ",parameterOffset=" + parameterOffset + ",parameterDisplacement=" + parameterDisplacement + ",dataCount=" + dataCount
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 10.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
* @throws CancellationException {@inheritDoc} */ @CanIgnoreReturnValue @Override public V get(long timeout, TimeUnit unit) throws InterruptedException, TimeoutException, ExecutionException { return sync.get(unit.toNanos(timeout)); } /* * Improve the documentation of when InterruptedException is thrown. Our
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jan 30 16:59:10 UTC 2025 - 13.7K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/TunnelingUnixSocket.java
super.connect(new UnixSocketAddress(path), 0); } @Override public void connect(SocketAddress endpoint, int timeout) throws IOException { this.inetSocketAddress = (InetSocketAddress) endpoint; super.connect(new UnixSocketAddress(path), timeout); } @Override public InetAddress getInetAddress() { return inetSocketAddress.getAddress(); }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Feb 12 16:33:52 UTC 2019 - 1.9K bytes - Viewed (0) -
src/test/java/jcifs/util/SimpleCircuitBreakerTest.java
} @Test @DisplayName("Test transition to HALF_OPEN after timeout") void testTransitionToHalfOpen() throws Exception { // Open the circuit circuitBreaker.tripBreaker(); assertEquals(SimpleCircuitBreaker.State.OPEN, circuitBreaker.getState()); // Wait for timeout Thread.sleep(150); // Next call should transition to HALF_OPEN
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 10.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Platform.java
return future.blockingGet(); } static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { return future.blockingGet(timeout, unit); } private Platform() {}
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 2.1K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/com/SmbComLockingAndXTest.java
// set fields via reflection setField(cmd, "fid", 0x1234); setField(cmd, "typeOfLock", (byte) 0x05); setField(cmd, "newOpLockLevel", (byte) 0x01); setField(cmd, "timeout", 3000L); // arrays of one lock and one unlock range LockingAndXRange lock = new LockingAndXRange(false); lock.encode(new byte[20], 0); // initialise fields by encoding to set pid etc (though not needed)
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 7.1K bytes - Viewed (0) -
src/main/java/jcifs/netbios/NameServiceClientImpl.java
} return this.nextNameTrnId; } void ensureOpen(final int timeout) throws IOException { this.closeTimeout = 0; if (this.transportContext.getConfig().getNetbiosSoTimeout() != 0) { this.closeTimeout = Math.max(this.transportContext.getConfig().getNetbiosSoTimeout(), timeout); } // If socket is still good, the new closeTimeout will
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 38.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/disni/DisniRdmaConnection.java
// RdmaCompletionEvent event = endpoint.getCqProcessor().getCqEvent(timeout); // if (event != null) { // return event.getBuffer(); // } // return null; // For skeleton implementation, return null (timeout) return null; } catch (Exception e) { state = RdmaConnectionState.ERROR;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 10.2K bytes - Viewed (0)