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.py429 self._loop = loop
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,
462 selector = getattr(self._loop, '_selector', None)
487 if self._loop.get_debug():
490 self._loop._remove_reader(self._fileno)
491 self._loop.call_soon(self._protocol.eof_received)
492 self._loop.call_soon(self._call_connection_lost, None)
495 self._loop._remove_reader(self._fileno)
[all …]
Dlocks.py159 self._loop = loop
161 self._loop = events.get_event_loop()
184 fut = self._loop.create_future()
247 self._loop = loop
249 self._loop = events.get_event_loop()
290 fut = self._loop.create_future()
311 self._loop = loop
313 self._loop = events.get_event_loop()
316 lock = Lock(loop=self._loop)
317 elif lock._loop is not self._loop:
[all …]
Dselector_events.py609 if self._loop is not None and not self._loop.is_closed():
610 polling = _test_selector_event(self._loop._selector,
617 polling = _test_selector_event(self._loop._selector,
646 self._loop._remove_reader(self._sock_fd)
649 self._loop._remove_writer(self._sock_fd)
650 self._loop.call_soon(self._call_connection_lost, None)
661 if self._loop.get_debug():
664 self._loop.call_exception_handler({
677 self._loop._remove_writer(self._sock_fd)
680 self._loop._remove_reader(self._sock_fd)
[all …]
Dproactor_events.py44 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)
100 if self._loop.get_debug():
103 self._loop.call_exception_handler({
130 self._loop.call_soon(self._call_connection_lost, exc)
166 self._loop.call_soon(self._loop_reading)
188 if self._loop.get_debug():
197 self._loop.call_soon(self._loop_reading, None)
204 self._loop.call_soon(self._data_received, data)
[all …]
Dfutures.py55 _loop = None variable in Future
79 self._loop = events.get_event_loop()
81 self._loop = loop
83 if self._loop.get_debug():
107 self._loop.call_exception_handler(context)
121 return self._loop
149 self._loop.call_soon(callback, self, context=ctx)
204 self._loop.call_soon(fn, self, context=context)
281 return fut._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():
160 loop = self._loop
197 self._loop.call_soon(cb, *data)
209 if self._loop.get_debug():
232 waiter = self._loop.create_future()
249 self._loop = None
Dstreams.py159 self._loop = events.get_event_loop()
161 self._loop = loop
169 if self._loop.get_debug():
175 if self._loop.get_debug():
207 waiter = self._loop.create_future()
227 self._closed = self._loop.create_future()
235 self._loop)
239 self._loop.create_task(res)
292 self._loop = loop
347 await sleep(0, loop=self._loop)
[all …]
Dsubprocess.py45 loop=self._loop)
52 loop=self._loop)
61 loop=self._loop)
110 self._loop = loop
137 debug = self._loop.get_debug()
163 if self._loop.get_debug():
167 if self._loop.get_debug():
187 loop=self._loop)
Dsslproto.py290 self._loop = loop
445 self._loop = loop
447 self._app_transport = _SSLProtocolTransport(self._loop, self)
493 self._loop.call_soon(self._app_protocol.connection_lost, exc)
559 if self._loop.get_debug():
595 if self._loop.get_debug():
597 self._handshake_start_time = self._loop.time()
605 self._loop.call_later(self._ssl_handshake_timeout,
636 if self._loop.get_debug():
637 dt = self._loop.time() - self._handshake_start_time
[all …]
Dwindows_events.py74 self._loop.call_exception_handler(context)
145 self._loop.call_exception_handler(context)
232 self._loop.call_exception_handler(context)
387 self._loop = None
408 self._loop = loop
418 fut = self._loop.create_future()
513 tasks.ensure_future(coro, loop=self._loop)
592 await tasks.sleep(delay, loop=self._loop)
626 f = _WaitCancelFuture(ov, handle, wait_handle, loop=self._loop)
629 loop=self._loop)
[all …]
Devents.py43 self._loop = loop
48 if self._loop.get_debug():
75 if self._loop.get_debug():
100 self._loop.call_exception_handler(context)
156 self._loop._timer_handle_cancelled(self)
626 _loop = None variable in BaseDefaultEventLoopPolicy._Local
637 if (self._local._loop is None and
642 if self._local._loop is None:
646 return self._local._loop
652 self._local._loop = loop
Dqueues.py34 self._loop = events.get_event_loop()
36 self._loop = loop
44 self._finished = locks.Event(loop=self._loop)
118 putter = self._loop.create_future()
156 getter = self._loop.create_future()
Dtasks.py116 self._loop.call_soon(self.__step, context=self._context)
127 self._loop.call_exception_handler(context)
217 _enter_task(self._loop, self)
244 if futures._get_loop(result) is not self._loop:
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(
[all …]
Dtransports.py253 self._loop = loop
266 self._loop.call_exception_handler({
280 self._loop.call_exception_handler({
Dbase_events.py190 self._write_ready_fut = self._transport._loop.create_future()
220 self._write_ready_fut = self._transport._loop.create_future()
251 self._loop = loop
288 self._loop._start_serving(
293 return self._loop
311 self._loop._stop_serving(sock)
327 await tasks.sleep(0, loop=self._loop)
337 self._serving_forever_fut = self._loop.create_future()
353 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.py28 self.assertIs(lock._loop, loop)
31 self.assertIs(lock._loop, self.loop)
36 self.assertIs(lock._loop, self.loop)
341 self.assertIs(ev._loop, loop)
344 self.assertIs(ev._loop, self.loop)
349 self.assertIs(ev._loop, self.loop)
467 self.assertIs(cond._loop, loop)
470 self.assertIs(cond._loop, self.loop)
475 self.assertIs(cond._loop, self.loop)
800 self.assertIs(cond._loop, lock._loop)
[all …]
Dtest_unix_events.py756 self.assertIsNotNone(tr._loop)
764 self.assertIsNone(tr._loop)
769 self.assertIsNotNone(tr._loop)
777 self.assertIsNone(tr._loop)
1005 self.assertIsNotNone(tr._loop)
1013 self.assertIsNone(tr._loop)
1018 self.assertIsNotNone(tr._loop)
1026 self.assertIsNone(tr._loop)
1810 self.assertIsNone(watcher._loop)
1828 self.assertIs(watcher._loop, loop)
[all …]
Dtest_queues.py71 self.assertIs(q._loop, loop)
74 self.assertIs(q._loop, self.loop)
79 self.assertIs(q._loop, self.loop)
Dtest_tasks.py145 self.assertIs(t._loop, self.loop)
151 self.assertIs(t._loop, loop)
163 self.assertIs(t._loop, self.loop)
168 self.assertIs(t._loop, loop)
2617 def _loop(self): member in BaseTaskIntrospectionTests.test__register_task_1.TaskLike
2922 self.assertIs(fut._loop, self.one_loop)
2927 self.assertIs(fut._loop, self.other_loop)
2946 self.assertIs(fut._loop, self.other_loop)
2950 self.assertIs(fut._loop, self.other_loop)
3018 self.assertIs(fut._loop, self.one_loop)
[all …]
Dtest_proactor_events.py303 tr._loop._proactor.send.return_value = f
308 tr._loop._proactor.send.assert_called_with(self.sock, b'data')
327 tr._loop._proactor.send.return_value = f
332 tr._loop._proactor.send.assert_called_with(self.sock, b'data')
Dtest_streams.py42 self.assertIs(stream._loop, m_events.get_event_loop.return_value)
748 self.assertIs(reader._loop, self.loop)
758 self.assertIs(protocol._loop, self.loop)
Dtest_futures.py141 self.assertIs(f._loop, self.loop)
458 self.assertIs(self.loop, f2._loop)
/external/u-boot/arch/arm/mach-tegra/
Dpsci.S82 _loop: wfi label
83 b _loop

12