Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for propagating (0.09 sec)

  1. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

        super(futures.size());
        this.futures = checkNotNull(futures);
        this.allMustSucceed = allMustSucceed;
        this.collectsValues = collectsValues;
      }
    
      @Override
      @SuppressWarnings("Interruption") // We are propagating an interrupt from a caller.
      protected final void afterDone() {
        super.afterDone();
    
        @RetainedLocalRef ImmutableCollection<? extends Future<?>> localFutures = futures;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

        private final Future<?> delegate;
    
        FutureAsCancellable(Future<?> delegate) {
          this.delegate = delegate;
        }
    
        @Override
        @SuppressWarnings("Interruption") // We are propagating an interrupt from a caller.
        public void cancel(boolean mayInterruptIfRunning) {
          delegate.cancel(mayInterruptIfRunning);
        }
    
        @Override
        public boolean isCancelled() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  3. tensorflow/c/eager/parallel_device/parallel_device_lib.cc

        // wants to recover and continue running ops on the parallel device (which
        // would otherwise deadlock).
        if (TF_GetCode(status) != TF_OK &&
            (first_bad_status == nullptr
             // Prefer propagating non-cancellation related statuses to avoid
             // shadowing the original failure.
             || TF_GetCode(first_bad_status.get()) == TF_CANCELLED)) {
          first_bad_status.reset(TF_NewStatus());
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/Futures.java

        NonCancellationPropagatingFuture(final ListenableFuture<V> delegate) {
          this.delegate = delegate;
        }
    
        @Override
        public void run() {
          // This prevents cancellation from propagating because we don't call setFuture(delegate) until
          // delegate is already done, so calling cancel() on this future won't affect it.
          @RetainedLocalRef ListenableFuture<V> localDelegate = delegate;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/Futures.java

        NonCancellationPropagatingFuture(final ListenableFuture<V> delegate) {
          this.delegate = delegate;
        }
    
        @Override
        public void run() {
          // This prevents cancellation from propagating because we don't call setFuture(delegate) until
          // delegate is already done, so calling cancel() on this future won't affect it.
          @RetainedLocalRef ListenableFuture<V> localDelegate = delegate;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

       *     completed normally; {@code true} otherwise
       */
      @CanIgnoreReturnValue
      @SuppressWarnings("Interruption") // We are propagating an interrupt from a caller.
      public boolean cancel(boolean mayInterruptIfRunning) {
        logger.get().log(FINER, "cancelling {0}", this);
        boolean cancelled = future.cancel(mayInterruptIfRunning);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 08 19:36:35 UTC 2024
    - 98.5K bytes
    - Viewed (0)
  7. compat/maven-compat/src/test/java/org/apache/maven/project/artifact/MavenMetadataSourceTest.java

            assertNotNull( artifact, "dependency artifact not found in map." );
            assertEquals( Artifact.SCOPE_COMPILE, artifact.getScope(), "dependency artifact has wrong scope." );
    
            //check for back-propagation of default scope.
            assertEquals( Artifact.SCOPE_COMPILE, dep.getScope(), "default scope NOT back-propagated to dependency." );
            */
        }
    
        @Test
        @Disabled
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  8. CREDITS

    infringement under applicable copyright law, except executing it on a
    computer or modifying a private copy.  Propagation includes copying,
    distribution (with or without modification), making available to the
    public, and in some countries other activities as well.
    
      To "convey" a work means any kind of propagation that enables other
    parties to make or receive copies.  Mere interaction with a user through
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 15:03:08 UTC 2024
    - 1.6M bytes
    - Viewed (0)
  9. compat/maven-model-builder/src/test/resources/dag.txt

    	quarkus/extensions/avro/deployment/pom.xml
    quarkus/extensions/smallrye-context-propagation/deployment/pom.xml
    	quarkus/core/deployment/pom.xml
    	quarkus/extensions/arc/deployment/pom.xml
    	quarkus/extensions/smallrye-context-propagation/spi/pom.xml
    	quarkus/extensions/smallrye-context-propagation/runtime/pom.xml
    	quarkus/test-framework/junit5-internal/pom.xml
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 224K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.25.md

    - Avoid propagating hosts' `search .` into containers' `/etc/resolv.conf` ([#112204](https://github.com/kubernetes/kubernetes/pull/112204), [@lucab](https://github.com/lucab)) [SIG Network and Node]
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Mon May 06 09:23:20 UTC 2024
    - 419.1K bytes
    - Viewed (0)
Back to top