Skip to content

Commit 5933505

Browse files
committed
out_flowcounter: Fix incorrect bytes calcuation
Signed-off-by: Hiroshi Hatake <[email protected]>
1 parent 9aa256b commit 5933505

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

plugins/out_flowcounter/out_flowcounter.c

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -216,6 +216,9 @@ static void out_fcount_flush(struct flb_event_chunk *event_chunk,
216216
while ((ret = flb_log_event_decoder_next(
217217
&log_decoder,
218218
&log_event)) == FLB_EVENT_DECODER_SUCCESS) {
219+
/* bytes consumed in the event stream so far */
220+
off = log_decoder.offset;
221+
219222
if (ctx->event_based) {
220223
flb_time_copy(&tm, &log_event.timestamp);
221224
}

0 commit comments

Comments
 (0)