Lines Matching refs:wsi
29 lws_raw_skt_connect(struct lws *wsi)
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->role_ops->adoption_cb[lwsi_role_server(wsi)],
65 wsi->user_space, NULL, 0);
67 lws_inform_client_conn_fail(wsi, (void *)"user", 4);
71 lws_set_timeout(wsi, NO_PENDING_TIMEOUT, 0);
72 lwsi_set_state(wsi, LRS_ESTABLISHED);
79 rops_handle_POLLIN_raw_skt(struct lws_context_per_thread *pt, struct lws *wsi,
90 if (lws_has_buffered_out(wsi)) {
95 if (lws_issue_raw(wsi, NULL, 0) < 0)
107 if (!lwsi_role_client(wsi) && lwsi_state(wsi) != LRS_ESTABLISHED) {
109 lwsl_wsi_debug(wsi, "wsistate 0x%x\n", (int)wsi->wsistate);
111 if (lwsi_state(wsi) != LRS_SSL_INIT)
112 if (lws_server_socket_service_ssl(wsi,
122 !(wsi->favoured_pollin &&
125 lwsl_wsi_debug(wsi, "POLLIN: state 0x%x", lwsi_state(wsi));
127 switch (lwsi_state(wsi)) {
138 n = lws_raw_skt_connect(wsi);
151 switch (lws_socks5c_handle_state(wsi, pollfd, &cce)) {
155 lws_inform_client_conn_fail(wsi, (void *)cce, strlen(cce));
158 lwsi_set_state(wsi, LRS_ESTABLISHED);
159 lws_client_connect_4_established(wsi, NULL, 0);
177 buffered = lws_buflist_aware_read(pt, wsi, &ebuf, 1, __func__);
180 if (wsi->unix_skt)
182 lwsl_wsi_info(wsi, "read 0 len");
183 wsi->seen_zero_length_recv = 1;
184 if (lws_change_pollfd(wsi, LWS_POLLIN, 0))
202 if (lws_fi(&wsi->fic, "udp_rx_loss")) {
208 n = user_callback_handle_rxflow(wsi->a.protocol->callback,
209 wsi, LWS_CALLBACK_RAW_RX,
210 wsi->user_space, ebuf.token,
216 lwsl_wsi_info(wsi, "LWS_CALLBACK_RAW_RX_fail");
220 if (lws_buflist_aware_finished_consuming(wsi, &ebuf, ebuf.len,
228 if (wsi->favoured_pollin &&
231 wsi->favoured_pollin = 0;
239 if (lwsi_state(wsi) == LRS_WAITING_CONNECT) {
240 if (!lws_client_connect_3_connect(wsi, NULL, NULL, 0, NULL))
243 if (lws_raw_skt_connect(wsi) < 0)
248 if (lwsi_state(wsi) == LRS_WAITING_SSL)
252 if (lws_change_pollfd(wsi, LWS_POLLOUT, 0))
256 wsi->could_have_pending = 0;
258 n = user_callback_handle_rxflow(wsi->a.protocol->callback,
259 wsi, LWS_CALLBACK_RAW_WRITEABLE,
260 wsi->user_space, NULL, 0);
269 lws_close_free_wsi(wsi, LWS_CLOSE_STATUS_NOSTATUS, "raw svc fail");
276 rops_adoption_bind_raw_skt(struct lws *wsi, int type, const char *vh_prot_name)
287 if ((type & LWS_ADOPT_FLAG_UDP) && !wsi->udp) {
291 wsi->udp = lws_malloc(sizeof(*wsi->udp), "udp struct");
292 if (!wsi->udp)
294 memset(wsi->udp, 0, sizeof(*wsi->udp));
298 lws_role_transition(wsi, 0, (type & LWS_ADOPT_ALLOW_SSL) ? LRS_SSL_INIT :
302 lws_bind_protocol(wsi, wsi->a.protocol, __func__);
305 lws_bind_protocol(wsi,
306 &wsi->a.vhost->protocols[wsi->a.vhost->raw_protocol_index],
315 rops_client_bind_raw_skt(struct lws *wsi,
322 if (!wsi->user_space && wsi->stash->cis[CIS_METHOD])
323 if (lws_ensure_user_space(wsi))
333 lws_role_transition(wsi, LWSIFR_CLIENT, LRS_UNCONNECTED,