diff options
| author |   Matus Fabian <matfabia@cisco.com> | 2024-06-28 16:11:04 +0200 |
|---|---|---|
| committer |   Florin Coras <florin.coras@gmail.com> | 2024-07-23 20:37:29 +0000 |
| commit | 5c4c1b63b9ba4c7b0d6f72833a8d706792c8dd9d (patch) | |
| tree | 8f65718e4b0d5a3cf562d877cc4f5efe9be75841 /src | |
| parent | d086a3650eea95056e738e2cc5dc18ce6edc278b (diff) | |
prom: concurrent connections fix
Type: fix
Change-Id: I57814edb735e9dac916f2e01de95ccfb739ce655
Signed-off-by: Matus Fabian <matfabia@cisco.com>
Diffstat (limited to 'src')
| -rw-r--r-- | src/plugins/prom/prom.c | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/src/plugins/prom/prom.c b/src/plugins/prom/prom.c index 76899a2fd12..475e98b1038 100644 --- a/src/plugins/prom/prom.c +++ b/src/plugins/prom/prom.c @@ -208,7 +208,7 @@ static uword prom_scraper_process (vlib_main_t *vm, vlib_node_runtime_t *rt, vlib_frame_t *f) { - uword *event_data = 0, event_type; + uword *event_data = 0, event_type, *sh_as_uword; prom_main_t *pm = &prom_main; hss_session_handle_t sh; f64 timeout = 10000.0; @@ -223,12 +223,15 @@ prom_scraper_process (vlib_main_t *vm, vlib_node_runtime_t *rt, /* timeout, do nothing */ break; case PROM_SCRAPER_EVT_RUN: - sh.as_u64 = event_data[0]; vec_reset_length (pm->stats); pm->stats = scrape_stats_segment (pm->stats, pm->stats_patterns, pm->used_only); - session_send_rpc_evt_to_thread_force (sh.thread_index, - send_data_to_hss_rpc, &sh); + vec_foreach (sh_as_uword, event_data) + { + sh.as_u64 = (u64) *sh_as_uword; + session_send_rpc_evt_to_thread_force ( + sh.thread_index, send_data_to_hss_rpc, sh_as_uword); + } pm->last_scrape = vlib_time_now (vm); break; default: |