in_http: allow multiple json payloads(fluent#5810)

nokute78 · edsiper · commit 902059764bae · 2022-08-15T10:26:00.000-06:00
Signed-off-by: Takahiro Yamashita &lt;nokute78@gmail.com&gt;
diff --git a/plugins/in_http/http_prot.c b/plugins/in_http/http_prot.c
@@ -194,9 +194,6 @@ int process_pack(struct flb_http *ctx, flb_sds_t tag, char *buf, size_t size)
                 flb_input_chunk_append_raw(ctx->ins, NULL, 0, mp_sbuf.data, mp_sbuf.size);
             }
             msgpack_sbuffer_destroy(&mp_sbuf);
-
-            break;
-    
         } 
         else if (result.data.type == MSGPACK_OBJECT_ARRAY) {
             obj = &result.data;
@@ -454,4 +451,4 @@ int http_prot_handle_error(struct flb_http *ctx, struct http_conn *conn,
 {
     send_response(conn, 400, "error: invalid request\n");
     return -1;
-}
+}

Original file line number	Diff line number	Diff line change
`@@ -194,9 +194,6 @@ int process_pack(struct flb_http ctx, flb_sds_t tag, char buf, size_t size)`
`194`	`194`	`flb_input_chunk_append_raw(ctx->ins, NULL, 0, mp_sbuf.data, mp_sbuf.size);`
`195`	`195`	`}`
`196`	`196`	`msgpack_sbuffer_destroy(&mp_sbuf);`
`197`		`-`
`198`		`- break;`
`199`		`-`
`200`	`197`	`}`
`201`	`198`	`else if (result.data.type == MSGPACK_OBJECT_ARRAY) {`
`202`	`199`	`obj = &result.data;`
`@@ -454,4 +451,4 @@ int http_prot_handle_error(struct flb_http ctx, struct http_conn conn,`
`454`	`451`	`{`
`455`	`452`	`send_response(conn, 400, "error: invalid request\n");`
`456`	`453`	`return -1;`
`457`		`-}`
	`454`	`+}`