Lines Matching refs:vhd
81 struct vhd { struct
102 struct vhd *bind_partner_vhd; argument
137 struct vhd *vhd = lws_container_of(sul, struct vhd, sul); in omc_connect_client() local
144 …lwsl_notice("%s: %s %s %s\n", __func__, vhd->ws_server_uri, vhd->metrics_proxy_path, vhd->ba_secre… in omc_connect_client()
146 lws_strncpy(url, vhd->ws_server_uri, sizeof(url)); in omc_connect_client()
150 vhd->ws_server_uri); in omc_connect_client()
154 i.context = vhd->cx; in omc_connect_client()
160 i.pwsi = &vhd->wsi; in omc_connect_client()
162 i.userdata = vhd; in omc_connect_client()
163 i.vhost = vhd->vhost; in omc_connect_client()
175 if (!lws_retry_sul_schedule(vhd->cx, 0, sul, &retry, in omc_connect_client()
176 omc_connect_client, &vhd->retry_count)) in omc_connect_client()
179 vhd->retry_count = 0; in omc_connect_client()
180 lws_retry_sul_schedule(vhd->cx, 0, sul, &retry, in omc_connect_client()
181 omc_connect_client, &vhd->retry_count); in omc_connect_client()
549 omc_lws_om_get_other_side_pss_client(struct vhd *vhd, struct pss *pss) in omc_lws_om_get_other_side_pss_client() argument
556 vhd->bind_partner_vhd->clients.head) { in omc_lws_om_get_other_side_pss_client()
576 struct vhd *vhd = (struct vhd *)lws_protocol_vh_priv_get( in callback_lws_openmetrics_prox_agg() local
589 vhd = lws_protocol_vh_priv_zalloc(lws_get_vhost(wsi), in callback_lws_openmetrics_prox_agg()
590 lws_get_protocol(wsi), sizeof(struct vhd)); in callback_lws_openmetrics_prox_agg()
591 if (!vhd) { in callback_lws_openmetrics_prox_agg()
596 vhd->cx = cx; in callback_lws_openmetrics_prox_agg()
606 &vhd->proxy_side_bind_name)) { in callback_lws_openmetrics_prox_agg()
617 lws_strncpy(vhd->sanity, "isagg", sizeof(vhd->sanity)); in callback_lws_openmetrics_prox_agg()
618 vhd->bind_partner_vhd = lws_vhd_find_by_pvo(cx, in callback_lws_openmetrics_prox_agg()
621 vhd->proxy_side_bind_name); in callback_lws_openmetrics_prox_agg()
622 if (vhd->bind_partner_vhd) { in callback_lws_openmetrics_prox_agg()
623 assert(!strcmp(vhd->bind_partner_vhd->sanity, "isws")); in callback_lws_openmetrics_prox_agg()
625 vhd->bind_partner_vhd->bind_partner_vhd = vhd; in callback_lws_openmetrics_prox_agg()
635 if (vhd) in callback_lws_openmetrics_prox_agg()
636 lws_sul_cancel(&vhd->sul); in callback_lws_openmetrics_prox_agg()
646 if (!vhd->bind_partner_vhd) in callback_lws_openmetrics_prox_agg()
660 vhd->bind_partner_vhd->clients.head) { in callback_lws_openmetrics_prox_agg()
669 lws_dll2_add_tail(&pss->list, &vhd->clients); in callback_lws_openmetrics_prox_agg()
689 partner_pss = omc_lws_om_get_other_side_pss_client(vhd, pss); in callback_lws_openmetrics_prox_agg()
751 struct vhd *vhd = (struct vhd *)lws_protocol_vh_priv_get( in callback_lws_openmetrics_prox_server() local
765 vhd = lws_protocol_vh_priv_zalloc(lws_get_vhost(wsi), in callback_lws_openmetrics_prox_server()
766 lws_get_protocol(wsi), sizeof(struct vhd)); in callback_lws_openmetrics_prox_server()
767 if (!vhd) { in callback_lws_openmetrics_prox_server()
772 vhd->cx = cx; in callback_lws_openmetrics_prox_server()
782 &vhd->proxy_side_bind_name)) { in callback_lws_openmetrics_prox_server()
793 lws_strncpy(vhd->sanity, "isws", sizeof(vhd->sanity)); in callback_lws_openmetrics_prox_server()
794 vhd->bind_partner_vhd = lws_vhd_find_by_pvo(cx, in callback_lws_openmetrics_prox_server()
797 vhd->proxy_side_bind_name); in callback_lws_openmetrics_prox_server()
798 if (vhd->bind_partner_vhd) { in callback_lws_openmetrics_prox_server()
799 assert(!strcmp(vhd->bind_partner_vhd->sanity, "isagg")); in callback_lws_openmetrics_prox_server()
801 vhd->bind_partner_vhd->bind_partner_vhd = vhd; in callback_lws_openmetrics_prox_server()
833 (unsigned int)vhd->clients.count); in callback_lws_openmetrics_prox_server()
837 partner_pss = omc_lws_om_get_other_side_pss_client(vhd, pss); in callback_lws_openmetrics_prox_server()
855 lws_dll2_add_tail(&pss->list, &vhd->clients); in callback_lws_openmetrics_prox_server()
877 partner_pss = omc_lws_om_get_other_side_pss_client(vhd, pss); in callback_lws_openmetrics_prox_server()
909 partner_pss = omc_lws_om_get_other_side_pss_client(vhd, pss); in callback_lws_openmetrics_prox_server()
945 struct vhd *vhd = (struct vhd *)lws_protocol_vh_priv_get( in callback_lws_openmetrics_prox_client() local
964 vhd = lws_protocol_vh_priv_zalloc(lws_get_vhost(wsi), in callback_lws_openmetrics_prox_client()
965 lws_get_protocol(wsi), sizeof(struct vhd)); in callback_lws_openmetrics_prox_client()
966 if (!vhd) in callback_lws_openmetrics_prox_client()
969 vhd->cx = cx; in callback_lws_openmetrics_prox_client()
970 vhd->vhost = lws_get_vhost(wsi); in callback_lws_openmetrics_prox_client()
979 lws_strncpy(vhd->ws_server_uri, cp, sizeof(vhd->ws_server_uri)); in callback_lws_openmetrics_prox_client()
988 lws_strncpy(vhd->metrics_proxy_path, cp, sizeof(vhd->metrics_proxy_path)); in callback_lws_openmetrics_prox_client()
997 lws_strncpy(vhd->ba_secret, cp, sizeof(vhd->ba_secret)); in callback_lws_openmetrics_prox_client()
1000 vhd->ws_server_uri, vhd->metrics_proxy_path, vhd->ba_secret); in callback_lws_openmetrics_prox_client()
1003 lws_sul_schedule(cx, 0, &vhd->sul, omc_connect_client, 1); in callback_lws_openmetrics_prox_client()
1007 if (vhd) in callback_lws_openmetrics_prox_client()
1008 lws_sul_cancel(&vhd->sul); in callback_lws_openmetrics_prox_client()
1018 if (lws_http_basic_auth_gen("metricsclient", vhd->ba_secret, in callback_lws_openmetrics_prox_client()
1068 vhd->metrics_proxy_path); in callback_lws_openmetrics_prox_client()
1069 lws_strncpy((char *)start, vhd->metrics_proxy_path, in callback_lws_openmetrics_prox_client()
1072 strlen(vhd->metrics_proxy_path), in callback_lws_openmetrics_prox_client()
1146 if (!lws_retry_sul_schedule(cx, 0, &vhd->sul, &retry, in callback_lws_openmetrics_prox_client()
1147 omc_connect_client, &vhd->retry_count)) in callback_lws_openmetrics_prox_client()
1150 vhd->retry_count = 0; in callback_lws_openmetrics_prox_client()
1151 lws_retry_sul_schedule(cx, 0, &vhd->sul, &retry, in callback_lws_openmetrics_prox_client()
1152 omc_connect_client, &vhd->retry_count); in callback_lws_openmetrics_prox_client()