Skip to content

Commit

Permalink
input_chunk: handle some chunk size debug messages as traces
Browse files Browse the repository at this point in the history
Signed-off-by: Eduardo Silva <[email protected]>
  • Loading branch information
edsiper committed Apr 9, 2024
1 parent 5824a43 commit 1b7a453
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions src/flb_input_chunk.c
Original file line number Diff line number Diff line change
Expand Up @@ -118,8 +118,8 @@ static ssize_t get_input_chunk_record_count(struct flb_input_chunk *input_chunk)
set_down = FLB_TRUE;
}

ret = cio_chunk_get_content(input_chunk->chunk,
&chunk_buffer,
ret = cio_chunk_get_content(input_chunk->chunk,
&chunk_buffer,
&chunk_size);

if (ret == CIO_OK) {
Expand Down Expand Up @@ -205,13 +205,13 @@ static int flb_input_chunk_release_space(
old_input_chunk->in->name);
}
else {
cmt_counter_add(output_plugin->cmt_dropped_records,
cfl_time_now(),
cmt_counter_add(output_plugin->cmt_dropped_records,
cfl_time_now(),
dropped_record_count,
1, (char *[]) {(char *) flb_output_name(output_plugin)});

flb_metrics_sum(FLB_METRIC_OUT_DROPPED_RECORDS,
dropped_record_count,
flb_metrics_sum(FLB_METRIC_OUT_DROPPED_RECORDS,
dropped_record_count,
output_plugin->metrics);
}
}
Expand Down Expand Up @@ -553,7 +553,7 @@ int flb_input_chunk_has_overlimit_routes(struct flb_input_chunk *ic,
}

FS_CHUNK_SIZE_DEBUG(o_ins);
flb_debug("[input chunk] chunk %s required %ld bytes and %ld bytes left "
flb_trace("[input chunk] chunk %s required %ld bytes and %ld bytes left "
"in plugin %s", flb_input_chunk_get_name(ic), chunk_size,
o_ins->total_limit_size -
o_ins->fs_backlog_chunks_size -
Expand Down Expand Up @@ -1739,7 +1739,7 @@ static int input_chunk_append_raw(struct flb_input_instance *in,
real_size = flb_input_chunk_get_real_size(ic);
real_diff = real_size - pre_real_size;
if (real_diff != 0) {
flb_debug("[input chunk] update output instances with new chunk size diff=%zd, records=%zu, input=%s",
flb_trace("[input chunk] update output instances with new chunk size diff=%zd, records=%zu, input=%s",
real_diff, n_records, flb_input_name(in));
flb_input_chunk_update_output_instances(ic, real_diff);
}
Expand Down Expand Up @@ -2112,7 +2112,7 @@ void flb_input_chunk_update_output_instances(struct flb_input_chunk *ic,
o_ins->fs_chunks_size += chunk_size;
ic->fs_counted = FLB_TRUE;

flb_debug("[input chunk] chunk %s update plugin %s fs_chunks_size by %ld bytes, "
flb_trace("[input chunk] chunk %s update plugin %s fs_chunks_size by %ld bytes, "
"the current fs_chunks_size is %ld bytes", flb_input_chunk_get_name(ic),
o_ins->name, chunk_size, o_ins->fs_chunks_size);
}
Expand Down

0 comments on commit 1b7a453

Please sign in to comment.