Lines Matching refs:ss
39 * stashes pending packets in all four directions (c->p, p->c, p->ss, ss->p).
63 lws_ss_handle_t *ss;
77 if (conn && conn->ss)
78 conn->ss->wsi = NULL;
98 if (!conn || !conn->wsi || !conn->ss)
103 if (lws_fi(&conn->ss->fic, "ssproxy_dsh_create_oom"))
109 __lws_lc_tag_append(&conn->wsi->lc, lws_ss_tag(conn->ss));
129 if (m->ss->rideshare != m->ss->policy && m->ss->rideshare) {
130 rsp = m->ss->rideshare->streamtype;
136 * in ss -> proxy [ -> client] direction. This can fail...
139 if (lws_fi(&m->ss->fic, "ssproxy_dsh_rx_queue_oom"))
156 if (!m->conn->onward_in_flow_control && m->ss->wsi &&
157 m->ss->policy->proxy_buflen_rxflow_on_above &&
159 m->ss->policy->proxy_buflen_rxflow_on_above) {
161 lws_wsi_tag(m->ss->wsi),
163 (unsigned long)m->ss->policy->proxy_buflen,
164 (unsigned long)m->ss->policy->proxy_buflen_rxflow_on_above);
169 lws_rx_flow_control(m->ss->wsi, 0);
180 * we are transmitting buffered payload originally from the client on to the ss
191 if (!m->conn->ss || m->conn->state != LPCSPROX_OPERATIONAL) {
192 lwsl_notice("%s: ss not ready\n", __func__);
204 if (lws_ss_deserialize_tx_payload(m->conn->dsh, m->ss->wsi,
210 _lws_ss_request_tx(m->conn->ss);
244 * appended with the onward ss tag information now we
249 dsh_size = m->ss->policy->proxy_buflen ?
250 m->ss->policy->proxy_buflen : 32768;
253 __func__, lws_ss_tag(m->ss),
282 lwsl_info("%s: ss DESTROYING, wsi up\n", __func__);
367 /* dsh is allocated when the onward ss is done */
414 if (conn->ss) {
415 struct lws *cw = conn->ss->wsi;
417 * conn->ss is the onward connection SS
421 __func__, lws_ss_tag(conn->ss),
422 lws_wsi_tag(conn->ss->wsi));
424 /* sever conn relationship with ss about to be deleted */
426 conn->ss->wsi = NULL;
438 * the ss we are about to delete
443 lws_ss_destroy(&conn->ss);
445 * Conn may have gone, at ss destroy handler in
446 * ssi.state for proxied ss
451 if (conn->state == LPCSPROX_DESTROYED || !conn->ss) {
460 lwsl_debug("%s: CLOSE; %s\n", __func__, lws_ss_tag(conn->ss));
481 ssi.handle_offset = offsetof(ss_proxy_t, ss);
493 &conn->state, conn, &conn->ss, &ssi, 0);
500 if (conn->ss)
501 lws_ss_destroy(&conn->ss);
518 * of stuff we received on its behalf from the ss
540 lws_ser_wu32be((uint8_t *)&s[4], conn->ss &&
541 conn->ss->policy ?
542 conn->ss->policy->client_buflen : 0);
549 if (conn->ss) {
550 rsp = conn->ss->policy;
573 md = conn->ss->metadata;
613 if (conn->ss->conmon_json) {
614 unsigned int xlen = conn->ss->conmon_len;
622 memcpy(&p[3], conn->ss->conmon_json, xlen);
624 lws_free_set_NULL(conn->ss->conmon_json);
647 * we're fulfilling rx that came in on ss
652 * + 11 u32 ust we received from ss
706 conn->ss->policy->proxy_buflen_rxflow_on_above &&
707 conn->ss->wsi &&
709 conn->ss->policy->proxy_buflen_rxflow_off_below) {
711 lws_wsi_tag(conn->ss->wsi),
713 (unsigned long)conn->ss->policy->proxy_buflen,
714 (unsigned long)conn->ss->policy->proxy_buflen_rxflow_off_below);
719 lws_rx_flow_control(conn->ss->wsi,
780 bind = "@proxy.ss.lws";
782 bind = "/tmp/proxy.ss.lws";
796 lwsl_err("%s: Failed to create ss proxy vhost\n", __func__);