| /third_party/python/Modules/ |
| D | _asynciomodule.c | 77 FutureObj_HEAD(fut)
196 get_future_loop(PyObject *fut) in get_future_loop() argument
204 if (Future_CheckExact(fut) || Task_CheckExact(fut)) { in get_future_loop()
205 PyObject *loop = ((FutureObj *)fut)->fut_loop; in get_future_loop()
210 if (_PyObject_LookupAttrId(fut, &PyId_get_loop, &getloop) < 0) { in get_future_loop()
219 return _PyObject_GetAttrId(fut, &PyId__loop); in get_future_loop()
393 future_is_alive(FutureObj *fut) in future_is_alive() argument
395 return fut->fut_loop != NULL; in future_is_alive()
400 future_ensure_alive(FutureObj *fut) in future_ensure_alive() argument
402 if (!future_is_alive(fut)) { in future_ensure_alive()
[all …]
|
| /third_party/python/Lib/asyncio/ |
| D | locks.py | 105 fut = self._get_loop().create_future()
106 self._waiters.append(fut)
113 await fut
115 self._waiters.remove(fut)
146 fut = next(iter(self._waiters))
153 if not fut.done():
154 fut.set_result(True)
190 for fut in self._waiters:
191 if not fut.done():
192 fut.set_result(True)
[all …]
|
| D | tasks.py | 392 async def wait_for(fut, timeout): argument
408 return await fut
411 fut = ensure_future(fut, loop=loop)
413 if fut.done():
414 return fut.result()
416 await _cancel_and_wait(fut, loop=loop)
418 return fut.result()
426 fut = ensure_future(fut, loop=loop)
427 fut.add_done_callback(cb)
434 if fut.done():
[all …]
|
| D | selector_events.py | 367 fut = self.create_future()
370 handle = self._add_reader(fd, self._sock_recv, fut, sock, n)
371 fut.add_done_callback(
373 return await fut
375 def _sock_read_done(self, fd, fut, handle=None): argument
379 def _sock_recv(self, fut, sock, n): argument
382 if fut.done():
391 fut.set_exception(exc)
393 fut.set_result(data)
408 fut = self.create_future()
[all …]
|
| D | windows_events.py | 128 def _unregister_wait_cb(self, fut): argument
202 def _unregister_wait_cb(self, fut): argument
218 super()._unregister_wait_cb(fut)
445 fut = self._loop.create_future()
446 fut.set_result(value)
447 return fut
586 fut = self._loop.create_future()
587 fut.set_result(None)
588 return fut
678 fut = self._wait_for_handle(event, None, True)
[all …]
|
| D | proactor_events.py | 272 def _loop_reading(self, fut=None): argument
276 if fut is not None:
277 assert self._read_fut is fut or (self._read_fut is None and
280 if fut.done():
282 length = fut.result()
290 fut.cancel()
439 def _pipe_closed(self, fut): argument
440 if fut.cancelled():
443 assert fut.result() == b''
447 assert fut is self._read_fut, (fut, self._read_fut)
[all …]
|
| D | futures.py | 296 def _get_loop(fut): argument
300 get_loop = fut.get_loop
305 return fut._loop
308 def _set_result_unless_cancelled(fut, result): argument
310 if fut.cancelled():
312 fut.set_result(result)
|
| D | unix_events.py | 358 fut = self.create_future()
359 self._sock_sendfile_native_impl(fut, None, sock, fileno,
361 return await fut
363 def _sock_sendfile_native_impl(self, fut, registered_fd, sock, fileno, argument
372 if fut.cancelled():
379 fut.set_result(total_sent)
386 self._sock_add_cancellation_callback(fut, sock)
387 self.add_writer(fd, self._sock_sendfile_native_impl, fut,
410 fut.set_exception(err)
413 fut.set_exception(exc)
[all …]
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_futures.py | 173 fut = self.cls.__new__(self.cls, loop=self.loop)
174 self.assertRaises(asyncio.InvalidStateError, fut.result)
176 fut = self.cls.__new__(self.cls, loop=self.loop)
177 self.assertRaises(asyncio.InvalidStateError, fut.exception)
179 fut = self.cls.__new__(self.cls, loop=self.loop)
181 fut.set_result(None)
183 fut = self.cls.__new__(self.cls, loop=self.loop)
185 fut.set_exception(Exception)
187 fut = self.cls.__new__(self.cls, loop=self.loop)
189 fut.cancel()
[all …]
|
| D | test_windows_events.py | 166 fut = self.loop._proactor.wait_for_handle(event, 0.5)
168 done = self.loop.run_until_complete(fut)
172 self.assertFalse(fut.result())
181 fut = self.loop._proactor.wait_for_handle(event, 10)
183 done = self.loop.run_until_complete(fut)
187 self.assertTrue(fut.result())
192 fut.cancel()
200 fut = self.loop._proactor.wait_for_handle(event, 10)
201 fut.cancel()
204 self.loop.run_until_complete(fut)
[all …]
|
| D | test_tasks.py | 162 fut = self.new_future(other_loop)
164 async def run(fut): argument
165 await fut
170 self.loop.run_until_complete(run(fut))
330 fut = asyncio.ensure_future(Aw(coro()), loop=loop)
331 loop.run_until_complete(fut)
332 self.assertEqual(fut.result(), 'ok')
518 async def wait_for(fut): argument
519 return await fut
521 fut = self.new_future(self.loop)
[all …]
|
| D | test_proactor_events.py | 52 fut = self.loop.create_future()
53 tr = self.socket_transport(waiter=fut)
55 self.assertIsNone(fut.result())
191 fut = self.loop.create_future()
192 fut.set_result(b'data')
195 tr._write_fut = fut
196 tr._loop_writing(fut)
200 fut = self.loop.create_future()
201 fut.set_result(1)
204 tr._write_fut = fut
[all …]
|
| D | test_base_events.py | 310 def check_in_thread(loop, event, debug, create_loop, fut): argument
326 loop.call_soon_threadsafe(fut.set_exception, exc)
328 loop.call_soon_threadsafe(fut.set_result, None)
332 fut = loop.create_future()
334 args = (loop, event, debug, create_loop, fut)
337 loop.run_until_complete(fut)
557 def zero_error(fut): argument
558 fut.set_result(True)
563 fut = self.loop.create_future()
564 self.loop.call_soon(zero_error, fut)
[all …]
|
| /third_party/python/Lib/unittest/ |
| D | async_case.py | 77 fut = self._asyncioTestLoop.create_future()
78 self._asyncioCallsQueue.put_nowait((fut, ret))
79 return self._asyncioTestLoop.run_until_complete(fut)
85 fut = self._asyncioTestLoop.create_future()
86 self._asyncioCallsQueue.put_nowait((fut, ret))
87 return self._asyncioTestLoop.run_until_complete(fut)
91 async def _asyncioLoopRunner(self, fut): argument
93 fut.set_result(None)
99 fut, awaitable = query
102 if not fut.cancelled():
[all …]
|
| /third_party/boost/libs/process/test/ |
| D | system_test2.cpp | 49 std::future<std::string> fut; variable
55 bp::std_out > fut,
61 BOOST_REQUIRE(fut.valid());
62 BOOST_REQUIRE(boost::starts_with(fut.get(), "abc"));
70 std::future<std::string> fut; variable
79 bp::std_out > fut, in __anonb4ac76570102()
90 BOOST_REQUIRE(fut.valid());
92 fut.get(), "abc"));
|
| D | async_fut.cpp | 44 std::future<std::string> fut; variable
56 bp::std_out > fut,
65 BOOST_REQUIRE(fut.valid());
71 BOOST_CHECK_NO_THROW(line = fut.get());
88 std::future<std::string> fut; variable
93 bp::std_out > fut,
102 BOOST_REQUIRE(fut.valid());
103 BOOST_CHECK_EQUAL(fut.get(), "");
|
| D | async_system_future.cpp | 35 std::future<int> fut = bp::async_system( variable
43 BOOST_CHECK_NO_THROW(exit_code = fut.get());
54 std::future<int> fut = bp::async_system( variable
60 BOOST_CHECK_THROW(fut.get(), boost::system::system_error);
|
| D | system_test1.cpp | 68 std::future<std::string> fut; variable
73 bp::std_out > fut,
77 BOOST_REQUIRE(fut.valid());
80 fut.get(), "abc"));
|
| /third_party/python/Doc/library/ |
| D | asyncio-future.rst | 153 if not fut.cancelled():
154 fut.set_result(42)
173 # Call 'print("Future:", fut)' when "fut" is done.
174 fut.add_done_callback(
225 async def set_after(fut, delay, value):
229 # Set *value* as a result of *fut* Future.
230 fut.set_result(value)
237 fut = loop.create_future()
244 set_after(fut, 1, '... world'))
248 # Wait until *fut* has a result (1 second) and print it.
[all …]
|
| /third_party/musl/src/thread/ |
| D | pthread_cond_timedwait.c | 66 volatile int *fut; in __pthread_cond_timedwait() local
78 fut = &c->_c_seq; in __pthread_cond_timedwait()
85 fut = &node.barrier; in __pthread_cond_timedwait()
100 do e = __timedwait_cp(fut, seq, clock, ts, !shared); in __pthread_cond_timedwait()
101 while (*fut==seq && (!e || e==EINTR)); in __pthread_cond_timedwait()
|
| /third_party/boost/boost/process/ |
| D | io.hpp | 245 …ture<p1,p2, std::string> operator=(std::future<std::string> & fut) const { return fut;} in operator =()
246 …ture<p1,p2, std::string> operator>(std::future<std::string> & fut) const { return fut;} in operator >()
247 …ture<p1,p2, std::vector<char>> operator=(std::future<std::vector<char>> & fut) const { return fut;} in operator =()
248 …ture<p1,p2, std::vector<char>> operator>(std::future<std::vector<char>> & fut) const { return fut;} in operator >()
|
| /third_party/flutter/skia/third_party/externals/icu/source/data/unit/ |
| D | uz.txt | 68 dnam{"kvadrat fut"}
69 one{"{0} kvadrat fut"}
70 other{"{0} kvadrat fut"}
381 dnam{"fut"}
382 one{"{0} fut"}
383 other{"{0} fut"}
384 per{"{0}/fut"}
649 dnam{"kub fut"}
650 one{"{0} kub fut"}
651 other{"{0} kub fut"}
[all …]
|
| /third_party/gettext/gettext-tools/examples/po/ |
| D | hu.po | 49 msgstr "Ez a program a(z) %d folyamatazonosítóval fut."
58 "Ez a program a(z) <b>%d</b> folyamatazonosítóval fut."
92 msgstr "Ez a program a(z) %1 folyamatazonosítóval fut."
105 msgstr "Ez a program a(z) $pid folyamatazonosítóval fut."
110 msgstr "Ez a program a(z) %(pid)d folyamatazonosítóval fut."
115 msgstr "Ez a program a(z) ~D folyamatazonosítóval fut."
122 msgstr "Ez a program a(z) {0} folyamatazonosítóval fut."
127 msgstr "Ez a program a(z) {pid} folyamatazonosítóval fut."
|
| /third_party/icu/icu4c/source/data/unit/ |
| D | uz.txt | 68 dnam{"kvadrat fut"}
69 one{"{0} kvadrat fut"}
70 other{"{0} kvadrat fut"}
520 dnam{"fut"}
521 one{"{0} fut"}
522 other{"{0} fut"}
523 per{"{0}/fut"}
842 dnam{"funt-fut"}
843 one{"{0} funt-kuch-fut"}
844 other{"{0} funt-fut"}
[all …]
|
| /third_party/skia/third_party/externals/icu/source/data/unit/ |
| D | uz.txt | 68 dnam{"kvadrat fut"}
69 one{"{0} kvadrat fut"}
70 other{"{0} kvadrat fut"}
520 dnam{"fut"}
521 one{"{0} fut"}
522 other{"{0} fut"}
523 per{"{0}/fut"}
842 dnam{"funt-fut"}
843 one{"{0} funt-kuch-fut"}
844 other{"{0} funt-fut"}
[all …]
|