Home
last modified time | relevance | path

Searched refs:wsi (Results 1 - 25 of 345) sorted by relevance

12345678910>>...14

/third_party/libwebsockets/lib/core-net/
H A Dclose.c40 __lws_reset_wsi(struct lws *wsi) in __lws_reset_wsi() argument
42 if (!wsi) in __lws_reset_wsi()
47 lws_free_set_NULL(wsi->cli_hostname_copy); in __lws_reset_wsi()
51 if (wsi->conmon.dns_results_copy) { in __lws_reset_wsi()
52 lws_conmon_addrinfo_destroy(wsi->conmon.dns_results_copy); in __lws_reset_wsi()
53 wsi->conmon.dns_results_copy = NULL; in __lws_reset_wsi()
56 wsi->conmon.ciu_dns = in __lws_reset_wsi()
57 wsi->conmon.ciu_sockconn = in __lws_reset_wsi()
58 wsi->conmon.ciu_tls = in __lws_reset_wsi()
59 wsi in __lws_reset_wsi()
206 __lws_free_wsi(struct lws *wsi) __lws_free_wsi() argument
272 lws_remove_child_from_any_parent(struct lws *wsi) lws_remove_child_from_any_parent() argument
306 lws_inform_client_conn_fail(struct lws *wsi, void *arg, size_t len) lws_inform_client_conn_fail() argument
326 lws_addrinfo_clean(struct lws *wsi) lws_addrinfo_clean() argument
346 __lws_close_free_wsi(struct lws *wsi, enum lws_close_status reason, const char *caller) __lws_close_free_wsi() argument
877 __lws_close_free_wsi_final(struct lws *wsi) __lws_close_free_wsi_final() argument
1008 lws_close_free_wsi(struct lws *wsi, enum lws_close_status reason, const char *caller) lws_close_free_wsi() argument
[all...]
H A Dwsi.c28 lws_wsi_tag(struct lws *wsi) in lws_wsi_tag() argument
30 if (!wsi) in lws_wsi_tag()
31 return "[null wsi]"; in lws_wsi_tag()
32 return lws_lc_tag(&wsi->lc); in lws_wsi_tag()
36 void lwsi_set_role(struct lws *wsi, lws_wsi_state_t role) in lwsi_set_role() argument
38 wsi->wsistate = (wsi->wsistate & (~LWSI_ROLE_MASK)) | role; in lwsi_set_role()
40 lwsl_wsi_debug(wsi, "state 0x%lx", (unsigned long)wsi->wsistate); in lwsi_set_role()
43 void lwsi_set_state(struct lws *wsi, lws_wsi_state_ argument
58 struct lws *wsi = (struct lws *)obj; lws_log_prepend_wsi() local
65 lws_vhost_bind_wsi(struct lws_vhost *vh, struct lws *wsi) lws_vhost_bind_wsi() argument
93 __lws_vhost_unbind_wsi(struct lws *wsi) __lws_vhost_unbind_wsi() argument
131 lws_get_network_wsi(struct lws *wsi) lws_get_network_wsi() argument
170 struct lws *wsi; lws_callback_all_protocol() local
189 lws_evlib_wsi_to_evlib_pt(struct lws *wsi) lws_evlib_wsi_to_evlib_pt() argument
212 struct lws *wsi; lws_callback_all_protocol_vhost_args() local
238 lws_callback_vhost_protocols(struct lws *wsi, int reason, void *in, size_t len) lws_callback_vhost_protocols() argument
257 struct lws *wsi = lws_container_of(s, struct lws, sul_fault_timedclose); lws_wsi_fault_timedclose_cb() local
266 lws_wsi_fault_timedclose(struct lws *wsi) lws_wsi_fault_timedclose() argument
294 struct lws *wsi; __lws_wsi_create_with_role() local
344 lws_wsi_inject_to_loop(struct lws_context_per_thread *pt, struct lws *wsi) lws_wsi_inject_to_loop() argument
371 lws_wsi_extract_from_loop(struct lws *wsi) lws_wsi_extract_from_loop() argument
393 struct lws *wsi = lws_zalloc(sizeof(*wsi), "fake wsi"); lws_callback_vhost_protocols_vhost() local
416 lws_rx_flow_control(struct lws *wsi, int _enable) lws_rx_flow_control() argument
475 struct lws *wsi; lws_rx_flow_allow_all_protocol() local
490 user_callback_handle_rxflow(lws_callback_function callback_function, struct lws *wsi, enum lws_callback_reasons reason, void *user, void *in, size_t len) user_callback_handle_rxflow() argument
507 __lws_rx_flow_control(struct lws *wsi) __lws_rx_flow_control() argument
560 lws_get_protocol(struct lws *wsi) lws_get_protocol() argument
567 lws_ensure_user_space(struct lws *wsi) lws_ensure_user_space() argument
589 lws_adjust_protocol_psds(struct lws *wsi, size_t new_size) lws_adjust_protocol_psds() argument
601 lws_get_tsi(struct lws *wsi) lws_get_tsi() argument
607 lws_is_ssl(struct lws *wsi) lws_is_ssl() argument
619 lws_get_ssl(struct lws *wsi) lws_get_ssl() argument
626 lws_has_buffered_out(struct lws *wsi) lws_has_buffered_out() argument
644 lws_partial_buffered(struct lws *wsi) lws_partial_buffered() argument
650 lws_get_peer_write_allowance(struct lws *wsi) lws_get_peer_write_allowance() argument
660 lws_role_transition(struct lws *wsi, enum lwsi_role role, enum lwsi_state state, const struct lws_role_ops *ops) lws_role_transition() argument
734 lws_get_urlarg_by_name_safe(struct lws *wsi, const char *name, char *buf, int len) lws_get_urlarg_by_name_safe() argument
771 lws_get_urlarg_by_name(struct lws *wsi, const char *name, char *buf, int len) lws_get_urlarg_by_name() argument
787 lws_extension_callback_pm_deflate(struct lws_context *context, const struct lws_extension *ext, struct lws *wsi, enum lws_extension_callback_reasons reason, void *user, void *in, size_t len) lws_extension_callback_pm_deflate() argument
805 lws_set_extension_option(struct lws *wsi, const char *ext_name, const char *opt_name, const char *opt_val) lws_set_extension_option() argument
813 lws_is_cgi(struct lws *wsi) lws_is_cgi() argument
881 lws_wsi_user(struct lws *wsi) lws_wsi_user() argument
887 lws_wsi_tsi(struct lws *wsi) lws_wsi_tsi() argument
894 lws_set_wsi_user(struct lws *wsi, void *data) lws_set_wsi_user() argument
904 lws_get_parent(const struct lws *wsi) lws_get_parent() argument
910 lws_get_child(const struct lws *wsi) lws_get_child() argument
916 lws_get_opaque_parent_data(const struct lws *wsi) lws_get_opaque_parent_data() argument
922 lws_set_opaque_parent_data(struct lws *wsi, void *data) lws_set_opaque_parent_data() argument
928 lws_get_opaque_user_data(const struct lws *wsi) lws_get_opaque_user_data() argument
934 lws_set_opaque_user_data(struct lws *wsi, void *data) lws_set_opaque_user_data() argument
940 lws_get_child_pending_on_writable(const struct lws *wsi) lws_get_child_pending_on_writable() argument
946 lws_clear_child_pending_on_writable(struct lws *wsi) lws_clear_child_pending_on_writable() argument
978 lws_get_socket_fd(struct lws *wsi) lws_get_socket_fd() argument
987 lws_vhost_get(struct lws *wsi) lws_vhost_get() argument
993 lws_get_vhost(struct lws *wsi) lws_get_vhost() argument
999 lws_protocol_get(struct lws *wsi) lws_protocol_get() argument
1006 lws_get_udp(const struct lws *wsi) lws_get_udp() argument
1013 lws_get_context(const struct lws *wsi) lws_get_context() argument
1019 lwsl_wsi_get_cx(struct lws *wsi) lwsl_wsi_get_cx() argument
1031 struct lws *wnew, *wsi = *_wsi; _lws_generic_transaction_completed_active_conn() local
1191 lws_raw_transaction_completed(struct lws *wsi) lws_raw_transaction_completed() argument
1214 lws_bind_protocol(struct lws *wsi, const struct lws_protocols *p, const char *reason) lws_bind_protocol() argument
1271 lws_http_close_immortal(struct lws *wsi) lws_http_close_immortal() argument
1297 lws_mux_mark_immortal(struct lws *wsi) lws_mux_mark_immortal() argument
1331 lws_http_mark_sse(struct lws *wsi) lws_http_mark_sse() argument
1348 lws_wsi_client_stash_item(struct lws *wsi, int stash_idx, int hdr_idx) lws_wsi_client_stash_item() argument
1366 lws_wsi_mux_insert(struct lws *wsi, struct lws *parent_wsi, unsigned int sid) lws_wsi_mux_insert() argument
1399 lws_wsi_mux_dump_children(struct lws *wsi) lws_wsi_mux_dump_children() argument
1416 lws_wsi_mux_close_children(struct lws *wsi, int reason) lws_wsi_mux_close_children() argument
1439 lws_wsi_mux_sibling_disconnect(struct lws *wsi) lws_wsi_mux_sibling_disconnect() argument
1462 lws_wsi_mux_dump_waiting_children(struct lws *wsi) lws_wsi_mux_dump_waiting_children() argument
1482 lws_wsi_mux_mark_parents_needing_writeable(struct lws *wsi) lws_wsi_mux_mark_parents_needing_writeable() argument
1538 lws_wsi_mux_action_pending_writeable_reqs(struct lws *wsi) lws_wsi_mux_action_pending_writeable_reqs() argument
1596 lws_wsi_tx_credit(struct lws *wsi, char peer_to_us, int add) lws_wsi_tx_credit() argument
1611 lws_wsi_txc_report_manual_txcr_in(struct lws *wsi, int32_t bump) lws_wsi_txc_report_manual_txcr_in() argument
1628 lws_wsi_mux_apply_queue(struct lws *wsi) lws_wsi_mux_apply_queue() argument
[all...]
H A Dwsi-timeout.c28 __lws_wsi_remove_from_sul(struct lws *wsi) in __lws_wsi_remove_from_sul() argument
30 lws_sul_cancel(&wsi->sul_timeout); in __lws_wsi_remove_from_sul()
31 lws_sul_cancel(&wsi->sul_hrtimer); in __lws_wsi_remove_from_sul()
32 lws_sul_cancel(&wsi->sul_validity); in __lws_wsi_remove_from_sul()
34 lws_sul_cancel(&wsi->sul_fault_timedclose); in __lws_wsi_remove_from_sul()
45 struct lws *wsi = lws_container_of(sul, struct lws, sul_hrtimer); in lws_sul_hrtimer_cb() local
47 if (wsi->a.protocol && in lws_sul_hrtimer_cb()
48 wsi->a.protocol->callback(wsi, LWS_CALLBACK_TIMER, in lws_sul_hrtimer_cb()
49 wsi in lws_sul_hrtimer_cb()
55 __lws_set_timer_usecs(struct lws *wsi, lws_usec_t us) __lws_set_timer_usecs() argument
65 lws_set_timer_usecs(struct lws *wsi, lws_usec_t usecs) lws_set_timer_usecs() argument
77 struct lws *wsi = lws_container_of(sul, struct lws, sul_timeout); lws_sul_wsitimeout_cb() local
125 __lws_set_timeout(struct lws *wsi, enum pending_timeout reason, int secs) __lws_set_timeout() argument
140 lws_set_timeout(struct lws *wsi, enum pending_timeout reason, int secs) lws_set_timeout() argument
176 lws_set_timeout_us(struct lws *wsi, enum pending_timeout reason, lws_usec_t us) lws_set_timeout_us() argument
201 struct lws *wsi = lws_container_of(sul, struct lws, sul_validity); lws_validity_cb() local
250 _lws_validity_confirmed_role(struct lws *wsi) _lws_validity_confirmed_role() argument
277 lws_validity_confirmed(struct lws *wsi) lws_validity_confirmed() argument
[all...]
H A Ddummy-callback.c32 proxy_header(struct lws *wsi, struct lws *par, unsigned char *temp, in proxy_header() argument
38 lwsl_wsi_debug(wsi, "no index %d:", index); in proxy_header()
44 lwsl_wsi_notice(wsi, "unable to copy par hdr idx %d (len %d)", in proxy_header()
49 lwsl_wsi_debug(wsi, "index %d: %s", index, (char *)temp); in proxy_header()
51 if (lws_add_http_header_by_token(wsi, (enum lws_token_indexes)index, temp, n, p, end)) { in proxy_header()
52 lwsl_wsi_notice(wsi, "unable to append par hdr idx %d (len %d)", in proxy_header()
61 stream_close(struct lws *wsi) in stream_close() argument
65 if (wsi->http.did_stream_close) in stream_close()
68 wsi->http.did_stream_close = 1; in stream_close()
70 if (wsi in stream_close()
110 lws_callback_ws_proxy(struct lws *wsi, enum lws_callback_reasons reason, void *user, void *in, size_t len) lws_callback_ws_proxy() argument
266 lws_callback_http_dummy(struct lws *wsi, enum lws_callback_reasons reason, void *user, void *in, size_t len) lws_callback_http_dummy() argument
[all...]
H A Doutput.c31 lws_issue_raw(struct lws *wsi, unsigned char *buf, size_t len) in lws_issue_raw() argument
33 struct lws_context *context = lws_get_context(wsi); in lws_issue_raw()
48 if (lwsi_state(wsi) == LRS_FLUSHING_BEFORE_CLOSE && in lws_issue_raw()
49 !lws_has_buffered_out(wsi) in lws_issue_raw()
51 && !wsi->http.comp_ctx.may_have_more in lws_issue_raw()
56 if (buf && lws_has_buffered_out(wsi)) { in lws_issue_raw()
57 lwsl_wsi_info(wsi, "** prot: %s, incr buflist_out by %lu", in lws_issue_raw()
58 wsi->a.protocol->name, (unsigned long)len); in lws_issue_raw()
66 if (lws_buflist_append_segment(&wsi->buflist_out, buf, len)) in lws_issue_raw()
73 if (wsi in lws_issue_raw()
214 lws_write(struct lws *wsi, unsigned char *buf, size_t len, enum lws_write_protocol wp) lws_write() argument
247 lws_ssl_capable_read_no_ssl(struct lws *wsi, unsigned char *buf, size_t len) lws_ssl_capable_read_no_ssl() argument
308 lws_ssl_capable_write_no_ssl(struct lws *wsi, unsigned char *buf, size_t len) lws_ssl_capable_write_no_ssl() argument
377 lws_ssl_pending_no_ssl(struct lws *wsi) lws_ssl_pending_no_ssl() argument
[all...]
H A Dpollfd.c28 _lws_change_pollfd(struct lws *wsi, int _and, int _or, struct lws_pollargs *pa) in _lws_change_pollfd() argument
39 if (!wsi) in _lws_change_pollfd()
42 assert(wsi->position_in_fds_table == LWS_NO_FDS_POS || in _lws_change_pollfd()
43 wsi->position_in_fds_table >= 0); in _lws_change_pollfd()
45 if (wsi->position_in_fds_table == LWS_NO_FDS_POS) in _lws_change_pollfd()
48 if (((volatile struct lws *)wsi)->handling_pollout && in _lws_change_pollfd()
58 ((volatile struct lws *)wsi)->leave_pollout_active = 1; in _lws_change_pollfd()
64 lwsl_wsi_debug(wsi, "using leave_pollout_active"); in _lws_change_pollfd()
69 context = wsi->a.context; in _lws_change_pollfd()
70 pt = &context->pt[(int)wsi in _lws_change_pollfd()
235 struct lws *wsi = lws_container_of(d, struct lws, lws_accept_modulation() local
256 struct lws *wsi = wsi_from_fd(pt->context, pt->fds[n].fd); __dump_fds() local
268 __insert_wsi_socket_into_fds(struct lws_context *context, struct lws *wsi) __insert_wsi_socket_into_fds() argument
358 __remove_wsi_socket_from_fds(struct lws *wsi) __remove_wsi_socket_from_fds() argument
473 __lws_change_pollfd(struct lws *wsi, int _and, int _or) __lws_change_pollfd() argument
507 lws_change_pollfd(struct lws *wsi, int _and, int _or) lws_change_pollfd() argument
522 lws_callback_on_writable(struct lws *wsi) lws_callback_on_writable() argument
563 lws_same_vh_protocol_insert(struct lws *wsi, int n) lws_same_vh_protocol_insert() argument
579 __lws_same_vh_protocol_remove(struct lws *wsi) __lws_same_vh_protocol_remove() argument
586 lws_same_vh_protocol_remove(struct lws *wsi) lws_same_vh_protocol_remove() argument
605 struct lws *wsi; lws_callback_on_writable_all_protocol_vhost() local
[all...]
H A Dservice.c49 lws_callback_as_writeable(struct lws *wsi) in lws_callback_as_writeable() argument
53 n = wsi->role_ops->writeable_cb[lwsi_role_server(wsi)]; in lws_callback_as_writeable()
54 m = user_callback_handle_rxflow(wsi->a.protocol->callback, in lws_callback_as_writeable()
55 wsi, (enum lws_callback_reasons) n, in lws_callback_as_writeable()
56 wsi->user_space, NULL, 0); in lws_callback_as_writeable()
62 lws_handle_POLLOUT_event(struct lws *wsi, struct lws_pollfd *pollfd) in lws_handle_POLLOUT_event() argument
64 volatile struct lws *vwsi = (volatile struct lws *)wsi; in lws_handle_POLLOUT_event()
67 if (wsi->socket_is_permanently_unusable) in lws_handle_POLLOUT_event()
77 wsi in lws_handle_POLLOUT_event()
248 lws_rxflow_cache(struct lws *wsi, unsigned char *buf, size_t n, size_t len) lws_rxflow_cache() argument
362 struct lws *wsi = lws_container_of(d, struct lws, dll_buflist); lws_service_adjust_timeout() local
384 lws_buflist_aware_read(struct lws_context_per_thread *pt, struct lws *wsi, struct lws_tokens *ebuf, char fr, const char *hint) lws_buflist_aware_read() argument
472 lws_buflist_aware_finished_consuming(struct lws *wsi, struct lws_tokens *ebuf, int used, int buffered, const char *hint) lws_buflist_aware_finished_consuming() argument
533 struct lws *wsi = lws_container_of(d, struct lws, dll_buflist); lws_service_do_ripe_rxflow() local
586 struct lws *wsi = lws_container_of(d, struct lws, dll_buflist); lws_service_flag_pending() local
610 struct lws *wsi = lws_container_of(p, struct lws, lws_service_flag_pending() local
642 struct lws *wsi; lws_service_fd_tsi() local
[all...]
/third_party/libwebsockets/lib/roles/ws/
H A Dclient-parser-ws.c32 int lws_ws_client_rx_sm(struct lws *wsi, unsigned char c) in lws_ws_client_rx_sm() argument
49 if (wsi->ws->rx_draining_ext) { in lws_ws_client_rx_sm()
52 lws_remove_wsi_from_draining_ext_list(wsi); in lws_ws_client_rx_sm()
54 lwsl_wsi_debug(wsi, "doing draining flow"); in lws_ws_client_rx_sm()
60 switch (wsi->lws_rx_parse_state) { in lws_ws_client_rx_sm()
63 wsi->ws->defeat_check_utf8 = 0; in lws_ws_client_rx_sm()
65 switch (wsi->ws->ietf_spec_revision) { in lws_ws_client_rx_sm()
67 wsi->ws->opcode = c & 0xf; in lws_ws_client_rx_sm()
69 switch (wsi->ws->opcode) { in lws_ws_client_rx_sm()
71 wsi in lws_ws_client_rx_sm()
[all...]
H A Dclient-ws.c47 struct lws *wsi) in lws_create_client_ws_object()
51 /* allocate the ws struct for the wsi */ in lws_create_client_ws_object()
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()
54 lwsl_wsi_notice(wsi, "OOM"); in lws_create_client_ws_object()
63 wsi->ws->ietf_spec_revision = (uint8_t)v; in lws_create_client_ws_object()
70 lws_ws_handshake_client(struct lws *wsi, unsigned char **buf, size_t len) in lws_ws_handshake_client() argument
74 if ((lwsi_state(wsi) != LRS_WAITING_PROXY_REPLY) && in lws_ws_handshake_client()
75 (lwsi_state(wsi) ! in lws_ws_handshake_client()
46 lws_create_client_ws_object(const struct lws_client_connect_info *i, struct lws *wsi) lws_create_client_ws_object() argument
146 lws_generate_client_ws_handshake(struct lws *wsi, char *p, const char *conn1) lws_generate_client_ws_handshake() argument
234 lws_client_ws_upgrade(struct lws *wsi, const char **cce) lws_client_ws_upgrade() argument
[all...]
H A Dops-ws.c35 lws_ws_rx_sm(struct lws *wsi, char already_processed, unsigned char c) in lws_ws_rx_sm() argument
53 switch (wsi->lws_rx_parse_state) { in lws_ws_rx_sm()
56 if (wsi->ws->rx_draining_ext) { in lws_ws_rx_sm()
61 lws_remove_wsi_from_draining_ext_list(wsi); in lws_ws_rx_sm()
68 switch (wsi->ws->ietf_spec_revision) { in lws_ws_rx_sm()
73 wsi->ws->all_zero_nonce = 1; in lws_ws_rx_sm()
78 wsi->ws->ietf_spec_revision); in lws_ws_rx_sm()
83 wsi->ws->mask[1] = c; in lws_ws_rx_sm()
85 wsi->ws->all_zero_nonce = 0; in lws_ws_rx_sm()
86 wsi in lws_ws_rx_sm()
752 lws_remaining_packet_payload(struct lws *wsi) lws_remaining_packet_payload() argument
757 lws_frame_is_binary(struct lws *wsi) lws_frame_is_binary() argument
763 lws_add_wsi_to_draining_ext_list(struct lws *wsi) lws_add_wsi_to_draining_ext_list() argument
780 lws_remove_wsi_from_draining_ext_list(struct lws *wsi) lws_remove_wsi_from_draining_ext_list() argument
807 lws_0405_frame_mask_generate(struct lws *wsi) lws_0405_frame_mask_generate() argument
826 lws_server_init_wsi_for_ws(struct lws *wsi) lws_server_init_wsi_for_ws() argument
871 lws_is_final_fragment(struct lws *wsi) lws_is_final_fragment() argument
885 lws_is_first_fragment(struct lws *wsi) lws_is_first_fragment() argument
891 lws_get_reserved_bits(struct lws *wsi) lws_get_reserved_bits() argument
897 lws_get_close_length(struct lws *wsi) lws_get_close_length() argument
903 lws_get_close_payload(struct lws *wsi) lws_get_close_payload() argument
909 lws_close_reason(struct lws *wsi, enum lws_close_status status, unsigned char *buf, size_t len) lws_close_reason() argument
930 lws_is_ws_with_ext(struct lws *wsi) lws_is_ws_with_ext() argument
940 rops_handle_POLLIN_ws(struct lws_context_per_thread *pt, struct lws *wsi, struct lws_pollfd *pollfd) rops_handle_POLLIN_ws() argument
1252 rops_handle_POLLOUT_ws(struct lws *wsi) rops_handle_POLLOUT_ws() argument
1471 struct lws *wsi; rops_service_flag_pending_ws() local
1498 rops_close_via_role_protocol_ws(struct lws *wsi, enum lws_close_status reason) rops_close_via_role_protocol_ws() argument
1529 rops_close_role_ws(struct lws_context_per_thread *pt, struct lws *wsi) rops_close_role_ws() argument
1580 rops_write_role_protocol_ws(struct lws *wsi, unsigned char *buf, size_t len, enum lws_write_protocol *wp) rops_write_role_protocol_ws() argument
1924 rops_close_kill_connection_ws(struct lws *wsi, enum lws_close_status reason) rops_close_kill_connection_ws() argument
1940 rops_callback_on_writable_ws(struct lws *wsi) rops_callback_on_writable_ws() argument
2030 rops_destroy_role_ws(struct lws *wsi) rops_destroy_role_ws() argument
2042 rops_issue_keepalive_ws(struct lws *wsi, int isvalid) rops_issue_keepalive_ws() argument
[all...]
H A Dserver-ws.c31 lws_extension_server_handshake(struct lws *wsi, char **p, int budget) in lws_extension_server_handshake() argument
33 struct lws_context *context = wsi->a.context; in lws_extension_server_handshake()
34 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi]; in lws_extension_server_handshake()
48 if (!lws_hdr_total_length(wsi, WSI_TOKEN_EXTENSIONS)) in lws_extension_server_handshake()
56 if (lws_hdr_copy(wsi, (char *)pt->serv_buf, (int)context->pt_serv_buf_size, in lws_extension_server_handshake()
62 wsi->ws->count_act_ext = 0; in lws_extension_server_handshake()
115 ext = wsi->a.vhost->ws.extensions; in lws_extension_server_handshake()
128 for (m = 0; m < wsi->ws->count_act_ext; m++) in lws_extension_server_handshake()
129 if (wsi->ws->active_extensions[m] == ext) { in lws_extension_server_handshake()
138 m = (wsi in lws_extension_server_handshake()
255 lws_process_ws_upgrade2(struct lws *wsi) lws_process_ws_upgrade2() argument
439 lws_process_ws_upgrade(struct lws *wsi) lws_process_ws_upgrade() argument
638 handshake_0405(struct lws_context *context, struct lws *wsi) handshake_0405() argument
805 lws_ws_frame_rest_is_payload(struct lws *wsi, uint8_t **buf, size_t len) lws_ws_frame_rest_is_payload() argument
990 lws_parse_ws(struct lws *wsi, unsigned char **buf, size_t len) lws_parse_ws() argument
[all...]
/third_party/libwebsockets/lib/roles/h1/
H A Dops-h1.c42 lws_read_h1(struct lws *wsi, unsigned char *buf, lws_filepos_t len) in lws_read_h1() argument
48 lwsl_debug("%s: h1 path: wsi state 0x%x\n", __func__, lwsi_state(wsi)); in lws_read_h1()
50 switch (lwsi_state(wsi)) { in lws_read_h1()
57 if (lwsi_role_ws(wsi)) in lws_read_h1()
60 if (lwsi_role_client(wsi)) in lws_read_h1()
63 wsi->hdr_parsing_completed = 0; in lws_read_h1()
68 if (!wsi->http.ah) { in lws_read_h1()
74 if (lws_ws_handshake_client(wsi, &buf, (size_t)len)) in lws_read_h1()
78 if (lws_handshake_server(wsi, in lws_read_h1()
331 lws_h1_server_socket_service(struct lws *wsi, struct lws_pollfd *pollfd) lws_h1_server_socket_service() argument
563 rops_handle_POLLIN_h1(struct lws_context_per_thread *pt, struct lws *wsi, struct lws_pollfd *pollfd) rops_handle_POLLIN_h1() argument
713 rops_handle_POLLOUT_h1(struct lws *wsi) rops_handle_POLLOUT_h1() argument
782 rops_write_role_protocol_h1(struct lws *wsi, unsigned char *buf, size_t len, enum lws_write_protocol *wp) rops_write_role_protocol_h1() argument
851 rops_alpn_negotiated_h1(struct lws *wsi, const char *alpn) rops_alpn_negotiated_h1() argument
871 rops_destroy_role_h1(struct lws *wsi) rops_destroy_role_h1() argument
907 rops_adoption_bind_h1(struct lws *wsi, int type, const char *vh_prot_name) rops_adoption_bind_h1() argument
975 rops_client_bind_h1(struct lws *wsi, const struct lws_client_connect_info *i) rops_client_bind_h1() argument
1070 rops_close_kill_connection_h1(struct lws *wsi, enum lws_close_status reason) rops_close_kill_connection_h1() argument
[all...]
/third_party/libwebsockets/lib/roles/http/client/
H A Dclient-http.c28 lws_client_http_body_pending(struct lws *wsi, int something_left_to_send) in lws_client_http_body_pending() argument
30 wsi->client_http_body_pending = !!something_left_to_send; in lws_client_http_body_pending()
34 lws_http_client_socket_service(struct lws *wsi, struct lws_pollfd *pollfd) in lws_http_client_socket_service() argument
36 struct lws_context *context = wsi->a.context; in lws_http_client_socket_service()
37 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi]; in lws_http_client_socket_service()
46 switch (lwsi_state(wsi)) { in lws_http_client_socket_service()
53 lwsl_err("%s: %s: WAITING_DNS\n", __func__, lws_wsi_tag(wsi)); in lws_http_client_socket_service()
54 if (!lws_client_connect_2_dnsreq(wsi)) { in lws_http_client_socket_service()
70 if (lws_client_connect_3_connect(wsi, NULL, NULL, 0, NULL) == NULL) { in lws_http_client_socket_service()
82 switch (lws_socks5c_handle_state(wsi, pollf in lws_http_client_socket_service()
501 lws_http_transaction_completed_client(struct lws *wsi) lws_http_transaction_completed_client() argument
573 lws_http_client_http_response(struct lws *wsi) lws_http_client_http_response() argument
585 lws_http_is_redirected_to_get(struct lws *wsi) lws_http_is_redirected_to_get() argument
591 lws_client_interpret_server_handshake(struct lws *wsi) lws_client_interpret_server_handshake() argument
1063 lws_http_multipart_headers(struct lws *wsi, uint8_t *p) lws_http_multipart_headers() argument
1090 lws_client_http_multipart(struct lws *wsi, const char *name, const char *filename, const char *content_type, char **p, char *end) lws_client_http_multipart() argument
1130 lws_generate_client_handshake(struct lws *wsi, char *pkt) lws_generate_client_handshake() argument
1326 lws_http_client_read(struct lws *wsi, char **buf, int *len) lws_http_client_read() argument
1599 struct lws *wsi; lws_client_reset() local
[all...]
/third_party/libwebsockets/lib/roles/h2/
H A Dops-h2.c93 * The wsi at this level is normally the network wsi... we can get called on
98 rops_handle_POLLIN_h2(struct lws_context_per_thread *pt, struct lws *wsi, in rops_handle_POLLIN_h2() argument
108 if (wsi->http.cgi && (pollfd->revents & LWS_POLLOUT)) { in rops_handle_POLLIN_h2()
109 if (lws_handle_POLLOUT_event(wsi, pollfd)) in rops_handle_POLLIN_h2()
117 wsi->lc.gutag, (unsigned int)wsi->wsistate, in rops_handle_POLLIN_h2()
122 if (wsi->wsistate == 0x10000013) { in rops_handle_POLLIN_h2()
123 wsi->bugcatcher++; in rops_handle_POLLIN_h2()
124 if (wsi in rops_handle_POLLIN_h2()
363 rops_handle_POLLOUT_h2(struct lws *wsi) rops_handle_POLLOUT_h2() argument
407 rops_write_role_protocol_h2(struct lws *wsi, unsigned char *buf, size_t len, enum lws_write_protocol *wp) rops_write_role_protocol_h2() argument
523 rops_check_upgrades_h2(struct lws *wsi) rops_check_upgrades_h2() argument
605 rops_tx_credit_h2(struct lws *wsi, char peer_to_us, int add) rops_tx_credit_h2() argument
641 rops_destroy_role_h2(struct lws *wsi) rops_destroy_role_h2() argument
678 rops_close_kill_connection_h2(struct lws *wsi, enum lws_close_status reason) rops_close_kill_connection_h2() argument
746 rops_callback_on_writable_h2(struct lws *wsi) rops_callback_on_writable_h2() argument
797 lws_h2_bind_for_post_before_action(struct lws *wsi) lws_h2_bind_for_post_before_action() argument
930 rops_perform_user_POLLOUT_h2(struct lws *wsi) rops_perform_user_POLLOUT_h2() argument
1270 rops_encapsulation_parent_h2(struct lws *wsi) rops_encapsulation_parent_h2() argument
1279 rops_alpn_negotiated_h2(struct lws *wsi, const char *alpn) rops_alpn_negotiated_h2() argument
1323 rops_issue_keepalive_h2(struct lws *wsi, int isvalid) rops_issue_keepalive_h2() argument
[all...]
/third_party/libwebsockets/lib/roles/cgi/
H A Dcgi-server.c81 if (!cgi->wsi->http.cgi->post_in_expected) in lws_cgi_grace()
82 cgi->wsi->http.cgi->cgi_transaction_over = 1; in lws_cgi_grace()
84 lws_callback_on_writable(cgi->wsi); in lws_cgi_grace()
92 struct lws *wsi = (struct lws *)opaque; in lws_cgi_reap_cb() local
98 if (wsi->http.cgi) in lws_cgi_reap_cb()
99 lwsl_wsi_info(wsi, "post_in_expected %d", in lws_cgi_reap_cb()
100 (int)wsi->http.cgi->post_in_expected); in lws_cgi_reap_cb()
106 if (wsi->http.cgi) in lws_cgi_reap_cb()
107 lws_sul_schedule(wsi->a.context, wsi in lws_cgi_reap_cb()
112 lws_cgi(struct lws *wsi, const char * const *exec_array, int script_uri_path_len, int timeout_secs, const struct lws_protocol_vhost_options *mp_cgienv) lws_cgi() argument
462 lws_cgi_write_split_stdout_headers(struct lws *wsi) lws_cgi_write_split_stdout_headers() argument
908 lws_cgi_kill(struct lws *wsi) lws_cgi_kill() argument
1067 lws_cgi_get_stdwsi(struct lws *wsi, enum lws_enum_stdinouterr ch) lws_cgi_get_stdwsi() argument
1076 lws_cgi_remove_and_kill(struct lws *wsi) lws_cgi_remove_and_kill() argument
[all...]
/third_party/libwebsockets/lib/core-net/client/
H A Dconnect4.c28 lws_client_connect_4_established(struct lws *wsi, struct lws *wsi_piggyback, in lws_client_connect_4_established() argument
32 struct lws_context_per_thread *pt = &wsi->a.context->pt[(int)wsi->tsi]; in lws_client_connect_4_established()
39 meth = lws_wsi_client_stash_item(wsi, CIS_METHOD, in lws_client_connect_4_established()
57 if (wsi->a.vhost->http.http_proxy_port) { in lws_client_connect_4_established()
60 cpa = lws_wsi_client_stash_item(wsi, CIS_ADDRESS, in lws_client_connect_4_established()
65 lwsl_wsi_info(wsi, "going via proxy"); in lws_client_connect_4_established()
70 "User-agent: lws\x0d\x0a", cpa, wsi->ocport, in lws_client_connect_4_established()
71 cpa, wsi->ocport); in lws_client_connect_4_established()
74 if (wsi in lws_client_connect_4_established()
[all...]
H A Dconnect2.c33 lws_getaddrinfo46(struct lws *wsi, const char *ads, struct addrinfo **result) in lws_getaddrinfo46() argument
35 lws_metrics_caliper_declare(cal, wsi->a.context->mt_conn_dns); in lws_getaddrinfo46()
48 if (wsi->ipv6) { in lws_getaddrinfo46()
63 wsi->conmon_datum = lws_now_usecs(); in lws_getaddrinfo46()
66 wsi->dns_reachability = 0; in lws_getaddrinfo46()
67 if (lws_fi(&wsi->fic, "dnsfail")) in lws_getaddrinfo46()
73 wsi->conmon.ciu_dns = (lws_conmon_interval_us_t) in lws_getaddrinfo46()
74 (lws_now_usecs() - wsi->conmon_datum); in lws_getaddrinfo46()
96 wsi->dns_reachability = 1; in lws_getaddrinfo46()
100 lws_metrics_hist_bump_priv_wsi(wsi, mth_conn_failure in lws_getaddrinfo46()
137 lws_client_connect_2_dnsreq(struct lws *wsi) global() argument
[all...]
H A Dconnect.c39 lws_http_client_connect_via_info2(struct lws *wsi) in lws_http_client_connect_via_info2() argument
41 struct client_info_stash *stash = wsi->stash; in lws_http_client_connect_via_info2()
44 lwsl_wsi_debug(wsi, "stash %p", stash); in lws_http_client_connect_via_info2()
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()
62 lws_hdr_simple_create(wsi, hnames[n], stash->cis[n])) in lws_http_client_connect_via_info2()
66 if (!wsi->a.vhost->socks_proxy_port) in lws_http_client_connect_via_info2()
67 lws_free_set_NULL(wsi->stash); in lws_http_client_connect_via_info2()
71 return lws_client_connect_2_dnsreq(wsi); in lws_http_client_connect_via_info2()
85 lws_client_stash_create(struct lws *wsi, const char **cisin) lws_client_stash_create() argument
131 struct lws *wsi, *safe = NULL; lws_client_connect_via_info() local
[all...]
H A Dconnect3.c132 struct lws *wsi = lws_container_of(sul, struct lws, in lws_client_conn_wait_timeout() local
140 lwsl_wsi_info(wsi, "connect wait timeout has fired"); in lws_client_conn_wait_timeout()
141 lws_client_connect_3_connect(wsi, NULL, NULL, 0, NULL); in lws_client_conn_wait_timeout()
147 struct lws *wsi = lws_container_of(sul, struct lws, in lws_client_dns_retry_timeout() local
156 lwsl_wsi_info(wsi, "dns retry"); in lws_client_dns_retry_timeout()
157 if (!lws_client_connect_2_dnsreq(wsi)) in lws_client_dns_retry_timeout()
158 lwsl_wsi_notice(wsi, "DNS lookup failed"); in lws_client_dns_retry_timeout()
176 lws_client_connect_check(struct lws *wsi, int *real_errno) in lws_client_connect_check() argument
192 if (!getsockopt(wsi->desc.sockfd, SOL_SOCKET, SO_ERROR, &e, &sl)) { in lws_client_connect_check()
195 lwsl_wsi_debug(wsi, "getsockop in lws_client_connect_check()
252 lws_client_connect_3_connect(struct lws *wsi, const char *ads, const struct addrinfo *result, int n, void *opaque) global() argument
[all...]
/third_party/libwebsockets/lib/roles/http/server/
H A Dserver.c66 struct lws *wsi = lws_container_of(d, struct lws, listen_list); in check_extant() local
69 if (!lws_vhost_compare_listen(wsi->a.vhost, a->vhost)) in check_extant()
72 if (wsi->af != a ->af) in check_extant()
75 lwsl_notice(" using listen skt from vhost %s\n", wsi->a.vhost->name); in check_extant()
91 struct lws *wsi; in _lws_vhost_init_server_af() local
299 * Create the listen wsi and customize it in _lws_vhost_init_server_af()
303 wsi = __lws_wsi_create_with_role(cx, m, &role_ops_listen, NULL); in _lws_vhost_init_server_af()
305 if (wsi == NULL) { in _lws_vhost_init_server_af()
310 wsi->af = (uint8_t)a->af; in _lws_vhost_init_server_af()
316 wsi in _lws_vhost_init_server_af()
638 lws_vfs_prepare_flags(struct lws *wsi) lws_vfs_prepare_flags() argument
655 lws_http_serve(struct lws *wsi, char *uri, const char *origin, const struct lws_http_mount *m) lws_http_serve() argument
941 lws_find_mount(struct lws *wsi, const char *uri_ptr, int uri_len) lws_find_mount() argument
1035 lws_unauthorised_basic_auth(struct lws *wsi) lws_unauthorised_basic_auth() argument
1116 lws_http_get_uri_and_method(struct lws *wsi, char **puri_ptr, int *puri_len) lws_http_get_uri_and_method() argument
1152 lws_check_basic_auth(struct lws *wsi, const char *basic_auth_login_file, unsigned int auth_mode) lws_check_basic_auth() argument
1252 lws_http_proxy_start(struct lws *wsi, const struct lws_http_mount *hit, char *uri_ptr, char ws) lws_http_proxy_start() argument
1509 lws_http_redirect_hit(struct lws_context_per_thread *pt, struct lws *wsi, const struct lws_http_mount *hit, char *uri_ptr, int uri_len, int *h) lws_http_redirect_hit() argument
1597 lws_http_action(struct lws *wsi) lws_http_action() argument
2070 lws_confirm_host_header(struct lws *wsi) lws_confirm_host_header() argument
2141 lws_http_to_fallback(struct lws *wsi, unsigned char *obuf, size_t olen) lws_http_to_fallback() argument
2194 lws_handshake_server(struct lws *wsi, unsigned char **buf, size_t len) lws_handshake_server() argument
2519 lws_http_transaction_completed(struct lws *wsi) lws_http_transaction_completed() argument
2725 lws_serve_http_file(struct lws *wsi, const char *file, const char *content_type, const char *other_headers, int other_headers_len) lws_serve_http_file() argument
3028 lws_serve_http_file_fragment(struct lws *wsi) lws_serve_http_file_fragment() argument
[all...]
/third_party/libwebsockets/lib/roles/mqtt/
H A Dops-mqtt.c28 rops_handle_POLLIN_mqtt(struct lws_context_per_thread *pt, struct lws *wsi, in rops_handle_POLLIN_mqtt() argument
37 (unsigned int)wsi->wsistate, wsi->a.protocol->name, in rops_handle_POLLIN_mqtt()
43 * nwsi no longer has a wsi->mqtt of its own. in rops_handle_POLLIN_mqtt()
55 if (lwsi_state(wsi) != LRS_ESTABLISHED) { in rops_handle_POLLIN_mqtt()
58 if (lwsi_state(wsi) == LRS_WAITING_SSL && in rops_handle_POLLIN_mqtt()
60 lws_change_pollfd(wsi, LWS_POLLOUT, 0)) { in rops_handle_POLLIN_mqtt()
66 lws_handle_POLLOUT_event(wsi, pollfd)) { in rops_handle_POLLIN_mqtt()
71 n = lws_mqtt_client_socket_service(wsi, pollfd, NULL); in rops_handle_POLLIN_mqtt()
81 lwsi_state_can_handle_POLLOUT(wsi) in rops_handle_POLLIN_mqtt()
229 rops_client_bind_mqtt(struct lws *wsi, const struct lws_client_connect_info *i) rops_client_bind_mqtt() argument
276 rops_handle_POLLOUT_mqtt(struct lws *wsi) rops_handle_POLLOUT_mqtt() argument
432 rops_issue_keepalive_mqtt(struct lws *wsi, int isvalid) rops_issue_keepalive_mqtt() argument
450 rops_close_role_mqtt(struct lws_context_per_thread *pt, struct lws *wsi) rops_close_role_mqtt() argument
503 rops_callback_on_writable_mqtt(struct lws *wsi) rops_callback_on_writable_mqtt() argument
559 rops_close_kill_connection_mqtt(struct lws *wsi, enum lws_close_status reason) rops_close_kill_connection_mqtt() argument
[all...]
/third_party/libwebsockets/lib/roles/raw-skt/
H A Dops-raw-skt.c29 lws_raw_skt_connect(struct lws *wsi) argument
37 switch (lws_client_create_tls(wsi, &cce, 1)) {
39 switch (lws_client_create_tls(wsi, &cce, 0)) {
42 lws_inform_client_conn_fail(wsi, (void *)cce, strlen(cce));
50 if (wsi->tls.use_ssl & LCCSCF_USE_SSL) {
51 n = lws_ssl_client_connect2(wsi, ccebuf, sizeof(ccebuf));
53 lws_inform_client_conn_fail(wsi, (void *)ccebuf,
63 n = user_callback_handle_rxflow(wsi->a.protocol->callback,
64 wsi, wsi
79 rops_handle_POLLIN_raw_skt(struct lws_context_per_thread *pt, struct lws *wsi, struct lws_pollfd *pollfd) global() argument
276 rops_adoption_bind_raw_skt(struct lws *wsi, int type, const char *vh_prot_name) global() argument
315 rops_client_bind_raw_skt(struct lws *wsi, const struct lws_client_connect_info *i) global() argument
[all...]
/third_party/libwebsockets/lib/roles/http/
H A Dparsers.c109 __lws_header_table_reset(struct lws *wsi, int autoservice) in __lws_header_table_reset() argument
111 struct allocated_headers *ah = wsi->http.ah; in __lws_header_table_reset()
118 assert(ah->wsi == wsi); in __lws_header_table_reset()
123 wsi->hdr_parsing_completed = 0; in __lws_header_table_reset()
125 /* while we hold the ah, keep a timeout on the wsi */ in __lws_header_table_reset()
126 __lws_set_timeout(wsi, PENDING_TIMEOUT_HOLDING_AH, in __lws_header_table_reset()
127 wsi->a.vhost->timeout_secs_ah_idle); in __lws_header_table_reset()
131 if (wsi->position_in_fds_table != LWS_NO_FDS_POS && in __lws_header_table_reset()
132 lws_buflist_next_segment_len(&wsi in __lws_header_table_reset()
149 lws_header_table_reset(struct lws *wsi, int autoservice) lws_header_table_reset() argument
161 _lws_header_ensure_we_are_on_waiting_list(struct lws *wsi) _lws_header_ensure_we_are_on_waiting_list() argument
184 __lws_remove_from_ah_waiting_list(struct lws *wsi) __lws_remove_from_ah_waiting_list() argument
207 lws_header_table_attach(struct lws *wsi, int autoservice) lws_header_table_attach() argument
306 __lws_header_table_detach(struct lws *wsi, int autoservice) __lws_header_table_detach() argument
445 lws_header_table_detach(struct lws *wsi, int autoservice) lws_header_table_detach() argument
459 lws_hdr_fragment_length(struct lws *wsi, enum lws_token_indexes h, int frag_idx) lws_hdr_fragment_length() argument
478 lws_hdr_total_length(struct lws *wsi, enum lws_token_indexes h) lws_hdr_total_length() argument
501 lws_hdr_copy_fragment(struct lws *wsi, char *dst, int len, enum lws_token_indexes h, int frag_idx) lws_hdr_copy_fragment() argument
532 lws_hdr_copy(struct lws *wsi, char *dst, int len, enum lws_token_indexes h) lws_hdr_copy() argument
598 lws_hdr_custom_length(struct lws *wsi, const char *name, int nlen) lws_hdr_custom_length() argument
622 lws_hdr_custom_copy(struct lws *wsi, char *dst, int len, const char *name, int nlen) lws_hdr_custom_copy() argument
656 lws_hdr_custom_name_foreach(struct lws *wsi, lws_hdr_custom_fe_cb_t cb, void *custom) lws_hdr_custom_name_foreach() argument
681 lws_hdr_simple_ptr(struct lws *wsi, enum lws_token_indexes h) lws_hdr_simple_ptr() argument
696 lws_pos_in_bounds(struct lws *wsi) lws_pos_in_bounds() argument
723 lws_hdr_simple_create(struct lws *wsi, enum lws_token_indexes h, const char *s) lws_hdr_simple_create() argument
760 issue_char(struct lws *wsi, unsigned char c) issue_char() argument
794 lws_parse_urldecode(struct lws *wsi, uint8_t *_c) lws_parse_urldecode() argument
1018 lws_parse(struct lws *wsi, unsigned char *buf, int *len) lws_parse() argument
1536 lws_http_cookie_get(struct lws *wsi, const char *name, char *buf, size_t *max_len) lws_http_cookie_get() argument
1621 lws_jwt_get_http_cookie_validate_jwt(struct lws *wsi, struct lws_jwt_sign_set_cookie *i, char *out, size_t *out_len) lws_jwt_get_http_cookie_validate_jwt() argument
1674 lws_jwt_sign_token_set_http_cookie(struct lws *wsi, const struct lws_jwt_sign_set_cookie *i, uint8_t **p, uint8_t *end) lws_jwt_sign_token_set_http_cookie() argument
[all...]
H A Dheader.c56 lws_wsi_is_h2(struct lws *wsi) in lws_wsi_is_h2() argument
58 return wsi->upgraded_to_http2 || in lws_wsi_is_h2()
59 wsi->mux_substream || in lws_wsi_is_h2()
61 wsi->client_mux_substream || in lws_wsi_is_h2()
63 lwsi_role_h2(wsi) || in lws_wsi_is_h2()
64 lwsi_role_h2_ENCAPSULATION(wsi); in lws_wsi_is_h2()
69 lws_add_http_header_by_name(struct lws *wsi, const unsigned char *name, in lws_add_http_header_by_name() argument
74 if (lws_wsi_is_h2(wsi)) in lws_add_http_header_by_name()
75 return lws_add_http2_header_by_name(wsi, name, in lws_add_http_header_by_name()
78 (void)wsi; in lws_add_http_header_by_name()
104 lws_finalize_http_header(struct lws *wsi, unsigned char **p, unsigned char *end) lws_finalize_http_header() argument
122 lws_finalize_write_http_header(struct lws *wsi, unsigned char *start, unsigned char **pp, unsigned char *end) lws_finalize_write_http_header() argument
141 lws_add_http_header_by_token(struct lws *wsi, enum lws_token_indexes token, const unsigned char *value, int length, unsigned char **p, unsigned char *end) lws_add_http_header_by_token() argument
159 lws_add_http_header_content_length(struct lws *wsi, lws_filepos_t content_length, unsigned char **p, unsigned char *end) lws_add_http_header_content_length() argument
182 lws_add_http_common_headers(struct lws *wsi, unsigned int code, const char *content_type, lws_filepos_t content_len, unsigned char **p, unsigned char *end) lws_add_http_common_headers() argument
310 lws_add_http_header_status(struct lws *wsi, unsigned int _code, unsigned char **p, unsigned char *end) lws_add_http_header_status() argument
415 lws_return_http_status(struct lws *wsi, unsigned int code, const char *html_body) lws_return_http_status() argument
529 lws_http_redirect(struct lws *wsi, int code, const unsigned char *loc, int len, unsigned char **p, unsigned char *end) lws_http_redirect() argument
563 lws_http_compression_apply(struct lws *wsi, const char *name, unsigned char **p, unsigned char *end, char decomp) lws_http_compression_apply() argument
577 lws_http_headers_detach(struct lws *wsi) lws_http_headers_detach() argument
590 struct lws *wsi; lws_sul_http_ah_lifecheck() local
[all...]
/third_party/libwebsockets/lib/tls/mbedtls/
H A Dmbedtls-ssl.c45 lws_ssl_capable_read(struct lws *wsi, unsigned char *buf, size_t len) in lws_ssl_capable_read() argument
47 struct lws_context *context = wsi->a.context; in lws_ssl_capable_read()
48 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi]; in lws_ssl_capable_read()
51 if (!wsi->tls.ssl) in lws_ssl_capable_read()
52 return lws_ssl_capable_read_no_ssl(wsi, buf, len); in lws_ssl_capable_read()
55 n = SSL_read(wsi->tls.ssl, buf, (int)len); in lws_ssl_capable_read()
58 lwsl_debug("%s: SSL_read ENOTCONN\n", lws_wsi_tag(wsi)); in lws_ssl_capable_read()
63 lwsl_debug("%s: %s: SSL_read says %d\n", __func__, lws_wsi_tag(wsi), n); in lws_ssl_capable_read()
66 wsi->socket_is_permanently_unusable = 1; in lws_ssl_capable_read()
72 m = SSL_get_error(wsi in lws_ssl_capable_read()
154 lws_ssl_pending(struct lws *wsi) lws_ssl_pending() argument
163 lws_ssl_capable_write(struct lws *wsi, unsigned char *buf, size_t len) lws_ssl_capable_write() argument
223 struct lws *wsi; lws_ssl_info_callback() local
250 lws_ssl_close(struct lws *wsi) lws_ssl_close() argument
305 lws_tls_ctx_from_wsi(struct lws *wsi) lws_tls_ctx_from_wsi() argument
314 __lws_tls_shutdown(struct lws *wsi) __lws_tls_shutdown() argument
[all...]

Completed in 13 milliseconds

12345678910>>...14