summaryrefslogtreecommitdiffstats
path: root/streaming
diff options
context:
space:
mode:
authorStelios Fragkakis <52996999+stelfrag@users.noreply.github.com>2023-03-23 10:23:19 +0200
committerGitHub <noreply@github.com>2023-03-23 10:23:19 +0200
commitc46b8e9fcc614ce08415b00ad4ba617e40b1443e (patch)
tree872523bdac6daefd5f5082c4a160e577d762a921 /streaming
parent62d63229b55f71c4db0eaae73819c203c490c061 (diff)
Schedule node info to the cloud after child connection (#14790)
* Schedule node info to the cloud after child connection * Remove debug code * Schedule localhost node info within 5 seconds of startup. If no children are detected Or a child connects (switch to immediate localhost node info update)
Diffstat (limited to 'streaming')
-rw-r--r--streaming/receiver.c3
1 files changed, 2 insertions, 1 deletions
diff --git a/streaming/receiver.c b/streaming/receiver.c
index de205de92e..ff7a956290 100644
--- a/streaming/receiver.c
+++ b/streaming/receiver.c
@@ -437,7 +437,7 @@ static void rrdpush_receiver_replication_reset(RRDHOST *host) {
rrdhost_receiver_replicating_charts_zero(host);
}
-bool rrdhost_set_receiver(RRDHOST *host, struct receiver_state *rpt) {
+static bool rrdhost_set_receiver(RRDHOST *host, struct receiver_state *rpt) {
bool signal_rrdcontext = false;
bool set_this = false;
@@ -472,6 +472,7 @@ bool rrdhost_set_receiver(RRDHOST *host, struct receiver_state *rpt) {
rrdpush_receiver_replication_reset(host);
rrdhost_flag_clear(rpt->host, RRDHOST_FLAG_RRDPUSH_RECEIVER_DISCONNECTED);
+ aclk_queue_node_info(rpt->host, true);
set_this = true;
}