Stream Compression Fix (#19355)
clear cached buffer on reconnect
Costa Tsaousis committed
Jan 9, 2025 at 09:57 UTC
5a39ba20b5ab5cd15dfb997966942188b78259e4
4 files changed
+7
-1
src/streaming/stream-sender-api.c
+1
-1
@@ -75,7 +75,7 @@ void stream_sender_structures_free(struct rrdhost *host) {
75
freez(host->sender);
76
host->sender = NULL;
77
78
- sender_buffer_destroy(&host->stream.snd.commit);
78
+ sender_host_buffer_free(host);
79
80
rrdhost_flag_clear(host, RRDHOST_FLAG_STREAM_SENDER_INITIALIZED);
81
}
src/streaming/stream-sender-commit.c
+4
@@ -19,6 +19,10 @@ void sender_thread_buffer_free(void) {
19
sender_buffer_destroy(&commit___thread);
20
}
21
22
+void sender_host_buffer_free(RRDHOST *host) {
23
+ sender_buffer_destroy(&host->stream.snd.commit);
24
+}
25
+
26
// Collector thread starting a transmission
27
BUFFER *sender_commit_start_with_trace(struct sender_state *s, struct sender_buffer *commit, const char *func) {
28
if(unlikely(commit->used))
src/streaming/stream-sender-commit.h
+1
@@ -24,6 +24,7 @@ void sender_buffer_destroy(struct sender_buffer *commit);
24
// thread buffer for sending data upstream (to a parent)
25
26
void sender_thread_buffer_free(void);
27
+void sender_host_buffer_free(struct rrdhost *host);
28
29
// get the thread buffer
30
// this is the preferred buffer for dedicated workers sending a lot of messages (like replication)
src/streaming/stream-sender.c
+1
@@ -158,6 +158,7 @@ static void stream_sender_on_disconnect(struct sender_state *s) {
158
stream_sender_clear_parent_claim_id(s->host);
159
stream_receiver_send_node_and_claim_id_to_child(s->host);
160
stream_path_parent_disconnected(s->host);
161
+ sender_host_buffer_free(s->host);
162
}
163
164
// --------------------------------------------------------------------------------------------------------------------