Searched refs:io_loop (Results 1 - 8 of 8) sorted by relevance
| /third_party/libwebsockets/lib/event-libs/libev/ |
| H A 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...] |
| H A D | private-lib-event-libs-libev.h | 42 struct ev_loop *io_loop; member
|
| /third_party/libwebsockets/lib/event-libs/libuv/ |
| H A D | libuv.c | 285 // uv_walk(pt_to_priv_uv(pt)->io_loop, lws_uv_walk_cb, NULL); in lws_uv_close_cb_sa()
332 if (pt_to_priv_uv(&context->pt[tsi])->io_loop) in lws_libuv_stop_without_kill()
333 uv_stop(pt_to_priv_uv(&context->pt[tsi])->io_loop); in lws_libuv_stop_without_kill()
339 if (pt_to_priv_uv(&context->pt[tsi])->io_loop) in lws_uv_getloop()
340 return pt_to_priv_uv(&context->pt[tsi])->io_loop; in lws_uv_getloop()
384 while (budget-- && (m = uv_run(pt_to_priv_uv(pt)->io_loop, in elops_destroy_context1_uv()
408 if (!pt->event_loop_foreign && pt_to_priv_uv(pt)->io_loop) { in elops_destroy_context2_uv()
411 uv_stop(pt_to_priv_uv(pt)->io_loop); in elops_destroy_context2_uv()
414 uv_loop_close(pt_to_priv_uv(pt)->io_loop); in elops_destroy_context2_uv()
416 lws_free_set_NULL(pt_to_priv_uv(pt)->io_loop); in elops_destroy_context2_uv()
[all...] |
| H A D | private-lib-event-libs-libuv.h | 55 uv_loop_t *io_loop; member
|
| /third_party/libwebsockets/lib/event-libs/libevent/ |
| H A 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, NUL in elops_destroy_pt_event()
[all...] |
| H A D | private-lib-event-libs-libevent.h | 33 struct event_base *io_loop; member
|
| /third_party/libwebsockets/lib/event-libs/sdevent/ |
| H A 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/ |
| H A 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()
|
Completed in 4 milliseconds