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->buffers - pipe->nrbufs) << PAGE_SHIFT); in splice_direct_to_actor()
992 pipe->nrbufs = pipe->curbuf = 0; in splice_direct_to_actor()
1078 if (pipe->nrbufs != pipe->buffers) in wait_for_space()
1448 if (pipe->nrbufs) in ipipe_prep()
1454 while (!pipe->nrbufs) { in ipipe_prep()
1486 if (pipe->nrbufs < pipe->buffers) in opipe_prep()
1492 while (pipe->nrbufs >= pipe->buffers) { in opipe_prep()
1551 if (!ipipe->nrbufs && !ipipe->writers) in splice_pipe_to_pipe()
1558 if (!ipipe->nrbufs || opipe->nrbufs >= opipe->buffers) { in splice_pipe_to_pipe()
1579 nbuf = (opipe->curbuf + opipe->nrbufs) & (opipe->buffers - 1); in splice_pipe_to_pipe()
1588 opipe->nrbufs++; in splice_pipe_to_pipe()
1590 ipipe->nrbufs--; in splice_pipe_to_pipe()
1613 opipe->nrbufs++; in splice_pipe_to_pipe()
1665 if (i >= ipipe->nrbufs || opipe->nrbufs >= opipe->buffers) in link_pipe()
1669 nbuf = (opipe->curbuf + opipe->nrbufs) & (opipe->buffers - 1); in link_pipe()
1695 opipe->nrbufs++; in link_pipe()