decode_statsd: Process further tag candidates if errornous part is found

Signed-off-by: Hiroshi Hatake <[email protected]>
fluent · Aug 7, 2024 · 9297d26 · 9297d26
1 parent b8a234b
commit 9297d26
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/cmt_decode_statsd.c b/src/cmt_decode_statsd.c
@@ -139,7 +139,7 @@ static int decode_labels(struct cmt *cmt,
         while (label_kv != NULL) {
             colon = strchr(label_kv, ':');
             if (colon == NULL) {
-                break;
+                goto retry;
             }
             label_k = cfl_sds_create_len(label_kv, colon - label_kv);
             if (label_k == NULL) {
@@ -184,6 +184,7 @@ static int decode_labels(struct cmt *cmt,
 
             cfl_sds_destroy(label_k);
 
+        retry:
             label_kv = strtok_r(NULL, ",", &store);
         }
     }