| /dports/net/libwebsockets/libwebsockets-v4.2.2/lib/core-net/ |
| H A D | close.c | 137 if (wsi->a.vhost && wsi->a.vhost->lserv_wsi == wsi) in __lws_reset_wsi()
227 lws_sul_debug_zombies(wsi->a.context, wsi, sizeof(wsi), __func__); in __lws_free_wsi()
282 wsi->a.protocol->callback(wsi, in lws_inform_client_conn_fail()
347 if (wsi == context->async_dns.wsi) in __lws_close_free_wsi()
385 wsi->a.protocol->callback(wsi, wsi->role_ops->close_cb[0], in __lws_close_free_wsi()
488 if (!wsi->told_user_closed && wsi->user_space && wsi->a.protocol && in __lws_close_free_wsi()
490 wsi->a.protocol->callback(wsi, in __lws_close_free_wsi()
520 lws_wsi_tag(wsi), wsi->desc.sockfd); in __lws_close_free_wsi()
563 wsi->a.protocol->callback(wsi, in __lws_close_free_wsi()
655 lws_wsi_tag(wsi), wsi->desc.sockfd); in __lws_close_free_wsi()
[all …]
|
| H A D | wsi.c | 30 if (!wsi) in lws_wsi_tag()
109 if (!wsi) in lws_get_network_wsi()
121 wsi = wsi->mux.parent_wsi; in lws_get_network_wsi()
236 wsi->evlib_wsi = (uint8_t *)wsi + sizeof(*wsi); in __lws_wsi_create_with_role()
344 if (lwsi_role_h2(wsi) || wsi->mux_substream || in lws_rx_flow_control()
435 if (lwsi_role_h2(wsi) || wsi->mux_substream || in __lws_rx_flow_control()
1118 wsi->a.protocol->callback(wsi, in lws_bind_protocol()
1156 if (wsi->a.protocol->callback(wsi, wsi->role_ops->protocol_bind_cb[ in lws_bind_protocol()
1360 wsi = wsi->mux.child_list; in lws_wsi_mux_dump_waiting_children()
1364 lws_wsi_tag(wsi), wsi->mux.my_sid, lwsi_state(wsi), in lws_wsi_mux_dump_waiting_children()
[all …]
|
| H A D | pollfd.c | 39 if (!wsi) in _lws_change_pollfd()
161 wsi->a.vhost->protocols[0].callback(wsi, in _lws_change_pollfd()
205 tid = wsi->a.vhost->protocols[0].callback(wsi, in _lws_change_pollfd()
259 wsi ? wsi->position_in_fds_table : -1); in __dump_fds()
280 __func__, lws_wsi_tag(wsi), wsi->tsi, wsi->desc.sockfd, pt->fds_count); in __insert_wsi_socket_into_fds()
298 assert(wsi); in __insert_wsi_socket_into_fds()
301 assert(wsi->event_pipe || wsi->a.vhost || wsi == pt->context->netlink); in __insert_wsi_socket_into_fds()
303 assert(wsi->event_pipe || wsi->a.vhost); in __insert_wsi_socket_into_fds()
381 if (wsi->a.vhost && wsi->a.vhost->protocols && in __remove_wsi_socket_from_fds()
475 if (!wsi || (!wsi->a.protocol && !wsi->event_pipe) || in __lws_change_pollfd()
[all …]
|
| H A D | output.c | 56 lws_wsi_tag(wsi), lws_vh_tag(wsi->a.vhost), in lws_issue_raw()
57 wsi->a.protocol->name, wsi->role_ops->name, in lws_issue_raw()
72 lws_wsi_tag(wsi), lws_vh_tag(wsi->a.vhost), in lws_issue_raw()
88 if (wsi->buflist_out) { in lws_issue_raw()
100 if (!wsi->mux_substream && !lws_socket_is_valid(wsi->desc.sockfd)) in lws_issue_raw()
187 if (wsi->ws) in lws_issue_raw()
222 wsi->udp->sa46_pending = wsi->udp->sa46; in lws_issue_raw()
256 if (wsi->a.vhost) in lws_write()
301 if (wsi->a.vhost) in lws_ssl_capable_read_no_ssl()
316 if (wsi->a.vhost) in lws_ssl_capable_read_no_ssl()
[all …]
|
| H A D | dummy-callback.c | 122 if (!wsi->h1_ws_proxied || !wsi->parent) in lws_callback_ws_proxy()
140 if (wsi->parent) in lws_callback_ws_proxy()
149 proxy_header(wsi, wsi->parent, tmp, sizeof(tmp), in lws_callback_ws_proxy()
152 proxy_header(wsi, wsi->parent, tmp, sizeof(tmp), in lws_callback_ws_proxy()
155 proxy_header(wsi, wsi->parent, tmp, sizeof(tmp), in lws_callback_ws_proxy()
335 if (!n && wsi->http.cgi && wsi->http.cgi->lsp && in lws_callback_http_dummy()
346 if (wsi->http.cgi && wsi->http.cgi->cgi_transaction_over) { in lws_callback_http_dummy()
354 if ((wsi->http.cgi && wsi->http.cgi->cgi_transaction_over) || in lws_callback_http_dummy()
385 n = lws_write(wsi, wsi->http.pending_return_headers + in lws_callback_http_dummy()
690 if (!(wsi->http.cgi->explicitly_chunked && wsi->mux_substream) && in lws_callback_http_dummy()
[all …]
|
| H A D | wsi-timeout.c | 51 if (wsi->a.protocol && in lws_sul_hrtimer_cb()
52 wsi->a.protocol->callback(wsi, LWS_CALLBACK_TIMER, in lws_sul_hrtimer_cb()
61 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in __lws_set_timer_usecs()
91 lws_wsi_tag(wsi), wsi->pending_timeout, in lws_sul_wsitimeout_cb()
92 wsi->hdr_parsing_completed, wsi->http.ah, in lws_sul_wsitimeout_cb()
95 if (wsi->http.cgi) in lws_sul_wsitimeout_cb()
101 lws_wsi_tag(wsi), wsi->pending_timeout); in lws_sul_wsitimeout_cb()
132 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in __lws_set_timeout()
148 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_set_timeout()
184 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_set_timeout_us()
[all …]
|
| H A D | service.c | 32 n = wsi->role_ops->writeable_cb[lwsi_role_server(wsi)]; in lws_callback_as_writeable()
114 if (wsi->http.cgi) { in lws_handle_POLLOUT_event()
175 if (lwsi_role_client(wsi) && !wsi->hdr_parsing_completed && in lws_handle_POLLOUT_event()
198 lws_wsi_tag(wsi), in lws_handle_POLLOUT_event()
199 (unsigned long)wsi->wsistate, wsi->role_ops->name); in lws_handle_POLLOUT_event()
234 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_rxflow_cache()
452 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_buflist_aware_finished_consuming()
526 lws_wsi_tag(wsi), lws_is_flowcontrolled(wsi), in lws_service_do_ripe_rxflow()
628 struct lws *wsi; in lws_service_fd_tsi() local
650 if (!wsi) in lws_service_fd_tsi()
[all …]
|
| /dports/net/libwebsockets/libwebsockets-v4.2.2/lib/roles/ws/ |
| H A D | ops-ws.c | 147 if (((wsi->ws->opcode) & 8) && !wsi->ws->final) { in lws_ws_rx_sm()
180 wsi->ws->continuation_possible = !wsi->ws->final; in lws_ws_rx_sm()
218 if ((!(wsi->ws->opcode & 8)) && wsi->ws->final) { in lws_ws_rx_sm()
400 c ^ wsi->ws->mask[(wsi->ws->mask_idx++) & 3]; in lws_ws_rx_sm()
498 wsi->a.protocol->callback, wsi, in lws_ws_rx_sm()
671 wsi->ws->final && wsi->ws->utf8 in lws_ws_rx_sm()
715 wsi->a.protocol->callback, wsi, in lws_ws_rx_sm()
1102 __func__, wsi, wsi->rxflow_bitmap); in rops_handle_POLLIN_ws()
1303 wsi->ws->ping_payload_len, lws_wsi_tag(wsi)); in rops_handle_POLLOUT_ws()
1328 wsi->role_ops->name, wsi->a.protocol->name, in rops_handle_POLLOUT_ws()
[all …]
|
| H A D | client-parser-ws.c | 148 if ((!(wsi->ws->opcode & 8)) && wsi->ws->final) { in lws_ws_client_rx_sm()
153 if ((wsi->ws->opcode & 8) && !wsi->ws->final) { in lws_ws_client_rx_sm()
163 wsi->ws->frame_is_binary = wsi->ws->opcode == in lws_ws_client_rx_sm()
340 if (wsi->ws->this_frame_masked && !wsi->ws->all_zero_nonce) in lws_ws_client_rx_sm()
341 c ^= wsi->ws->mask[(wsi->ws->mask_idx++) & 3]; in lws_ws_client_rx_sm()
348 wsi->ws->rx_ubuf[LWS_PRE + (wsi->ws->rx_ubuf_head++)] = c; in lws_ws_client_rx_sm()
418 wsi->a.protocol->callback, wsi, in lws_ws_client_rx_sm()
468 wsi->ws->ping_payload_len = (uint8_t)wsi->ws->rx_ubuf_head; in lws_ws_client_rx_sm()
575 if (wsi->ws->check_utf8 && !wsi->ws->defeat_check_utf8) { in lws_ws_client_rx_sm()
588 wsi->ws->final && wsi->ws->utf8 in lws_ws_client_rx_sm()
[all …]
|
| H A D | server-ws.c | 138 m = (wsi->a.protocol->callback)(wsi, in lws_extension_server_handshake()
158 wsi->ws->active_extensions[wsi->ws->count_act_ext] = ext; in lws_extension_server_handshake()
162 if (ext->callback(lws_get_context(wsi), ext, wsi, in lws_extension_server_handshake()
335 wsi->ws = lws_zalloc(sizeof(*wsi->ws), "ws struct"); in lws_process_ws_upgrade2()
355 if ((wsi->a.protocol->callback)(wsi, in lws_process_ws_upgrade2()
397 if (handshake_0405(wsi->a.context, wsi)) { in lws_process_ws_upgrade2()
559 lws_bind_protocol(wsi, &wsi->a.vhost->protocols[n], in lws_process_ws_upgrade()
704 if (wsi->proxied_ws_parent && wsi->child_list) in handshake_0405()
852 mask[n] = wsi->ws->mask[(wsi->ws->mask_idx + n) & 3]; in lws_ws_frame_rest_is_payload()
872 wsi->ws->mask_idx = (wsi->ws->mask_idx + avail) & 3; in lws_ws_frame_rest_is_payload()
[all …]
|
| H A D | client-ws.c | 52 wsi->ws = lws_zalloc(sizeof(*wsi->ws), "client ws struct"); in lws_create_client_ws_object()
53 if (!wsi->ws) { in lws_create_client_ws_object()
185 n = wsi->a.vhost->protocols[0].callback(wsi, in lws_generate_client_ws_handshake()
355 wsi->a.protocol = &wsi->a.vhost->protocols[0]; in lws_client_ws_upgrade()
398 wsi->a.protocol = &wsi->a.vhost->protocols[n]; in lws_client_ws_upgrade()
416 if (wsi->a.protocol && strcmp(wsi->a.protocol->name, in lws_client_ws_upgrade()
418 wsi->a.protocol = &wsi->a.vhost->protocols[n]; in lws_client_ws_upgrade()
521 if (ext->callback(lws_get_context(wsi), ext, wsi, in lws_client_ws_upgrade()
570 if (ext->callback(lws_get_context(wsi), ext, wsi, in lws_client_ws_upgrade()
572 wsi->ws->act_ext_user[wsi->ws->count_act_ext], in lws_client_ws_upgrade()
[all …]
|
| /dports/net/libwebsockets/libwebsockets-v4.2.2/lib/roles/http/client/ |
| H A D | client-http.c | 684 if (wsi->a.protocol->callback(wsi, in lws_client_interpret_server_handshake()
897 if (wsi->a.protocol->callback(wsi, in lws_client_interpret_server_handshake()
919 if (wsi->a.protocol->callback(wsi, in lws_client_interpret_server_handshake()
933 if (wsi->a.protocol->callback(wsi, in lws_client_interpret_server_handshake()
1207 if (wsi->a.protocol->callback(wsi, in lws_generate_client_handshake()
1415 if (wsi->chunked && !wsi->chunk_remaining) in lws_http_client_read()
1460 if (wsi->chunked && wsi->chunk_remaining) in lws_http_client_read()
1470 if (wsi->chunked && !wsi->chunk_remaining) in lws_http_client_read()
1543 pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_client_reset()
1661 if (wsi->a.protocol && wsi->role_ops && wsi->protocol_bind_balance) { in lws_client_reset()
[all …]
|
| /dports/net/libwebsockets/libwebsockets-v4.2.2/lib/roles/h1/ |
| H A D | ops-h1.c | 167 n = (unsigned int)wsi->a.protocol->callback(wsi, in lws_read_h1()
181 if (lwsi_role_h2(wsi) && !wsi->http.content_length_given) { in lws_read_h1()
236 lws_wsi_tag(wsi), wsi->a.protocol->name); in lws_read_h1()
238 n = (unsigned int)wsi->a.protocol->callback(wsi, in lws_read_h1()
266 if (lwsi_role_ws(wsi) && lwsi_role_server(wsi) && in lws_read_h1()
373 if (!wsi->http.ah && lws_header_table_attach(wsi, 0)) { in lws_h1_server_socket_service()
440 if (lwsi_role_h2(wsi) && lwsi_state(wsi) != LRS_BODY) in lws_h1_server_socket_service()
880 if (ah->in_use && ah->wsi == wsi) { in rops_destroy_role_h1()
951 wsi->a.protocol = &wsi->a.vhost->protocols[ in rops_adoption_bind_h1()
954 wsi->a.protocol = &wsi->a.vhost->protocols[0]; in rops_adoption_bind_h1()
[all …]
|
| /dports/net/libwebsockets/libwebsockets-v4.2.2/lib/core-net/client/ |
| H A D | connect3.c | 192 return wsi;
209 return wsi;
248 memset(&wsi->sa46_peer, 0, sizeof(wsi->sa46_peer));
351 wsi->c_pri, wsi->flags))
359 if (wsi->a.context->event_loop_ops->sock_accept(wsi))
363 if (__insert_wsi_socket_into_fds(wsi->a.context, wsi)) {
384 wsi->a.protocol = &wsi->a.vhost->protocols[0];
393 m = lws_socket_bind(wsi->a.vhost, wsi, wsi->desc.sockfd,
547 return wsi;
590 wsi->a.protocol->callback(wsi, LWS_CALLBACK_WSI_CREATE,
[all …]
|
| H A D | connect4.c | 96 wsi->c_port = (uint16_t)wsi->a.vhost->http.http_proxy_port; in lws_client_connect_4_established()
109 wsi->conn_port = wsi->c_port; in lws_client_connect_4_established()
112 return wsi; in lws_client_connect_4_established()
127 return wsi; in lws_client_connect_4_established()
165 __func__, wsi->lc.gutag, wsi->role_ops->name, in lws_client_connect_4_established()
166 wsi->a.protocol->name, rawish, wsi->a.vhost->name, in lws_client_connect_4_established()
212 __func__, wsi->lc.gutag, lwsi_state(wsi)); in lws_client_connect_4_established()
232 wsi->a.protocol->callback, wsi, in lws_client_connect_4_established()
278 return wsi; in lws_client_connect_4_established()
284 return wsi; in lws_client_connect_4_established()
[all …]
|
| H A D | connect.c | 47 return wsi; in lws_http_client_connect_via_info2()
49 wsi->a.opaque_user_data = wsi->stash->opaque_user_data; in lws_http_client_connect_via_info2()
253 wsi->a.protocol = &wsi->a.vhost->protocols[0]; in lws_client_connect_via_info()
278 __func__, lws_wsi_tag(wsi), wsi->role_ops->name, in lws_client_connect_via_info()
337 memset(wsi->stash, 0, sizeof(*wsi->stash)); in lws_client_connect_via_info()
443 lws_wsi_tag(wsi), wsi->role_ops->adoption_cb[0], in lws_client_connect_via_info()
444 wsi->role_ops->name, wsi->a.protocol->name); in lws_client_connect_via_info()
446 wsi->a.protocol->callback(wsi, wsi->role_ops->adoption_cb[0], in lws_client_connect_via_info()
493 wsi = lws_http_client_connect_via_info2(wsi); in lws_client_connect_via_info()
496 if (wsi) in lws_client_connect_via_info()
[all …]
|
| H A D | connect2.c | 48 if (wsi->ipv6) { in lws_getaddrinfo46()
148 return wsi;
193 if (wsi->a.protocol->callback(wsi,
203 return wsi;
227 if (wsi->stash && wsi->stash->cis[CIS_HOST])
267 if (wsi->stash)
290 wsi->ipv6 = LWS_IPV6_ENABLED(wsi->a.vhost);
292 if (wsi->stash)
372 n = lws_async_dns_query(wsi->a.context, wsi->tsi, ads,
374 wsi, NULL);
[all …]
|
| /dports/net/libwebsockets/libwebsockets-v4.2.2/lib/roles/h2/ |
| H A D | ops-h2.c | 171 if (wsi->mux_substream || wsi->upgraded_to_http2) { in rops_handle_POLLIN_h2()
238 if (lwsi_role_http(wsi) && lwsi_role_client(wsi) && in rops_handle_POLLIN_h2()
400 if (!lwsi_role_ws(wsi) && !wsi->mux_stream_immortal && in rops_write_role_protocol_h2()
632 if (ah->in_use && ah->wsi == wsi) { in rops_destroy_role_h2()
646 if (wsi->upgraded_to_http2 || wsi->mux_substream) { in rops_destroy_role_h2()
666 wsi, in rops_close_kill_connection_h2()
673 if (wsi->mux_substream && wsi->h2_stream_carries_ws) in rops_close_kill_connection_h2()
683 if (wsi->upgraded_to_http2 || wsi->mux_substream in rops_close_kill_connection_h2()
746 if (wsi->upgraded_to_http2 && !wsi->h2.h2n->pps && in rops_callback_on_writable_h2()
840 (int)wsi->wsistate, wsi->a.protocol->name); in lws_h2_bind_for_post_before_action()
[all …]
|
| /dports/net/libwebsockets/libwebsockets-v4.2.2/lib/roles/http/server/ |
| H A D | server.c | 356 if (wsi) in _lws_vhost_init_server()
1089 bar = wsi->a.protocol->callback(wsi, in lws_check_basic_auth()
1714 n = (unsigned int)wsi->a.protocol->callback(wsi, in lws_http_action()
1836 wsi->upgraded_to_http2, wsi->mux_substream); in lws_http_action()
1868 lws_wsi_tag(wsi), (int)wsi->wsistate); in lws_http_action()
2022 if (wsi->role_ops->rx_cb[lwsi_role_server(wsi)]) in lws_http_to_fallback()
2475 lws_wsi_tag(wsi), (int)wsi->wsistate, wsi->buflist); in lws_http_transaction_completed()
2796 if (wsi->cache_secs && wsi->cache_reuse) { in lws_serve_http_file()
2916 if (wsi->http.filepos == wsi->http.filelen) in lws_serve_http_file_fragment()
2933 wsi->http.filepos = wsi->http.range.start; in lws_serve_http_file_fragment()
[all …]
|
| /dports/net/libwebsockets/libwebsockets-v4.2.2/lib/roles/mqtt/ |
| H A D | ops-mqtt.c | 37 (unsigned int)wsi->wsistate, wsi->a.protocol->name, in rops_handle_POLLIN_mqtt()
217 lws_bind_protocol(wsi, wsi->a.protocol, __func__);
221 &wsi->a.vhost->protocols[wsi->a.vhost->mqtt_protocol_index],
236 if (!wsi->user_space && wsi->stash->cis[CIS_METHOD]) in rops_client_bind_mqtt()
240 if (!wsi->stash->cis[CIS_METHOD] && !wsi->stash->cis[CIS_ALPN]) in rops_client_bind_mqtt()
283 if (wsi->mqtt && wsi->mqtt->send_pingreq && !wsi->mqtt->inside_payload) { in rops_handle_POLLOUT_mqtt()
306 wsi = lws_get_network_wsi(wsi); in rops_handle_POLLOUT_mqtt()
316 if (!wsi->mqtt) in rops_handle_POLLOUT_mqtt()
422 if (!wsi->mqtt) in rops_close_role_mqtt()
489 if (wsi->upgraded_to_http2 && !wsi->h2.h2n->pps && in rops_callback_on_writable_mqtt()
[all …]
|
| /dports/net/libwebsockets/libwebsockets-v4.2.2/lib/roles/cgi/ |
| H A D | cgi-server.c | 107 lws_sul_schedule(wsi->a.context, wsi->tsi, &wsi->http.cgi->sul_grace, in lws_cgi_reap_cb()
127 wsi->http.cgi = lws_zalloc(sizeof(*wsi->http.cgi), "new cgi"); in lws_cgi()
136 cgi->wsi = wsi; /* set cgi's owning wsi */ in lws_cgi()
428 n = user_callback_handle_rxflow(wsi->a.protocol->callback, wsi, in lws_cgi()
666 wsi->http.cgi->headers_pos = wsi->http.cgi->headers_start; in lws_cgi_write_split_stdout_headers()
667 wsi->http.cgi->headers_dumped = wsi->http.cgi->headers_pos; in lws_cgi_write_split_stdout_headers()
700 wsi->http.cgi->match[1], wsi->hdr_state); in lws_cgi_write_split_stdout_headers()
714 wsi->http.cgi->l[wsi->http.cgi->lp++] = c; in lws_cgi_write_split_stdout_headers()
715 wsi->http.cgi->l[wsi->http.cgi->lp] = '\0'; in lws_cgi_write_split_stdout_headers()
825 m = !wsi->http.cgi->implied_chunked && !wsi->mux_substream && in lws_cgi_write_split_stdout_headers()
[all …]
|
| /dports/net/libwebsockets/libwebsockets-v4.2.2/lib/tls/mbedtls/ |
| H A D | mbedtls-ssl.c | 51 if (!wsi->tls.ssl) in lws_ssl_capable_read()
103 if (wsi->a.vhost) in lws_ssl_capable_read()
120 if (wsi->a.vhost) in lws_ssl_capable_read()
134 if (!wsi->tls.ssl) in lws_ssl_capable_read()
154 if (!wsi->tls.ssl) in lws_ssl_pending()
175 if (!wsi->tls.ssl) in lws_ssl_capable_write()
181 if (wsi->a.vhost) in lws_ssl_capable_write()
208 if (wsi->a.vhost) in lws_ssl_capable_write()
221 struct lws *wsi; in lws_ssl_info_callback() local
231 if (!wsi) in lws_ssl_info_callback()
[all …]
|
| /dports/net/libwebsockets/libwebsockets-v4.2.2/lib/roles/http/ |
| H A D | parsers.c | 118 assert(ah->wsi == wsi); in __lws_header_table_reset()
136 pt = &wsi->a.context->pt[(int)wsi->tsi]; in __lws_header_table_reset()
220 lws_wsi_tag(wsi), (void *)wsi->http.ah, wsi->tsi, in lws_header_table_attach()
265 wsi->http.ah->wsi = wsi; /* mark our owner */ in lws_header_table_attach()
321 lws_wsi_tag(wsi), (void *)ah, wsi->tsi, in __lws_header_table_detach()
343 memset(&wsi->http.ah, 0, sizeof(wsi->http.ah)); in __lws_header_table_detach()
387 ah->wsi = wsi; /* new owner */ in __lws_header_table_detach()
607 if (!wsi->http.ah || wsi->mux_substream) in lws_hdr_custom_length()
633 if (!wsi->http.ah || wsi->mux_substream) in lws_hdr_custom_copy()
723 wsi->http.ah->frags[wsi->http.ah->nfrag].offset = wsi->http.ah->pos; in lws_hdr_simple_create()
[all …]
|
| H A D | header.c | 74 if (lws_wsi_is_h2(wsi)) in lws_add_http_header_by_name()
78 (void)wsi; in lws_add_http_header_by_name()
102 if (lws_wsi_is_h2(wsi)) in lws_finalize_http_header()
105 (void)wsi; in lws_finalize_http_header()
141 if (lws_wsi_is_h2(wsi)) in lws_add_http_header_by_token()
207 !wsi->http.lcs && in lws_add_http_common_headers()
217 if (!wsi->mux_substream && wsi->http.lcs) { in lws_add_http_common_headers()
421 if (!wsi->a.vhost) { in lws_return_http_status()
560 (void)wsi; in lws_http_compression_apply()
584 struct lws *wsi; in lws_sul_http_ah_lifecheck() local
[all …]
|
| /dports/net/libwebsockets/libwebsockets-v4.2.2/lib/roles/raw-skt/ |
| H A D | ops-raw-skt.c | 56 if (!lwsi_role_client(wsi) && lwsi_state(wsi) != LRS_ESTABLISHED) { in rops_handle_POLLIN_raw_skt()
59 (int)wsi->wsistate); in rops_handle_POLLIN_raw_skt()
76 lws_wsi_tag(wsi), lwsi_state(wsi)); in rops_handle_POLLIN_raw_skt()
123 if (wsi->unix_skt) in rops_handle_POLLIN_raw_skt()
229 wsi->udp = lws_malloc(sizeof(*wsi->udp), "udp struct"); in rops_adoption_bind_raw_skt()
230 if (!wsi->udp) in rops_adoption_bind_raw_skt()
232 memset(wsi->udp, 0, sizeof(*wsi->udp)); in rops_adoption_bind_raw_skt()
240 lws_bind_protocol(wsi, wsi->a.protocol, __func__); in rops_adoption_bind_raw_skt()
243 lws_bind_protocol(wsi, in rops_adoption_bind_raw_skt()
244 &wsi->a.vhost->protocols[wsi->a.vhost->raw_protocol_index], in rops_adoption_bind_raw_skt()
[all …]
|