- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for propagating (0.15 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)