Add seperate err msg for Unpack issue

Signed-off-by: Athish Pranav D <[email protected]>
fluent · Sep 2, 2024 · 9ecd6cf · 9ecd6cf
1 parent e7b5c29
commit 9ecd6cf
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/include/fluent-bit/flb_msgpack_append_message.h b/include/fluent-bit/flb_msgpack_append_message.h
@@ -25,6 +25,7 @@
 #define FLB_MAP_NOT_MODIFIED    -1
 #define FLB_MAP_EXPANSION_ERROR -2
 #define FLB_MAP_EXPANSION_INVALID_VALUE_TYPE -3
+#define FLB_MSGPACK_UNPACK_ERROR -4
 
 #include <fluent-bit/flb_pack.h>
 #include <msgpack/unpack.h>

diff --git a/src/flb_msgpack_append_message.c b/src/flb_msgpack_append_message.c
@@ -114,11 +114,11 @@ int flb_msgpack_append_map_to_record(char **result_buffer,
     if ((i=msgpack_unpack_next(&unpacker, map_data, map_size, &off)) !=
         MSGPACK_UNPACK_SUCCESS ) {
         msgpack_unpacked_destroy(&unpacker);
-        return FLB_MAP_EXPANSION_ERROR;
+        return FLB_MSGPACK_UNPACK_ERROR;
     }
     if (unpacker.data.type != MSGPACK_OBJECT_MAP) {
         msgpack_unpacked_destroy(&unpacker);
-        return FLB_MAP_EXPANSION_ERROR;
+        return FLB_MSGPACK_UNPACK_ERROR;
     }
 
     message_entry.val = unpacker.data;