Skip to content

Commit

Permalink
input_chunk: info level instead of debug for chunk removal msg (fluen…
Browse files Browse the repository at this point in the history
…t#6719)

Signed-off-by: Wesley Pettit <wppttt@amazon.com>
  • Loading branch information
PettitWesley authored and EC2 Default User committed Jun 8, 2023
1 parent 6e2adce commit e28b273
Showing 1 changed file with 11 additions and 5 deletions.
16 changes: 11 additions & 5 deletions src/flb_input_chunk.c
Original file line number Diff line number Diff line change
Expand Up @@ -584,9 +584,9 @@ int flb_input_chunk_find_space_new_data(struct flb_input_chunk *ic,
FS_CHUNK_SIZE_DEBUG_MOD(o_ins, old_ic, -old_ic_bytes);
o_ins->fs_chunks_size -= old_ic_bytes;

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

if (flb_routes_mask_is_empty(old_ic->routes_mask)) {
if (old_ic->task != NULL) {
Expand All @@ -597,12 +597,18 @@ int flb_input_chunk_find_space_new_data(struct flb_input_chunk *ic,
if (old_ic->task->users == 0) {
flb_debug("[task] drop task_id %d with no active route from input plugin %s",
old_ic->task->id, ic->in->name);
/* end-user friendly message */
flb_info("[input chunk] remove chunk %s with size %zd bytes from input plugin %s to output plugin %s "
"to place the incoming data with size %zu bytes, total_limit_size=%zu, task_id=%d",
flb_input_chunk_get_name(old_ic), old_ic_bytes, ic->in->name, o_ins->name, chunk_size,
o_ins->total_limit_size, old_ic->task->id);
flb_task_destroy(old_ic->task, FLB_TRUE);
}
}
else {
flb_debug("[input chunk] drop chunk %s with no output route from input plugin %s",
flb_input_chunk_get_name(old_ic), ic->in->name);
flb_info("[input chunk] remove chunk %s with size %zd bytes from input plugin %s to output plugin %s "
"to place the incoming data with size %zu bytes, total_limit_size=%zu", flb_input_chunk_get_name(old_ic),
old_ic_bytes, ic->in->name, o_ins->name, chunk_size, o_ins->total_limit_size);
flb_input_chunk_destroy(old_ic, FLB_TRUE);
}
}
Expand Down

0 comments on commit e28b273

Please sign in to comment.