Searched refs:io_loop (Results 1 – 10 of 10) sorted by relevance
| /third_party/libwebsockets/lib/event-libs/libev/ |
| D | libev.c | 45 ev_timer_start(ptpr->io_loop, &ptpr->hrtimer); in lws_ev_hrtimer_cb()
75 ev_timer_start(ptpr->io_loop, &ptpr->hrtimer); in lws_ev_idle_cb()
120 ev_idle_start(ptpr->io_loop, &ptpr->idle); in lws_accept_cb()
152 ev_io_start(ptpr->io_loop, &vh_to_priv_ev(vh)->w_accept.watcher); in elops_listen_init_ev()
183 ptpr->io_loop = loop; in elops_init_pt_ev()
249 ev_io_stop(ptpr->io_loop, &vh_to_priv_ev(vh)->w_accept.watcher); in elops_listen_destroy_ev()
264 ev_timer_stop(ptpr->io_loop, &ptpr->hrtimer); in elops_destroy_pt_ev()
265 ev_idle_stop(ptpr->io_loop, &ptpr->idle); in elops_destroy_pt_ev()
268 ev_signal_stop(ptpr->io_loop, &ptpr->w_sigint.watcher); in elops_destroy_pt_ev()
313 ptpr->io_loop, in elops_io_ev()
[all …]
|
| D | private-lib-event-libs-libev.h | 42 struct ev_loop *io_loop; member
|
| /third_party/libwebsockets/lib/event-libs/libevent/ |
| D | libevent.c | 173 event_base_loopbreak(pt_to_priv_event(pt)->io_loop); in lws_event_sigint_cb()
187 w_read->watcher = event_new(ptpr->io_loop, wsi->desc.sockfd, in elops_listen_init_event()
215 ptpr->io_loop = loop; in elops_init_pt_event()
280 wpr->w_read.watcher = event_new(ptpr->io_loop, fd, in elops_accept_event()
282 wpr->w_write.watcher = event_new(ptpr->io_loop, fd, in elops_accept_event()
295 if (!ptpr->io_loop || wsi->a.context->being_destroyed || in elops_io_event()
329 if (pt_to_priv_event(&context->pt[tsi])->io_loop) in elops_run_pt_event()
331 pt_to_priv_event(&context->pt[tsi])->io_loop); in elops_run_pt_event()
354 if (!ptpr->io_loop) in elops_destroy_pt_event()
365 event_base_loopexit(ptpr->io_loop, NULL); in elops_destroy_pt_event()
[all …]
|
| D | private-lib-event-libs-libevent.h | 33 struct event_base *io_loop; member
|
| /third_party/libwebsockets/lib/event-libs/libuv/ |
| D | libuv.c | 331 if (pt_to_priv_uv(&context->pt[tsi])->io_loop) in lws_libuv_stop_without_kill()
332 uv_stop(pt_to_priv_uv(&context->pt[tsi])->io_loop); in lws_libuv_stop_without_kill()
338 if (pt_to_priv_uv(&context->pt[tsi])->io_loop) in lws_uv_getloop()
339 return pt_to_priv_uv(&context->pt[tsi])->io_loop; in lws_uv_getloop()
383 while (budget-- && (m = uv_run(pt_to_priv_uv(pt)->io_loop, in elops_destroy_context1_uv()
407 if (!pt->event_loop_foreign && pt_to_priv_uv(pt)->io_loop) { in elops_destroy_context2_uv()
410 uv_stop(pt_to_priv_uv(pt)->io_loop); in elops_destroy_context2_uv()
413 uv_loop_close(pt_to_priv_uv(pt)->io_loop); in elops_destroy_context2_uv()
415 lws_free_set_NULL(pt_to_priv_uv(pt)->io_loop); in elops_destroy_context2_uv()
514 n = uv_poll_init(pt_to_priv_uv(pt)->io_loop, w_read->pwatcher, in elops_accept_uv()
[all …]
|
| D | private-lib-event-libs-libuv.h | 55 uv_loop_t *io_loop; member
|
| /third_party/libwebsockets/lib/event-libs/sdevent/ |
| D | sdevent.c | 11 struct sd_event *io_loop; member
165 if (!pt_to_priv_sd(pt)->io_loop || in io_sd()
222 sd_event_add_io(pt_to_priv_sd(pt)->io_loop, in init_vhost_listen_wsi_sd()
256 if (!ptpriv->io_loop) { in init_pt_sd()
269 ptpriv->io_loop = loop; in init_pt_sd()
341 sd_event_add_io(pt_to_priv_sd(pt)->io_loop, in sock_accept_sd()
348 sd_event_add_io(pt_to_priv_sd(pt)->io_loop, in sock_accept_sd()
364 if (ptpriv->io_loop) in run_pt_sd()
365 sd_event_run(ptpriv->io_loop, (uint64_t) -1); in run_pt_sd()
400 if (ptpriv->io_loop) { in destroy_pt_sd()
[all …]
|
| /third_party/libwebsockets/minimal-examples/http-server/minimal-http-server-eventlib-custom/ |
| D | minimal-http-server.c | 186 custom_poll_ctx_t *io_loop; member
203 priv->io_loop = (custom_poll_ctx_t *)_loop; in init_pt_custom()
214 return custom_poll_add_fd(priv->io_loop, lws_get_socket_fd(wsi), POLLIN); in sock_accept_custom()
238 custom_poll_change_fd(priv->io_loop, lws_get_socket_fd(wsi), in io_custom()
247 return custom_poll_del_fd(priv->io_loop, lws_get_socket_fd(wsi)); in wsi_logical_close_custom()
|
| /third_party/libwebsockets/lib/event-libs/ |
| D | README.md | 106 uv_loop_t *io_loop;
|
| /third_party/nghttp2/python/ |
| D | nghttp2.pyx | 1637 def io_loop(self): member in HTTP2Client
|