Lines Matching defs:wsi
28 rops_handle_POLLIN_raw_proxy(struct lws_context_per_thread *pt, struct lws *wsi,
36 if (lws_has_buffered_out(wsi)) {
41 if (lws_issue_raw(wsi, NULL, 0) < 0)
51 if (lwsi_state(wsi) == LRS_WAITING_CONNECT)
56 lwsi_state(wsi) != LRS_SSL_ACK_PENDING &&
57 !(wsi->favoured_pollin &&
62 buffered = lws_buflist_aware_read(pt, wsi, &ebuf, 1, __func__);
69 wsi->seen_zero_length_recv = 1;
70 if (lws_change_pollfd(wsi, LWS_POLLIN, 0))
86 n = user_callback_handle_rxflow(wsi->a.protocol->callback,
87 wsi, lwsi_role_client(wsi) ?
90 wsi->user_space, ebuf.token,
97 if (lws_buflist_aware_finished_consuming(wsi, &ebuf, ebuf.len,
101 if (wsi->favoured_pollin &&
104 wsi->favoured_pollin = 0;
111 if (lws_handle_POLLOUT_event(wsi, pollfd)) {
117 if (lws_http_client_socket_service(wsi, pollfd))
124 lws_close_free_wsi(wsi, LWS_CLOSE_STATUS_NOSTATUS, "raw svc fail");
130 rops_adoption_bind_raw_proxy(struct lws *wsi, int type,
143 wsi->udp = lws_malloc(sizeof(*wsi->udp), "udp struct");
146 lws_role_transition(wsi, LWSIFR_SERVER, (type & LWS_ADOPT_ALLOW_SSL) ?
151 lws_bind_protocol(wsi, wsi->a.protocol, __func__);
154 lws_bind_protocol(wsi,
155 &wsi->a.vhost->protocols[wsi->a.vhost->raw_protocol_index],
162 rops_client_bind_raw_proxy(struct lws *wsi,
169 if (!wsi->user_space && wsi->stash->cis[CIS_METHOD])
170 if (lws_ensure_user_space(wsi))
179 lws_role_transition(wsi, LWSIFR_CLIENT, LRS_UNCONNECTED,
186 rops_handle_POLLOUT_raw_proxy(struct lws *wsi)
188 if (lwsi_state(wsi) == LRS_ESTABLISHED)
191 if (lwsi_role_client(wsi))