From 96ba2dadb48439e667c62b721a6d8c41a92a5187 Mon Sep 17 00:00:00 2001 From: Costa Tsaousis Date: Wed, 9 Nov 2022 20:43:52 +0200 Subject: break active-active loop from replicating non-existing child to each other (#13968) break active-active loop from replicating non-existing child to each-other --- streaming/receiver.c | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'streaming/receiver.c') diff --git a/streaming/receiver.c b/streaming/receiver.c index ed5d51fe3d..40673f05b4 100644 --- a/streaming/receiver.c +++ b/streaming/receiver.c @@ -726,6 +726,9 @@ static int rrdpush_receive(struct receiver_state *rpt) rrdcontext_host_child_connected(rpt->host); + + rrdhost_flag_clear(rpt->host, RRDHOST_FLAG_RRDPUSH_RECEIVER_DISCONNECTED); + size_t count = streaming_parser(rpt, &cd, fp_in, fp_out, #ifdef ENABLE_HTTPS (rpt->ssl.conn) ? &rpt->ssl : NULL @@ -734,6 +737,8 @@ static int rrdpush_receive(struct receiver_state *rpt) #endif ); + rrdhost_flag_set(rpt->host, RRDHOST_FLAG_RRDPUSH_RECEIVER_DISCONNECTED); + log_stream_connection(rpt->client_ip, rpt->client_port, rpt->key, rpt->host->machine_guid, rpt->hostname, "DISCONNECTED"); -- cgit v1.2.3