Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 16 for cancellation (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/grid/README.md

    Context timeouts are propagated, and a default timeout of 1 minute is added if none is specified.
    
    There is no cancellation propagation for single payload requests.
    When the context is canceled, the request will return at once with an appropriate error.
    However, the remote call will not see the cancellation - as can be seen from the 'missing' context on the handler.
    The result will be discarded.
    
    ### Typed handlers
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  2. guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *
     * <p>This class has limited support for cancellation and other "early completions":
     *
     * <ul>
     *   <li>While calls to {@code submit} and {@code submitAsync} return a {@code Future} that can be
     *       cancelled, cancellation never propagates to a task that has started to run -- neither to
     *       the callable itself nor to any {@code Future} returned by an {@code AsyncCallable}.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 01:35:55 GMT 2025
    - 22.1K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Tests for {@link AbstractFuture} with the cancellation cause system property set */
    @AndroidIncompatible // custom classloading
    
    @NullUnmarked
    public class AbstractFutureCancellationCauseTest extends TestCase {
    
      private ClassLoader oldClassLoader;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Call.kt

       * necessarily indicate application-layer success: `response` may still indicate an unhappy HTTP
       * response code like 404 or 500.
       *
       * @throws IOException if the request could not be executed due to cancellation, a connectivity
       *     problem or timeout. Because networks can fail during an exchange, it is possible that the
       *     remote server accepted the request before the failure.
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

       * Implementations must support such concurrent calls.
       *
       * Note that cancellation is best-effort and that a call may proceed normally after it has been
       * canceled. For example, happy-path events like [requestHeadersStart] and [requestHeadersEnd] may
       * occur after a call is canceled. Typically cancellation takes effect when an expensive I/O
       * operation is required.
       *
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:03:04 GMT 2025
    - 24.9K bytes
    - Click Count (0)
  6. cmd/common-main.go

    	select {
    	case <-ctx.Done():
    		return true
    	default:
    		return false
    	}
    }
    
    // bgContext returns a context that can be used for async operations.
    // Cancellation/timeouts are removed, so parent cancellations/timeout will
    // not propagate from parent.
    // Context values are preserved.
    // This can be used for goroutines that live beyond the parent context.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 32.5K bytes
    - Click Count (3)
  7. cmd/metacache-set.go

    }
    
    // listPathRaw will list a path on the provided drives.
    // See listPathRawOptions on how results are delivered.
    // Directories are always returned.
    // Cache will be bypassed.
    // Context cancellation will be respected but may take a while to effectuate.
    func listPathRaw(ctx context.Context, opts listPathRawOptions) (err error) {
    	disks := opts.disks
    	if len(disks) == 0 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 30.7K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

          Object result = Iterables.getOnlyElement(finalResults);
          if (result == CancellationException.class) {
            assertTrue(future.isCancelled());
            assertTrue(cancellationSuccess.get());
            // cancellation can interleave in 3 ways
            // 1. prior to setFuture
            // 2. after setFuture before set() on the future assigned
            // 3. after setFuture and set() are called but before the listener completes.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 46.8K bytes
    - Click Count (0)
  9. guava/src/com/google/common/util/concurrent/MoreExecutors.java

        }
    
        /*
         * TODO: https://github.com/google/guava/issues/2143 - In addition to overriding `execute`, also
         * override the `Future`-returning methods of `ExecutorService` to propagate cancellation from
         * our `TrustedListenableFutureTask` to a `Future` returned by the delegate executor?
         */
    
        @Override
        public final void execute(Runnable command) {
          delegate.execute(command);
        }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 45.2K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

          Object result = Iterables.getOnlyElement(finalResults);
          if (result == CancellationException.class) {
            assertTrue(future.isCancelled());
            assertTrue(cancellationSuccess.get());
            // cancellation can interleave in 3 ways
            // 1. prior to setFuture
            // 2. after setFuture before set() on the future assigned
            // 3. after setFuture and set() are called but before the listener completes.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 46.8K bytes
    - Click Count (0)
Back to Top