summaryrefslogtreecommitdiffstats
path: root/streaming
diff options
context:
space:
mode:
authorEmmanuel Vasilakis <mrzammler@mm.st>2022-05-03 10:37:14 +0300
committerGitHub <noreply@github.com>2022-05-03 10:37:14 +0300
commit0996abc7c0ef80bf9d128cfe52b69082831c61e4 (patch)
treea48f1a15cb339429ea01fe4a81e6129b127bcda5 /streaming
parent22863c42b9ccf59d340f39c7719b6ef19b455a16 (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')
-rw-r--r--streaming/receiver.c2
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);