X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=liblttngkconsumerd%2Flttngkconsumerd.c;h=b6a533c1757dc5aee7006d66c2057460d98afdd9;hp=ba26026c4458cb955ce70a5c2727a8b3b7413e48;hb=751667bdf3d5d79ca89a6dcf1a2d8155c8cfbc3c;hpb=6533b585a3a53a0b52c2da14baec5e874d1bf3bb diff --git a/liblttngkconsumerd/lttngkconsumerd.c b/liblttngkconsumerd/lttngkconsumerd.c index ba26026c4..b6a533c17 100644 --- a/liblttngkconsumerd/lttngkconsumerd.c +++ b/liblttngkconsumerd/lttngkconsumerd.c @@ -474,9 +474,7 @@ int lttng_kconsumerd_on_read_subbuffer_splice( perror("Error in file splice"); goto splice_error; } - if (ret >= len) { - len = 0; - } + len -= ret; /* This won't block, but will start writeout asynchronously */ sync_file_range(outfd, kconsumerd_fd->out_fd_offset, ret, SYNC_FILE_RANGE_WRITE);