| /third_party/python/Lib/asyncio/ |
| H A D | unix_events.py | 465 self._loop = loop
483 self._loop.call_soon(self._protocol.connection_made, self)
485 self._loop.call_soon(self._add_reader,
489 self._loop.call_soon(futures._set_result_unless_cancelled,
495 self._loop._add_reader(fd, callback)
507 selector = getattr(self._loop, '_selector', None)
532 if self._loop.get_debug():
535 self._loop._remove_reader(self._fileno)
536 self._loop.call_soon(self._protocol.eof_received)
537 self._loop
[all...] |
| H A D | runners.py | 53 self._loop = None
70 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
[all...] |
| H A 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:
|
| H A D | taskgroups.py | 32 self._loop = None
60 if self._loop is None:
61 self._loop = events.get_running_loop()
63 self._parent_task = tasks.current_task(self._loop)
109 self._on_completed_fut = self._loop.create_future()
163 task = self._loop.create_task(coro)
165 task = self._loop.create_task(coro, context=context)
207 self._loop.call_exception_handler({
|
| H A 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
[all...] |
| H A D | selector_events.py | 800 if self._loop is not None and not self._loop.is_closed():
801 polling = _test_selector_event(self._loop._selector,
808 polling = _test_selector_event(self._loop._selector,
840 self._loop._remove_reader(self._sock_fd)
841 if self._loop.get_debug():
849 if self._loop.get_debug():
856 self._loop._remove_reader(self._sock_fd)
859 self._loop._remove_writer(self._sock_fd)
860 self._loop
[all...] |
| H A D | streams.py | 129 self._loop = events._get_event_loop(stacklevel=4)
131 self._loop = loop
139 if self._loop.get_debug():
145 if self._loop.get_debug():
170 waiter = self._loop.create_future()
210 self._closed = self._loop.create_future()
219 loop = self._loop
234 self._loop.call_exception_handler(context)
245 self._loop)
249 self._task = self._loop
[all...] |
| H A 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
173 self._loop.call_soon(callback, self, context=ctx)
230 self._loop.call_soon(fn, self, context=context)
301 # Otherwise fallbacks to using the old '_loop' property.
308 return fut._loop
[all...] |
| H A D | base_subprocess.py | 18 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():
228 waiter = self._loop.create_future()
250 self._loop = None
|
| H A D | sslproto.py | 85 self._loop = loop
310 self._loop = loop
375 self._app_transport = _SSLProtocolTransport(self._loop, self)
409 self._loop.call_soon(self._app_protocol.connection_lost, exc)
457 if self._loop.get_debug():
531 if self._loop.get_debug():
533 self._handshake_start_time = self._loop.time()
541 self._loop.call_later(self._ssl_handshake_timeout,
588 if self._loop.get_debug():
589 dt = self._loop
[all...] |
| H A 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()
175 if self._loop.get_debug():
179 if self._loop.get_debug():
|
| H A D | windows_events.py | 80 self._loop.call_exception_handler(context)
151 self._loop.call_exception_handler(context)
238 self._loop.call_exception_handler(context)
419 self._loop = None
440 self._loop = loop
454 fut = self._loop.create_future()
607 tasks.ensure_future(coro, loop=self._loop)
615 fut = self._loop.create_future()
728 f = _WaitCancelFuture(ov, handle, wait_handle, loop=self._loop)
731 loop=self._loop)
[all...] |
| H A D | events.py | 27 __slots__ = ('_callback', '_args', '_cancelled', '_loop',
35 self._loop = loop
40 if self._loop.get_debug():
67 if self._loop.get_debug():
94 self._loop.call_exception_handler(context)
149 self._loop._timer_handle_cancelled(self)
660 _loop = None variable in BaseDefaultEventLoopPolicy._Local
671 if (self._local._loop is None and
676 if self._local._loop is None:
680 return self._local._loop
[all...] |
| H A D | tasks.py | 120 self._loop.call_soon(self.__step, context=self._context)
131 self._loop.call_exception_handler(context)
261 _enter_task(self._loop, self)
290 if futures._get_loop(result) is not self._loop:
294 self._loop.call_soon(
300 self._loop.call_soon(
315 self._loop.call_soon(
320 self._loop.call_soon(self.__step, context=self._context)
326 self._loop.call_soon(
331 self._loop
[all...] |
| H A D | transports.py | 268 __slots__ = ('_loop', '_protocol_paused', '_high_water', '_low_water')
273 self._loop = loop
288 self._loop.call_exception_handler({
304 self._loop.call_exception_handler({
|
| H A D | base_events.py | 217 self._write_ready_fut = self._transport._loop.create_future()
247 self._write_ready_fut = self._transport._loop.create_future()
278 self._loop = loop
316 self._loop._start_serving(
322 return self._loop
340 self._loop._stop_serving(sock)
366 self._serving_forever_fut = self._loop.create_future()
382 waiter = self._loop.create_future()
|
| /third_party/node/deps/openssl/openssl/engines/asm/ |
| H A D | e_padlock-x86_64.pl | 346 ja .L${mode}_loop
360 jmp .L${mode}_loop
362 .L${mode}_loop:
419 jnz .L${mode}_loop
425 jae .L${mode}_loop
439 jnz .L${mode}_loop
455 jmp .L${mode}_loop
555 jmp .L${mode}_loop
|
| /third_party/openssl/engines/asm/ |
| H A D | e_padlock-x86_64.pl | 346 ja .L${mode}_loop
360 jmp .L${mode}_loop
362 .L${mode}_loop:
419 jnz .L${mode}_loop
425 jae .L${mode}_loop
439 jnz .L${mode}_loop
455 jmp .L${mode}_loop
555 jmp .L${mode}_loop
|
| /third_party/node/deps/npm/node_modules/diff/lib/patch/ |
| H A D | create.js | 78 var _loop = function _loop(
220 _loop(
|
| /third_party/libfuse/test/ |
| H A D | conftest.py | 37 self._thread = threading.Thread(target=self._loop, daemon=True, args=(fd_r,))
49 def _loop(self, ifd): member in OutputChecker
|
| /third_party/node/deps/npm/node_modules/columnify/ |
| H A D | columnify.js | 224 var _loop = function _loop(i) {
234 _loop(i);
|
| /third_party/python/Lib/test/test_asyncio/ |
| H A D | test_unix_events.py | 781 self.assertIsNotNone(tr._loop)
789 self.assertIsNone(tr._loop)
794 self.assertIsNotNone(tr._loop)
802 self.assertIsNone(tr._loop)
808 self.assertIsNone(tr._loop)
821 self.assertIsNone(tr._loop)
1052 self.assertIsNotNone(tr._loop)
1060 self.assertIsNone(tr._loop)
1065 self.assertIsNotNone(tr._loop)
1073 self.assertIsNone(tr._loop)
[all...] |
| /third_party/libwebsockets/lib/event-libs/libevent/ |
| H A D | libevent.c | 196 elops_init_pt_event(struct lws_context *context, void *_loop, int tsi) in elops_init_pt_event() argument
198 struct event_base *loop = (struct event_base *)_loop; in elops_init_pt_event()
202 lwsl_cx_info(context, "loop %p", _loop); in elops_init_pt_event()
|
| /third_party/libwebsockets/lib/event-libs/libev/ |
| H A D | libev.c | 158 elops_init_pt_ev(struct lws_context *context, void *_loop, int tsi) in elops_init_pt_ev() argument
163 struct ev_loop *loop = (struct ev_loop *)_loop; in elops_init_pt_ev()
168 lwsl_cx_info(context, "loop %p", _loop); in elops_init_pt_ev()
|
| /third_party/libwebsockets/minimal-examples/http-server/minimal-http-server-eventlib-custom/ |
| H A D | minimal-http-server.c | 196 init_pt_custom(struct lws_context *cx, void *_loop, int tsi) in init_pt_custom() argument
203 priv->io_loop = (custom_poll_ctx_t *)_loop; in init_pt_custom()
|