processor: allow processors to operate in the same input context

Signed-off-by: Eduardo Silva <[email protected]>
fluent · Oct 28, 2024 · 3fd4ec0 · 3fd4ec0
1 parent f0d083b
commit 3fd4ec0
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/flb_processor.c b/src/flb_processor.c
@@ -660,11 +660,13 @@ int flb_processor_run(struct flb_processor *proc,
                         return -1;
                     }
 
-                    if (cur_buf != data) {
+                    if (cur_buf != data && cur_buf != tmp_buf) {
                         cmt_destroy(cur_buf);
                     }
 
-                    cur_buf = (void *)tmp_buf;
+                    if (tmp_buf != NULL) {
+                        cur_buf = tmp_buf;
+                    }
                 }
             }
             else if (type == FLB_PROCESSOR_TRACES) {