Lines Matching refs:pipe

702 	struct pipe_inode_info *pipe;  member
755 err = buf->ops->confirm(cs->pipe, buf); in fuse_copy_fill()
767 if (cs->nr_segs == cs->pipe->buffers) in fuse_copy_fill()
855 err = buf->ops->confirm(cs->pipe, buf); in fuse_try_move_page()
868 if (buf->ops->steal(cs->pipe, buf) != 0) in fuse_try_move_page()
944 if (cs->nr_segs == cs->pipe->buffers) in fuse_ref_page()
1366 struct pipe_inode_info *pipe, in fuse_dev_splice_read() argument
1379 bufs = kmalloc(pipe->buffers * sizeof(struct pipe_buffer), GFP_KERNEL); in fuse_dev_splice_read()
1385 cs.pipe = pipe; in fuse_dev_splice_read()
1391 pipe_lock(pipe); in fuse_dev_splice_read()
1393 if (!pipe->readers) { in fuse_dev_splice_read()
1400 if (pipe->nrbufs + cs.nr_segs > pipe->buffers) { in fuse_dev_splice_read()
1406 int newbuf = (pipe->curbuf + pipe->nrbufs) & (pipe->buffers - 1); in fuse_dev_splice_read()
1407 struct pipe_buffer *buf = pipe->bufs + newbuf; in fuse_dev_splice_read()
1418 pipe->nrbufs++; in fuse_dev_splice_read()
1422 if (pipe->files) in fuse_dev_splice_read()
1427 pipe_unlock(pipe); in fuse_dev_splice_read()
1431 if (waitqueue_active(&pipe->wait)) in fuse_dev_splice_read()
1432 wake_up_interruptible(&pipe->wait); in fuse_dev_splice_read()
1433 kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN); in fuse_dev_splice_read()
1974 static ssize_t fuse_dev_splice_write(struct pipe_inode_info *pipe, in fuse_dev_splice_write() argument
1990 bufs = kmalloc(pipe->buffers * sizeof(struct pipe_buffer), GFP_KERNEL); in fuse_dev_splice_write()
1994 pipe_lock(pipe); in fuse_dev_splice_write()
1997 for (idx = 0; idx < pipe->nrbufs && rem < len; idx++) in fuse_dev_splice_write()
1998 rem += pipe->bufs[(pipe->curbuf + idx) & (pipe->buffers - 1)].len; in fuse_dev_splice_write()
2002 pipe_unlock(pipe); in fuse_dev_splice_write()
2011 BUG_ON(nbuf >= pipe->buffers); in fuse_dev_splice_write()
2012 BUG_ON(!pipe->nrbufs); in fuse_dev_splice_write()
2013 ibuf = &pipe->bufs[pipe->curbuf]; in fuse_dev_splice_write()
2019 pipe->curbuf = (pipe->curbuf + 1) & (pipe->buffers - 1); in fuse_dev_splice_write()
2020 pipe->nrbufs--; in fuse_dev_splice_write()
2022 ibuf->ops->get(pipe, ibuf); in fuse_dev_splice_write()
2032 pipe_unlock(pipe); in fuse_dev_splice_write()
2037 cs.pipe = pipe; in fuse_dev_splice_write()
2046 buf->ops->release(pipe, buf); in fuse_dev_splice_write()