- Sort Score
- Num 10 results
- Language All
Results 81 - 90 of 447 for Timeout (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/jvmTest/kotlin/okhttp3/InterceptorOverridesTest.kt
} OverrideParam.ConnectTimeout -> { client = client .newBuilder() .socketFactory( DelayingSocketFactory(onConnect = { timeout -> if (timeout == 10) { throw IOException() } }), ).build() overrideBadImplementation(override = override.override, testItFails = testItFails)Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 11 02:37:00 GMT 2026 - 28.8K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/exception/CommandExecutionExceptionTest.java
// Scenario 2: Command timeout CommandExecutionException timeout = new CommandExecutionException("Command execution timed out after 30 seconds", new RuntimeException("Timeout")); assertTrue(timeout.getMessage().contains("timed out")); assertNotNull(timeout.getCause()); // Scenario 3: Permission deniedCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 11 08:43:05 GMT 2026 - 9.4K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
} @CanIgnoreReturnValue @Override @ParametricNullness public V get(long timeout, TimeUnit unit) throws TimeoutException, InterruptedException, ExecutionException { long timeoutNanos = unit.toNanos(timeout); if (timeoutNanos <= OverflowAvoidingLockSupport.MAX_NANOSECONDS_THRESHOLD) { return super.get(timeout, unit); } // Waiting 68 years should be enough for any program. return super.get(
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Feb 10 11:51:21 GMT 2026 - 4.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/score/ScoreBooster.java
* @param priority The priority. */ public void setPriority(final int priority) { this.priority = priority; } /** * Sets the request timeout. * @param bulkRequestTimeout The request timeout. */ public void setRequestTimeout(final String bulkRequestTimeout) { requestTimeout = bulkRequestTimeout; } /** * Sets the request cache size.Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 6.6K bytes - Click Count (0) -
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) } }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 1.7K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/Hc5HttpClient.java
final Integer soTimeoutParam = getInitParameter(SO_TIMEOUT_PROPERTY, soTimeout, Integer.class); // Set response timeout (equivalent to socket timeout in HC4) if (soTimeoutParam != null) { requestConfigBuilder.setResponseTimeout(Timeout.ofMilliseconds(soTimeoutParam)); } // user agent userAgent = getInitParameter(USER_AGENT_PROPERTY, userAgent, String.class);
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Sat Jan 31 12:23:29 GMT 2026 - 62.2K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/exception/LdapOperationExceptionTest.java
Exception cause = new RuntimeException("Connection timeout"); LdapOperationException exception = new LdapOperationException(message, cause); assertEquals(message, exception.getMessage()); assertEquals(cause, exception.getCause()); assertEquals("Connection timeout", exception.getCause().getMessage()); } @Test
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 11 08:43:05 GMT 2026 - 8.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
lastUnit = unit; return null; } // No need to test these methods as they are handled by WrappingExecutorServiceTest @Override public boolean awaitTermination(long timeout, TimeUnit unit) { throw new UnsupportedOperationException(); } @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RetryTlsHandshake.kt
when { // If there was a protocol problem, don't recover. e is ProtocolException -> false // If there was an interruption or timeout (SocketTimeoutException), don't recover. // For the socket connect timeout case we do not try the same host with a different // ConnectionSpec: we assume it is unreachable. e is InterruptedIOException -> falseCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 1.7K bytes - Click Count (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 waitCreated: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Mon Aug 04 04:07:30 GMT 2025 - 1.9K bytes - Click Count (0)