/third_party/libwebsockets/lib/roles/h1/ |
D | ops-h1.c | 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() 105 switch (lwsi_state(wsi)) { in lws_read_h1() 165 if (lwsi_state(wsi) != LRS_DISCARD_BODY) { in lws_read_h1() 223 if (lwsi_state(wsi) == LRS_DISCARD_BODY) { in lws_read_h1() 296 lwsl_err("%s: Unhandled state %d\n", __func__, lwsi_state(wsi)); in lws_read_h1() 335 if (lwsi_state(wsi) == LRS_DEFERRING_ACTION) in lws_h1_server_socket_service() 362 if (lwsi_state(wsi) == LRS_SSL_ACK_PENDING) in lws_h1_server_socket_service() 367 if ((lwsi_state(wsi) == LRS_ESTABLISHED || in lws_h1_server_socket_service() 368 lwsi_state(wsi) == LRS_ISSUING_FILE || in lws_h1_server_socket_service() [all …]
|
/third_party/libwebsockets/lib/roles/h2/ |
D | ops-h2.c | 135 if (lwsi_state(wsi) == LRS_PRE_WS_SERVING_ACCEPT) { in rops_handle_POLLIN_h2() 140 if (lwsi_state(wsi) == LRS_WAITING_CONNECT) { in rops_handle_POLLIN_h2() 160 if (lwsi_state(wsi) == LRS_RETURNED_CLOSE) in rops_handle_POLLIN_h2() 168 if (lwsi_state(wsi) == LRS_RETURNED_CLOSE || in rops_handle_POLLIN_h2() 169 lwsi_state(wsi) == LRS_WAITING_TO_SEND_CLOSE || in rops_handle_POLLIN_h2() 170 lwsi_state(wsi) == LRS_AWAITING_CLOSE_ACK) { in rops_handle_POLLIN_h2() 226 (lwsi_state(wsi) != LRS_ESTABLISHED && in rops_handle_POLLIN_h2() 228 lwsi_state(wsi) != LRS_H2_WAITING_TO_SEND_HEADERS))) { in rops_handle_POLLIN_h2() 294 if (lwsi_role_h2(wsi) && lwsi_state(wsi) != LRS_BODY && in rops_handle_POLLIN_h2() 295 lwsi_state(wsi) != LRS_DISCARD_BODY) in rops_handle_POLLIN_h2() [all …]
|
/third_party/libwebsockets/lib/core-net/client/ |
D | connect4.c | 123 if (lwsi_state(wsi) != LRS_ESTABLISHED) in lws_client_connect_4_established() 162 lwsi_state(wsi_piggyback)); in lws_client_connect_4_established() 167 wsi->a.vhost->name, lwsi_state(wsi)); in lws_client_connect_4_established() 177 if (lwsi_state(wsi) != LRS_H1C_ISSUE_HANDSHAKE2) in lws_client_connect_4_established() 187 if (lwsi_state(wsi) == LRS_WAITING_CONNECT && in lws_client_connect_4_established() 218 "client_h2_alpn %d", lwsi_state(wsi), in lws_client_connect_4_established() 221 if (lwsi_state(wsi) != in lws_client_connect_4_established()
|
D | connect2.c | 149 if (lwsi_state(wsi) == LRS_WAITING_DNS || 150 lwsi_state(wsi) == LRS_WAITING_CONNECT) { 224 lwsi_state(wsi)); 226 if (lwsi_state(wsi) == LRS_UNCONNECTED) {
|
/third_party/libwebsockets/lib/roles/raw-skt/ |
D | ops-raw-skt.c | 56 if (!lwsi_role_client(wsi) && lwsi_state(wsi) != LRS_ESTABLISHED) { in rops_handle_POLLIN_raw_skt() 60 if (lwsi_state(wsi) != LRS_SSL_INIT) in rops_handle_POLLIN_raw_skt() 74 lwsl_wsi_debug(wsi, "POLLIN: state 0x%x", lwsi_state(wsi)); in rops_handle_POLLIN_raw_skt() 76 switch (lwsi_state(wsi)) { in rops_handle_POLLIN_raw_skt() 180 if (lwsi_state(wsi) == LRS_WAITING_CONNECT && in rops_handle_POLLIN_raw_skt()
|
/third_party/libwebsockets/lib/core-net/ |
D | close.c | 478 if (lwsi_state(wsi) == LRS_DEAD_SOCKET) in __lws_close_free_wsi() 483 lwsi_state(wsi) == LRS_SHUTDOWN) in __lws_close_free_wsi() 524 if (lwsi_state(wsi) == LRS_WAITING_CONNECT || in __lws_close_free_wsi() 525 lwsi_state(wsi) == LRS_WAITING_DNS || in __lws_close_free_wsi() 526 lwsi_state(wsi) == LRS_H1C_ISSUE_HANDSHAKE) in __lws_close_free_wsi() 618 (lwsi_state(wsi) == LRS_WAITING_SERVER_REPLY && in __lws_close_free_wsi() 621 lwsi_state(wsi) == LRS_WAITING_DNS || in __lws_close_free_wsi() 622 lwsi_state(wsi) == LRS_WAITING_CONNECT) && in __lws_close_free_wsi() 628 lwsi_state(wsi)); in __lws_close_free_wsi() 644 lwsi_state(wsi) != LRS_SHUTDOWN && in __lws_close_free_wsi() [all …]
|
D | service.c | 98 if (lwsi_state(wsi) == LRS_FLUSHING_BEFORE_CLOSE) { in lws_handle_POLLOUT_event() 193 lwsi_state(wsi) != LRS_H2_WAITING_TO_SEND_HEADERS && in lws_handle_POLLOUT_event() 194 lwsi_state(wsi) != LRS_ISSUE_HTTP_BODY) in lws_handle_POLLOUT_event() 365 lwsi_state(wsi) != LRS_DEFERRING_ACTION) in lws_service_adjust_timeout() 544 lwsi_state(wsi) != LRS_DEFERRING_ACTION) { in lws_service_do_ripe_rxflow() 589 lwsi_state(wsi) != LRS_DEFERRING_ACTION) { in lws_service_flag_pending() 725 if (lwsi_state(wsi) == LRS_SHUTDOWN && in lws_service_fd_tsi()
|
D | wsi-timeout.c | 109 if (lwsi_state(wsi) == LRS_WAITING_SSL) in lws_sul_wsitimeout_cb() 112 if (lwsi_state(wsi) == LRS_WAITING_SERVER_REPLY) in lws_sul_wsitimeout_cb()
|
D | output.c | 48 if (lwsi_state(wsi) == LRS_FLUSHING_BEFORE_CLOSE && in lws_issue_raw() 146 if (lwsi_state(wsi) == LRS_FLUSHING_BEFORE_CLOSE) { in lws_issue_raw()
|
D | vhost.c | 1829 (lwsi_state(w) == LRS_H2_WAITING_TO_SEND_HEADERS || 1830 lwsi_state(w) == LRS_ESTABLISHED || 1831 lwsi_state(w) == LRS_IDLING)) { 1834 lwsi_state(w)); 1836 if (lwsi_state(w) == LRS_IDLING) 1859 lwsi_state(w) == LRS_ESTABLISHED) { 1890 if (lwsi_state(w) == LRS_IDLING)
|
D | wsi.c | 660 lws_role_transition(struct lws *wsi, enum lwsi_role role, enum lwsi_state state, in lws_role_transition() 1472 wsi->mux.my_sid, lwsi_state(wsi), in lws_wsi_mux_dump_waiting_children() 1642 lwsi_state(w) == LRS_H2_WAITING_TO_SEND_HEADERS) { in lws_wsi_mux_apply_queue() 1657 lwsi_state(wsi) == LRS_ESTABLISHED) { in lws_wsi_mux_apply_queue()
|
D | socks5-client.c | 285 switch (lwsi_state(wsi)) { in lws_socks5c_handle_state()
|
/third_party/libwebsockets/lib/roles/ws/ |
D | ops-ws.c | 456 if (lwsi_state(wsi) == LRS_AWAITING_CLOSE_ACK) { in lws_ws_rx_sm() 464 if (lwsi_state(wsi) == LRS_RETURNED_CLOSE) in lws_ws_rx_sm() 599 if (lwsi_state(wsi) == LRS_RETURNED_CLOSE || in lws_ws_rx_sm() 600 lwsi_state(wsi) == LRS_AWAITING_CLOSE_ACK) in lws_ws_rx_sm() 965 if (lwsi_state(wsi) == LRS_PRE_WS_SERVING_ACCEPT) { in rops_handle_POLLIN_ws() 973 if (lwsi_state(wsi) == LRS_WAITING_CONNECT) { in rops_handle_POLLIN_ws() 993 if (lwsi_state(wsi) == LRS_RETURNED_CLOSE) in rops_handle_POLLIN_ws() 999 if (lwsi_state(wsi) == LRS_RETURNED_CLOSE || in rops_handle_POLLIN_ws() 1000 lwsi_state(wsi) == LRS_WAITING_TO_SEND_CLOSE) { in rops_handle_POLLIN_ws() 1107 (lwsi_state(wsi) != LRS_ESTABLISHED && in rops_handle_POLLIN_ws() [all …]
|
D | client-parser-ws.c | 394 if (lwsi_state(wsi) == LRS_AWAITING_CLOSE_ACK) { in lws_ws_client_rx_sm() 631 if (lwsi_state(wsi) == LRS_RETURNED_CLOSE || in lws_ws_client_rx_sm() 632 lwsi_state(wsi) == LRS_WAITING_TO_SEND_CLOSE || in lws_ws_client_rx_sm() 633 lwsi_state(wsi) == LRS_AWAITING_CLOSE_ACK) in lws_ws_client_rx_sm()
|
D | client-ws.c | 74 if ((lwsi_state(wsi) != LRS_WAITING_PROXY_REPLY) && in lws_ws_handshake_client() 75 (lwsi_state(wsi) != LRS_H1C_ISSUE_HANDSHAKE) && in lws_ws_handshake_client() 76 (lwsi_state(wsi) != LRS_WAITING_SERVER_REPLY) && in lws_ws_handshake_client()
|
/third_party/libwebsockets/lib/roles/raw-proxy/ |
D | ops-raw-proxy.c | 51 if (lwsi_state(wsi) == LRS_WAITING_CONNECT) in rops_handle_POLLIN_raw_proxy() 56 lwsi_state(wsi) != LRS_SSL_ACK_PENDING && in rops_handle_POLLIN_raw_proxy() 188 if (lwsi_state(wsi) == LRS_ESTABLISHED) in rops_handle_POLLOUT_raw_proxy()
|
/third_party/libwebsockets/lib/roles/ |
D | private-lib-roles.h | 85 enum lwsi_state { enum 156 #define lwsi_state(wsi) ((enum lwsi_state)(wsi->wsistate & LRS_MASK)) macro 158 ((enum lwsi_state)(wsi->wsistate_pre_close & LRS_MASK))
|
/third_party/libwebsockets/lib/roles/mqtt/ |
D | ops-mqtt.c | 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() 83 if (lwsi_state(wsi) == LRS_RETURNED_CLOSE) in rops_handle_POLLIN_mqtt() 109 if (!(lwsi_role_client(wsi) && lwsi_state(wsi) != LRS_ESTABLISHED)) { in rops_handle_POLLIN_mqtt() 386 if (lwsi_state(wsi) == LRS_ESTABLISHED && in rops_handle_POLLOUT_mqtt()
|
D | mqtt.c | 509 if (lwsi_state(wsi) == LRS_MQTTC_AWAIT_CONNACK && in _lws_mqtt_rx_parser() 1958 if (lwsi_state(wsi) != LRS_ESTABLISHED) { in lws_mqtt_client_send_publish() 1960 lws_wsi_tag(wsi), lwsi_state(wsi)); in lws_mqtt_client_send_publish() 2115 switch (lwsi_state(wsi)) { in lws_mqtt_client_send_subcribe() 2297 switch (lwsi_state(wsi)) { in lws_mqtt_client_send_unsubcribe()
|
/third_party/libwebsockets/lib/roles/mqtt/client/ |
D | client-mqtt-handshake.c | 39 switch (lwsi_state(wsi)) { in lws_mqtt_client_send_connect() 162 lwsl_err("%s: unexpected state %d\n", __func__, lwsi_state(wsi)); in lws_mqtt_client_send_connect()
|
D | client-mqtt.c | 201 switch (lwsi_state(wsi)) { in lws_mqtt_client_socket_service()
|
/third_party/libwebsockets/lib/tls/ |
D | tls-client.c | 62 if (lwsi_state(wsi) == LRS_WAITING_SSL) { in lws_ssl_client_connect2()
|
D | tls-server.c | 139 switch (lwsi_state(wsi)) { in lws_server_socket_service_ssl()
|
/third_party/libwebsockets/lib/roles/http/client/ |
D | client-http.c | 46 switch (lwsi_state(wsi)) { in lws_http_client_socket_service() 316 if (lwsi_state(wsi) == LRS_IDLING) { in lws_http_client_socket_service() 481 __func__, lws_wsi_tag(wsi), lwsi_state(wsi)); in lws_http_client_socket_service()
|
/third_party/libwebsockets/lib/roles/http/ |
D | parsers.c | 290 if (lwsi_role_client(wsi) && lwsi_state(wsi) == LRS_UNCONNECTED) in lws_header_table_attach() 334 (unsigned long)lwsi_role(wsi), lwsi_state(wsi)); in __lws_header_table_detach() 415 if (lwsi_role_client(wsi) && lwsi_state(wsi) == LRS_UNCONNECTED) { in __lws_header_table_detach()
|