Lines Matching defs:wsi
68 lws_proxy_clean_conn_ss(struct lws *wsi)
71 lws_ss_handle_t *h = (lws_ss_handle_t *)wsi->a.opaque_user_data;
74 if (!wsi)
78 conn->ss->wsi = NULL;
88 if (m->conn->wsi) /* if possible, request client conn write */
89 lws_callback_on_writable(m->conn->wsi);
98 if (!conn || !conn->wsi || !conn->ss)
101 pt = &conn->wsi->a.context->pt[(int)conn->wsi->tsi];
109 __lws_lc_tag_append(&conn->wsi->lc, lws_ss_tag(conn->ss));
156 if (!m->conn->onward_in_flow_control && m->ss->wsi &&
161 lws_wsi_tag(m->ss->wsi),
166 * stop taking in rx once the onward wsi rx is above the
169 lws_rx_flow_control(m->ss->wsi, 0);
173 if (m->conn->wsi) /* if possible, request client conn write */
174 lws_callback_on_writable(m->conn->wsi);
204 if (lws_ss_deserialize_tx_payload(m->conn->dsh, m->ss->wsi,
243 * the accepted incoming proxy link wsi tag name to be
271 if (!m->conn->wsi) {
282 lwsl_info("%s: ss DESTROYING, wsi up\n", __func__);
294 if (lws_ss_serialize_state(m->conn->wsi, m->conn->dsh, state, ack))
301 if (m->conn->wsi) /* if possible, request client conn write */
302 lws_callback_on_writable(m->conn->wsi);
317 if (m->conn->wsi) /* if possible, request client conn write */
318 lws_callback_on_writable(m->conn->wsi);
326 callback_ss_proxy(struct lws *wsi, enum lws_callback_reasons reason,
358 if (lws_fi(&wsi->fic, "ssproxy_client_adopt_oom"))
369 pss->conn->wsi = wsi;
370 wsi->bound_ss_proxy_conn = 1; /* opaque is conn */
379 lws_set_timeout(wsi, PENDING_TIMEOUT_AWAITING_CLIENT_HS_SEND, 3);
389 * the client unix domain socket connection (wsi / conn->wsi)
393 * But right now, the SS and possibly the SS onward wsi are
397 assert(conn->wsi == wsi);
398 conn->wsi = NULL;
401 lws_wsi_tag(wsi));
404 lws_set_opaque_user_data(wsi, NULL);
407 * The current wsi is decoupled from the pss / conn and
415 struct lws *cw = conn->ss->wsi;
420 lwsl_info("%s: destroying %s, wsi %s\n",
422 lws_wsi_tag(conn->ss->wsi));
426 conn->ss->wsi = NULL;
428 if (cw && wsi != cw) {
430 /* disconnect onward SS from its wsi */
435 * The wsi doing the onward connection can no
470 if (!conn || !conn->wsi) {
492 lws_get_context(wsi), conn->dsh, in, len,
507 lws_callback_on_writable(conn->wsi);
514 __func__, lws_wsi_tag(wsi), lwsi_state(wsi));
521 if (!conn || !conn->wsi)
557 rsp = lws_ss_policy_lookup(wsi->a.context,
563 lws_set_timeout(wsi, 0, 0);
644 wsi->a.context->detailed_latency_cb) {
663 wsi->detlat.acc_size =
664 wsi->detlat.req_size = si - 19;
666 wsi->detlat.latencies[
681 if (lws_fi(&wsi->fic, "ssproxy_client_write_fail"))
684 n = lws_write(wsi, (uint8_t *)cp, (unsigned int)n, LWS_WRITE_RAW);
707 conn->ss->wsi &&
711 lws_wsi_tag(conn->ss->wsi),
719 lws_rx_flow_control(conn->ss->wsi,
726 if (!lws_send_pipe_choked(wsi)) {
732 lws_callback_on_writable(wsi);
744 return lws_callback_http_dummy(wsi, reason, user, in, len);