diff options
Diffstat (limited to 'src/line_protocol_output.cpp')
| -rw-r--r-- | src/line_protocol_output.cpp | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/src/line_protocol_output.cpp b/src/line_protocol_output.cpp index 2e49ed1..99c1de0 100644 --- a/src/line_protocol_output.cpp +++ b/src/line_protocol_output.cpp @@ -307,16 +307,11 @@ void output_line_protocol_topk(struct fieldstat_instance *instance, struct metri used_len += add_user_tag_set(metric, line_buf + used_len, line_buf_size - used_len); used_len += snprintf(line_buf + used_len, line_buf_size - used_len, " "); - printf("remaining line_buf_size: %zu\n", line_buf_size - used_len); - // TODO: <key>=value,<key>=value... heavy_keeper_archieve_before_output(metric); struct heavy_keeper *hk = choose_heavy_keeper_for_output(metric); used_len += add_field_set_for_topk(hk, line_buf + used_len, line_buf_size - used_len); - if (used_len == 0) { - printf("ERROR: line protocol has no space in UDP buffer for writing field."); // line protocol packet has at lease one field - } - used_len += snprintf(line_buf + used_len, line_buf_size - used_len, "\n"); // TODO: 这个回车是干嘛的？ + used_len += snprintf(line_buf + used_len, line_buf_size - used_len, "\n"); send_line_buf(&instance->line_protocol_output, line_buf, used_len); } |