- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 170 for Canceled (0.05 sec)
-
guava/src/com/google/common/util/concurrent/FutureCallback.java
/** Invoked with the result of the {@code Future} computation when it is successful. */ void onSuccess(@ParametricNullness V result); /** * Invoked when a {@code Future} computation fails or is canceled. * * <p>If the future's {@link Future#get() get} method throws an {@link ExecutionException}, then * the cause is passed to this method. Any other thrown object is passed unaltered. */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Interceptor.kt
* * * For asynchronous calls made with [Call.enqueue], an [IOException] is propagated to the caller * indicating that the call was canceled. The interceptor's exception is delivered to the current * thread's [uncaught exception handler][Thread.UncaughtExceptionHandler]. By default this
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3.5K bytes - Viewed (0) -
cmd/shared-lock.go
if err != nil { continue } keepLock: for { select { case <-ctx.Done(): return case <-lkctx.Context().Done(): // The context of the lock is canceled, this can happen // if one lock lost quorum due to cluster instability // in that case, try to lock again. break keepLock case ld.lockContext <- lkctx: // Send the lock context to anyone asking for it
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Feb 13 09:26:38 UTC 2023 - 2.3K bytes - Viewed (0) -
.github/workflows/replication.yaml
name: MinIO advanced tests on: pull_request: branches: - master # This ensures that previous jobs for the PR are canceled when the PR is # updated. concurrency: group: ${{ github.workflow }}-${{ github.head_ref }} cancel-in-progress: true permissions: contents: read jobs: replication-test: name: Advanced Tests with Go ${{ matrix.go-version }} runs-on: ubuntu-latest strategy:
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 2.2K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourcesHttpTest.kt
val request = Request.Builder().url(server.url("/")).build() val response = client.newCall(request).execute() response.processEventSource(listener) listener.assertOpen() listener.assertFailure("canceled") } @Test fun failureWith401IsReadable() { server.enqueue( MockResponse( code = 401, body = "{\"error\":{\"message\":\"No auth credentials found\",\"code\":401}}",
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 13:49:38 UTC 2025 - 3.6K bytes - Viewed (0) -
cmd/service.go
// Add new service requests here. ) // Global service signal channel. var globalServiceSignalCh = make(chan serviceSignal) // GlobalContext context that is canceled when server is requested to shut down. // cancelGlobalContext can be used to indicate server shutdown. var GlobalContext, cancelGlobalContext = context.WithCancel(context.Background())
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Feb 28 07:02:14 UTC 2024 - 3.8K bytes - Viewed (0) -
.github/workflows/iam-integrations.yaml
name: IAM integration on: pull_request: branches: - master # This ensures that previous jobs for the PR are canceled when the PR is # updated. concurrency: group: ${{ github.workflow }}-${{ github.head_ref }} cancel-in-progress: true permissions: contents: read jobs: iam-matrix-test: name: "[Go=${{ matrix.go-version }}|ldap=${{ matrix.ldap }}|etcd=${{ matrix.etcd }}|openid=${{ matrix.openid }}]"
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 5.3K bytes - Viewed (0) -
cmd/metrics-v3-api.go
apiRequests4xxErrorsTotalMD = NewCounterMD(apiRequests4xxErrorsTotal, "Total number of requests with 4xx errors", "name", "type") apiRequestsCanceledTotalMD = NewCounterMD(apiRequestsCanceledTotal, "Total number of requests canceled by the client", "name", "type") apiRequestsTTFBSecondsDistributionMD = NewCounterMD(apiRequestsTTFBSecondsDistribution, "Distribution of time to first byte across API calls", "name", "type", "le")
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Sep 24 17:13:00 UTC 2024 - 9.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
import okhttp3.internal.stripBody import okhttp3.internal.withSuppressed /** * This interceptor recovers from failures and follows redirects as necessary. It may throw an * [IOException] if the call was canceled. */ class RetryAndFollowUpInterceptor( private val client: OkHttpClient, ) : Interceptor { @Throws(IOException::class) override fun intercept(chain: Interceptor.Chain): Response {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 12.4K bytes - Viewed (0) -
cmd/http-stats.go
hstats.totalS3Requests.Inc(api) code := w.StatusCode switch { case code == 0: case code == 499: // 499 is a good error, shall be counted as canceled. hstats.totalS3Canceled.Inc(api) case code >= http.StatusBadRequest: if code >= http.StatusInternalServerError { hstats.totalS35xxErrors.Inc(api) } else { hstats.totalS34xxErrors.Inc(api) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Sep 24 17:13:00 UTC 2024 - 11.4K bytes - Viewed (0)