| /third_party/python/Lib/asyncio/ |
| D | unix_events.py | 453 self._loop = loop
471 self._loop.call_soon(self._protocol.connection_made, self)
473 self._loop.call_soon(self._loop._add_reader,
477 self._loop.call_soon(futures._set_result_unless_cancelled,
487 selector = getattr(self._loop, '_selector', None)
512 if self._loop.get_debug():
515 self._loop._remove_reader(self._fileno)
516 self._loop.call_soon(self._protocol.eof_received)
517 self._loop.call_soon(self._call_connection_lost, None)
523 self._loop._remove_reader(self._fileno)
[all …]
|
| D | mixins.py | 13 _loop = None variable in _LoopBoundMixin
25 if self._loop is None:
27 if self._loop is None:
28 self._loop = loop
29 if loop is not self._loop:
|
| D | proactor_events.py | 34 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)
188 self._loop.call_soon(self._loop_reading)
210 if self._loop.get_debug():
219 self._loop.call_soon(self._loop_reading, None)
[all …]
|
| D | selector_events.py | 659 if self._loop is not None and not self._loop.is_closed():
660 polling = _test_selector_event(self._loop._selector,
667 polling = _test_selector_event(self._loop._selector,
696 self._loop._remove_reader(self._sock_fd)
699 self._loop._remove_writer(self._sock_fd)
700 self._loop.call_soon(self._call_connection_lost, None)
710 if self._loop.get_debug():
713 self._loop.call_exception_handler({
726 self._loop._remove_writer(self._sock_fd)
729 self._loop._remove_reader(self._sock_fd)
[all …]
|
| D | streams.py | 128 self._loop = events._get_event_loop(stacklevel=4)
130 self._loop = loop
138 if self._loop.get_debug():
144 if self._loop.get_debug():
176 waiter = self._loop.create_future()
212 self._closed = self._loop.create_future()
229 self._loop.call_exception_handler(context)
240 self._loop)
244 self._loop.create_task(res)
311 self._loop = loop
[all …]
|
| 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():
233 waiter = self._loop.create_future()
250 self._loop = None
|
| D | futures.py | 52 _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)
124 loop = self._loop
171 self._loop.call_soon(callback, self, context=ctx)
228 self._loop.call_soon(fn, self, context=context)
305 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)
119 self._loop = loop
146 debug = self._loop.get_debug()
172 if self._loop.get_debug():
176 if self._loop.get_debug():
|
| D | sslproto.py | 289 self._loop = loop
443 self._loop = loop
445 self._app_transport = _SSLProtocolTransport(self._loop, self)
491 self._loop.call_soon(self._app_protocol.connection_lost, exc)
565 if self._loop.get_debug():
601 if self._loop.get_debug():
603 self._handshake_start_time = self._loop.time()
611 self._loop.call_later(self._ssl_handshake_timeout,
644 if self._loop.get_debug():
645 dt = self._loop.time() - self._handshake_start_time
[all …]
|
| D | events.py | 35 self._loop = loop
40 if self._loop.get_debug():
67 if self._loop.get_debug():
94 self._loop.call_exception_handler(context)
150 self._loop._timer_handle_cancelled(self)
639 _loop = None variable in BaseDefaultEventLoopPolicy._Local
650 if (self._local._loop is None and
655 if self._local._loop is None:
659 return self._local._loop
665 self._local._loop = loop
|
| 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)
414 self._loop = None
435 self._loop = loop
445 fut = self._loop.create_future()
578 tasks.ensure_future(coro, loop=self._loop)
586 fut = self._loop.create_future()
699 f = _WaitCancelFuture(ov, handle, wait_handle, loop=self._loop)
702 loop=self._loop)
[all …]
|
| D | tasks.py | 112 self._loop.call_soon(self.__step, context=self._context)
123 self._loop.call_exception_handler(context)
226 _enter_task(self._loop, self)
255 if futures._get_loop(result) is not self._loop:
259 self._loop.call_soon(
265 self._loop.call_soon(
280 self._loop.call_soon(
285 self._loop.call_soon(self.__step, context=self._context)
291 self._loop.call_soon(
296 self._loop.call_soon(
[all …]
|
| D | transports.py | 267 self._loop = loop
282 self._loop.call_exception_handler({
298 self._loop.call_exception_handler({
|
| D | base_events.py | 216 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)
363 self._serving_forever_fut = self._loop.create_future()
379 waiter = self._loop.create_future()
|
| /third_party/libfuse/test/ |
| 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/ |
| D | columnify.js | 224 var _loop = function _loop(i) { function
234 _loop(i);
|
| /third_party/python/Lib/test/test_asyncio/ |
| 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 …]
|
| D | test_tasks.py | 192 self.assertIs(t._loop, self.loop)
198 self.assertIs(t._loop, loop)
206 self.assertIs(t._loop, self.loop)
221 self.assertIs(t._loop, self.loop)
232 self.assertIs(t._loop, self.loop)
243 self.assertIs(t._loop, self.loop)
258 self.assertIs(t._loop, self.loop)
269 self.assertIs(t._loop, self.loop)
2246 self.assertEqual(outer._loop, self.loop)
2260 self.assertEqual(outer._loop, self.loop)
[all …]
|
| D | test_futures.py | 152 self.assertIs(f._loop, self.loop)
162 self.assertIs(f._loop, self.loop)
511 self.assertIs(self.loop, f2._loop)
525 self.assertIs(self.loop, f2._loop)
|
| /third_party/libwebsockets/lib/event-libs/libev/ |
| 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/lib/event-libs/libevent/ |
| 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/minimal-examples/http-server/minimal-http-server-eventlib-custom/ |
| 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()
|
| /third_party/libwebsockets/lib/event-libs/sdevent/ |
| D | sdevent.c | 246 init_pt_sd(struct lws_context *context, void *_loop, int tsi) in init_pt_sd() argument
250 struct sd_event *loop = (struct sd_event *)_loop; in init_pt_sd()
|
| /third_party/libwebsockets/include/libwebsockets/ |
| D | lws-eventlib-exports.h | 51 int (*init_pt)(struct lws_context *context, void *_loop, int tsi);
|
| /third_party/libwebsockets/lib/event-libs/glib/ |
| D | glib.c | 307 elops_init_pt_glib(struct lws_context *context, void *_loop, int tsi) in elops_init_pt_glib() argument
311 GMainLoop *loop = (GMainLoop *)_loop; in elops_init_pt_glib()
|