summaryrefslogtreecommitdiffstats
path: root/streaming
diff options
context:
space:
mode:
authorEmmanuel Vasilakis <mrzammler@mm.st>2023-01-17 16:39:47 +0200
committerGitHub <noreply@github.com>2023-01-17 16:39:47 +0200
commit02f4b6cba721e871b7955780c595257dc7fa1f0f (patch)
treef418f8151836ee331557ca7600a2572e9bdf1a3d /streaming
parent99385a744a23c497ccecd26efd2373ff17522da2 (diff)
Make sure variables are streamed after SENDER_CONNECTED flag is set (#14283)
make sure vars are sent after SENDER_CONNECTED flag is set
Diffstat (limited to 'streaming')
-rw-r--r--streaming/sender.c5
1 files changed, 5 insertions, 0 deletions
diff --git a/streaming/sender.c b/streaming/sender.c
index 4a33990558..7de7142b50 100644
--- a/streaming/sender.c
+++ b/streaming/sender.c
@@ -275,6 +275,9 @@ static void rrdpush_sender_charts_and_replication_reset(RRDHOST *host) {
static void rrdpush_sender_on_connect(RRDHOST *host) {
rrdpush_sender_cbuffer_flush(host);
rrdpush_sender_charts_and_replication_reset(host);
+}
+
+static void rrdpush_sender_after_connect(RRDHOST *host) {
rrdpush_sender_thread_send_custom_host_variables(host);
}
@@ -739,6 +742,8 @@ static bool attempt_to_connect(struct sender_state *state)
// let the data collection threads know we are ready
rrdhost_flag_set(state->host, RRDHOST_FLAG_RRDPUSH_SENDER_CONNECTED);
+ rrdpush_sender_after_connect(state->host);
+
return true;
}