Lines Matching refs:pipe
865 err = pipe_buf_confirm(cs->pipe, buf); in fuse_copy_fill()
877 if (cs->nr_segs >= cs->pipe->max_usage) in fuse_copy_fill()
973 err = pipe_buf_confirm(cs->pipe, buf); in fuse_try_move_folio()
986 if (!pipe_buf_try_steal(cs->pipe, buf)) in fuse_try_move_folio()
1022 pipe_buf_release(cs->pipe, buf); in fuse_try_move_folio()
1068 if (cs->nr_segs >= cs->pipe->max_usage) in fuse_ref_folio()
1549 struct pipe_inode_info *pipe, in fuse_dev_splice_read() argument
1561 bufs = kvmalloc_array(pipe->max_usage, sizeof(struct pipe_buffer), in fuse_dev_splice_read()
1568 cs.pipe = pipe; in fuse_dev_splice_read()
1573 if (pipe_buf_usage(pipe) + cs.nr_segs > pipe->max_usage) { in fuse_dev_splice_read()
1585 ret = add_to_pipe(pipe, &bufs[page_nr++]); in fuse_dev_splice_read()
2245 static ssize_t fuse_dev_splice_write(struct pipe_inode_info *pipe, in fuse_dev_splice_write() argument
2262 pipe_lock(pipe); in fuse_dev_splice_write()
2264 head = pipe->head; in fuse_dev_splice_write()
2265 tail = pipe->tail; in fuse_dev_splice_write()
2270 pipe_unlock(pipe); in fuse_dev_splice_write()
2277 rem += pipe_buf(pipe, idx)->len; in fuse_dev_splice_write()
2291 ibuf = pipe_buf(pipe, tail); in fuse_dev_splice_write()
2298 pipe->tail = tail; in fuse_dev_splice_write()
2300 if (!pipe_buf_get(pipe, ibuf)) in fuse_dev_splice_write()
2312 pipe_unlock(pipe); in fuse_dev_splice_write()
2317 cs.pipe = pipe; in fuse_dev_splice_write()
2324 pipe_lock(pipe); in fuse_dev_splice_write()
2330 pipe_buf_release(pipe, buf); in fuse_dev_splice_write()
2332 pipe_unlock(pipe); in fuse_dev_splice_write()