diff options
| author | Costa Tsaousis <costa@netdata.cloud> | 2022-11-09 20:43:52 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-11-09 20:43:52 +0200 |
| commit | 96ba2dadb48439e667c62b721a6d8c41a92a5187 (patch) | |
| tree | c45ae146c1c1a55d3d63981ab04dcbefaf1c09b9 /streaming/sender.c | |
| parent | 4b39609c35fceae5374fd051c0b987eb708312f6 (diff) | |
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
Diffstat (limited to 'streaming/sender.c')
| -rw-r--r-- | streaming/sender.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/streaming/sender.c b/streaming/sender.c index 8579f81475..0682597286 100644 --- a/streaming/sender.c +++ b/streaming/sender.c @@ -165,13 +165,13 @@ void sender_commit(struct sender_state *s, BUFFER *wb) { static inline void rrdpush_sender_thread_close_socket(RRDHOST *host) { - rrdhost_flag_clear(host, RRDHOST_FLAG_RRDPUSH_SENDER_READY_4_METRICS); - rrdhost_flag_clear(host, RRDHOST_FLAG_RRDPUSH_SENDER_CONNECTED); - if(host->sender->rrdpush_sender_socket != -1) { close(host->sender->rrdpush_sender_socket); host->sender->rrdpush_sender_socket = -1; } + + rrdhost_flag_clear(host, RRDHOST_FLAG_RRDPUSH_SENDER_READY_4_METRICS); + rrdhost_flag_clear(host, RRDHOST_FLAG_RRDPUSH_SENDER_CONNECTED); } static inline void rrdpush_sender_add_host_variable_to_buffer(BUFFER *wb, const RRDVAR_ACQUIRED *rva) { |