fix: include changes from fluent/fluent-bit#11614

Signed-off-by: Patrick Stephens <pat@telemetryforge.io>

Author: patrick-stephens

.github/workflows/unit-tests.yaml

@@ -38,8 +38,11 @@ jobs:
               SANITIZE_ADDRESS=On
               SANITIZE_UNDEFINED=On
           - name: coverage
+            # Coverage needs more stack for some of the tests
+            # https://github.com/fluent/fluent-bit/pull/11614
             options: |
               FLB_COVERAGE=On
+              FLB_CORO_STACK_SIZE=4194304
           # Uncomment to enable additional config as needed
           # - name: memory
           #   options: |

source/src/flb_mp.c

@@ -47,27 +47,29 @@ int flb_mp_count(const void *data, size_t bytes)
 
 int flb_mp_count_remaining(const void *data, size_t bytes, size_t *remaining_bytes)
 {
-    size_t remaining;
+    size_t remaining = 0;
     int count = 0;
     mpack_reader_t reader;
 
-    mpack_reader_init_data(&reader, (const char *) data, bytes);
-    for (;;) {
-        remaining = mpack_reader_remaining(&reader, NULL);
-        if (!remaining) {
-            break;
-        }
-        mpack_discard(&reader);
-        if (mpack_reader_error(&reader)) {
-            break;
+    if (data) {
+        mpack_reader_init_data(&reader, (const char *) data, bytes);
+        for (;;) {
+            remaining = mpack_reader_remaining(&reader, NULL);
+            if (!remaining) {
+                break;
+            }
+            mpack_discard(&reader);
+            if (mpack_reader_error(&reader)) {
+                break;
+            }
+            count++;
         }
-        count++;
+        mpack_reader_destroy(&reader);
     }
 
     if (remaining_bytes) {
         *remaining_bytes = remaining;
     }
-    mpack_reader_destroy(&reader);
     return count;
 }