| /third_party/libwebsockets/lib/plat/windows/ |
| D | windows-service.c | 32 _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()
44 m = lws_service_fd_tsi(context, &pt->fds[n], tsi); in _lws_plat_service_forced_tsi()
60 _lws_plat_service_tsi(struct lws_context *context, int timeout_ms, int tsi) in _lws_plat_service_tsi() argument
73 pt = &context->pt[tsi]; in _lws_plat_service_tsi()
95 context->event_loop_ops->run_pt(context, tsi); in _lws_plat_service_tsi()
147 if (_lws_plat_service_forced_tsi(context, tsi)) in _lws_plat_service_tsi()
154 if (!lws_service_adjust_timeout(context, 1, tsi)) in _lws_plat_service_tsi()
176 lws_service_fd_tsi(context, &pt->fds[n], tsi); in _lws_plat_service_tsi()
|
| D | windows-pipe.c | 38 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()
|
| D | windows-spawn.c | 52 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()
|
| /third_party/libwebsockets/lib/event-libs/libuv/ |
| D | libuv.c | 97 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi]; in lws_io_cb()
147 lws_service_fd_tsi(context, &eventfd, wsi->tsi); in lws_io_cb()
264 int tsi = (int)(pt - &context->pt[0]); in lws_uv_close_cb_sa() local
268 tsi, in lws_uv_close_cb_sa()
293 lwsl_cx_info(context, "thr %d: seen final static handle gone", tsi); in lws_uv_close_cb_sa()
311 int tsi) in lws_libuv_static_refcount_add() argument
313 struct lws_context_per_thread *pt = &context->pt[tsi]; in lws_libuv_static_refcount_add()
329 lws_libuv_stop_without_kill(const struct lws_context *context, int tsi) in lws_libuv_stop_without_kill() argument
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()
[all …]
|
| /third_party/libwebsockets/lib/plat/unix/ |
| D | unix-service.c | 37 _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()
|
| D | unix-pipe.c | 33 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()
|
| D | unix-spawn.c | 58 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/lib/event-libs/libev/ |
| D | libev.c | 115 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()
[all …]
|
| /third_party/libwebsockets/lib/event-libs/libevent/ |
| D | libevent.c | 141 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])->io_loop) in elops_run_pt_event()
[all …]
|
| /third_party/libwebsockets/include/libwebsockets/ |
| D | lws-service.h | 65 lws_service_tsi(struct lws_context *context, int timeout_ms, int tsi);
133 int tsi);
153 lws_service_adjust_timeout(struct lws_context *context, int timeout_ms, int tsi);
187 lws_uv_getloop(struct lws_context *context, int tsi);
191 int tsi);
|
| D | lws-eventlib-exports.h | 51 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);
|
| D | lws-timeout-timer.h | 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/ |
| D | service.c | 29 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()
[all …]
|
| D | sorted-usec-list.c | 77 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()
272 lws_sul_schedule(struct lws_context *ctx, int tsi, lws_sorted_usec_list_t *sul, in lws_sul_schedule() argument
275 struct lws_context_per_thread *_pt = &ctx->pt[tsi]; in lws_sul_schedule()
286 lws_sul2_schedule(ctx, tsi, LWSSULLI_MISS_IF_SUSPENDED, sul); in lws_sul_schedule()
293 lws_sul_schedule_wakesuspend(struct lws_context *ctx, int tsi, in lws_sul_schedule_wakesuspend() argument
297 struct lws_context_per_thread *_pt = &ctx->pt[tsi]; in lws_sul_schedule_wakesuspend()
308 lws_sul2_schedule(ctx, tsi, LWSSULLI_WAKE_IF_SUSPENDED, sul); in lws_sul_schedule_wakesuspend()
|
| D | wsi-timeout.c | 57 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()
209 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_validity_cb()
251 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in _lws_validity_confirmed_role()
|
| D | adopt.c | 79 new_wsi->tsi = (char)n; in lws_create_new_server_wsi()
81 vhost->name, new_wsi->tsi); in lws_create_new_server_wsi()
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()
618 if (lws_service_fd_tsi(wsi->a.context, pfd, wsi->tsi)) in adopt_socket_readbuf()
|
| /third_party/libwebsockets/lib/event-libs/glib/ |
| D | glib.c | 138 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()
[all …]
|
| /third_party/libwebsockets/lib/event-libs/uloop/ |
| D | uloop.c | 117 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/sdevent/ |
| D | sdevent.c | 96 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/plat/optee/ |
| D | network.c | 90 _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/plat/freertos/ |
| D | freertos-pipe.c | 30 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()
|
| D | freertos-service.c | 41 _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()
|
| /third_party/libwebsockets/lib/secure-streams/ |
| D | secure-streams.c | 527 struct lws_context_per_thread *pt = &h->context->pt[h->tsi]; in lws_ss_set_timeout_us()
543 lws_service_assert_loop_thread(h->context, h->tsi); in _lws_ss_backoff()
604 lws_service_assert_loop_thread(h->context, h->tsi); in lws_smd_ss_cb()
632 lws_service_assert_loop_thread(h->context, h->tsi); in lws_ss_smd_tx_cb()
677 lws_service_assert_loop_thread(h->context, h->tsi); in _lws_ss_client_connect()
921 lws_service_assert_loop_thread(h->context, h->tsi); in lws_ss_client_connect()
937 lws_ss_create(struct lws_context *context, int tsi, const lws_ss_info_t *ssi, in lws_ss_create() argument
941 struct lws_context_per_thread *pt = &context->pt[tsi]; in lws_ss_create()
951 lws_service_assert_loop_thread(context, tsi); in lws_ss_create()
1068 h->tsi = (uint8_t)tsi; in lws_ss_create()
[all …]
|
| /third_party/libwebsockets/lib/event-libs/poll/ |
| D | poll.c | 29 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()
|
| /third_party/curl/lib/ |
| D | getinfo.c | 532 struct curl_tlssessioninfo *tsi = &data->tsi; in getinfo_slist() local
537 *tsip = tsi; in getinfo_slist()
538 tsi->backend = Curl_ssl_backend(); in getinfo_slist()
539 tsi->internals = NULL; in getinfo_slist()
542 if(conn && tsi->backend != CURLSSLBACKEND_NONE) { in getinfo_slist()
543 tsi->internals = Curl_ssl_get_internals(data, FIRSTSOCKET, info, 0); in getinfo_slist()
|