Lines Matching refs:nrbufs
199 while (pipe->nrbufs < pipe->buffers) { in splice_to_pipe()
200 int newbuf = (pipe->curbuf + pipe->nrbufs) & (pipe->buffers - 1); in splice_to_pipe()
210 pipe->nrbufs++; in splice_to_pipe()
236 } else if (pipe->nrbufs == pipe->buffers) { in add_to_pipe()
239 int newbuf = (pipe->curbuf + pipe->nrbufs) & (pipe->buffers - 1); in add_to_pipe()
241 pipe->nrbufs++; in add_to_pipe()
377 if (pipe->nrbufs == pipe->buffers) in default_file_splice_read()
446 if (sd->len < sd->total_len && pipe->nrbufs > 1) in pipe_to_sendpage()
486 while (pipe->nrbufs) { in splice_from_pipe_feed()
515 pipe->nrbufs--; in splice_from_pipe_feed()
546 while (!pipe->nrbufs) { in splice_from_pipe_next()
722 for (n = 0, idx = pipe->curbuf; left && n < pipe->nrbufs; n++, idx++) { in iter_file_splice_write()
762 pipe->nrbufs--; in iter_file_splice_write()
945 WARN_ON_ONCE(pipe->nrbufs != 0); in splice_direct_to_actor()
953 pipe_pages = pipe->buffers - pipe->nrbufs; in splice_direct_to_actor()
993 pipe->nrbufs = pipe->curbuf = 0; in splice_direct_to_actor()
1079 if (pipe->nrbufs != pipe->buffers) in wait_for_space()
1188 pipe_pages = opipe->buffers - opipe->nrbufs; in do_splice()
1456 if (pipe->nrbufs) in ipipe_prep()
1462 while (!pipe->nrbufs) { in ipipe_prep()
1494 if (pipe->nrbufs < pipe->buffers) in opipe_prep()
1500 while (pipe->nrbufs >= pipe->buffers) { in opipe_prep()
1559 if (!ipipe->nrbufs && !ipipe->writers) in splice_pipe_to_pipe()
1566 if (!ipipe->nrbufs || opipe->nrbufs >= opipe->buffers) { in splice_pipe_to_pipe()
1587 nbuf = (opipe->curbuf + opipe->nrbufs) & (opipe->buffers - 1); in splice_pipe_to_pipe()
1596 opipe->nrbufs++; in splice_pipe_to_pipe()
1598 ipipe->nrbufs--; in splice_pipe_to_pipe()
1621 opipe->nrbufs++; in splice_pipe_to_pipe()
1673 if (i >= ipipe->nrbufs || opipe->nrbufs >= opipe->buffers) in link_pipe()
1677 nbuf = (opipe->curbuf + opipe->nrbufs) & (opipe->buffers - 1); in link_pipe()
1703 opipe->nrbufs++; in link_pipe()