| /external/python/cpython3/Lib/asyncio/ |
| D | runners.py | 52 self._loop = None
69 loop = self._loop
78 self._loop = None
84 return self._loop
100 task = self._loop.create_task(coro, context=context)
118 return self._loop.run_until_complete(task)
137 self._loop = events.new_event_loop()
141 events.set_event_loop(self._loop)
144 self._loop = self._loop_factory()
146 self._loop.set_debug(self._debug)
[all …]
|
| D | mixins.py | 10 _loop = None variable in _LoopBoundMixin
15 if self._loop is None:
17 if self._loop is None:
18 self._loop = loop
19 if loop is not self._loop:
|
| D | unix_events.py | 502 self._loop = loop
520 self._loop.call_soon(self._protocol.connection_made, self)
522 self._loop.call_soon(self._add_reader,
526 self._loop.call_soon(futures._set_result_unless_cancelled,
532 self._loop._add_reader(fd, callback)
544 selector = getattr(self._loop, '_selector', None)
569 if self._loop.get_debug():
572 self._loop._remove_reader(self._fileno)
573 self._loop.call_soon(self._protocol.eof_received)
574 self._loop.call_soon(self._call_connection_lost, None)
[all …]
|
| D | streams.py | 128 self._loop = events.get_event_loop()
130 self._loop = loop
138 if self._loop.get_debug():
144 if self._loop.get_debug():
169 waiter = self._loop.create_future()
208 self._closed = self._loop.create_future()
217 loop = self._loop
230 self._loop.call_exception_handler(context)
239 writer = StreamWriter(transport, self, reader, self._loop)
248 self._loop.call_exception_handler({
[all …]
|
| D | taskgroups.py | 32 self._loop = None
58 if self._loop is None:
59 self._loop = events.get_running_loop()
60 self._parent_task = tasks.current_task(self._loop)
117 self._on_completed_fut = self._loop.create_future()
196 task = self._loop.create_task(coro, name=name)
198 task = self._loop.create_task(coro, name=name, context=context)
246 self._loop.call_exception_handler({
|
| D | selector_events.py | 805 if self._loop is not None and not self._loop.is_closed():
806 polling = _test_selector_event(self._loop._selector,
813 polling = _test_selector_event(self._loop._selector,
845 self._loop._remove_reader(self._sock_fd)
846 if self._loop.get_debug():
854 if self._loop.get_debug():
861 self._loop._remove_reader(self._sock_fd)
864 self._loop._remove_writer(self._sock_fd)
865 self._loop.call_soon(self._call_connection_lost, None)
877 if self._loop.get_debug():
[all …]
|
| D | proactor_events.py | 34 if transport._loop.get_debug():
67 self._loop.call_soon(self._protocol.connection_made, self)
70 self._loop.call_soon(futures._set_result_unless_cancelled,
109 self._loop.call_soon(self._call_connection_lost, None)
122 if self._loop.get_debug():
125 self._loop.call_exception_handler({
152 self._loop.call_soon(self._call_connection_lost, exc)
192 self._loop.call_soon(self._loop_reading)
214 if self._loop.get_debug():
223 self._loop.call_soon(self._loop_reading, None)
[all …]
|
| D | futures.py | 53 _loop = None variable in Future
80 self._loop = events.get_event_loop()
82 self._loop = loop
84 if self._loop.get_debug():
105 self._loop.call_exception_handler(context)
121 loop = self._loop
170 self._loop.call_soon(callback, self, context=ctx)
225 self._loop.call_soon(fn, self, context=context)
307 return fut._loop
|
| D | subprocess.py | 28 self._stdin_closed = self._loop.create_future()
46 loop=self._loop)
53 loop=self._loop)
62 loop=self._loop)
122 self._loop = loop
149 debug = self._loop.get_debug()
178 if self._loop.get_debug():
182 if self._loop.get_debug():
|
| D | base_subprocess.py | 21 self._loop = loop
48 if self._loop.get_debug():
56 self._loop.create_task(self._connect_pipes(waiter))
116 if self._loop.get_debug():
177 loop = self._loop
216 self._loop.call_soon(cb, *data)
228 if self._loop.get_debug():
246 waiter = self._loop.create_future()
268 self._loop = None
|
| D | sslproto.py | 89 self._loop = loop
313 self._loop = loop
378 self._app_transport = _SSLProtocolTransport(self._loop, self)
415 self._loop.call_soon(self._app_protocol.connection_lost, exc)
463 if self._loop.get_debug():
537 if self._loop.get_debug():
539 self._handshake_start_time = self._loop.time()
547 self._loop.call_later(self._ssl_handshake_timeout,
595 if self._loop.get_debug():
596 dt = self._loop.time() - self._handshake_start_time
[all …]
|
| D | events.py | 40 self._loop = loop
45 if self._loop.get_debug():
58 debug=self._loop.get_debug()))
76 if self._loop.get_debug():
95 debug=self._loop.get_debug())
104 self._loop.call_exception_handler(context)
159 self._loop._timer_handle_cancelled(self)
682 _loop = None variable in BaseDefaultEventLoopPolicy._Local
693 if (self._local._loop is None and
715 if self._local._loop is None:
[all …]
|
| D | tasks.py | 124 if eager_start and self._loop.is_running():
127 self._loop.call_soon(self.__step, context=self._context)
138 self._loop.call_exception_handler(context)
263 prev_task = _swap_current_task(self._loop, self)
272 curtask = _swap_current_task(self._loop, prev_task)
291 _enter_task(self._loop, self)
295 _leave_task(self._loop, self)
327 if futures._get_loop(result) is not self._loop:
331 self._loop.call_soon(
337 self._loop.call_soon(
[all …]
|
| D | windows_events.py | 81 self._loop.call_exception_handler(context)
152 self._loop.call_exception_handler(context)
239 self._loop.call_exception_handler(context)
421 self._loop = None
442 self._loop = loop
456 fut = self._loop.create_future()
574 tasks.ensure_future(coro, loop=self._loop)
582 fut = self._loop.create_future()
686 f = _WaitCancelFuture(ov, handle, wait_handle, loop=self._loop)
689 loop=self._loop)
[all …]
|
| D | transports.py | 275 self._loop = loop
290 self._loop.call_exception_handler({
306 self._loop.call_exception_handler({
|
| /external/pigweed/pw_transfer/py/pw_transfer/ |
| D | client.py | 143 self._loop = asyncio.new_event_loop()
145 asyncio.set_event_loop(self._loop)
162 lambda chunk: self._loop.call_soon_threadsafe(
169 lambda chunk: self._loop.call_soon_threadsafe(
181 self._loop.call_soon_threadsafe(self._quit_event.set)
365 asyncio.set_event_loop(self._loop)
374 self._loop.create_task(self._transfer_event_loop())
375 self._loop.run_forever()
379 exit_thread = self._loop.create_task(self._quit_event.wait())
380 new_transfer = self._loop.create_task(self._new_transfer_queue.get())
[all …]
|
| /external/autotest/client/cros/audio/ |
| D | cras_dbus_utils.py | 48 self._loop = GObject.MainLoop()
77 self._loop.run()
86 if self._loop.is_running():
92 self._loop.quit()
104 if self._loop.is_running():
106 self._loop.quit()
204 self._loop.run()
214 if self._loop.is_running():
248 if self._loop.is_running():
252 self._loop.quit()
|
| /external/grpc-grpc/src/python/grpcio/grpc/aio/ |
| D | _channel.py | 89 _loop: asyncio.AbstractEventLoop
96 _loop: asyncio.AbstractEventLoop
109 self._loop = loop
160 self._loop,
174 self._loop,
206 self._loop,
220 self._loop,
251 self._loop,
265 self._loop,
296 self._loop,
[all …]
|
| D | _interceptor.py | 548 self._status_code_task = self._loop.create_task(call.code())
552 self._loop.create_task(
612 _loop: asyncio.AbstractEventLoop
630 self._loop = loop
691 self._loop,
710 _loop: asyncio.AbstractEventLoop
729 self._loop = loop
804 self._loop,
832 _loop: asyncio.AbstractEventLoop
850 self._loop = loop
[all …]
|
| D | _server.py | 48 self._loop = cygrpc.get_working_loop()
61 self._loop,
188 self._loop,
|
| /external/python/pyee/pyee/ |
| D | asyncio.py | 39 self._loop: Optional[AbstractEventLoop] = loop
53 if self._loop:
57 fut: Any = ensure_future(cast(Any, coro), loop=self._loop)
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/ |
| D | call.pyx.pxi | 52 self._loop = channel.loop
248 future = self._loop.create_future()
270 future = self._loop.create_future()
328 self._loop)
351 await execute_batch(self, ops, self._loop)
374 self._loop
387 self._loop)
393 await execute_batch(self, ops, self._loop)
402 status_task = self._loop.create_task(self._handle_status_once_received())
426 self._loop)
[all …]
|
| D | server.pyx.pxi | 125 self._loop = loop
131 raw_message = await _receive_message(self._rpc_state, self._loop)
147 self._loop)
160 self._loop
198 self._loop
299 self._loop = context._loop
307 self._loop)
314 self._loop)
899 self._loop = loop
906 self._shutdown_completed = self._loop.create_future()
[all …]
|
| D | server.pxd.pxi | 48 cdef object _loop # asyncio.AbstractEventLoop
56 cdef object _loop # asyncio.AbstractEventLoop
82 cdef object _loop # asyncio.EventLoop
|
| /external/clang/test/CodeGenObjC/ |
| D | objc2-weak-ivar-debug.m | 9 __weak Loop *_loop; field
16 L->_loop = 0;
|