- Sort Score
- Num 10 results
- Language All
Results 131 - 140 of 426 for timedOut (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/gcs/GcsClient.java
* <li>credentialsFile - Path to service account JSON file (optional)</li> * <li>connectTimeout - Connection timeout in milliseconds (default: 10000)</li> * <li>writeTimeout - Write timeout in milliseconds (default: 10000)</li> * <li>readTimeout - Read timeout in milliseconds (default: 10000)</li> * </ul> * * <p>The client supports URLs in the format: {@code gcs://bucket-name/object-path} *
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Thu Dec 11 08:38:29 GMT 2025 - 17.5K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 11.9K bytes - Click Count (0) -
buildscripts/race.sh
#!/usr/bin/env bash set -e export GORACE="history_size=7" export MINIO_API_REQUESTS_MAX=10000 for d in $(go list ./...); do CGO_ENABLED=1 go test -v -race --timeout 100m "$d"
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Jul 02 21:28:55 GMT 2024 - 184 bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
* given time. * * @param timeout how long to wait before giving up, in units of [unit] * @param unit a [TimeUnit] determining how to interpret the [timeout] parameter * @return the head of the request queue */ @Throws(InterruptedException::class) public fun takeRequest( timeout: Long, unit: TimeUnit, ): RecordedRequest? = requestQueue.poll(timeout, unit) /**
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 40.3K bytes - Click Count (0) -
cmd/lock-rest-server.go
type lockRESTServer struct { ll *localLocker } // RefreshHandler - refresh the current lock func (l *lockRESTServer) RefreshHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) { // Add a timeout similar to what we expect upstream. ctx, cancel := context.WithTimeout(context.Background(), dsync.DefaultTimeouts.RefreshCall) defer cancel() resp := lockRPCRefresh.NewResponse()Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jan 31 19:54:34 GMT 2025 - 6.3K bytes - Click Count (0) -
.teamcity/src/main/kotlin/configurations/FunctionalTest.kt
os = testCoverage.os, buildJvm = testCoverage.buildJvm, arch = testCoverage.arch, extraParameters = assembledExtraParameters, timeout = testCoverage.testType.timeout, maxParallelForks = testCoverage.testType.maxParallelForks.toString(), extraSteps = extraBuildSteps, preSteps = preBuildSteps, )Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Thu Oct 09 05:26:45 GMT 2025 - 5.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
return; } /* * If we're about to complete the TimeoutFuture, we want to release our reference to it. * Otherwise, we'll pin it (and its result) in memory until the timeout task is GCed. (The * need to clear our reference to the TimeoutFuture is the reason we use a *static* nested * class with a manual reference back to the "containing" class.) *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 8K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/Smb2CancelRequestTest.java
// Given Smb2CancelRequest request = new Smb2CancelRequest(mockConfig, 1L, 0L); // When Integer timeout = request.getOverrideTimeout(); // Then assertNull(timeout, "Cancel requests should not override timeout"); } @Test @DisplayName("Test allowChain returns false") void testAllowChain() { // GivenCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 9.8K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/entity/PingResponseTest.java
assertTrue(mockConfig.getApiPingEsFieldSet().contains("cluster_name")); assertTrue(mockConfig.getApiPingEsFieldSet().contains("status")); assertTrue(mockConfig.getApiPingEsFieldSet().contains("timed_out")); assertTrue(mockConfig.getApiPingEsFieldSet().contains("number_of_nodes")); assertTrue(mockConfig.getApiPingEsFieldSet().contains("number_of_data_nodes"));
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 7.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/llm/LlmException.java
/** Error code for service unavailable (HTTP 502/503). */ public static final String ERROR_SERVICE_UNAVAILABLE = "service_unavailable"; /** Error code for request timeout. */ public static final String ERROR_TIMEOUT = "timeout"; /** Error code for context length exceeded. */ public static final String ERROR_CONTEXT_LENGTH_EXCEEDED = "context_length_exceeded"; /** Error code for model not found. */Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 07 01:53:06 GMT 2026 - 3.5K bytes - Click Count (0)