X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=lib%2Foutput_buffer.c;h=f6c304bdf02efdfa6c229bfefdc6043002b72893;hb=3a03f0cf8005221d90045bed762e7d5e38f944fb;hp=03cd848bfd9f05aa9dbace684766503b17d6ea55;hpb=f672ef67527a27eb2bbc59aa6041a42d88a00838;p=fio.git diff --git a/lib/output_buffer.c b/lib/output_buffer.c index 03cd848b..f6c304bd 100644 --- a/lib/output_buffer.c +++ b/lib/output_buffer.c @@ -3,7 +3,7 @@ #include #include "output_buffer.h" -#include "../log.h" +#include "../minmax.h" #define BUF_INC 1024 @@ -17,32 +17,26 @@ void buf_output_init(struct buf_output *out) void buf_output_free(struct buf_output *out) { free(out->buf); + buf_output_init(out); } size_t buf_output_add(struct buf_output *out, const char *buf, size_t len) { - while (out->max_buflen - out->buflen < len) { + if (out->max_buflen - out->buflen < len) { + size_t need = len - (out->max_buflen - out->buflen); size_t old_max = out->max_buflen; - out->max_buflen += BUF_INC; + need = max((size_t) BUF_INC, need); + out->max_buflen += need; out->buf = realloc(out->buf, out->max_buflen); - memset(&out->buf[old_max], 0, BUF_INC); + + old_max = max(old_max, out->buflen + len); + if (old_max + need > out->max_buflen) + need = out->max_buflen - old_max; + memset(&out->buf[old_max], 0, need); } memcpy(&out->buf[out->buflen], buf, len); out->buflen += len; return len; } - -size_t buf_output_flush(struct buf_output *out) -{ - size_t ret = 0; - - if (out->buflen) { - ret = log_info_buf(out->buf, out->buflen); - memset(out->buf, 0, out->max_buflen); - out->buflen = 0; - } - - return ret; -}