| /external/robolectric-shadows/utils/src/main/java/org/robolectric/util/ |
| D | SimpleFuture.java | 17 private boolean cancelled; field in SimpleFuture
25 return cancelled; in isCancelled()
30 cancelled = true; in cancel()
34 return cancelled; in cancel()
38 if (cancelled) { in get()
47 if (cancelled) { in get()
57 if (!cancelled) { in run()
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | mutex_ops.cc | 82 bool* cancelled = nullptr; in AcquireAsync() local
84 cancelled = new bool(false); // TF_GUARDED_BY(mu_); in AcquireAsync()
87 !cm->RegisterCallback(token, [this, cancelled]() { in AcquireAsync()
89 *cancelled = true; in AcquireAsync()
93 delete cancelled; in AcquireAsync()
100 [this, cm, cancelled, in AcquireAsync()
106 while (locked_ && !(cancelled && *cancelled)) { in AcquireAsync()
109 local_locked = locked_ = !(cancelled && *cancelled); in AcquireAsync()
113 delete cancelled; in AcquireAsync()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/ |
| D | TakeWhileTest.kt | 33 var cancelled = false in <lambda>() variable
37 hang { cancelled = true } in <lambda>()
46 assertTrue(cancelled) in <lambda>()
51 var cancelled = false in <lambda>() variable
55 hang { cancelled = true } in <lambda>()
64 assertTrue(cancelled) in <lambda>()
|
| D | FilterTest.kt | 28 var cancelled = false in <lambda>() variable
34 hang {cancelled = true} in <lambda>()
45 assertTrue(cancelled) in <lambda>()
64 var cancelled = false in <lambda>() variable
70 hang {cancelled = true} in <lambda>()
81 assertTrue(cancelled) in <lambda>()
|
| D | TakeTest.kt | 65 var cancelled = false in <lambda>() variable
69 hang { cancelled = true } in <lambda>()
77 assertTrue(cancelled) in <lambda>()
82 var cancelled = false in <lambda>() variable
86 hang { cancelled = true } in <lambda>()
97 assertTrue(cancelled) in <lambda>()
|
| D | MapNotNullTest.kt | 32 var cancelled = false in <lambda>() variable
38 hang { cancelled = true } in <lambda>()
49 assertTrue(cancelled) in <lambda>()
|
| D | OnEachTest.kt | 32 var cancelled = false in <lambda>() variable
38 hang { cancelled = true } in <lambda>()
49 assertTrue(cancelled) in <lambda>()
|
| D | MapTest.kt | 31 var cancelled = false in <lambda>() variable
37 hang { cancelled = true } in <lambda>()
48 assertTrue(cancelled) in <lambda>()
|
| D | TransformWhileTest.kt | 29 var cancelled = false in <lambda>() variable
33 hang { cancelled = true } in <lambda>()
45 assertTrue(cancelled) in <lambda>()
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
| D | _channel_rpc.py | 26 def cancelled(self): member in _UnaryUnary
27 self._rpc_state.cancelled()
45 def cancelled(self): member in _UnaryStream
46 self._rpc_state.cancelled()
66 def cancelled(self): member in _StreamUnary
67 self._rpc_state.cancelled()
91 def cancelled(self): member in _StreamStream
92 self._rpc_state.cancelled()
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/ |
| D | AsyncCallServerTest.cs | 67 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in CancelNotificationAfterStartDisposes()
79 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in CancelNotificationAfterStartDisposesAfterPendingReadFinishes()
92 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in ReadAfterCancelNotificationCanSucceed()
113 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in ReadCompletionFailureClosesRequestStream()
123 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in WriteAfterCancelNotificationFails()
140 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in WriteCompletionFailureThrows()
159 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in WriteAndWriteStatusCanRunConcurrently()
174 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in WriteAfterWriteStatusThrowsInvalidOperationException()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/java/benchmarks/flow/scrabble/optimizations/ |
| D | FlowableCharSequence.java | 40 volatile boolean cancelled; field in FlowableCharSequence.CharSequenceSubscription
50 cancelled = true; in cancel()
72 if (cancelled) { in fastPath()
79 if (!cancelled) { in fastPath()
94 if (cancelled) { in slowPath()
105 if (!cancelled) { in slowPath()
|
| /external/pigweed/pw_protobuf/ |
| D | find_test.cc | 51 EXPECT_TRUE(decoder.cancelled()); in TEST()
62 EXPECT_FALSE(decoder.cancelled()); in TEST()
75 EXPECT_TRUE(decoder.cancelled()); in TEST()
88 EXPECT_FALSE(decoder.cancelled()); in TEST()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | SharedResourceHolderTest.java | 128 assertFalse(scheduledDestroyTask.cancelled); in cancelDestroyTask()
132 assertTrue(scheduledDestroyTask.cancelled); in cancelDestroyTask()
142 assertFalse(scheduledDestroyTask.cancelled); in cancelDestroyTask()
200 private boolean cancelled; field in SharedResourceHolderTest.MockScheduledFuture
219 if (cancelled || finished) { in cancel()
222 cancelled = true; in cancel()
228 return cancelled; in isCancelled()
243 return cancelled || finished; in isDone()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ServerCallImpl.java | 61 private volatile boolean cancelled; field in ServerCallImpl
189 return cancelled; in isCancelled()
244 public void cancelled(Context context) { in ServerStreamListenerImpl()
245 ServerStreamListenerImpl.this.call.cancelled = true; in ServerStreamListenerImpl()
254 if (call.cancelled) { in messagesAvailable()
279 if (call.cancelled) { in halfClosed()
292 call.cancelled = true; in closed()
304 if (call.cancelled) { in onReady()
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _channel_ready_future_test.py | 52 self.assertFalse(ready_future.cancelled())
58 self.assertTrue(ready_future.cancelled())
76 self.assertFalse(ready_future.cancelled())
81 self.assertFalse(ready_future.cancelled())
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/testing/ |
| D | _time_test.py | 90 cancelled = future.cancel()
95 self.assertTrue(cancelled)
96 self.assertTrue(future.cancelled())
111 cancelled = set()
114 cancelled.add(test_event)
118 (self.assertFalse if test_event in cancelled else
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/ |
| D | _utilities_test.py | 55 self.assertFalse(ready_future.cancelled())
61 self.assertTrue(ready_future.cancelled())
79 self.assertFalse(ready_future.cancelled())
84 self.assertFalse(ready_future.cancelled())
|
| /external/python/cpython3/Lib/asyncio/ |
| D | futures.py | 173 def cancelled(self): member in Future
310 if fut.cancelled():
330 if source.cancelled():
348 if dest.cancelled():
351 if source.cancelled():
385 if destination.cancelled():
392 if (destination.cancelled() and
|
| /external/python/futures/docs/ |
| D | index.rst | 208 it cannot be cancelled and the method will return `False`, otherwise the call
209 will be cancelled and the method will return `True`.
211 .. method:: Future.cancelled()
213 Return `True` if the call was successfully cancelled.
218 cancelled.
222 Return `True` if the call was successfully cancelled or finished running.
232 If the future is cancelled before completing then :exc:`CancelledError` will
245 If the future is cancelled before completing then :exc:`CancelledError` will
253 future as its only argument, when the future is cancelled or finishes
262 If the future has already completed or been cancelled then *fn* will be
[all …]
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-task.rst | 337 **won't be cancelled** and will continue to run.
342 If ``gather()`` is *cancelled*, all submitted awaitables
343 (that have not completed yet) are also *cancelled*.
345 If any Task or Future from the *aws* sequence is *cancelled*, it is
347 call is **not** cancelled in this case. This is to prevent the
349 Tasks/Futures to be cancelled.
399 If the *gather* itself is cancelled, the cancellation is
409 from being :meth:`cancelled <Task.cancel>`.
421 *except* that if the coroutine containing it is cancelled, the
422 Task running in ``something()`` is not cancelled. From the point
[all …]
|
| D | asyncio-future.rst | 77 set, or until they are cancelled.
103 If the Future has been *cancelled*, this method raises
127 A Future is *done* if it was *cancelled* or if it has a result
131 .. method:: cancelled()
133 Return ``True`` if the Future was *cancelled*.
136 *cancelled* before setting a result or an exception for it::
138 if not fut.cancelled():
177 If the Future is already *done* or *cancelled*, return ``False``.
178 Otherwise, change the Future's state to *cancelled*,
191 If the Future has been *cancelled*, this method raises a
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | AsyncCallServer.cs | 205 private void HandleFinishedServerside(bool success, bool cancelled) in HandleFinishedServerside() argument
229 if (cancelled) in HandleFinishedServerside()
239 void IReceivedCloseOnServerCallback.OnReceivedCloseOnServer(bool success, bool cancelled) in IReceivedCloseOnServerCallback.OnReceivedCloseOnServer() argument
241 HandleFinishedServerside(success, cancelled); in IReceivedCloseOnServerCallback.OnReceivedCloseOnServer()
|
| /external/perfetto/infra/ci/worker/ |
| D | worker.py | 125 cancelled = False
141 if (sigterm.is_set() or polled_status != 'STARTED') and not cancelled:
143 cancelled = True
146 status = ('INTERRUPTED' if sigterm.is_set() else 'CANCELLED' if cancelled else
|
| /external/dagger2/java/dagger/producers/internal/ |
| D | DependencyMethodProducer.java | 44 private boolean cancelled = false; field in DependencyMethodProducer
52 if (cancelled) { in get()
76 cancelled = true; in cancel()
|