Skip to content

Commit b725d6b

Browse files
authored
input_chunk: info level instead of debug for chunk removal msg (fluent#6719)
Signed-off-by: Wesley Pettit <[email protected]>
1 parent 1c94702 commit b725d6b

File tree

1 file changed

+11
-5
lines changed

1 file changed

+11
-5
lines changed

src/flb_input_chunk.c

Lines changed: 11 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -602,9 +602,9 @@ int flb_input_chunk_find_space_new_data(struct flb_input_chunk *ic,
602602
FS_CHUNK_SIZE_DEBUG_MOD(o_ins, old_ic, -old_ic_bytes);
603603
o_ins->fs_chunks_size -= old_ic_bytes;
604604

605-
flb_debug("[input chunk] remove route of chunk %s with size %ld bytes to output plugin %s "
606-
"to place the incoming data with size %ld bytes", flb_input_chunk_get_name(old_ic),
607-
old_ic_bytes, o_ins->name, chunk_size);
605+
flb_debug("[input chunk] consider route removal for chunk %s with size %zd bytes from input plugin %s to output plugin %s "
606+
"to place the incoming data with size %zu bytes, total_limit_size=%zu", flb_input_chunk_get_name(old_ic),
607+
old_ic_bytes, ic->in->name, o_ins->name, chunk_size, o_ins->total_limit_size);
608608

609609
if (flb_routes_mask_is_empty(old_ic->routes_mask)) {
610610
if (old_ic->task != NULL) {
@@ -615,12 +615,18 @@ int flb_input_chunk_find_space_new_data(struct flb_input_chunk *ic,
615615
if (old_ic->task->users == 0) {
616616
flb_debug("[task] drop task_id %d with no active route from input plugin %s",
617617
old_ic->task->id, ic->in->name);
618+
/* end-user friendly message */
619+
flb_info("[input chunk] remove chunk %s with size %zd bytes from input plugin %s to output plugin %s "
620+
"to place the incoming data with size %zu bytes, total_limit_size=%zu, task_id=%d",
621+
flb_input_chunk_get_name(old_ic), old_ic_bytes, ic->in->name, o_ins->name, chunk_size,
622+
o_ins->total_limit_size, old_ic->task->id);
618623
flb_task_destroy(old_ic->task, FLB_TRUE);
619624
}
620625
}
621626
else {
622-
flb_debug("[input chunk] drop chunk %s with no output route from input plugin %s",
623-
flb_input_chunk_get_name(old_ic), ic->in->name);
627+
flb_info("[input chunk] remove chunk %s with size %zd bytes from input plugin %s to output plugin %s "
628+
"to place the incoming data with size %zu bytes, total_limit_size=%zu", flb_input_chunk_get_name(old_ic),
629+
old_ic_bytes, ic->in->name, o_ins->name, chunk_size, o_ins->total_limit_size);
624630
flb_input_chunk_destroy(old_ic, FLB_TRUE);
625631
}
626632
}

0 commit comments

Comments
 (0)