| /external/python/cpython3/Lib/asyncio/ |
| proactor_events.py | 44 self._loop.call_soon(self._protocol.connection_made, self)
47 self._loop.call_soon(futures._set_result_unless_cancelled,
86 self._loop.call_soon(self._call_connection_lost, None)
130 self._loop.call_soon(self._call_connection_lost, exc)
166 self._loop.call_soon(self._loop_reading)
197 self._loop.call_soon(self._loop_reading, None)
204 self._loop.call_soon(self._data_received, data)
360 self._loop.call_soon(self._call_connection_lost, None)
534 # call_soon(), which is forbidden when the event loop is closed.
616 self.call_soon(self._loop_self_reading
[all...] |
| unix_events.py | 446 self._loop.call_soon(self._protocol.connection_made, self)
448 self._loop.call_soon(self._loop._add_reader,
452 self._loop.call_soon(futures._set_result_unless_cancelled,
491 self._loop.call_soon(self._protocol.eof_received)
492 self._loop.call_soon(self._call_connection_lost, None)
536 self._loop.call_soon(self._call_connection_lost, exc)
573 self._loop.call_soon(self._protocol.connection_made, self)
580 self._loop.call_soon(self._loop._add_reader,
585 self._loop.call_soon(futures._set_result_unless_cancelled,
693 self._loop.call_soon(self._call_connection_lost, None
[all...] |
| tasks.py | 116 self._loop.call_soon(self.__step, context=self._context)
248 self._loop.call_soon(
254 self._loop.call_soon(
268 self._loop.call_soon(
273 self._loop.call_soon(self.__step, context=self._context)
279 self._loop.call_soon(
284 self._loop.call_soon(
|
| base_subprocess.py | 182 loop.call_soon(self._protocol.connection_made, self)
184 loop.call_soon(callback, *data)
197 self._loop.call_soon(cb, *data)
|
| futures.py | 43 via the event loop's call_soon().
149 self._loop.call_soon(callback, self, context=ctx)
201 scheduled with call_soon.
204 self._loop.call_soon(fn, self, context=context)
|
| selector_events.py | 650 self._loop.call_soon(self._call_connection_lost, None)
682 self._loop.call_soon(self._call_connection_lost, exc)
727 self._loop.call_soon(self._protocol.connection_made, self)
729 self._loop.call_soon(self._add_reader,
733 self._loop.call_soon(futures._set_result_unless_cancelled,
[all...] |
| sslproto.py | 493 self._loop.call_soon(self._app_protocol.connection_lost, exc)
655 self._loop.call_soon(self._process_write_backlog)
|
| base_events.py | 678 def call_soon(self, callback, *args, context=None): member in class:BaseEventLoop
691 self._check_callback(callback, 'call_soon')
732 """Like call_soon(), but thread-safe."""
[all...] |
| events.py | 263 def call_soon(self, callback, *args): member in class:AbstractEventLoop
742 When called from a coroutine or a callback (e.g. scheduled with call_soon
|
| windows_events.py | 362 self.call_soon(loop_accept_pipe)
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| test_streams.py | 152 self.loop.call_soon(cb)
176 self.loop.call_soon(cb)
191 self.loop.call_soon(cb)
234 self.loop.call_soon(cb)
292 self.loop.call_soon(cb)
306 self.loop.call_soon(cb)
489 self.loop.call_soon(cb)
511 self.loop.call_soon(cb)
[all...] |
| test_proactor_events.py | 739 @mock.patch.object(BaseProactorEventLoop, 'call_soon')
741 def test_ctor(self, socketpair, call_soon):
748 call_soon.assert_called_with(loop._loop_self_reading)
808 call_soon = self.loop.call_soon = mock.Mock()
811 self.assertTrue(call_soon.called)
814 loop = call_soon.call_args[0][0]
835 call_soon = self.loop.call_soon = mock.Mock()
838 loop = call_soon.call_args[0][0
[all...] |
| test_subprocess.py | 343 self.loop.call_soon(task.cancel)
365 self.loop.call_soon(task.cancel)
383 self.loop.call_soon(task.cancel)
|
| test_base_events.py | 218 h = self.loop.call_soon(cb)
226 self.loop.call_soon(1)
277 loop.call_soon(cb)
283 loop.call_soon(cb)
311 loop.call_soon(event.set)
390 handle = loop.call_soon(lambda: True)
500 self.loop.call_soon(throw)
566 # Test call_soon (events.Handle)
569 self.loop.call_soon(zero_error, fut)
623 handle = self.loop.call_soon(zero_error
[all...] |
| test_locks.py | 150 self.loop.call_soon(task.cancel)
220 self.loop.call_soon(trigger)
413 self.loop.call_soon(wait.cancel)
545 self.loop.call_soon(wait.cancel)
566 self.loop.call_soon(wait_task.cancel)
567 self.loop.call_soon(cond.release)
953 self.loop.call_soon(acquire.cancel)
|
| test_events.py | 304 self.loop.call_soon(callback, 'hello', 'world')
326 self.loop.call_soon(callback, 'world')
340 self.loop.call_soon(callback, 'world')
365 self.loop.call_soon = patched_call_soon
389 self.loop.call_soon(w.send, b'abc')
391 self.loop.call_soon(w.send, b'def')
393 self.loop.call_soon(w.close)
394 self.loop.call_soon(self.loop.stop)
791 loop.call_soon(loop.stop)
[all...] |
| test_tasks.py | 446 loop.call_soon(t.cancel)
2206 def call_soon(callback, *args, **kwargs): function in function:BaseTaskTests.test_error_in_call_soon
[all...] |
| utils.py | 126 loop.call_soon(loop.stop)
|
| /external/python/cpython3/Modules/ |
| _asynciomodule.c | 15 _Py_IDENTIFIER(call_soon); variable
340 call_soon(PyObject *loop, PyObject *func, PyObject *arg, PyObject *ctx) function
351 /* Use FASTCALL to pass a keyword-only argument to call_soon */
417 int ret = call_soon(
451 if (call_soon(fut->fut_loop, cb, (PyObject *)fut, ctx)) {
629 if (call_soon(fut->fut_loop, arg, (PyObject*) fut, ctx)) {
897 scheduled with call_soon.
[all...] |
