| /third_party/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()
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/Internal/ |
| D | AsyncCallServerTest.cs | 70 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in CancelNotificationAfterStartDisposes()
82 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in CancelNotificationAfterStartDisposesAfterPendingReadFinishes()
95 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in ReadAfterCancelNotificationCanSucceed()
116 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in ReadCompletionFailureClosesRequestStream()
126 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in WriteAfterCancelNotificationFails()
143 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in WriteCompletionFailureThrows()
162 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in WriteAndWriteStatusCanRunConcurrently()
177 fakeCall.ReceivedCloseOnServerCallback.OnReceivedCloseOnServer(true, cancelled: true); in WriteAfterWriteStatusThrowsInvalidOperationException()
|
| /third_party/grpc/src/python/grpcio_tests/tests_aio/unit/ |
| D | close_channel_test.py | 77 self.assertTrue(call.cancelled())
89 self.assertTrue(call.cancelled())
100 self.assertTrue(call.cancelled())
111 self.assertTrue(call.cancelled())
121 self.assertTrue(call.cancelled())
132 self.assertFalse(call1.cancelled())
133 self.assertTrue(call2.cancelled())
|
| D | call_test.py | 173 self.assertFalse(call.cancelled())
182 self.assertTrue(call.cancelled())
249 self.assertFalse(call.cancelled())
263 self.assertTrue(call.cancelled())
277 self.assertFalse(call.cancelled())
305 self.assertFalse(call.cancelled())
312 self.assertTrue(call.cancelled())
374 self.assertFalse(call.cancelled())
509 self.assertFalse(call.cancelled())
511 self.assertTrue(call.cancelled())
[all …]
|
| D | client_unary_unary_interceptor_test.py | 264 self.assertFalse(call.cancelled())
301 self.assertFalse(call.cancelled())
330 self.assertFalse(call.cancelled())
363 self.assertFalse(call.cancelled())
397 self.assertFalse(call.cancelled())
426 self.assertFalse(call.cancelled())
435 self.assertTrue(call.cancelled())
467 self.assertFalse(call.cancelled())
476 self.assertTrue(call.cancelled())
508 self.assertTrue(call.cancelled())
[all …]
|
| D | client_unary_stream_interceptor_test.py | 104 self.assertEqual(call.cancelled(), False)
270 self.assertFalse(call.cancelled())
280 self.assertTrue(call.cancelled())
306 self.assertFalse(call.cancelled())
316 self.assertTrue(call.cancelled())
339 self.assertTrue(call.cancelled())
364 self.assertTrue(call.cancelled())
|
| D | client_stream_unary_interceptor_test.py | 100 self.assertEqual(call.cancelled(), False)
139 self.assertEqual(call.cancelled(), False)
238 self.assertEqual(call.cancelled(), False)
331 self.assertFalse(call.cancelled())
345 self.assertTrue(call.cancelled())
375 self.assertFalse(call.cancelled())
389 self.assertTrue(call.cancelled())
423 self.assertTrue(call.cancelled())
456 self.assertTrue(call.cancelled())
|
| /third_party/glib/gio/ |
| D | gfilemonitor.c | 56 gboolean cancelled; member
221 res = monitor->priv->cancelled; in g_file_monitor_is_cancelled()
239 if (!monitor->priv->cancelled) in g_file_monitor_cancel()
243 monitor->priv->cancelled = TRUE; in g_file_monitor_cancel()
291 if (monitor->priv->cancelled) in g_file_monitor_emit_event()
|
| D | gcancellable.c | 47 gboolean cancelled; member
142 G_STRUCT_OFFSET (GCancellableClass, cancelled), in g_cancellable_class_init()
274 if (g_atomic_int_get (&priv->cancelled)) in g_cancellable_reset()
279 g_atomic_int_set (&priv->cancelled, FALSE); in g_cancellable_reset()
297 return cancellable != NULL && g_atomic_int_get (&cancellable->priv->cancelled); in g_cancellable_is_cancelled()
413 if (g_atomic_int_get (&cancellable->priv->cancelled)) in g_cancellable_make_pollfd()
498 if (g_atomic_int_get (&priv->cancelled)) in g_cancellable_cancel()
504 g_atomic_int_set (&priv->cancelled, TRUE); in g_cancellable_cancel()
570 if (g_atomic_int_get (&cancellable->priv->cancelled)) in g_cancellable_connect()
|
| /third_party/gstreamer/gstplugins_bad/gst-libs/gst/uridownloader/ |
| D | gsturidownloader.c | 48 gboolean cancelled; member
265 downloader->priv->cancelled = TRUE; in gst_uri_downloader_bus_handler()
355 downloader->priv->cancelled = FALSE; in gst_uri_downloader_reset()
367 downloader->priv->cancelled = TRUE; in gst_uri_downloader_cancel()
371 gboolean cancelled; in gst_uri_downloader_cancel() local
373 cancelled = downloader->priv->cancelled; in gst_uri_downloader_cancel()
374 downloader->priv->cancelled = TRUE; in gst_uri_downloader_cancel()
375 if (cancelled) in gst_uri_downloader_cancel()
568 if (downloader->priv->cancelled) { in gst_uri_downloader_fetch_uri_with_range()
594 if (downloader->priv->cancelled) { in gst_uri_downloader_fetch_uri_with_range()
[all …]
|
| /third_party/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 self.assertTrue)(
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/ |
| D | _channel_ready_future_test.py | 53 self.assertFalse(ready_future.cancelled())
59 self.assertTrue(ready_future.cancelled())
81 self.assertFalse(ready_future.cancelled())
86 self.assertFalse(ready_future.cancelled())
|
| /third_party/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())
|
| /third_party/python/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
|
| D | locks.py | 99 all(w.cancelled() for w in self._waiters))):
275 cancelled = False
281 cancelled = True
283 if cancelled:
389 if self._value > 0 and not fut.cancelled():
|
| /third_party/python/Doc/library/ |
| D | asyncio-task.rst | 357 **won't be cancelled** and will continue to run.
362 If ``gather()`` is *cancelled*, all submitted awaitables
363 (that have not completed yet) are also *cancelled*.
365 If any Task or Future from the *aws* sequence is *cancelled*, it is
367 call is **not** cancelled in this case. This is to prevent the
369 Tasks/Futures to be cancelled.
425 If the *gather* itself is cancelled, the cancellation is
446 from being :meth:`cancelled <Task.cancel>`.
458 *except* that if the coroutine containing it is cancelled, the
459 Task running in ``something()`` is not cancelled. From the point
[all …]
|
| D | asyncio-future.rst | 88 set, or until they are cancelled.
118 If the Future has been *cancelled*, this method raises
142 A Future is *done* if it was *cancelled* or if it has a result
146 .. method:: cancelled()
148 Return ``True`` if the Future was *cancelled*.
151 *cancelled* before setting a result or an exception for it::
153 if not fut.cancelled():
192 If the Future is already *done* or *cancelled*, return ``False``.
193 Otherwise, change the Future's state to *cancelled*,
206 If the Future has been *cancelled*, this method raises a
|
| D | concurrent.futures.rst | 87 are completed or running won't be cancelled, regardless of the value
92 returning. The remaining futures are cancelled.
323 finished running and cannot be cancelled then the method will return
324 ``False``, otherwise the call will be cancelled and the method will
327 .. method:: cancelled()
329 Return ``True`` if the call was successfully cancelled.
334 cancelled.
338 Return ``True`` if the call was successfully cancelled or finished
350 If the future is cancelled before completing then :exc:`.CancelledError`
364 If the future is cancelled before completing then :exc:`.CancelledError`
[all …]
|
| /third_party/grpc/src/python/grpcio/grpc/aio/ |
| D | _call.py | 183 def cancelled(self) -> bool: member in Call
184 return self._cython_call.cancelled()
272 if not self.cancelled():
337 if not self.cancelled():
430 if not self.cancelled():
444 if not self.cancelled():
500 if not self.cancelled():
546 if not self.cancelled():
583 if not self.cancelled():
626 if not self.cancelled():
|
| /third_party/grpc/src/python/grpcio/grpc/experimental/aio/ |
| D | _call.py | 183 def cancelled(self) -> bool: member in Call
184 return self._cython_call.cancelled()
272 if not self.cancelled():
337 if not self.cancelled():
431 if not self.cancelled():
445 if not self.cancelled():
501 if not self.cancelled():
547 if not self.cancelled():
584 if not self.cancelled():
627 if not self.cancelled():
|
| /third_party/grpc/src/csharp/Grpc.Core/Internal/ |
| D | AsyncCallServer.cs | 208 private void HandleFinishedServerside(bool success, bool cancelled) in HandleFinishedServerside() argument
232 if (cancelled) in HandleFinishedServerside()
242 void IReceivedCloseOnServerCallback.OnReceivedCloseOnServer(bool success, bool cancelled) in IReceivedCloseOnServerCallback.OnReceivedCloseOnServer() argument
244 HandleFinishedServerside(success, cancelled); in IReceivedCloseOnServerCallback.OnReceivedCloseOnServer()
|
| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/ |
| D | call.pyx.pxi | 20 _UNKNOWN_CANCELLATION_DETAILS = 'RPC cancelled for unknown reason.'
194 StatusCode.cancelled,
206 StatusCode.cancelled,
216 because the RPC finished or because was cancelled..
223 def cancelled(self): member in _AioCall
224 """Returns if the RPC was cancelled.
227 True if the RPC was cancelled.
232 return self._status.code() == StatusCode.cancelled
276 """Returns if the RPC was cancelled locally.
279 True when was cancelled locally, False when was cancelled remotelly or
[all …]
|
| /third_party/grpc/src/core/lib/security/credentials/plugin/ |
| D | plugin_credentials.cc | 79 if (!r->cancelled) pending_request_remove_locked(r); in pending_request_complete()
144 if (!r->cancelled) { in plugin_md_request_metadata_ready()
204 if (request->cancelled) { in get_request_metadata()
243 pending_request->cancelled = true; in cancel_get_request_metadata()
|
| /third_party/grpc/src/python/grpcio_testing/grpc_testing/ |
| D | __init__.py | 41 def cancelled(self): member in UnaryUnaryChannelRpc
84 def cancelled(self): member in UnaryStreamChannelRpc
137 def cancelled(self): member in StreamUnaryChannelRpc
200 def cancelled(self): member in StreamStreamChannelRpc
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_futures.py | 48 def cancelled(self): member in DuckFuture
57 self.assertFalse(self.cancelled())
63 self.assertFalse(self.cancelled())
137 self.assertFalse(f.cancelled())
140 self.assertTrue(f.cancelled())
218 self.assertFalse(fut.cancelled())
245 self.assertTrue(f.cancelled())
258 self.assertFalse(f.cancelled())
276 self.assertFalse(f.cancelled())
400 self.assertTrue(newf_cancelled.cancelled())
[all …]
|