in_forward: fix checking return value of cmt_decode_msgpack_create(#8000

) (#8015) Signed-off-by: Takahiro Yamashita <[email protected]>
fluent · Oct 17, 2023 · 79e9730 · 79e9730
1 parent 7833942
commit 79e9730
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/plugins/in_forward/fw_prot.c b/plugins/in_forward/fw_prot.c
@@ -778,7 +778,8 @@ int fw_prot_process(struct flb_input_instance *ins, struct fw_conn *conn)
                         }
                         else if (event_type == FLB_EVENT_TYPE_METRICS) {
                             ret = cmt_decode_msgpack_create(&cmt, (char *) data, len, &off);
-                            if (ret == -1) {
+                            if (ret != CMT_DECODE_MSGPACK_SUCCESS) {
+                                flb_error("cmt_decode_msgpack_create failed. ret=%d", ret);
                                 msgpack_unpacked_destroy(&result);
                                 msgpack_unpacker_free(unp);
                                 flb_sds_destroy(out_tag);