From 11de4e4ab77177bc1a4f9b6358151adf525f2ca0 Mon Sep 17 00:00:00 2001 From: Costa Tsaousis Date: Sat, 16 Sep 2023 16:00:42 +0300 Subject: Functions: allow collectors to be restarted (#15983) --- streaming/rrdpush.c | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'streaming') diff --git a/streaming/rrdpush.c b/streaming/rrdpush.c index 72c7c6786f..df7db6ed8f 100644 --- a/streaming/rrdpush.c +++ b/streaming/rrdpush.c @@ -489,6 +489,12 @@ RRDSET_STREAM_BUFFER rrdset_push_metric_initialize(RRDSET *st, time_t wall_clock rrdhost_flag_clear(host, RRDHOST_FLAG_RRDPUSH_SENDER_LOGGED_STATUS); } + if(unlikely(host_flags & RRDHOST_FLAG_GLOBAL_FUNCTIONS_UPDATED)) { + BUFFER *wb = sender_start(host->sender); + rrd_functions_expose_global_rrdpush(host, wb); + sender_commit(host->sender, wb, STREAM_TRAFFIC_TYPE_METADATA); + } + RRDSET_FLAGS rrdset_flags = __atomic_load_n(&st->flags, __ATOMIC_SEQ_CST); bool exposed_upstream = (rrdset_flags & RRDSET_FLAG_UPSTREAM_EXPOSED); bool replication_in_progress = !(rrdset_flags & RRDSET_FLAG_SENDER_REPLICATION_FINISHED); -- cgit v1.2.3