diff options
| author | Costa Tsaousis <costa@netdata.cloud> | 2023-09-16 16:00:42 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-09-16 16:00:42 +0300 |
| commit | 11de4e4ab77177bc1a4f9b6358151adf525f2ca0 (patch) | |
| tree | 96cc31e5e41103e85f7935eb7bb04b571668c246 /streaming | |
| parent | 638d9b064d0f7818a3672f26163413efff9f30a3 (diff) | |
Functions: allow collectors to be restarted (#15983)
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/rrdpush.c | 6 |
1 files changed, 6 insertions, 0 deletions
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); |