| /external/clang/test/OpenMP/ |
| D | cancellation_point_messages.cpp | 4 #pragma omp cancellation // expected-error {{expected an OpenMP directive}} in main()
5 #pragma omp cancellation point // expected-error {{one of 'for', 'parallel', 'sections' or 'taskgro… in main()
7 #pragma omp cancellation point parallel untied // expected-error {{unexpected OpenMP clause 'untied… in main()
8 #pragma omp cancellation point unknown // expected-error {{one of 'for', 'parallel', 'secti… in main()
9 #pragma omp cancellation point sections( // expected-warning {{extra tokens at the end of '#p… in main()
10 #pragma omp cancellation point for, ) // expected-warning {{extra tokens at the end of '#p… in main()
11 #pragma omp cancellation point taskgroup() // expected-warning {{extra tokens at the end of '#p… in main()
12 #pragma omp cancellation point parallel, if // expected-warning {{extra tokens at the end of '#p… in main()
14 #pragma omp cancellation point for // expected-error {{'#pragma omp cancellation point' cannot be a… in main()
20 #pragma omp cancellation point taskgroup // expected-error {{region cannot be closely nested inside… in main()
[all …]
|
| D | cancellation_point_ast_print.cpp | 13 #pragma omp cancellation point parallel in main()
17 // CHECK-NEXT: #pragma omp cancellation point parallel in main()
21 #pragma omp cancellation point sections in main()
25 // CHECK: #pragma omp cancellation point sections in main()
29 #pragma omp cancellation point for in main()
33 // CHECK-NEXT: #pragma omp cancellation point for in main()
37 #pragma omp cancellation point taskgroup in main()
41 // CHECK: #pragma omp cancellation point taskgroup in main()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/src/ |
| D | ListenableFuture.kt | 22 * succeed, barring a race with external cancellation of returned [ListenableFuture]. in <lambda>()
24 * Cancellation is propagated bidirectionally. in <lambda>()
38 * Note that the error and cancellation semantics of [future] are _different_ than [async]'s. in <lambda>()
66 * Cancellation is propagated bidirectionally.
70 * race with cancellation of the `Deferred`.
76 * cancellation to `this` `ListenableFuture`. Propagation will succeed, barring a race with the
88 * `Deferred`. This can only race with cancellation of the returned `Deferred`, so the in asDeferred()
90 * cancellation) _eventually_ reach its "cancelled" state when either promise is successfully in asDeferred()
95 * cancellation may not succeed and the `ListenableFuture` may complete in a non-cancelled in asDeferred()
100 * This is unavoidable, so make sure no idempotent cancellation work is performed by a in asDeferred()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | CancellableContinuation.kt | 83 * guaranteed can be provided by having a cancellation fallback. in <lambda>()
111 * Internal function that setups cancellation behavior in [suspendCancellableCoroutine]. in <lambda>()
122 …* Cancels this continuation with an optional cancellation `cause`. The result is `true` if this co… in <lambda>()
128 …* Registers a [handler] to be **synchronously** invoked on [cancellation][cancel] (regular or exce… in <lambda>()
130 * with the cancellation exception. Otherwise, the handler will be invoked as soon as this in <lambda>()
179 * successfully (before cancellation), the coroutine's job was cancelled before it had a in <lambda>()
231 * // Remove callback on cancellation
238 …okeOnCancellation` block can be called at any time due to asynchronous nature of cancellation, even
241 * ### Prompt cancellation guarantee
243 * This function provides **prompt cancellation guarantee**.
[all …]
|
| D | Job.kt | 21 * Jobs can be arranged into parent-child hierarchies where cancellation
22 * of a parent leads to immediate cancellation of all its [children] recursively.
85 * ### Cancellation cause
91 …* Normal cancellation of a job is distinguished from its failure by the type of this exception tha…
93 …* If a cancellation cause is a different exception type, then the job is considered to have _faile…
97 …* Note, that [cancel] function on a job only accepts [CancellationException] as a cancellation cau…
98 …* calling [cancel] always results in a normal cancellation of a job, which does not lead to cancel…
161 * See [Job] documentation for more details on cancellation and failures.
174 * the original cancellation cause that was passed to [cancel] function.
194 * Cancels this job with an optional cancellation [cause]. in getCancellationException()
[all …]
|
| D | CancellableContinuationImpl.kt | 47 * 1) It can have only cancellation listener (no "on cancelling") in <lambda>()
48 * 2) It always invokes cancellation listener if it's cancelled (no 'invokeImmediately') in <lambda>()
49 * 3) It can have at most one cancellation listener in <lambda>()
50 * 4) Its cancellation listeners cannot be deregistered in <lambda>()
68 If the cancellation handler is specified via a [Segment] instance and the index in it in <lambda>()
79 SINGLE_A CancelHandler : Active active, one cancellation listener in <lambda>()
195 * Attempt to postpone cancellation for reusable cancellable continuation in <lambda>()
198 // Ensure that we are postponing cancellation to the right reusable instance in <lambda>()
217 dispatchResume(resumeMode) // no need for additional cancellation checks in <lambda>()
225 // Even if cancellation has failed, we should detach child to avoid potential leak in <lambda>()
[all …]
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | cancellation_test.cc | 16 #include "tensorflow/core/framework/cancellation.h"
31 TEST(Cancellation, SimpleNoCancel) { in TEST() argument
44 TEST(Cancellation, SimpleCancel) { in TEST() argument
56 TEST(Cancellation, StartCancelTriggersAllCallbacks) { in TEST() argument
71 TEST(Cancellation, StartCancelWithStatusTriggersAllCallbacks) { in TEST() argument
86 TEST(Cancellation, CancelBeforeRegister) { in TEST() argument
94 TEST(Cancellation, DeregisterAfterCancel) { in TEST() argument
107 TEST(Cancellation, CancelMultiple) { in TEST() argument
131 TEST(Cancellation, IsCancelled) { in TEST() argument
151 TEST(Cancellation, IsCancelling) { in TEST() argument
[all …]
|
| D | cancellation.h | 47 // This class should never simultaneously be used as the cancellation manager
88 // to perform any cancellation cleanup.
106 // // the Cancel method to look up the operation for cancellation.
119 // // Take action to cancel the operation with the given cancellation
128 // on this cancellation manager. Furthermore, it is important that
133 // Similar to RegisterCallback, but if the cancellation manager starts a
134 // cancellation with an error status, it will log the error status before
142 // with the given cancellation token. Returns true iff the callback
146 // NOTE(mrry): This method may block if cancellation is in progress.
148 // to invoke any cancellation callback that has been registered with this
[all …]
|
| D | local_rendezvous.cc | 216 // Increment the refcount when cancellation manager is present, to make in RecvAsync()
219 // (1) Recv registers cancellation callback to cm, and then cm is in RecvAsync()
220 // cancelled, unref in the cancellation callback; in RecvAsync()
221 // (2) Recv registers cancellation callback to cm, but cm is already in RecvAsync()
224 // the cancellation callback, unref in the item done callback; in RecvAsync()
226 // the cancellation callback because cm already StartCancel, in this in RecvAsync()
227 // case the cancellation callback will be invoked by the cm anyway, in RecvAsync()
228 // unref in the cancellation callback. in RecvAsync()
236 // Find an item in the queue with a cancellation token that matches in RecvAsync()
293 // cancellation callback before calling the `done` callback, because the in RecvAsync()
[all …]
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/cancellation/ |
| D | CancellationServer.java | 17 package io.grpc.examples.cancellation;
43 * <p>Any abort of an ongoing RPC is considered "cancellation" of that RPC. The common causes of
44 * cancellation are the client explicitly cancelling, the deadline expires, and I/O failures. The
45 * service is not informed the reason for the cancellation.
47 * <p>There are two APIs for services to be notified of RPC cancellation: io.grpc.Context and
49 * thread-safe. The ServerCallStreamObserver cancellation callback is called like other
90 * cancellation.
96 // cancellation notifications tends to work well. in bidirectionalStreamingEcho()
152 // setOnCloseHandler() to be notified when the RPC completed without cancellation (as best as in bidirectionalStreamingEcho()
160 * uses Context to be notified of RPC cancellation.
[all …]
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-play-services/src/ |
| D | Tasks.kt | 20 val cancellation = CancellationTokenSource() in <lambda>() constant
21 val source = TaskCompletionSource<T>(cancellation.token) in <lambda>()
25 cancellation.cancel() in <lambda>()
44 * For bi-directional cancellation, an overload that accepts [CancellationTokenSource] can be used.
49 …ts this task to an instance of [Deferred] with a [CancellationTokenSource] to control cancellation. in asDeferred()
50 * The cancellation of this function is bi-directional: in asDeferred()
104 * For bi-directional cancellation, an overload that accepts [CancellationTokenSource] can be used.
109 …mpletion of the task that is linked to the given [CancellationTokenSource] to control cancellation. in await()
111 * This suspending function is cancellable and cancellation is bi-directional: in await()
|
| /external/python/google-api-python-client/docs/dyn/ |
| D | run_v1.operations.html | 79 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
86 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
|
| D | cloudbuild_v1.projects.locations.operations.html | 79 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
89 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
132 …le.com/apis/design/errors). # The error result of the operation in case of failure or cancellation.
|
| D | ml_v1.projects.locations.operations.html | 79 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
89 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
126 …le.com/apis/design/errors). # The error result of the operation in case of failure or cancellation.
|
| D | osconfig_v1alpha.projects.locations.osPolicyAssignments.operations.html | 79 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
89 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
132 …le.com/apis/design/errors). # The error result of the operation in case of failure or cancellation.
|
| D | cloudbuild_v1alpha1.projects.locations.operations.html | 79 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
89 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
132 …le.com/apis/design/errors). # The error result of the operation in case of failure or cancellation.
|
| D | cloudbuild_v1alpha2.projects.locations.operations.html | 79 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
89 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
132 …le.com/apis/design/errors). # The error result of the operation in case of failure or cancellation.
|
| D | cloudbuild_v1beta1.projects.locations.operations.html | 79 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
89 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
132 …le.com/apis/design/errors). # The error result of the operation in case of failure or cancellation.
|
| D | osconfig_v1.projects.locations.osPolicyAssignments.operations.html | 79 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
89 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
132 …le.com/apis/design/errors). # The error result of the operation in case of failure or cancellation.
|
| D | cloudbuild_v1.operations.html | 79 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
89 …cancellation on a long-running operation. The server makes a best effort to cancel the operation, …
132 …le.com/apis/design/errors). # The error result of the operation in case of failure or cancellation.
|
| /external/grpc-grpc/examples/python/cancellation/ |
| D | README.md | 1 ### Cancellation subsection
14 #### Cancellation on the Client Side argument
74 catch the `RpcError` raised by the for loop upon cancellation.
77 #### Cancellation on the Server Side argument
79 A server is responsible for cancellation in two ways. It must respond in some way
80 when a client initiates a cancellation, otherwise long-running computations
109 ##### Initiating a Cancellation on the Server Side
111 Initiating a cancellation from the server side is simpler. Just call
|
| /external/rust/crates/tokio-util/src/sync/ |
| D | cancellation_token.rs | 2 //! The token allows to signal a cancellation request to one or more tasks.
15 /// A token which can be used to signal a cancellation request to one or more
19 /// obtain a Future which will be resolved when cancellation is requested.
21 /// Cancellation can be requested through the [`CancellationToken::cancel`] method.
35 /// // Wait for either cancellation or a very long time
81 // This field internally has a reference to the cancellation token, but camouflages
83 // that the reference is only used while the cancellation token is still alive. To
85 // before the cancellation token.
162 /// // Wait for either cancellation or a very long time
191 /// This will wake up all tasks which are waiting for cancellation.
[all …]
|
| /external/kotlinx.coroutines/docs/ |
| D | cancellation-and-timeouts.md | 1 …ved to the [https://kotlinlang.org/docs/cancellation-and-timeouts.html](https://kotlinlang.org/doc…
3 To edit the documentation, open the [topics/cancellation-and-timeouts.md](topics/cancellation-and-t…
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 317 /** A special value to represent cancellation and the 'wasInterrupted' bit. */
318 private static final class Cancellation { class in AbstractFuture
320 @CheckForNull static final Cancellation CAUSELESS_INTERRUPTED;
321 @CheckForNull static final Cancellation CAUSELESS_CANCELLED;
328 CAUSELESS_CANCELLED = new Cancellation(false, null);
329 CAUSELESS_INTERRUPTED = new Cancellation(true, null);
336 Cancellation(boolean wasInterrupted, @CheckForNull Throwable cause) { in Cancellation() method in AbstractFuture.Cancellation
380 * <li>{@link Cancellation} terminal state, {@code cancel} was called.
591 if (obj instanceof Cancellation) { in getDoneValue()
592 throw cancellationExceptionWithCause("Task was cancelled.", ((Cancellation) obj).cause); in getDoneValue()
[all …]
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | AbstractFuture.java | 317 /** A special value to represent cancellation and the 'wasInterrupted' bit. */
318 private static final class Cancellation { class in AbstractFuture
320 @CheckForNull static final Cancellation CAUSELESS_INTERRUPTED;
321 @CheckForNull static final Cancellation CAUSELESS_CANCELLED;
328 CAUSELESS_CANCELLED = new Cancellation(false, null);
329 CAUSELESS_INTERRUPTED = new Cancellation(true, null);
336 Cancellation(boolean wasInterrupted, @CheckForNull Throwable cause) { in Cancellation() method in AbstractFuture.Cancellation
380 * <li>{@link Cancellation} terminal state, {@code cancel} was called.
591 if (obj instanceof Cancellation) { in getDoneValue()
592 throw cancellationExceptionWithCause("Task was cancelled.", ((Cancellation) obj).cause); in getDoneValue()
[all …]
|