| /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/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():
|
| D | tasks.py | 480 return_when == FIRST_EXCEPTION and (not f.cancelled() and
719 if not fut.cancelled():
725 if fut.cancelled():
744 if fut.cancelled():
834 if outer.cancelled():
835 if not inner.cancelled():
840 if inner.cancelled():
|
| /third_party/node/test/fixtures/test-runner/output/ |
| D | abort.snapshot | 28 error: 'test did not finish before its parent and was cancelled'
36 error: 'test did not finish before its parent and was cancelled'
158 error: 'test did not finish before its parent and was cancelled'
166 error: 'test did not finish before its parent and was cancelled'
267 # cancelled 14
|
| D | default_output.snapshot | 23 [32m'test did not finish before its parent and was cancelled'[39m
31 [34mℹ cancelled 1[39m
57 [32m'test did not finish before its parent and was cancelled'[39m
|
| D | abort_suite.snapshot | 28 error: 'test did not finish before its parent and was cancelled'
36 error: 'test did not finish before its parent and was cancelled'
139 # cancelled 5
|
| D | arbitrary-output-colored.snapshot | 8 [34mℹ cancelled 0[39m
25 # cancelled 0
|
| /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 …]
|
| D | asyncio-exceptions.rst | 25 The operation has been cancelled.
28 when asyncio Tasks are cancelled. In almost all situations the
|
| /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 …]
|
| /third_party/gstreamer/gstplugins_good/gst/multifile/ |
| D | gstsplitfilesrc.c | 320 goto cancelled; in gst_split_file_src_start()
330 goto cancelled; in gst_split_file_src_start()
339 goto cancelled; in gst_split_file_src_start()
345 cancelled: in gst_split_file_src_start()
512 goto cancelled; in gst_split_file_src_create()
524 goto cancelled; in gst_split_file_src_create()
541 cancelled: in gst_split_file_src_create()
|
| /third_party/python/Lib/unittest/ |
| D | async_case.py | 102 if not fut.cancelled():
107 if not fut.cancelled():
140 if task.cancelled():
|
| /third_party/node/test/parallel/ |
| D | test-runner-extraneous-async-activity.js | 16 assert.match(stdout, /^# cancelled 0$/m);
30 assert.match(stdout, /^# cancelled 0$/m);
|
| /third_party/node/deps/uv/src/ |
| D | threadpool.c | 275 int cancelled; in uv__work_cancel() local
280 cancelled = !QUEUE_EMPTY(&w->wq) && w->work != NULL; in uv__work_cancel()
281 if (cancelled) in uv__work_cancel()
287 if (!cancelled) in uv__work_cancel()
|
| /third_party/python/Lib/unittest/test/ |
| D | test_async_case.py | 282 cancelled = False
286 nonlocal cancelled
290 cancelled = True
298 self.assertTrue(cancelled)
|
| /third_party/spirv-tools/utils/vscode/src/lsp/protocol/ |
| D | protocol.go | 56 func (canceller) Cancel(ctx context.Context, conn *jsonrpc2.Conn, id jsonrpc2.ID, cancelled bool) b…
57 if cancelled {
|
| /third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/utils/vscode/src/lsp/protocol/ |
| D | protocol.go | 56 func (canceller) Cancel(ctx context.Context, conn *jsonrpc2.Conn, id jsonrpc2.ID, cancelled bool) b…
57 if cancelled {
|
| /third_party/skia/third_party/externals/spirv-tools/utils/vscode/src/lsp/protocol/ |
| D | protocol.go | 56 func (canceller) Cancel(ctx context.Context, conn *jsonrpc2.Conn, id jsonrpc2.ID, cancelled bool) b…
57 if cancelled {
|
| /third_party/skia/third_party/externals/spirv-tools/utils/vscode/src/lsp/jsonrpc2/ |
| D | handler.go | 39 Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool
99 func (EmptyHandler) Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool {
|
| /third_party/spirv-tools/utils/vscode/src/lsp/jsonrpc2/ |
| D | handler.go | 39 Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool
99 func (EmptyHandler) Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool {
|
| /third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/utils/vscode/src/lsp/jsonrpc2/ |
| D | handler.go | 39 Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool
99 func (EmptyHandler) Cancel(ctx context.Context, conn *Conn, id ID, cancelled bool) bool {
|
| /third_party/gstreamer/gstplugins_bad/gst-libs/gst/adaptivedemux/ |
| D | gstadaptivedemux.c | 429 stream->cancelled = TRUE; in gst_adaptive_demux_set_exit_block()
1634 stream->cancelled = TRUE; in gst_adaptive_demux_expose_streams()
1738 stream->cancelled = TRUE; in gst_adaptive_demux_stream_free()
2275 if (!stream->cancelled && gst_adaptive_demux_is_running (demux) && in gst_adaptive_demux_src_event()
2484 stream->cancelled = FALSE; in gst_adaptive_demux_start_tasks()
2562 stream->cancelled = TRUE; in gst_adaptive_demux_stop_tasks()
2873 while (stream->do_block && !stream->cancelled) { in gst_adaptive_demux_stream_push_buffer()
2877 if (stream->cancelled) { in gst_adaptive_demux_stream_push_buffer()
2984 if (G_UNLIKELY (stream->cancelled)) { in gst_adaptive_demux_stream_push_buffer()
3045 if (G_UNLIKELY (stream->cancelled)) { in _src_chain()
[all …]
|