in_emitter: fix do_in_emitter_add_record after refactor of input chunk return codes.

Signed-off-by: Phillip Adair Stewart Whelan <[email protected]>

Author: pwhelan

plugins/in_emitter/emitter.c

@@ -106,7 +106,7 @@ int static do_in_emitter_add_record(struct em_chunk *ec,
                                ec->tag, flb_sds_len(ec->tag),
                                ec->mp_sbuf.data,
                                ec->mp_sbuf.size);
-    if (ret == -1) {
+    if (ret < 0) {
         flb_plg_error(ctx->ins, "error registering chunk with tag: %s", ec->tag);
         /* Release the echunk */
         em_chunk_destroy(ec);
@@ -237,6 +237,9 @@ static int in_emitter_ingest_ring_buffer(struct flb_input_instance *in,
         flb_sds_destroy(ec.tag);
         msgpack_sbuffer_destroy(&ec.mp_sbuf);
     }
+    if (ret < 0) {
+        return -1;
+    }
     return ret;
 }