/third_party/libwebsockets/lib/roles/h2/ |
H A D | hpack.c | 424 struct lws *nwsi = lws_get_network_wsi(wsi); in lws_h2_dynamic_table_dump() 429 if (!nwsi->h2.h2n) in lws_h2_dynamic_table_dump() 431 dyn = &nwsi->h2.h2n->hpack_dyn_table; in lws_h2_dynamic_table_dump() 433 lwsl_header("Dump dyn table for nwsi %s (%d / %d members, pos = %d, " in lws_h2_dynamic_table_dump() 434 "start index %d, virt used %d / %d)\n", lws_wsi_tag(nwsi), in lws_h2_dynamic_table_dump() 572 struct lws *nwsi; in lws_hpack_dynamic_size() local 591 nwsi = lws_get_network_wsi(wsi); in lws_hpack_dynamic_size() 592 if (!nwsi->h2.h2n) in lws_hpack_dynamic_size() 595 dyn = &nwsi->h2.h2n->hpack_dyn_table; in lws_hpack_dynamic_size() 598 (unsigned int)nwsi in lws_hpack_dynamic_size() 798 lws_hpack_handle_pseudo_rules(struct lws *nwsi, struct lws *wsi, int m) lws_hpack_handle_pseudo_rules() argument 826 struct lws *nwsi = lws_get_network_wsi(wsi); lws_hpack_interpret() local [all...] |
H A D | http2.c | 156 struct lws *nwsi = lws_get_network_wsi(wsi); in lws_h2_update_peer_txcredit() local 188 nwsi->txc.peer_tx_cr_est += bump; in lws_h2_update_peer_txcredit() 190 lws_wsi_txc_describe(&nwsi->txc, __func__, nwsi->mux.my_sid); in lws_h2_update_peer_txcredit() 192 lws_pps_schedule(nwsi, pps); in lws_h2_update_peer_txcredit() 219 struct lws *nwsi = lws_get_network_wsi(parent_wsi); in __lws_wsi_server_new() local 220 struct lws_h2_netconn *h2n = nwsi->h2.h2n; in __lws_wsi_server_new() 240 lws_h2_goaway(nwsi, H2_ERR_PROTOCOL_ERROR, "Bad sid"); in __lws_wsi_server_new() 284 wsi->txc.tx_cr = (int32_t)nwsi->h2.h2n->peer_set.s[H2SET_INITIAL_WINDOW_SIZE]; in __lws_wsi_server_new() 286 (int32_t)nwsi in __lws_wsi_server_new() 328 struct lws *nwsi = lws_get_network_wsi(parent_wsi); lws_wsi_h2_adopt() local 431 struct lws *nwsi = lws_get_network_wsi(wsi); lws_pps_schedule() local 475 struct lws *nwsi = lws_get_network_wsi(wsi); lws_h2_rst_stream() local 507 struct lws *nwsi = lws_get_network_wsi(wsi); lws_h2_settings() local [all...] |
H A D | ops-h2.c | 607 struct lws *nwsi = lws_get_network_wsi(wsi); in rops_tx_credit_h2() local 625 nwsi->txc.tx_cr += add; in rops_tx_credit_h2() 634 if (n > nwsi->txc.peer_tx_cr_est) in rops_tx_credit_h2() 635 n = nwsi->txc.peer_tx_cr_est; in rops_tx_credit_h2() 1325 struct lws *nwsi = lws_get_network_wsi(wsi); in rops_issue_keepalive_h2() local 1330 _lws_validity_confirmed_role(nwsi); in rops_issue_keepalive_h2() 1340 assert(wsi == nwsi); in rops_issue_keepalive_h2() 1355 lws_pps_schedule(nwsi, pps); in rops_issue_keepalive_h2()
|
H A D | private-lib-roles-h2.h | 328 lws_h2_settings(struct lws *nwsi, struct http2_settings *settings,
|
/third_party/libwebsockets/lib/roles/http/server/ |
H A D | access-log.c | 48 struct lws *nwsi; in lws_prepare_access_log_info() local 97 nwsi = lws_get_network_wsi(wsi); in lws_prepare_access_log_info() 99 if (nwsi->sa46_peer.sa4.sin_family) in lws_prepare_access_log_info() 100 lws_sa46_write_numeric_address(&nwsi->sa46_peer, ta, sizeof(ta)); in lws_prepare_access_log_info()
|
H A D | server.c | 3039 struct lws *nwsi; in lws_serve_http_file_fragment() local 3129 nwsi = lws_get_network_wsi(wsi); in lws_serve_http_file_fragment() 3130 if (nwsi->h2.h2n && in lws_serve_http_file_fragment() 3131 poss > (lws_filepos_t)nwsi->h2.h2n->peer_set.s[H2SET_MAX_FRAME_SIZE]) in lws_serve_http_file_fragment() 3132 poss = (lws_filepos_t)nwsi->h2.h2n->peer_set.s[H2SET_MAX_FRAME_SIZE]; in lws_serve_http_file_fragment() 3294 * nwsi if there was a network-level in lws_serve_http_file_fragment()
|
/third_party/libwebsockets/lib/core-net/ |
H A D | wsi.c | 633 struct lws *nwsi = lws_get_network_wsi(wsi); in lws_has_buffered_out() local 635 if (nwsi->buflist_out) in lws_has_buffered_out() 1273 struct lws *nwsi; in lws_http_close_immortal() local 1281 nwsi = lws_get_network_wsi(wsi); in lws_http_close_immortal() 1282 lwsl_wsi_debug(wsi, "%s (%d)", lws_wsi_tag(nwsi), in lws_http_close_immortal() 1283 nwsi->immortal_substream_count); in lws_http_close_immortal() 1284 assert(nwsi->immortal_substream_count); in lws_http_close_immortal() 1285 nwsi->immortal_substream_count--; in lws_http_close_immortal() 1286 if (!nwsi->immortal_substream_count) in lws_http_close_immortal() 1288 * since we closed the only immortal stream on this nwsi, w in lws_http_close_immortal() 1299 struct lws *nwsi; lws_mux_mark_immortal() local [all...] |
H A D | vhost.c | 1744 * ACTIVE_CONNS_QUEUED: We're queued on an active connection, set *nwsi to that 1745 * ACTIVE_CONNS_MUXED: We are joining an active mux conn *nwsi as a child 1750 lws_vhost_active_conns(struct lws *wsi, struct lws **nwsi, const char *adsin) argument 1772 *nwsi = w; 1783 *nwsi = wsi->mux.parent_wsi; 1860 *nwsi = w; 1915 *nwsi = w;
|
H A D | private-lib-core-net.h | 1510 lws_vhost_active_conns(struct lws *wsi, struct lws **nwsi, const char *adsin);
|
/third_party/libwebsockets/lib/roles/mqtt/ |
H A D | ops-mqtt.c | 41 * After the CONNACK and nwsi establishment, the first logical in rops_handle_POLLIN_mqtt() 42 * stream is migrated out of the nwsi to be child sid 1, and the in rops_handle_POLLIN_mqtt() 43 * nwsi no longer has a wsi->mqtt of its own. in rops_handle_POLLIN_mqtt() 45 * RX events on the nwsi must be converted to events seen or not in rops_handle_POLLIN_mqtt() 366 * If the nwsi is in the middle of a frame, we can only in rops_handle_POLLOUT_mqtt() 434 struct lws *nwsi = lws_get_network_wsi(wsi); in rops_issue_keepalive_mqtt() local 437 _lws_validity_confirmed_role(nwsi); in rops_issue_keepalive_mqtt() 442 nwsi->mqtt->send_pingreq = 1; in rops_issue_keepalive_mqtt() 443 lws_callback_on_writable(nwsi); in rops_issue_keepalive_mqtt() 452 struct lws *nwsi in rops_close_role_mqtt() local [all...] |
H A D | mqtt.c | 1265 * the nwsi, and we succeeded to create a new in _lws_mqtt_rx_parser() 1268 * Since others may join us sharing the nwsi, in _lws_mqtt_rx_parser() 1271 * define the lifecycle of the nwsi... it means in _lws_mqtt_rx_parser() 1273 * being both the nwsi and act like a child in _lws_mqtt_rx_parser() 1275 * nwsi duties and turn our wsi into a child of in _lws_mqtt_rx_parser() 1276 * the nwsi with its own lifecycle. in _lws_mqtt_rx_parser() 1278 * The nwsi gets a mostly empty wsi->nwsi used in _lws_mqtt_rx_parser() 1301 wsi->told_user_closed = 1; /* don't tell nwsi closed */ in _lws_mqtt_rx_parser() 1312 wsi->mqtt = lws_zalloc(sizeof(*wsi->mqtt), "nwsi mqt in _lws_mqtt_rx_parser() 1578 struct lws *nwsi = lws_get_network_wsi(w); _lws_mqtt_rx_parser() local 1962 struct lws *nwsi = lws_get_network_wsi(wsi); lws_mqtt_client_send_publish() local 2124 struct lws *nwsi = lws_get_network_wsi(wsi); lws_mqtt_client_send_subcribe() local 2310 struct lws *nwsi = lws_get_network_wsi(wsi); lws_mqtt_client_send_unsubcribe() local [all...] |
/third_party/libwebsockets/lib/tls/openssl/ |
H A D | openssl-session.c | 130 struct lws *nwsi = lws_get_network_wsi(wsi); in lws_tls_session_is_reused() local 132 if (!nwsi || !nwsi->tls.ssl) in lws_tls_session_is_reused() 135 return (int)SSL_session_reused(nwsi->tls.ssl); in lws_tls_session_is_reused()
|
/third_party/libwebsockets/lib/tls/mbedtls/ |
H A D | mbedtls-session.c | 117 struct lws *nwsi = lws_get_network_wsi(wsi); in lws_tls_session_is_reused() local 119 if (!nwsi) in lws_tls_session_is_reused() 122 return nwsi->tls_session_reused; in lws_tls_session_is_reused()
|
/third_party/libwebsockets/lib/secure-streams/protocols/ |
H A D | ss-mqtt.c | 555 * original nwsi, in the case it was migrated in secstream_mqtt() 563 struct lws *nwsi = lws_get_network_wsi(wsi); in secstream_mqtt() local 564 lws_start_foreach_ll(struct lws *, w, nwsi->mux.child_list) { in secstream_mqtt() 868 struct lws *nwsi = lws_get_network_wsi(wsi); in secstream_mqtt() local 876 if (nwsi && (nwsi->mux.child_count == 1)) in secstream_mqtt() 877 lws_mqtt_client_send_disconnect(nwsi); in secstream_mqtt()
|
/third_party/libwebsockets/lib/roles/cgi/ |
H A D | cgi-server.c | 853 struct lws *nwsi = lws_get_network_wsi(wsi); in lws_cgi_write_split_stdout_headers() local 858 if (!nwsi->immortal_substream_count) in lws_cgi_write_split_stdout_headers() 859 __lws_set_timeout(nwsi, in lws_cgi_write_split_stdout_headers()
|
/third_party/libwebsockets/lib/roles/http/client/ |
H A D | client-http.c | 230 * So this is it, we are an h2 nwsi client connection in lws_http_client_socket_service() 597 struct lws *nwsi = lws_get_network_wsi(wsi); in lws_client_interpret_server_handshake() local 761 ssl = nwsi->tls.use_ssl & LCCSCF_USE_SSL; in lws_client_interpret_server_handshake() 765 port = nwsi->c_port; in lws_client_interpret_server_handshake() 786 ssl = nwsi->tls.use_ssl & LCCSCF_USE_SSL; in lws_client_interpret_server_handshake()
|