Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 170 for Canceled (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. .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)
  5. 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)
  6. 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)
  7. .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)
  8. 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)
  9. 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)
  10. 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)
Back to top