| /toolchain/binutils/binutils-2.27/gas/testsuite/gas/xtensa/ |
| loop_misalign.s | 2 _loop a5,l5
|
| /external/python/cpython3/Lib/asyncio/ |
| locks.py | 147 self._loop = loop
149 self._loop = events.get_event_loop()
173 fut = self._loop.create_future()
217 self._loop = loop
219 self._loop = events.get_event_loop()
261 fut = self._loop.create_future()
282 self._loop = loop
284 self._loop = events.get_event_loop()
287 lock = Lock(loop=self._loop)
288 elif lock._loop is not self._loop
[all...] |
| selector_events.py | 582 if self._loop is not None and not self._loop.is_closed():
583 polling = _test_selector_event(self._loop._selector,
590 polling = _test_selector_event(self._loop._selector,
618 self._loop._remove_reader(self._sock_fd)
621 self._loop._remove_writer(self._sock_fd)
622 self._loop.call_soon(self._call_connection_lost, None)
637 if self._loop.get_debug():
640 self._loop.call_exception_handler({
653 self._loop._remove_writer(self._sock_fd
[all...] |
| unix_events.py | 331 self._loop = loop
348 self._loop.call_soon(self._protocol.connection_made, self)
350 self._loop.call_soon(self._loop._add_reader,
354 self._loop.call_soon(futures._set_result_unless_cancelled,
364 selector = getattr(self._loop, '_selector', None)
390 if self._loop.get_debug():
393 self._loop._remove_reader(self._fileno)
394 self._loop.call_soon(self._protocol.eof_received)
395 self._loop.call_soon(self._call_connection_lost, None
[all...] |
| futures.py | 83 self.loop = future._loop
131 _loop = None variable in class:Future
155 self._loop = events.get_event_loop()
157 self._loop = loop
159 if self._loop.get_debug():
185 self._loop.call_exception_handler(context)
212 self._loop.call_soon(callback, self)
273 self._loop.call_soon(fn, self)
326 self._loop.call_soon(self._tb_logger.activate)
398 source_loop = source._loop if isfuture(source) else Non
[all...] |
| tasks.py | 66 return {t for t in cls._all_tasks if t._loop is loop}
76 self._loop.call_soon(self._step)
91 self._loop.call_exception_handler(context)
173 self.__class__._current_tasks[self._loop] = self
195 if result._loop is not self._loop:
196 self._loop.call_soon(
203 self._loop.call_soon(
216 self._loop.call_soon(
223 self._loop.call_soon(self._step
[all...] |
| proactor_events.py | 41 self._loop.call_soon(self._protocol.connection_made, self)
44 self._loop.call_soon(futures._set_result_unless_cancelled,
84 self._loop.call_soon(self._call_connection_lost, None)
101 if self._loop.get_debug():
104 self._loop.call_exception_handler({
125 self._loop.call_soon(self._call_connection_lost, exc)
159 self._loop.call_soon(self._loop_reading)
167 if self._loop.get_debug():
176 self._loop.call_soon(self._loop_reading, self._read_fut)
177 if self._loop.get_debug()
[all...] |
| subprocess.py | 46 loop=self._loop)
53 loop=self._loop)
62 loop=self._loop)
111 self._loop = loop
142 debug = self._loop.get_debug()
170 if self._loop.get_debug():
174 if self._loop.get_debug():
195 loop=self._loop)
|
| sslproto.py | 298 self._loop = loop
437 self._loop = loop
439 self._app_transport = _SSLProtocolTransport(self._loop,
480 self._loop.call_soon(self._app_protocol.connection_lost, exc)
505 if self._loop.get_debug():
530 if self._loop.get_debug():
561 if self._loop.get_debug():
563 self._handshake_start_time = self._loop.time()
570 self._loop.call_soon(self._process_write_backlog)
588 if self._loop.get_debug()
[all...] |
| events.py | 83 __slots__ = ('_callback', '_args', '_cancelled', '_loop',
87 self._loop = loop
92 if self._loop.get_debug():
117 if self._loop.get_debug():
138 self._loop.call_exception_handler(context)
194 self._loop._timer_handle_cancelled(self)
567 _loop = None variable in class:BaseDefaultEventLoopPolicy._Local
578 if (self._local._loop is None and
582 if self._local._loop is None:
585 return self._local._loop
614 _loop = None variable in class:_RunningLoop
[all...] |
| base_subprocess.py | 20 self._loop = loop
47 if self._loop.get_debug():
55 self._loop.create_task(self._connect_pipes(waiter))
114 if self._loop.get_debug():
166 loop = self._loop
203 self._loop.call_soon(cb, *data)
215 if self._loop.get_debug():
240 waiter = self._loop.create_future()
257 self._loop = None
|
| queues.py | 42 self._loop = events.get_event_loop()
44 self._loop = loop
52 self._finished = locks.Event(loop=self._loop)
130 putter = self._loop.create_future()
164 getter = self._loop.create_future()
|
| transports.py | 250 self._loop = loop
263 self._loop.call_exception_handler({
277 self._loop.call_exception_handler({
|
| streams.py | 160 self._loop = events.get_event_loop()
162 self._loop = loop
170 if self._loop.get_debug():
176 if self._loop.get_debug():
209 waiter = self._loop.create_future()
236 self._loop)
240 self._loop.create_task(res)
281 self._loop = loop
347 self._loop = events.get_event_loop()
349 self._loop = loo
[all...] |
| windows_events.py | 71 self._loop.call_exception_handler(context)
142 self._loop.call_exception_handler(context)
229 self._loop.call_exception_handler(context)
400 self._loop = None
415 self._loop = loop
425 fut = self._loop.create_future()
496 tasks.ensure_future(coro, loop=self._loop)
555 yield from tasks.sleep(delay, loop=self._loop)
587 f = _WaitCancelFuture(ov, handle, wait_handle, loop=self._loop)
590 loop=self._loop)
[all...] |
| base_events.py | 183 fut._loop.stop()
189 self._loop = loop
213 self._loop._stop_serving(sock)
228 waiter = self._loop.create_future()
[all...] |
| /external/autotest/client/cros/audio/ |
| cras_dbus_utils.py | 60 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(
[all...] |
| /external/python/cpython3/Lib/test/test_asyncio/ |
| test_locks.py | 28 self.assertIs(lock._loop, loop)
31 self.assertIs(lock._loop, self.loop)
36 self.assertIs(lock._loop, self.loop)
245 self.assertIs(ev._loop, loop)
248 self.assertIs(ev._loop, self.loop)
253 self.assertIs(ev._loop, self.loop)
375 self.assertIs(cond._loop, loop)
378 self.assertIs(cond._loop, self.loop)
383 self.assertIs(cond._loop, self.loop)
691 self.assertIs(cond._loop, lock._loop
[all...] |
| test_unix_events.py | 503 self.assertIsNotNone(tr._loop)
511 self.assertIsNone(tr._loop)
516 self.assertIsNotNone(tr._loop)
524 self.assertIsNone(tr._loop)
752 self.assertIsNotNone(tr._loop)
760 self.assertIsNone(tr._loop)
765 self.assertIsNotNone(tr._loop)
773 self.assertIsNone(tr._loop)
[all...] |
| test_proactor_events.py | 286 tr._loop._proactor.send.return_value = f
291 tr._loop._proactor.send.assert_called_with(self.sock, b'data')
310 tr._loop._proactor.send.return_value = f
315 tr._loop._proactor.send.assert_called_with(self.sock, b'data')
|
| test_queues.py | 73 self.assertIs(q._loop, loop)
76 self.assertIs(q._loop, self.loop)
81 self.assertIs(q._loop, self.loop)
|
| test_tasks.py | 129 self.assertIs(t._loop, self.loop)
134 self.assertIs(t._loop, loop)
146 self.assertIs(t._loop, self.loop)
151 self.assertIs(t._loop, loop)
[all...] |
| test_streams.py | 40 self.assertIs(stream._loop, m_events.get_event_loop.return_value)
750 self.assertIs(reader._loop, self.loop)
760 self.assertIs(protocol._loop, self.loop)
|
| test_futures.py | 141 self.assertIs(f._loop, self.loop)
386 self.assertIs(self.loop, f2._loop)
|
| test_subprocess.py | 66 self.assertIsNone(transport._loop)
|
