- Sort Score
- Num 10 results
- Language All
Results 331 - 340 of 420 for cancelFn (0.1 seconds)
-
docs/sts/tls.md
*Applications that use direct S3 API will work fine, however interactive users uploading content using (when POSTing to the presigned URL an app generates) a popup becomes visible on browser to provide client certs, you would have to manually cancel and continue. This may be annoying to use but there is no workaround for now.* ## Explore Further - [MinIO Admin Complete Guide](https://docs.min.io/community/minio-object-store/reference/minio-mc-admin.html)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 6K bytes - Click Count (1) -
cmd/admin-router.go
adminRouter.Methods(http.MethodPost).Path(adminVersion+"/pools/cancel").HandlerFunc(adminMiddleware(adminAPI.CancelDecommission, traceAllFlag)).Queries("pool", "{pool:.*}") // Rebalance operations
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 10 18:57:03 GMT 2025 - 26.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
if (!newRouteSelector.hasNext()) throw IOException("exhausted all routes") val newRouteSelection = newRouteSelector.next() routeSelection = newRouteSelection if (isCanceled()) throw IOException("Canceled") return planConnectToRoute(newRouteSelection.next(), newRouteSelection.routes) } /** * Returns a plan to reuse a pooled connection, or null if the pool doesn't have a connection for
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 12.1K bytes - Click Count (0) -
cmd/handler-api.go
if unlock, ok := val.(chan struct{}); ok && unlock != nil { // Wait until unfrozen. select { case <-unlock: case <-r.Context().Done(): // if client canceled we don't need to wait here forever. return } } } } globalHTTPStats.addRequestsInQueue(1) pool := globalAPIConfig.getRequestsPool() if pool == nil {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.4K bytes - Click Count (0) -
build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Tue Sep 23 13:49:45 GMT 2025 - 12K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/PythonJob.java
resultBuf.append(e.getMessage()).append("\n"); } finally { if (timeoutTask != null && !timeoutTask.isCanceled()) { timeoutTask.cancel(); } } return resultBuf.toString(); } /** * Executes the Python script with the configured parameters.
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 8.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/SuggestJob.java
resultBuf.append(e.getMessage()).append("\n"); } finally { if (timeoutTask != null && !timeoutTask.isCanceled()) { timeoutTask.cancel(); } } return resultBuf.toString(); } /** * Executes the suggest creator process.
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 10.5K bytes - Click Count (0) -
guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
Object unused = new Object() { @SuppressWarnings({"removal", "Finalize"}) // b/487687332 @Override protected void finalize() { future.cancel(false); } }; unused = null; // Hint to the JIT that unused is unreachable GcFinalization.awaitDone(future); assertTrue(future.isDone()); assertTrue(future.isCancelled()); }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 16:11:48 GMT 2026 - 8.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
} } private static final class RuntimeExceptionThrowingFuture<V> implements Future<V> { final CountDownLatch allowGetToComplete = new CountDownLatch(1); @Override public boolean cancel(boolean mayInterruptIfRunning) { throw new AssertionFailedError(); } @Override public V get() throws InterruptedException { /*
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 10K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java
if (accessTimeoutTarget != null) { accessTimeoutTarget.stop(); if (accessTimeoutTask != null && !accessTimeoutTask.isCanceled()) { accessTimeoutTask.cancel(); } } } } /** * Gets response data for the given URI. * * @param uri the URI to get response data for
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Sun Nov 23 12:19:14 GMT 2025 - 15.1K bytes - Click Count (0)