Lines Matching refs:nrbufs

200 	while (pipe->nrbufs < pipe->buffers) {  in splice_to_pipe()
201 int newbuf = (pipe->curbuf + pipe->nrbufs) & (pipe->buffers - 1); in splice_to_pipe()
211 pipe->nrbufs++; in splice_to_pipe()
237 } else if (pipe->nrbufs == pipe->buffers) { in add_to_pipe()
240 int newbuf = (pipe->curbuf + pipe->nrbufs) & (pipe->buffers - 1); in add_to_pipe()
242 pipe->nrbufs++; in add_to_pipe()
380 if (pipe->nrbufs == pipe->buffers) in default_file_splice_read()
449 if (sd->len < sd->total_len && pipe->nrbufs > 1) in pipe_to_sendpage()
489 while (pipe->nrbufs) { in splice_from_pipe_feed()
518 pipe->nrbufs--; in splice_from_pipe_feed()
549 while (!pipe->nrbufs) { in splice_from_pipe_next()
725 for (n = 0, idx = pipe->curbuf; left && n < pipe->nrbufs; n++, idx++) { in iter_file_splice_write()
766 pipe->nrbufs--; in iter_file_splice_write()
991 pipe->nrbufs = pipe->curbuf = 0; in splice_direct_to_actor()
1077 if (pipe->nrbufs != pipe->buffers) in wait_for_space()
1438 if (pipe->nrbufs) in ipipe_prep()
1444 while (!pipe->nrbufs) { in ipipe_prep()
1476 if (pipe->nrbufs < pipe->buffers) in opipe_prep()
1482 while (pipe->nrbufs >= pipe->buffers) { in opipe_prep()
1541 if (!ipipe->nrbufs && !ipipe->writers) in splice_pipe_to_pipe()
1548 if (!ipipe->nrbufs || opipe->nrbufs >= opipe->buffers) { in splice_pipe_to_pipe()
1569 nbuf = (opipe->curbuf + opipe->nrbufs) & (opipe->buffers - 1); in splice_pipe_to_pipe()
1578 opipe->nrbufs++; in splice_pipe_to_pipe()
1580 ipipe->nrbufs--; in splice_pipe_to_pipe()
1597 opipe->nrbufs++; in splice_pipe_to_pipe()
1649 if (i >= ipipe->nrbufs || opipe->nrbufs >= opipe->buffers) in link_pipe()
1653 nbuf = (opipe->curbuf + opipe->nrbufs) & (opipe->buffers - 1); in link_pipe()
1673 opipe->nrbufs++; in link_pipe()