Add seperate err msg for Unpack issue

Signed-off-by: Athish Pranav D <[email protected]>

Author: Athishpranav2003

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>

plugins/filter_parser/filter_parser.c

@@ -101,11 +101,11 @@ static int configure(struct filter_parser_ctx *ctx,
     int ret;
     struct mk_list *head;
     struct flb_kv *kv;
-    ctx->hash_value_field = NULL;
 
     ctx->key_name = NULL;
     ctx->reserve_data = FLB_FALSE;
     ctx->preserve_key = FLB_FALSE;
+    ctx->hash_value_field = NULL;
     mk_list_init(&ctx->parsers);
 
     if (flb_filter_config_map_set(f_ins, ctx) < 0) {
@@ -353,7 +353,7 @@ static int cb_parser_filter(const void *data, size_t bytes,
                     out_buf = strdup(parsed_buf);
                     out_size = parsed_size;
                 }
-                if (ctx->hash_value_field!=NULL) {
+                if (ctx->hash_value_field != NULL) {
                     char *new_buf = NULL;
                     size_t new_size;
                     int ret;

src/flb_msgpack_append_message.c

@@ -111,14 +111,15 @@ int flb_msgpack_append_map_to_record(char **result_buffer,
     message_entry.key.via.str.ptr  = message_key_name;
 
     msgpack_unpacked_init(&unpacker);
-    if ((i=msgpack_unpack_next(&unpacker, map_data, map_size, &off)) !=
-        MSGPACK_UNPACK_SUCCESS ) {
+    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;