diff options
author | Emmanuel Vasilakis <mrzammler@mm.st> | 2022-05-03 10:37:14 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-05-03 10:37:14 +0300 |
commit | 0996abc7c0ef80bf9d128cfe52b69082831c61e4 (patch) | |
tree | a48f1a15cb339429ea01fe4a81e6129b127bcda5 /streaming/receiver.c | |
parent | 22863c42b9ccf59d340f39c7719b6ef19b455a16 (diff) |
Check for chart obsoletion on children re-connections (#12707)
* check for chart obsoletion on children connections
* use rrdset_is_obsolete
Diffstat (limited to 'streaming/receiver.c')
-rw-r--r-- | streaming/receiver.c | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/streaming/receiver.c b/streaming/receiver.c index 1fcef26ff9..5cba2c9267 100644 --- a/streaming/receiver.c +++ b/streaming/receiver.c @@ -646,6 +646,7 @@ static int rrdpush_receive(struct receiver_state *rpt) rpt->host->hostname); } } + rpt->host->trigger_chart_obsoletion_check = now_realtime_sec(); rrdhost_unlock(rpt->host); // call the plugins.d processor to receive the metrics @@ -686,6 +687,7 @@ static int rrdpush_receive(struct receiver_state *rpt) if(health_enabled == CONFIG_BOOLEAN_AUTO) rpt->host->health_enabled = 0; } + rpt->host->trigger_chart_obsoletion_check = 0; rrdhost_unlock(rpt->host); if (rpt->host->receiver == rpt) { rrdpush_sender_thread_stop(rpt->host); |