diff options
author | Emmanuel Vasilakis <mrzammler@mm.st> | 2023-01-17 16:39:47 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-01-17 16:39:47 +0200 |
commit | 02f4b6cba721e871b7955780c595257dc7fa1f0f (patch) | |
tree | f418f8151836ee331557ca7600a2572e9bdf1a3d /streaming | |
parent | 99385a744a23c497ccecd26efd2373ff17522da2 (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.c | 5 |
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; } |