input_chunk: update bytes counter for backoff logs (#2771)

Signed-off-by: Jeff Luo <[email protected]>
fluent · Nov 15, 2020 · 221140a · 221140a
1 parent 6116421
commit 221140a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/flb_input_chunk.c b/src/flb_input_chunk.c
@@ -308,6 +308,7 @@ struct flb_input_chunk *flb_input_chunk_map(struct flb_input_instance *in,
                                             void *chunk)
 {
     uint64_t chunk_routes_mask;
+    ssize_t bytes;
 
 #ifdef FLB_HAVE_METRICS
     int ret;
@@ -351,6 +352,9 @@ struct flb_input_chunk *flb_input_chunk_map(struct flb_input_instance *in,
     }
     ic->routes_mask = chunk_routes_mask;
 
+    bytes = flb_input_chunk_get_size(ic);
+    flb_input_chunk_update_output_instances(ic, bytes);
+
     return ic;
 }