in_forward: fix leaks when processing metrics and traces (#9199)

Signed-off-by: Leonardo Alminana <[email protected]>
fluent · Aug 13, 2024 · e60c2f7 · e60c2f7
1 parent c7c0c09
commit e60c2f7
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/plugins/in_forward/fw_prot.c b/plugins/in_forward/fw_prot.c
@@ -1122,6 +1122,7 @@ static int append_log(struct flb_input_instance *ins, struct fw_conn *conn,
         flb_input_metrics_append(conn->in,
                                  out_tag, flb_sds_len(out_tag),
                                  cmt);
+        cmt_decode_msgpack_destroy(cmt);
     }
     else if (event_type == FLB_EVENT_TYPE_TRACES) {
         off = 0;
@@ -1133,6 +1134,8 @@ static int append_log(struct flb_input_instance *ins, struct fw_conn *conn,
         flb_input_trace_append(ins,
                                out_tag, flb_sds_len(out_tag),
                                ctr);
+
+        ctr_decode_msgpack_destroy(ctr);
     }
 
     return 0;