in_emitter: return on error in loop in in_emitter_ingest_ring_buffer.

pwhelan · pwhelan · commit ff42ee90c571 · 2025-02-24T20:00:53.000-03:00
Signed-off-by: Phillip Whelan &lt;phillip.whelan@chronosphere.io&gt;
diff --git a/plugins/in_emitter/emitter.c b/plugins/in_emitter/emitter.c
@@ -236,8 +236,6 @@ static int in_emitter_ingest_ring_buffer(struct flb_input_instance *in,
                                    ec.mp_sbuf.size);
         flb_sds_destroy(ec.tag);
         msgpack_sbuffer_destroy(&ec.mp_sbuf);
-    }
-    if (ret < 0) {
         return -1;
     }
     return ret;

Original file line number	Diff line number	Diff line change
`@@ -236,8 +236,6 @@ static int in_emitter_ingest_ring_buffer(struct flb_input_instance *in,`
`236`	`236`	`ec.mp_sbuf.size);`
`237`	`237`	`flb_sds_destroy(ec.tag);`
`238`	`238`	`msgpack_sbuffer_destroy(&ec.mp_sbuf);`
`239`		`- }`
`240`		`- if (ret < 0) {`
`241`	`239`	`return -1;`
`242`	`240`	`}`
`243`	`241`	`return ret;`