Home
last modified time | relevance | path

Searched refs:tsi (Results 1 - 25 of 97) sorted by relevance

1234

/third_party/libwebsockets/lib/plat/windows/
H A Dwindows-service.c32 _lws_plat_service_forced_tsi(struct lws_context *context, int tsi) in _lws_plat_service_forced_tsi() argument
34 struct lws_context_per_thread *pt = &context->pt[tsi]; in _lws_plat_service_forced_tsi()
37 r = lws_service_flag_pending(context, tsi); in _lws_plat_service_forced_tsi()
45 m = lws_service_fd_tsi(context, &pt->fds[n], tsi); in _lws_plat_service_forced_tsi()
61 _lws_plat_service_tsi(struct lws_context *context, int timeout_ms, int tsi) in _lws_plat_service_tsi() argument
74 pt = &context->pt[tsi]; in _lws_plat_service_tsi()
96 context->event_loop_ops->run_pt(context, tsi); in _lws_plat_service_tsi()
148 if (_lws_plat_service_forced_tsi(context, tsi)) in _lws_plat_service_tsi()
155 if (!lws_service_adjust_timeout(context, 1, tsi)) in _lws_plat_service_tsi()
177 lws_service_fd_tsi(context, &pt->fds[n], tsi); in _lws_plat_service_tsi()
[all...]
H A Dwindows-pipe.c38 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_plat_pipe_create()
97 lws_plat_pipe_signal(struct lws_context *ctx, int tsi) in lws_plat_pipe_signal() argument
99 struct lws_context_per_thread *pt = &ctx->pt[tsi]; in lws_plat_pipe_signal()
119 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_plat_pipe_close()
H A Dwindows-spawn.c52 lws_sul_schedule(lsp->info.vh->context, lsp->info.tsi, in lws_spawn_sul_reap()
65 lws_create_basic_wsi(struct lws_context *context, int tsi, in lws_create_basic_wsi() argument
68 struct lws_context_per_thread *pt = &context->pt[tsi]; in lws_create_basic_wsi()
74 if ((unsigned int)context->pt[tsi].fds_count == in lws_create_basic_wsi()
81 new_wsi = __lws_wsi_create_with_role(context, tsi, ops, NULL); in lws_create_basic_wsi()
182 lws_sul_schedule(lsp->info.vh->context, lsp->info.tsi, in lws_spawn_reap()
411 lsp->stdwsi[n] = lws_create_basic_wsi(i->vh->context, i->tsi, in lws_spawn_piped()
507 lws_sul_schedule(context, i->tsi, &lsp->sul, lws_spawn_timeout, in lws_spawn_piped()
523 lws_sul_schedule(context, i->tsi, &lsp->sul, in lws_spawn_piped()
563 lws_sul_schedule(lsp->info.vh->context, lsp->info.tsi, in lws_spawn_stdwsi_closed()
[all...]
/third_party/libwebsockets/lib/event-libs/libuv/
H A Dlibuv.c98 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi]; in lws_io_cb()
148 lws_service_fd_tsi(context, &eventfd, wsi->tsi); in lws_io_cb()
265 int tsi = (int)(pt - &context->pt[0]); in lws_uv_close_cb_sa() local
269 tsi, in lws_uv_close_cb_sa()
294 lwsl_cx_info(context, "thr %d: seen final static handle gone", tsi); in lws_uv_close_cb_sa()
312 int tsi) in lws_libuv_static_refcount_add()
314 struct lws_context_per_thread *pt = &context->pt[tsi]; in lws_libuv_static_refcount_add()
330 lws_libuv_stop_without_kill(const struct lws_context *context, int tsi) in lws_libuv_stop_without_kill() argument
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]) in lws_libuv_stop_without_kill()
311 lws_libuv_static_refcount_add(uv_handle_t *h, struct lws_context *context, int tsi) lws_libuv_static_refcount_add() argument
337 lws_uv_getloop(struct lws_context *context, int tsi) lws_uv_getloop() argument
644 elops_run_pt_uv(struct lws_context *context, int tsi) elops_run_pt_uv() argument
651 elops_destroy_pt_uv(struct lws_context *context, int tsi) elops_destroy_pt_uv() argument
717 elops_init_pt_uv(struct lws_context *context, void *_loop, int tsi) elops_init_pt_uv() argument
891 elops_foreign_thread_uv(struct lws_context *cx, int tsi) elops_foreign_thread_uv() argument
[all...]
/third_party/libwebsockets/lib/plat/unix/
H A Dunix-service.c37 _lws_plat_service_forced_tsi(struct lws_context *context, int tsi) in _lws_plat_service_forced_tsi() argument
39 struct lws_context_per_thread *pt = &context->pt[tsi]; in _lws_plat_service_forced_tsi()
42 r = lws_service_flag_pending(context, tsi); in _lws_plat_service_forced_tsi()
51 m = lws_service_fd_tsi(context, &pt->fds[n], tsi); in _lws_plat_service_forced_tsi()
72 _lws_plat_service_tsi(struct lws_context *context, int timeout_ms, int tsi) in _lws_plat_service_tsi() argument
96 pt = &context->pt[tsi]; in _lws_plat_service_tsi()
107 context->event_loop_ops->run_pt(context, tsi); in _lws_plat_service_tsi()
140 if (!lws_service_adjust_timeout(context, 1, tsi)) in _lws_plat_service_tsi()
216 if (_lws_plat_service_forced_tsi(context, tsi) < 0) in _lws_plat_service_tsi()
H A Dunix-pipe.c33 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_plat_pipe_create()
65 lws_plat_pipe_signal(struct lws_context *ctx, int tsi) in lws_plat_pipe_signal() argument
67 struct lws_context_per_thread *pt = &ctx->pt[tsi]; in lws_plat_pipe_signal()
85 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_plat_pipe_close()
H A Dunix-spawn.c58 lws_sul_schedule(lsp->info.vh->context, lsp->info.tsi, in lws_spawn_sul_reap()
71 lws_create_stdwsi(struct lws_context *context, int tsi, in lws_create_stdwsi() argument
74 struct lws_context_per_thread *pt = &context->pt[tsi]; in lws_create_stdwsi()
86 new_wsi = __lws_wsi_create_with_role(context, tsi, ops, NULL); in lws_create_stdwsi()
193 lws_sul_schedule(lsp->info.vh->context, lsp->info.tsi, in lws_spawn_reap()
378 lsp->stdwsi[n] = lws_create_stdwsi(i->vh->context, i->tsi, in lws_spawn_piped()
487 lws_sul_schedule(context, i->tsi, &lsp->sul, lws_spawn_timeout, in lws_spawn_piped()
495 lws_sul_schedule(context, i->tsi, &lsp->sul, in lws_spawn_piped()
601 lws_sul_schedule(lsp->info.vh->context, lsp->info.tsi, in lws_spawn_stdwsi_closed()
/third_party/libwebsockets/include/libwebsockets/
H A Dlws-service.h59 * \param tsi: Thread service index, starting at 0
65 lws_service_tsi(struct lws_context *context, int timeout_ms, int tsi);
127 * \param tsi: thread service index
133 int tsi);
140 * \param tsi: thread service index
153 lws_service_adjust_timeout(struct lws_context *context, int timeout_ms, int tsi);
176 * - lws_libuv_static_refcount_add(handle, context, tsi) to mark the handle with
187 lws_uv_getloop(struct lws_context *context, int tsi);
191 int tsi);
H A Dlws-eventlib-exports.h51 int (*init_pt)(struct lws_context *context, void *_loop, int tsi);
63 void (*run_pt)(struct lws_context *context, int tsi);
65 void (*destroy_pt)(struct lws_context *context, int tsi);
69 int (*foreign_thread)(struct lws_context *context, int tsi);
83 lws_evlib_tsi_to_evlib_pt(struct lws_context *ctx, int tsi);
114 _lws_plat_service_forced_tsi(struct lws_context *context, int tsi);
H A Dlws-timeout-timer.h177 * \param tsi: the thread service index (usually 0)
200 lws_sul2_schedule(struct lws_context *context, int tsi, int flags,
234 lws_sul_schedule(struct lws_context *ctx, int tsi, lws_sorted_usec_list_t *sul,
237 lws_sul_schedule_wakesuspend(struct lws_context *ctx, int tsi,
/third_party/libwebsockets/lib/core-net/
H A Dservice.c29 lws_service_assert_loop_thread(struct lws_context *cx, int tsi) in lws_service_assert_loop_thread() argument
35 if (!cx->event_loop_ops->foreign_thread(cx, tsi)) in lws_service_assert_loop_thread()
250 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_rxflow_cache()
297 lws_service_adjust_timeout(struct lws_context *context, int timeout_ms, int tsi) in lws_service_adjust_timeout() argument
309 if (!tsi && lws_smd_message_pending(context)) { in lws_service_adjust_timeout()
316 pt = &context->pt[tsi]; in lws_service_adjust_timeout()
475 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_buflist_aware_finished_consuming()
568 lws_service_flag_pending(struct lws_context *context, int tsi) in lws_service_flag_pending() argument
576 pt = &context->pt[tsi]; in lws_service_flag_pending()
598 service_flag_pending(context, tsi); in lws_service_flag_pending()
638 lws_service_fd_tsi(struct lws_context *context, struct lws_pollfd *pollfd, int tsi) lws_service_fd_tsi() argument
847 lws_service_tsi(struct lws_context *context, int timeout_ms, int tsi) lws_service_tsi() argument
[all...]
H A Dsorted-usec-list.c77 lws_sul2_schedule(struct lws_context *context, int tsi, int flags, in lws_sul2_schedule() argument
80 struct lws_context_per_thread *pt = &context->pt[tsi]; in lws_sul2_schedule()
278 lws_sul_schedule(struct lws_context *ctx, int tsi, lws_sorted_usec_list_t *sul, in lws_sul_schedule() argument
281 struct lws_context_per_thread *_pt = &ctx->pt[tsi]; in lws_sul_schedule()
292 lws_sul2_schedule(ctx, tsi, LWSSULLI_MISS_IF_SUSPENDED, sul); in lws_sul_schedule()
299 lws_sul_schedule_wakesuspend(struct lws_context *ctx, int tsi, in lws_sul_schedule_wakesuspend() argument
303 struct lws_context_per_thread *_pt = &ctx->pt[tsi]; in lws_sul_schedule_wakesuspend()
314 lws_sul2_schedule(ctx, tsi, LWSSULLI_WAKE_IF_SUSPENDED, sul); in lws_sul_schedule_wakesuspend()
H A Dwsi-timeout.c57 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in __lws_set_timer_usecs()
79 struct lws_context_per_thread *pt = &cx->pt[(int)wsi->tsi]; in lws_sul_wsitimeout_cb()
127 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in __lws_set_timeout()
142 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_set_timeout()
178 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_set_timeout_us()
202 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_validity_cb()
210 struct lws_context_per_thread *pt = &cx->pt[(int)wsi->tsi]; in lws_validity_cb()
252 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in _lws_validity_confirmed_role()
H A Dadopt.c79 new_wsi->tsi = (char)n; in lws_create_new_server_wsi()
80 lwsl_wsi_debug(new_wsi, "joining vh %s, tsi %d", in lws_create_new_server_wsi()
81 vhost->name, new_wsi->tsi); in lws_create_new_server_wsi()
132 * entirely different pt / tsi for load balancing. In that case as in __lws_adopt_descriptor_vhost1()
145 n = parent->tsi; in __lws_adopt_descriptor_vhost1()
161 pt = &context->pt[(int)new_wsi->tsi]; in __lws_adopt_descriptor_vhost1()
252 &new_wsi->a.context->pt[(int)new_wsi->tsi]; in lws_adopt_ss_server_accept()
278 if (lws_ss_create(new_wsi->a.context, new_wsi->tsi, in lws_adopt_ss_server_accept()
357 &new_wsi->a.context->pt[(int)new_wsi->tsi]; in lws_adopt_descriptor_vhost2()
586 pt = &wsi->a.context->pt[(int)wsi->tsi]; in adopt_socket_readbuf()
[all...]
/third_party/libwebsockets/lib/event-libs/libevent/
H A Dlibevent.c141 pt = &context->pt[(int)wsi->tsi]; in lws_event_cb()
145 lws_service_fd_tsi(context, &eventfd, wsi->tsi); in lws_event_cb()
181 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi]; in elops_listen_init_event()
196 elops_init_pt_event(struct lws_context *context, void *_loop, int tsi) in elops_init_pt_event() argument
199 struct lws_context_per_thread *pt = &context->pt[tsi]; in elops_init_pt_event()
207 context->pt[tsi].event_loop_foreign = 1; in elops_init_pt_event()
272 pt = &context->pt[(int)wsi->tsi]; in elops_accept_event()
291 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in elops_io_event()
326 elops_run_pt_event(struct lws_context *context, int tsi) in elops_run_pt_event() argument
329 if (pt_to_priv_event(&context->pt[tsi]) in elops_run_pt_event()
349 elops_destroy_pt_event(struct lws_context *context, int tsi) elops_destroy_pt_event() argument
[all...]
/third_party/libwebsockets/lib/event-libs/libev/
H A Dlibev.c115 pt = &context->pt[(int)wsi->tsi]; in lws_accept_cb()
118 lws_service_fd_tsi(context, &eventfd, (int)wsi->tsi); in lws_accept_cb()
141 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi]; in elops_listen_init_ev()
158 elops_init_pt_ev(struct lws_context *context, void *_loop, int tsi) in elops_init_pt_ev() argument
160 struct lws_context_per_thread *pt = &context->pt[tsi]; in elops_init_pt_ev()
175 context->pt[tsi].event_loop_foreign = 1; in elops_init_pt_ev()
188 if (!context->pt[tsi].event_loop_foreign) { in elops_init_pt_ev()
245 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi]; in elops_listen_destroy_ev()
255 elops_destroy_pt_ev(struct lws_context *context, int tsi) in elops_destroy_pt_ev() argument
257 struct lws_context_per_thread *pt = &context->pt[tsi]; in elops_destroy_pt_ev()
339 elops_run_pt_ev(struct lws_context *context, int tsi) elops_run_pt_ev() argument
[all...]
/third_party/libwebsockets/lib/plat/optee/
H A Dnetwork.c90 _lws_plat_service_tsi(struct lws_context *context, int timeout_ms, int tsi) in _lws_plat_service_tsi() argument
102 pt = &context->pt[tsi]; in _lws_plat_service_tsi()
123 if (lws_service_adjust_timeout(context, 1, tsi)) { in _lws_plat_service_tsi()
153 m = lws_service_flag_pending(context, tsi); in _lws_plat_service_tsi()
177 m = lws_service_fd_tsi(context, &pt->fds[n], tsi); in _lws_plat_service_tsi()
224 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi]; in lws_plat_insert_socket_into_fds()
233 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi]; in lws_plat_delete_socket_from_fds()
/third_party/libwebsockets/lib/event-libs/uloop/
H A Duloop.c117 pt = &context->pt[(int)wu->wsi->tsi]; in lws_uloop_cb()
121 lws_service_fd_tsi(context, &eventfd, wu->wsi->tsi); in lws_uloop_cb()
151 elops_init_pt_uloop(struct lws_context *context, void *v, int tsi) in elops_init_pt_uloop() argument
153 struct lws_context_per_thread *pt = &context->pt[tsi]; in elops_init_pt_uloop()
190 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in elops_io_uloop()
212 elops_run_pt_uloop(struct lws_context *context, int tsi) in elops_run_pt_uloop() argument
229 elops_destroy_pt_uloop(struct lws_context *context, int tsi) in elops_destroy_pt_uloop() argument
231 struct lws_context_per_thread *pt = &context->pt[tsi]; in elops_destroy_pt_uloop()
248 pt = &wsi->a.context->pt[(int)wsi->tsi]; in elops_destroy_wsi_uloop()
/third_party/libwebsockets/lib/event-libs/glib/
H A Dglib.c138 pt = &sub->wsi->a.context->pt[(int)sub->wsi->tsi]; in lws_glib_dispatch()
142 lws_service_fd_tsi(sub->wsi->a.context, &eventfd, sub->wsi->tsi); in lws_glib_dispatch()
264 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in elops_accept_glib()
307 elops_init_pt_glib(struct lws_context *context, void *_loop, int tsi) in elops_init_pt_glib() argument
309 struct lws_context_per_thread *pt = &context->pt[tsi]; in elops_init_pt_glib()
316 context->pt[tsi].event_loop_foreign = 1; in elops_init_pt_glib()
348 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in elops_io_glib()
388 elops_run_pt_glib(struct lws_context *context, int tsi) in elops_run_pt_glib() argument
390 struct lws_context_per_thread *pt = &context->pt[tsi]; in elops_run_pt_glib()
404 pt = &wsi->a.context->pt[(int)wsi->tsi]; in elops_destroy_wsi_glib()
433 elops_destroy_pt_glib(struct lws_context *context, int tsi) elops_destroy_pt_glib() argument
[all...]
/third_party/libwebsockets/lib/plat/freertos/
H A Dfreertos-pipe.c30 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_plat_pipe_create()
89 lws_plat_pipe_signal(struct lws_context *ctx, int tsi) in lws_plat_pipe_signal() argument
91 struct lws_context_per_thread *pt = &ctx->pt[tsi]; in lws_plat_pipe_signal()
117 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_plat_pipe_close()
H A Dfreertos-service.c41 _lws_plat_service_tsi(struct lws_context *context, int timeout_ms, int tsi) in _lws_plat_service_tsi() argument
53 pt = &context->pt[tsi]; in _lws_plat_service_tsi()
108 if (lws_service_adjust_timeout(context, 1, tsi)) { in _lws_plat_service_tsi()
193 m = lws_service_flag_pending(context, tsi); in _lws_plat_service_tsi()
203 m = lws_service_fd_tsi(context, &pt->fds[n], tsi); in _lws_plat_service_tsi()
H A Dfreertos-fds.c30 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi]; in lws_plat_insert_socket_into_fds()
39 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi]; in lws_plat_delete_socket_from_fds()
/third_party/libwebsockets/lib/event-libs/sdevent/
H A Dsdevent.c96 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi]; in sock_accept_handler()
123 lws_service_fd_tsi(context, &eventfd, wsi->tsi); in sock_accept_handler()
159 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in io_sd()
220 pt = &wsi->a.context->pt[(int)wsi->tsi]; in init_vhost_listen_wsi_sd()
246 init_pt_sd(struct lws_context *context, void *_loop, int tsi) in init_pt_sd() argument
248 struct lws_context_per_thread *pt = &context->pt[tsi]; in init_pt_sd()
338 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in sock_accept_sd()
359 run_pt_sd(struct lws_context *context, int tsi) in run_pt_sd() argument
361 struct lws_context_per_thread *pt = &context->pt[tsi]; in run_pt_sd()
379 destroy_pt_sd(struct lws_context *context, int tsi) in destroy_pt_sd() argument
[all...]
/third_party/libwebsockets/lib/secure-streams/
H A Dsecure-streams.c533 struct lws_context_per_thread *pt = &h->context->pt[h->tsi]; in lws_ss_set_timeout_us()
549 lws_service_assert_loop_thread(h->context, h->tsi); in _lws_ss_backoff()
610 lws_service_assert_loop_thread(h->context, h->tsi); in lws_smd_ss_cb()
638 lws_service_assert_loop_thread(h->context, h->tsi); in lws_ss_smd_tx_cb()
683 lws_service_assert_loop_thread(h->context, h->tsi); in _lws_ss_client_connect()
927 lws_service_assert_loop_thread(h->context, h->tsi); in lws_ss_client_connect()
943 lws_ss_create(struct lws_context *context, int tsi, const lws_ss_info_t *ssi, in lws_ss_create() argument
947 struct lws_context_per_thread *pt = &context->pt[tsi]; in lws_ss_create()
957 lws_service_assert_loop_thread(context, tsi); in lws_ss_create()
1074 h->tsi in lws_ss_create()
1829 lws_ss_assert_extant(struct lws_context *cx, int tsi, struct lws_ss_handle *h) lws_ss_assert_extant() argument
[all...]
/third_party/libwebsockets/lib/event-libs/poll/
H A Dpoll.c29 elops_foreign_thread_poll(struct lws_context *cx, int tsi) in elops_foreign_thread_poll() argument
31 struct lws_context_per_thread *pt = &cx->pt[tsi]; in elops_foreign_thread_poll()

Completed in 13 milliseconds

1234