Lines Matching refs:pss
108 struct pss { struct
249 lws_metrics_om_ac_stash(struct pss *pss, const char *buf, size_t len) in lws_metrics_om_ac_stash() argument
253 q = lwsac_use(&pss->ac, LWS_PRE + len + 2, LWS_PRE + len + 2); in lws_metrics_om_ac_stash()
255 lwsac_free(&pss->ac); in lws_metrics_om_ac_stash()
262 pss->tot += len; in lws_metrics_om_ac_stash()
273 lws_metrics_om_format(struct pss *pss, lws_metric_pub_t *pub, const char *nm) in lws_metrics_om_format() argument
294 lws_metrics_om_ac_stash(pss, buf, in lws_metrics_om_format()
324 return lws_metrics_om_ac_stash(pss, buf, lws_ptr_diff_size_t(p, buf)); in lws_metrics_om_format()
330 struct pss *pss = (struct pss *)user; in append_om_metric() local
347 return lws_metrics_om_format(pss, pub, nm); in append_om_metric()
387 ome_prepare(struct lws_context *ctx, struct pss *pss) in ome_prepare() argument
393 pss->tot = 0; in ome_prepare()
414 if (lws_metrics_om_ac_stash(pss, (const char *)buf + LWS_PRE, in ome_prepare()
425 if (lws_metrics_om_ac_stash(pss, (const char *)buf + LWS_PRE, in ome_prepare()
439 if (lws_metrics_om_ac_stash(pss, in ome_prepare()
448 if (lws_metrics_foreach(ctx, pss, append_om_metric)) in ome_prepare()
454 if (lws_metrics_om_ac_stash(pss, (char *)buf + LWS_PRE, in ome_prepare()
458 pss->walk = pss->ac; in ome_prepare()
475 struct pss *pss = (struct pss *)user; in callback_lws_openmetrics_export() local
481 ome_prepare(cx, pss); in callback_lws_openmetrics_export()
487 pss->tot, &p, end) || in callback_lws_openmetrics_export()
496 lwsac_free(&pss->ac); in callback_lws_openmetrics_export()
500 if (!pss->walk) in callback_lws_openmetrics_export()
504 ip = (uint8_t *)pss->walk + in callback_lws_openmetrics_export()
505 lwsac_sizeof(pss->walk == pss->ac) + LWS_PRE; in callback_lws_openmetrics_export()
509 if (m > lwsac_get_tail_pos(pss->walk) - in callback_lws_openmetrics_export()
510 lwsac_sizeof(pss->walk == pss->ac)) in callback_lws_openmetrics_export()
519 pss->walk = lwsac_get_next(pss->walk); in callback_lws_openmetrics_export()
520 } while (pss->walk); in callback_lws_openmetrics_export()
527 wm = pss->walk ? LWS_WRITE_HTTP : LWS_WRITE_HTTP_FINAL; in callback_lws_openmetrics_export()
533 if (!pss->walk) { in callback_lws_openmetrics_export()
548 static struct pss *
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
557 struct pss *apss = lws_container_of(d, struct pss, list); in omc_lws_om_get_other_side_pss_client()
559 if (!strcmp(pss->proxy_path, apss->proxy_path)) in omc_lws_om_get_other_side_pss_client()
579 struct pss *pss = (struct pss *)user, *partner_pss; in callback_lws_openmetrics_prox_agg() local
649 lws_strnncpy(pss->proxy_path, (const char *)in, len, in callback_lws_openmetrics_prox_agg()
650 sizeof(pss->proxy_path)); in callback_lws_openmetrics_prox_agg()
652 if (pss->list.owner) { in callback_lws_openmetrics_prox_agg()
657 pss->wsi = wsi; in callback_lws_openmetrics_prox_agg()
661 struct pss *apss = lws_container_of(d, struct pss, list); in callback_lws_openmetrics_prox_agg()
669 lws_dll2_add_tail(&pss->list, &vhd->clients); in callback_lws_openmetrics_prox_agg()
678 lwsac_free(&pss->ac); in callback_lws_openmetrics_prox_agg()
679 lws_dll2_remove(&pss->list); in callback_lws_openmetrics_prox_agg()
684 if (!pss->walk) 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()
694 ip = (uint8_t *)pss->walk + in callback_lws_openmetrics_prox_agg()
695 lwsac_sizeof(pss->walk == partner_pss->ac) + LWS_PRE; in callback_lws_openmetrics_prox_agg()
699 if (m > lwsac_get_tail_pos(pss->walk) - in callback_lws_openmetrics_prox_agg()
700 lwsac_sizeof(pss->walk == partner_pss->ac)) in callback_lws_openmetrics_prox_agg()
709 pss->walk = lwsac_get_next(pss->walk); in callback_lws_openmetrics_prox_agg()
710 } while (pss->walk); in callback_lws_openmetrics_prox_agg()
717 wm = pss->walk ? LWS_WRITE_HTTP : LWS_WRITE_HTTP_FINAL; in callback_lws_openmetrics_prox_agg()
723 if (!pss->walk) { in callback_lws_openmetrics_prox_agg()
725 lws_dll2_remove(&pss->list); in callback_lws_openmetrics_prox_agg()
754 struct pss *pss = (struct pss *)user, *partner_pss; in callback_lws_openmetrics_prox_server() local
820 pss->greet = 1; in callback_lws_openmetrics_prox_server()
821 pss->wsi = wsi; in callback_lws_openmetrics_prox_server()
830 lws_dll2_remove(&pss->list); in callback_lws_openmetrics_prox_server()
832 pss->proxy_path, in callback_lws_openmetrics_prox_server()
834 lwsac_free(&pss->ac); 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()
843 if (pss->greet) { in callback_lws_openmetrics_prox_server()
844 pss->greet = 0; in callback_lws_openmetrics_prox_server()
845 lws_strnncpy(pss->proxy_path, (const char *)in, len, in callback_lws_openmetrics_prox_server()
846 sizeof(pss->proxy_path)); in callback_lws_openmetrics_prox_server()
850 pss->proxy_path); in callback_lws_openmetrics_prox_server()
855 lws_dll2_add_tail(&pss->list, &vhd->clients); in callback_lws_openmetrics_prox_server()
865 pss->tot = 0; in callback_lws_openmetrics_prox_server()
867 lws_metrics_om_ac_stash(pss, (const char *)in, len); in callback_lws_openmetrics_prox_server()
870 struct pss *partner_pss; in callback_lws_openmetrics_prox_server()
876 pss->walk = pss->ac; 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()
889 pss->tot, &p, end) || in callback_lws_openmetrics_prox_server()
896 partner_pss->walk = pss->ac; in callback_lws_openmetrics_prox_server()
904 if (!pss->trigger) in callback_lws_openmetrics_prox_server()
907 pss->trigger = 0; 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()
948 struct pss *pss = (struct pss *)user; in callback_lws_openmetrics_prox_client() local
1038 pss->greet = 1; in callback_lws_openmetrics_prox_client()
1045 lwsac_free(&pss->ac); in callback_lws_openmetrics_prox_client()
1053 ome_prepare(cx, pss); in callback_lws_openmetrics_prox_client()
1054 pss->walk = pss->ac; in callback_lws_openmetrics_prox_client()
1060 if (pss->greet) { in callback_lws_openmetrics_prox_client()
1078 pss->greet = 0; in callback_lws_openmetrics_prox_client()
1082 if (!pss->walk) in callback_lws_openmetrics_prox_client()
1091 first = pss->walk == pss->ac; in callback_lws_openmetrics_prox_client()
1094 ip = (uint8_t *)pss->walk + in callback_lws_openmetrics_prox_client()
1095 lwsac_sizeof(pss->walk == pss->ac) + LWS_PRE; in callback_lws_openmetrics_prox_client()
1099 if (m > lwsac_get_tail_pos(pss->walk) - in callback_lws_openmetrics_prox_client()
1100 lwsac_sizeof(pss->walk == pss->ac)) { in callback_lws_openmetrics_prox_client()
1111 pss->walk = lwsac_get_next(pss->walk); in callback_lws_openmetrics_prox_client()
1112 } while (pss->walk); in callback_lws_openmetrics_prox_client()
1120 !pss->walk); in callback_lws_openmetrics_prox_client()
1131 if (!pss->walk) { in callback_lws_openmetrics_prox_client()
1133 lwsac_free(&pss->ac); in callback_lws_openmetrics_prox_client()
1164 sizeof(struct pss),
1170 sizeof(struct pss),
1176 sizeof(struct pss),
1184 sizeof(struct pss),