processor: allow processors to operate in the same input context

edsiper · edsiper · commit 3fd4ec06994e · 2024-10-28T06:50:27.000-06:00
Signed-off-by: Eduardo Silva &lt;eduardo@calyptia.com&gt;
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) {

Original file line number	Diff line number	Diff line change
`@@ -660,11 +660,13 @@ int flb_processor_run(struct flb_processor *proc,`
`660`	`660`	`return -1;`
`661`	`661`	`}`
`662`	`662`
`663`		`- if (cur_buf != data) {`
	`663`	`+ if (cur_buf != data && cur_buf != tmp_buf) {`
`664`	`664`	`cmt_destroy(cur_buf);`
`665`	`665`	`}`
`666`	`666`
`667`		`- cur_buf = (void *)tmp_buf;`
	`667`	`+ if (tmp_buf != NULL) {`
	`668`	`+ cur_buf = tmp_buf;`
	`669`	`+ }`
`668`	`670`	`}`
`669`	`671`	`}`
`670`	`672`	`else if (type == FLB_PROCESSOR_TRACES) {`