Home
last modified time | relevance | path

Searched refs:_loop (Results 1 – 25 of 32) sorted by relevance

12

/external/python/cpython3/Lib/asyncio/
Dunix_events.py443 self._loop = loop
461 self._loop.call_soon(self._protocol.connection_made, self)
463 self._loop.call_soon(self._loop._add_reader,
467 self._loop.call_soon(futures._set_result_unless_cancelled,
477 selector = getattr(self._loop, '_selector', None)
502 if self._loop.get_debug():
505 self._loop._remove_reader(self._fileno)
506 self._loop.call_soon(self._protocol.eof_received)
507 self._loop.call_soon(self._call_connection_lost, None)
513 self._loop._remove_reader(self._fileno)
[all …]
Dlocks.py164 self._loop = events.get_event_loop()
166 self._loop = loop
195 fut = self._loop.create_future()
260 self._loop = events.get_event_loop()
262 self._loop = loop
306 fut = self._loop.create_future()
327 self._loop = events.get_event_loop()
329 self._loop = loop
336 elif lock._loop is not self._loop:
370 fut = self._loop.create_future()
[all …]
Dselector_events.py649 if self._loop is not None and not self._loop.is_closed():
650 polling = _test_selector_event(self._loop._selector,
657 polling = _test_selector_event(self._loop._selector,
686 self._loop._remove_reader(self._sock_fd)
689 self._loop._remove_writer(self._sock_fd)
690 self._loop.call_soon(self._call_connection_lost, None)
700 if self._loop.get_debug():
703 self._loop.call_exception_handler({
716 self._loop._remove_writer(self._sock_fd)
719 self._loop._remove_reader(self._sock_fd)
[all …]
Dproactor_events.py34 if transport._loop.get_debug():
66 self._loop.call_soon(self._protocol.connection_made, self)
69 self._loop.call_soon(futures._set_result_unless_cancelled,
108 self._loop.call_soon(self._call_connection_lost, None)
121 if self._loop.get_debug():
124 self._loop.call_exception_handler({
151 self._loop.call_soon(self._call_connection_lost, exc)
187 self._loop.call_soon(self._loop_reading)
209 if self._loop.get_debug():
218 self._loop.call_soon(self._loop_reading, None)
[all …]
Dstreams.py147 self._loop = events.get_event_loop()
149 self._loop = loop
157 if self._loop.get_debug():
163 if self._loop.get_debug():
195 waiter = self._loop.create_future()
231 self._closed = self._loop.create_future()
248 self._loop.call_exception_handler(context)
259 self._loop)
263 self._loop.create_task(res)
326 self._loop = loop
[all …]
Dfutures.py52 _loop = None variable in Future
76 self._loop = events.get_event_loop()
78 self._loop = loop
80 if self._loop.get_debug():
104 self._loop.call_exception_handler(context)
118 loop = self._loop
149 self._loop.call_soon(callback, self, context=ctx)
204 self._loop.call_soon(fn, self, context=context)
281 return fut._loop
Dsubprocess.py29 self._stdin_closed = self._loop.create_future()
47 loop=self._loop)
54 loop=self._loop)
63 loop=self._loop)
120 self._loop = loop
147 debug = self._loop.get_debug()
173 if self._loop.get_debug():
177 if self._loop.get_debug():
197 loop=self._loop)
Dbase_subprocess.py18 self._loop = loop
45 if self._loop.get_debug():
53 self._loop.create_task(self._connect_pipes(waiter))
113 if self._loop.get_debug():
159 loop = self._loop
198 self._loop.call_soon(cb, *data)
210 if self._loop.get_debug():
233 waiter = self._loop.create_future()
250 self._loop = None
Dsslproto.py290 self._loop = loop
444 self._loop = loop
446 self._app_transport = _SSLProtocolTransport(self._loop, self)
492 self._loop.call_soon(self._app_protocol.connection_lost, exc)
566 if self._loop.get_debug():
602 if self._loop.get_debug():
604 self._handshake_start_time = self._loop.time()
612 self._loop.call_later(self._ssl_handshake_timeout,
645 if self._loop.get_debug():
646 dt = self._loop.time() - self._handshake_start_time
[all …]
Devents.py36 self._loop = loop
41 if self._loop.get_debug():
68 if self._loop.get_debug():
95 self._loop.call_exception_handler(context)
151 self._loop._timer_handle_cancelled(self)
622 _loop = None variable in BaseDefaultEventLoopPolicy._Local
633 if (self._local._loop is None and
638 if self._local._loop is None:
642 return self._local._loop
648 self._local._loop = loop
Dwindows_events.py75 self._loop.call_exception_handler(context)
146 self._loop.call_exception_handler(context)
233 self._loop.call_exception_handler(context)
405 self._loop = None
426 self._loop = loop
436 fut = self._loop.create_future()
569 tasks.ensure_future(coro, loop=self._loop)
577 fut = self._loop.create_future()
690 f = _WaitCancelFuture(ov, handle, wait_handle, loop=self._loop)
693 loop=self._loop)
[all …]
Dtasks.py164 self._loop.call_soon(self.__step, context=self._context)
175 self._loop.call_exception_handler(context)
274 _enter_task(self._loop, self)
301 if futures._get_loop(result) is not self._loop:
305 self._loop.call_soon(
311 self._loop.call_soon(
325 self._loop.call_soon(
330 self._loop.call_soon(self.__step, context=self._context)
336 self._loop.call_soon(
341 self._loop.call_soon(
[all …]
Dqueues.py35 self._loop = events.get_event_loop()
37 self._loop = loop
122 putter = self._loop.create_future()
160 getter = self._loop.create_future()
Dtransports.py267 self._loop = loop
282 self._loop.call_exception_handler({
298 self._loop.call_exception_handler({
Dbase_events.py216 self._write_ready_fut = self._transport._loop.create_future()
246 self._write_ready_fut = self._transport._loop.create_future()
277 self._loop = loop
314 self._loop._start_serving(
319 return self._loop
337 self._loop._stop_serving(sock)
353 await tasks.sleep(0, loop=self._loop)
363 self._serving_forever_fut = self._loop.create_future()
379 waiter = self._loop.create_future()
/external/autotest/client/cros/audio/
Dcras_dbus_utils.py60 self._loop = _get_gobject().MainLoop()
89 self._loop.run()
98 if self._loop.is_running():
104 self._loop.quit()
116 if self._loop.is_running():
118 self._loop.quit()
216 self._loop.run()
226 if self._loop.is_running():
260 if self._loop.is_running():
264 self._loop.quit()
/external/clang/test/CodeGenObjC/
Dobjc2-weak-ivar-debug.m9 __weak Loop *_loop; field
16 L->_loop = 0;
/external/python/cpython3/Lib/test/test_asyncio/
Dtest_locks.py33 self.assertIs(lock._loop, loop)
37 self.assertIs(lock._loop, self.loop)
42 self.assertIs(lock._loop, self.loop)
363 self.assertIs(ev._loop, loop)
367 self.assertIs(ev._loop, self.loop)
372 self.assertIs(ev._loop, self.loop)
497 self.assertIs(cond._loop, loop)
500 self.assertIs(cond._loop, self.loop)
505 self.assertIs(cond._loop, self.loop)
846 self.assertIs(cond._loop, lock._loop)
[all …]
Dtest_unix_events.py771 self.assertIsNotNone(tr._loop)
779 self.assertIsNone(tr._loop)
784 self.assertIsNotNone(tr._loop)
792 self.assertIsNone(tr._loop)
798 self.assertIsNone(tr._loop)
811 self.assertIsNone(tr._loop)
1042 self.assertIsNotNone(tr._loop)
1050 self.assertIsNone(tr._loop)
1055 self.assertIsNotNone(tr._loop)
1063 self.assertIsNone(tr._loop)
[all …]
Dtest_queues.py78 self.assertIs(q._loop, loop)
82 self.assertIs(q._loop, self.loop)
87 self.assertIs(q._loop, self.loop)
Dtest_tasks.py145 self.assertIs(t._loop, self.loop)
151 self.assertIs(t._loop, loop)
164 self.assertIs(t._loop, self.loop)
169 self.assertIs(t._loop, loop)
2684 def _loop(self): member in BaseTaskIntrospectionTests.test__register_task_1.TaskLike
2984 self.assertIs(fut._loop, self.one_loop)
2990 self.assertIs(fut._loop, self.other_loop)
3009 self.assertIs(fut._loop, self.other_loop)
3013 self.assertIs(fut._loop, self.other_loop)
3079 self.assertIs(fut._loop, self.one_loop)
[all …]
Dtest_proactor_events.py307 tr._loop._proactor.send.return_value = f
312 tr._loop._proactor.send.assert_called_with(self.sock, b'data')
331 tr._loop._proactor.send.return_value = f
336 tr._loop._proactor.send.assert_called_with(self.sock, b'data')
Dtest_streams.py46 self.assertIs(stream._loop, m_events.get_event_loop.return_value)
779 self.assertIs(reader._loop, self.loop)
789 self.assertIs(protocol._loop, self.loop)
Dtest_futures.py145 self.assertIs(f._loop, self.loop)
462 self.assertIs(self.loop, f2._loop)
/external/u-boot/arch/arm/mach-tegra/
Dpsci.S82 _loop: wfi label
83 b _loop

12