| /external/python/cpython3/Modules/ |
| D | _asynciomodule.c | 56 FutureObj_HEAD(fut)
92 future_schedule_callbacks(FutureObj *fut) in future_schedule_callbacks() argument
98 if (fut->fut_callbacks == NULL) { in future_schedule_callbacks()
103 len = PyList_GET_SIZE(fut->fut_callbacks); in future_schedule_callbacks()
108 iters = PyList_GetSlice(fut->fut_callbacks, 0, len); in future_schedule_callbacks()
112 if (PyList_SetSlice(fut->fut_callbacks, 0, len, NULL) < 0) { in future_schedule_callbacks()
122 fut->fut_loop, &PyId_call_soon, "OO", cb, fut, NULL); in future_schedule_callbacks()
138 future_init(FutureObj *fut, PyObject *loop) in future_init() argument
152 Py_CLEAR(fut->fut_loop); in future_init()
153 fut->fut_loop = loop; in future_init()
[all …]
|
| /external/python/cpython3/Lib/asyncio/ |
| D | locks.py | 173 fut = self._loop.create_future()
174 self._waiters.append(fut)
176 yield from fut
180 self._waiters.remove(fut)
196 for fut in self._waiters:
197 if not fut.done():
198 fut.set_result(True)
240 for fut in self._waiters:
241 if not fut.done():
242 fut.set_result(True)
[all …]
|
| D | tasks.py | 316 def wait_for(fut, timeout, *, loop=None): argument
333 return (yield from fut)
339 fut = ensure_future(fut, loop=loop)
340 fut.add_done_callback(cb)
347 fut.remove_done_callback(cb)
348 fut.cancel()
351 if fut.done():
352 return fut.result()
354 fut.remove_done_callback(cb)
355 fut.cancel()
[all …]
|
| D | selector_events.py | 365 fut = self.create_future()
366 self._sock_recv(fut, False, sock, n)
367 return fut
369 def _sock_recv(self, fut, registered, sock, n): argument
379 if fut.cancelled():
384 self.add_reader(fd, self._sock_recv, fut, True, sock, n)
386 fut.set_exception(exc)
388 fut.set_result(data)
403 fut = self.create_future()
405 self._sock_sendall(fut, False, sock, data)
[all …]
|
| D | windows_events.py | 119 def _unregister_wait_cb(self, fut): argument
193 def _unregister_wait_cb(self, fut): argument
209 super()._unregister_wait_cb(fut)
425 fut = self._loop.create_future()
426 fut.set_result(value)
427 return fut
568 fut = self._wait_for_handle(event, None, True)
571 fut._done_callback = done_callback
572 return fut
723 for address, (fut, ov, obj, callback) in list(self._cache.items()):
[all …]
|
| D | proactor_events.py | 180 def _loop_reading(self, fut=None): argument
186 if fut is not None:
187 assert self._read_fut is fut or (self._read_fut is None and
190 data = fut.result() # deliver data later in "finally" clause
319 def _pipe_closed(self, fut): argument
320 if fut.cancelled():
323 assert fut.result() == b''
327 assert fut is self._read_fut, (fut, self._read_fut)
|
| D | futures.py | 343 def _set_result_unless_cancelled(fut, result): argument
345 if fut.cancelled():
347 fut.set_result(result)
|
| D | base_events.py | 168 fut = loop.create_future()
169 fut.set_result([info])
170 return fut
176 def _run_until_complete_cb(fut): argument
177 exc = fut._exception
183 fut._loop.stop()
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_futures.py | 304 fut = self._new_future(loop=self.loop)
307 yield from fut
313 fut.cancel()
317 fut = self._new_future(loop=self.loop)
318 del fut
323 fut = self._new_future(loop=self.loop)
324 fut.set_result(42)
325 del fut
330 fut = self._new_future(loop=self.loop)
331 fut.set_result(42)
[all …]
|
| D | test_windows_events.py | 114 fut = self.loop._proactor.wait_for_handle(event, 0.5)
116 done = self.loop.run_until_complete(fut)
120 self.assertFalse(fut.result())
127 fut = self.loop._proactor.wait_for_handle(event, 10)
129 done = self.loop.run_until_complete(fut)
133 self.assertTrue(fut.result())
138 fut.cancel()
146 fut = self.loop._proactor.wait_for_handle(event, 10)
147 fut.cancel()
150 self.loop.run_until_complete(fut)
[all …]
|
| D | test_tasks.py | 97 fut = self.new_future(other_loop)
100 def run(fut): argument
101 yield from fut
106 self.loop.run_until_complete(run(fut))
212 fut = asyncio.ensure_future(Aw(coro()), loop=loop)
213 loop.run_until_complete(fut)
214 assert fut.result() == 'ok'
388 def wait_for(fut): argument
389 return (yield from fut)
391 fut = self.new_future(self.loop)
[all …]
|
| D | test_proactor_events.py | 42 fut = asyncio.Future(loop=self.loop)
43 tr = self.socket_transport(waiter=fut)
45 self.assertIsNone(fut.result())
177 fut = asyncio.Future(loop=self.loop)
178 fut.set_result(b'data')
181 tr._write_fut = fut
182 tr._loop_writing(fut)
186 fut = asyncio.Future(loop=self.loop)
187 fut.set_result(1)
190 tr._write_fut = fut
[all …]
|
| D | test_base_events.py | 311 def check_in_thread(loop, event, debug, create_loop, fut): argument
327 loop.call_soon_threadsafe(fut.set_exception, exc)
329 loop.call_soon_threadsafe(fut.set_result, None)
333 fut = asyncio.Future(loop=loop)
335 args = (loop, event, debug, create_loop, fut)
338 loop.run_until_complete(fut)
584 def zero_error(fut): argument
585 fut.set_result(True)
590 fut = asyncio.Future(loop=self.loop)
591 self.loop.call_soon(zero_error, fut)
[all …]
|
| D | test_subprocess.py | 471 fut = asyncio.create_subprocess_exec(
476 process = yield from fut
|
| /external/icu/icu4c/source/data/unit/ |
| D | uz.txt | 68 dnam{"kvadrat fut"}
69 one{"{0} kvadrat fut"}
70 other{"{0} kvadrat fut"}
365 dnam{"fut"}
366 one{"{0} fut"}
367 other{"{0} fut"}
368 per{"{0}/fut"}
628 dnam{"kub fut"}
629 one{"{0} kub fut"}
630 other{"{0} kub fut"}
[all …]
|
| D | az.txt | 68 dnam{"kvadrat fut"}
69 one{"{0} kvadrat fut"}
70 other{"{0} kvadrat fut"}
365 dnam{"fut"}
366 one{"{0} fut"}
367 other{"{0} fut"}
617 dnam{"akr-fut"}
618 one{"{0} akr-fut"}
619 other{"{0} akr-fut"}
633 dnam{"kub fut"}
[all …]
|
| /external/nanohttpd/websocket/src/test/java/fi/iki/elonen/samples/echo/ |
| D | SimpleEchoSocket.java | 87 Future<Void> fut; in onConnect() local
90 fut = session.getRemote().sendStringByFuture(message); in onConnect()
91 fut.get(5, TimeUnit.SECONDS); in onConnect()
|
| /external/python/cpython3/Lib/test/ |
| D | test_asyncgen.py | 30 fut = coro.throw(AwaitException)
32 fut = coro.send(None)
36 if fut == ('throw',):
576 fut = asyncio.Future(loop=self.loop)
582 await fut
604 fut.cancel()
780 fut = asyncio.ensure_future(asyncio.sleep(delay, loop=self.loop),
782 self.loop.call_later(delay / 2, lambda: fut.cancel())
783 return await fut
870 fut = asyncio.ensure_future(asyncio.sleep(delay, loop=self.loop),
[all …]
|
| D | test_concurrent_futures.py | 486 for fut in futures:
487 self.assertRaises(BrokenProcessPool, fut.result)
|
| /external/python/cpython3/Modules/clinic/ |
| D | _asynciomodule.c.h | 501 _asyncio_Task__wakeup_impl(TaskObj *self, PyObject *fut);
509 PyObject *fut; in _asyncio_Task__wakeup() local
512 &fut)) { in _asyncio_Task__wakeup()
515 return_value = _asyncio_Task__wakeup_impl(self, fut); in _asyncio_Task__wakeup()
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-dev.rst | 66 if not fut.cancelled():
67 fut.set_result('done')
78 def slow_operation(fut):
79 if fut.cancelled():
82 yield from fut
107 loop.call_soon_threadsafe(fut.cancel)
|
| D | asyncio-task.rst | 269 ``fut.add_done_callback(functools.partial(print, "Future:",
270 flush=True))`` will call ``print("Future:", fut, flush=True)``.
698 .. coroutinefunction:: wait_for(fut, timeout, \*, loop=None)
710 If the wait is cancelled, the future *fut* is also cancelled.
714 result = yield from asyncio.wait_for(fut, 60.0)
717 If the wait is cancelled, the future *fut* is now also cancelled.
|
| /external/python/cpython3/Lib/distutils/command/ |
| D | build_ext.py | 466 for ext, fut in zip(self.extensions, futures):
468 fut.result()
|
| /external/icu/icu4c/source/data/region/ |
| D | yav.txt | 221 WF{"walíis na futúna"}
|
| /external/honggfuzz/examples/apache-httpd/corpus_http2/ |
| D | 158f64397e4656b20a0981ff6adbcfbd.0000a3c2.honggfuzz.cov | 83 ��\ә�%��ǰ�tF�k��2��Y��s?���VbӶ���ɞ���/�;A��]q�^� ��C�� �#��T/��e�؏H5 ;3��p�fut�� ��940-…
|