Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for canceler (0.04 sec)

  1. cmd/batch-handlers.go

    	}
    	return nil
    }
    
    // delete canceler from the map, cancel job if requested
    func (j *BatchJobPool) canceler(jobID string, cancel bool) error {
    	if j == nil {
    		return errInvalidArgument
    	}
    	j.jmu.Lock()
    	defer j.jmu.Unlock()
    	if canceler, ok := j.jobCancelers[jobID]; ok {
    		if cancel {
    			canceler()
    		}
    	}
    	if cancel {
    		delete(j.jobCancelers, jobID)
    	}
    	return nil
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool.go

    	// Updates must be closed before we return.
    	defer xioutil.SafeClose(updates)
    
    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    	var results []dataUsageCache
    	var firstErr error
    
    	allBuckets, err := z.ListBuckets(ctx, BucketOptions{})
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/Futures.java

       * input future and that of the future returned by the chain function. That is, if the returned
       * {@code Future} is cancelled, it will attempt to cancel the other two, and if either of the
       * other two is cancelled, the returned {@code Future} will receive a callback in which it will
       * attempt to cancel itself.
       *
       * @param input The future to transform
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

        assertStillOpen(closeable1, closeable2, closeable3, closeable4);
    
        // Cancel step 3, resume step 2, and pause in step 4.
        assertWithMessage("step3.cancel()").that(step3.cancel(false)).isTrue();
        step2Waiter.awaitReturned();
        step4Waiter.awaitStarted();
    
        // Step 1 is not cancelled because it was done.
        assertWithMessage("step1.statusFuture().isCancelled()")
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 75.4K bytes
    - Viewed (0)
  5. docs/changelogs/changelog_3x.md

        canceling calls would cause the shared HTTP/2 connection to be unnecessarily released. This
        harmed connection reuse.
     *  Fix: Ensure canceled and discarded HTTP/2 data is not permanently counted against the limited
        flow control window. We had a few bugs where window size accounting was broken when streams
        were canceled or reset.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

              .Builder()
              .url(server.url("/"))
              .build(),
          )
        call.cancel()
        assertFailsWith<IOException> {
          call.execute()
        }.also { expected ->
          assertThat(expected.message).isEqualTo("Canceled")
        }
        assertThat(listener.recordedEventTypes()).containsExactly(
          "Canceled",
          "CallStart",
          "CallFailed",
        )
      }
    
      @Test
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 60.4K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        override fun dispatch(request: RecordedRequest): MockResponse {
          // This guarantees a deterministic sequence when handling the canceled request:
          // 1. Server reads request and dequeues first response
          // 2. Client cancels request
          // 3. Server tries to send response on the canceled stream
          // Otherwise, there is no guarantee for the sequence. For example, the server may use the
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 73.4K bytes
    - Viewed (0)
  8. cmd/test-utils_test.go

    		setObjectLayer(newObjectLayerFn())
    		cancel()
    		removeRoots(fsDirs)
    	}
    }
    
    // ExecObjectLayerTestWithDirs - executes object layer tests.
    // Creates single node and Erasure ObjectLayer instance and runs test for both the layers.
    func ExecObjectLayerTestWithDirs(t TestErrHandler, objTest objTestTypeWithDirs) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	if localMetacacheMgr != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

         *
         * If the server does not respond to each ping with a pong within `interval`, this client will
         * assume that connectivity has been lost. When this happens on a web socket the connection is
         * canceled and its listener is [notified][WebSocketListener.onFailure]. When it happens on an
         * HTTP/2 connection the connection is closed and any calls it is carrying
         * [will fail with an IOException][java.io.IOException].
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  10. cmd/api-errors.go

    		return ErrRequestTimedout
    	}
    
    	// Only return ErrClientDisconnected if the provided context is actually canceled.
    	// This way downstream context.Canceled will still report ErrRequestTimedout
    	if contextCanceled(ctx) && errors.Is(ctx.Err(), context.Canceled) {
    		return ErrClientDisconnected
    	}
    
    	// Unwrap the error first
    	err = unwrapAll(err)
    
    	switch err {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 16 07:34:24 UTC 2025
    - 93K bytes
    - Viewed (1)
Back to top