Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for propagating (0.1 sec)

  1. android/guava/src/com/google/common/io/Closeables.java

          } else {
            throw e;
          }
        }
      }
    
      /**
       * Closes the given {@link InputStream}, logging any {@code IOException} that's thrown rather than
       * propagating it.
       *
       * <p>While it's not safe in the general case to ignore exceptions that are thrown when closing an
       * I/O resource, it should generally be safe in the case of a resource that's being used only for
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 17 14:35:11 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. LICENSE

    run a copy of the Program.  Ancillary propagation of a covered work
    occurring solely as a consequence of using peer-to-peer transmission
    to receive a copy likewise does not require acceptance.  However,
    nothing other than this License grants you permission to propagate or
    modify any covered work.  These actions infringe copyright if you do
    not accept this License.  Therefore, by modifying or propagating a
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 33.7K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. CHANGELOG/CHANGELOG-1.11.md

    * Setup dns servers and search domains for Windows Pods in dockershim. Docker EE version >= 17.10.0 is required for propagating DNS to containers. ([#63905](https://github.com/kubernetes/kubernetes/pull/63905), [@feiskyer](https://github.com/feiskyer))
    
    ### Additional changes
    
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Feb 06 06:04:15 UTC 2020
    - 328.4K bytes
    - Viewed (0)
  10. 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)
Back to top