| /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/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 | 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-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 | 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/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/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/ |
| 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/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/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()
|