/fs/ |
H A D | pipe.c | 2 * linux/fs/pipe.c 32 * The max size that a non-root user is allowed to grow the pipe. Can 33 * be set by root in /proc/sys/fs/pipe-max-size 38 * Minimum pipe size, as required by POSIX 57 static void pipe_lock_nested(struct pipe_inode_info *pipe, int subclass) argument 59 if (pipe->files) 60 mutex_lock_nested(&pipe->mutex, subclass); 63 void pipe_lock(struct pipe_inode_info *pipe) argument 66 * pipe_lock() nests non-pipe inode locks (for writing to a file) 68 pipe_lock_nested(pipe, I_MUTEX_PAREN 72 pipe_unlock(struct pipe_inode_info *pipe) argument 79 __pipe_lock(struct pipe_inode_info *pipe) argument 84 __pipe_unlock(struct pipe_inode_info *pipe) argument 104 pipe_wait(struct pipe_inode_info *pipe) argument 119 anon_pipe_buf_release(struct pipe_inode_info *pipe, struct pipe_buffer *buf) argument 147 generic_pipe_buf_steal(struct pipe_inode_info *pipe, struct pipe_buffer *buf) argument 176 generic_pipe_buf_get(struct pipe_inode_info *pipe, struct pipe_buffer *buf) argument 206 generic_pipe_buf_release(struct pipe_inode_info *pipe, struct pipe_buffer *buf) argument 234 struct pipe_inode_info *pipe = filp->private_data; local 342 struct pipe_inode_info *pipe = filp->private_data; local 479 struct pipe_inode_info *pipe = filp->private_data; local 505 struct pipe_inode_info *pipe = filp->private_data; local 532 put_pipe_info(struct inode *inode, struct pipe_inode_info *pipe) argument 550 struct pipe_inode_info *pipe = file->private_data; local 572 struct pipe_inode_info *pipe = filp->private_data; local 590 struct pipe_inode_info *pipe; local 608 free_pipe_info(struct pipe_inode_info *pipe) argument 641 struct pipe_inode_info *pipe; local 805 wait_for_partner(struct pipe_inode_info *pipe, unsigned int *cnt) argument 817 wake_up_partner(struct pipe_inode_info *pipe) argument 824 struct pipe_inode_info *pipe; local 964 pipe_set_size(struct pipe_inode_info *pipe, unsigned long nr_pages) argument 1050 struct pipe_inode_info *pipe; local [all...] |
H A D | splice.c | 4 * This is the "extended pipe" functionality, where a pipe is used as 5 * an arbitrary in-memory buffer. Think of a pipe as a small kernel 9 * that transfers data buffers to or from a pipe buffer. 39 * Attempt to steal a page from a pipe buffer. This should perhaps go into 44 static int page_cache_pipe_buf_steal(struct pipe_inode_info *pipe, argument 89 static void page_cache_pipe_buf_release(struct pipe_inode_info *pipe, argument 100 static int page_cache_pipe_buf_confirm(struct pipe_inode_info *pipe, argument 146 static int user_page_pipe_buf_steal(struct pipe_inode_info *pipe, argument 153 return generic_pipe_buf_steal(pipe, bu 164 wakeup_pipe_readers(struct pipe_inode_info *pipe) argument 183 splice_to_pipe(struct pipe_inode_info *pipe, struct splice_pipe_desc *spd) argument 275 splice_grow_spd(const struct pipe_inode_info *pipe, struct splice_pipe_desc *spd) argument 304 __generic_file_splice_read(struct file *in, loff_t *ppos, struct pipe_inode_info *pipe, size_t len, unsigned int flags) argument 520 generic_file_splice_read(struct file *in, loff_t *ppos, struct pipe_inode_info *pipe, size_t len, unsigned int flags) argument 553 generic_pipe_buf_nosteal(struct pipe_inode_info *pipe, struct pipe_buffer *buf) argument 601 default_file_splice_read(struct file *in, loff_t *ppos, struct pipe_inode_info *pipe, size_t len, unsigned int flags) argument 702 pipe_to_sendpage(struct pipe_inode_info *pipe, struct pipe_buffer *buf, struct splice_desc *sd) argument 721 wakeup_pipe_writers(struct pipe_inode_info *pipe) argument 749 splice_from_pipe_feed(struct pipe_inode_info *pipe, struct splice_desc *sd, splice_actor *actor) argument 807 splice_from_pipe_next(struct pipe_inode_info *pipe, struct splice_desc *sd) argument 858 splice_from_pipe_end(struct pipe_inode_info *pipe, struct splice_desc *sd) argument 877 __splice_from_pipe(struct pipe_inode_info *pipe, struct splice_desc *sd, splice_actor *actor) argument 908 splice_from_pipe(struct pipe_inode_info *pipe, struct file *out, loff_t *ppos, size_t len, unsigned int flags, splice_actor *actor) argument 942 iter_file_splice_write(struct pipe_inode_info *pipe, struct file *out, loff_t *ppos, size_t len, unsigned int flags) argument 1066 write_pipe_buf(struct pipe_inode_info *pipe, struct pipe_buffer *buf, struct splice_desc *sd) argument 1080 default_file_splice_write(struct pipe_inode_info *pipe, struct file *out, loff_t *ppos, size_t len, unsigned int flags) argument 1106 generic_splice_sendpage(struct pipe_inode_info *pipe, struct file *out, loff_t *ppos, size_t len, unsigned int flags) argument 1117 do_splice_from(struct pipe_inode_info *pipe, struct file *out, loff_t *ppos, size_t len, unsigned int flags) argument 1134 do_splice_to(struct file *in, loff_t *ppos, struct pipe_inode_info *pipe, size_t len, unsigned int flags) argument 1173 struct pipe_inode_info *pipe; local 1279 direct_splice_actor(struct pipe_inode_info *pipe, struct splice_desc *sd) argument 1532 pipe_to_user(struct pipe_inode_info *pipe, struct pipe_buffer *buf, struct splice_desc *sd) argument 1546 struct pipe_inode_info *pipe; local 1591 struct pipe_inode_info *pipe; local 1717 ipipe_prep(struct pipe_inode_info *pipe, unsigned int flags) argument 1755 opipe_prep(struct pipe_inode_info *pipe, unsigned int flags) argument [all...] |
H A D | coredump.c | 450 struct pipe_inode_info *pipe = file->private_data; local 452 pipe_lock(pipe); 453 pipe->readers++; 454 pipe->writers--; 455 wake_up_interruptible_sync(&pipe->wait); 456 kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN); 457 pipe_unlock(pipe); 463 wait_event_interruptible(pipe->wait, pipe->readers == 1); 465 pipe_lock(pipe); [all...] |
H A D | bad_inode.c | 134 static ssize_t bad_file_splice_write(struct pipe_inode_info *pipe, argument 142 struct pipe_inode_info *pipe, size_t len, 141 bad_file_splice_read(struct file *in, loff_t *ppos, struct pipe_inode_info *pipe, size_t len, unsigned int flags) argument
|
H A D | Makefile | 9 char_dev.o stat.o exec.o pipe.o namei.o fcntl.o \
|
/fs/nfs/blocklayout/ |
H A D | rpc_pipefs.c | 146 struct rpc_pipe *pipe) 153 dentry = rpc_mkpipe_dentry(dir, "blocklayout", NULL, pipe); 159 struct rpc_pipe *pipe) 161 if (pipe->dentry) 162 rpc_unlink(pipe->dentry); 208 struct rpc_pipe *pipe) 216 dentry = nfs4blocklayout_register_sb(pipefs_sb, pipe); 222 struct rpc_pipe *pipe) 228 nfs4blocklayout_unregister_sb(pipefs_sb, pipe); 145 nfs4blocklayout_register_sb(struct super_block *sb, struct rpc_pipe *pipe) argument 158 nfs4blocklayout_unregister_sb(struct super_block *sb, struct rpc_pipe *pipe) argument 207 nfs4blocklayout_register_net(struct net *net, struct rpc_pipe *pipe) argument 221 nfs4blocklayout_unregister_net(struct net *net, struct rpc_pipe *pipe) argument
|
/fs/autofs4/ |
H A D | inode.c | 60 /* Free wait queues, close pipe */ 209 struct file * pipe; local 225 sbi->pipe = NULL; 261 pipe = NULL; 307 DPRINTK("pipe fd = %d, pgrp = %u", pipefd, pid_nr(sbi->oz_pgrp)); 308 pipe = fget(pipefd); 310 if (!pipe) { 311 printk("autofs: could not open pipe file descriptor\n"); 314 ret = autofs_prepare_pipe(pipe); 317 sbi->pipe [all...] |
H A D | autofs_i.h | 110 struct file *pipe; member in struct:autofs_sb_info 214 static inline int autofs_prepare_pipe(struct file *pipe) argument 216 if (!pipe->f_op->write) 218 if (!S_ISFIFO(file_inode(pipe)->i_mode)) 220 /* We want a packet pipe */ 221 pipe->f_flags |= O_DIRECT;
|
H A D | waitq.c | 51 fput(sbi->pipe); /* Close the pipe */ 52 sbi->pipe = NULL; 102 struct file *pipe = NULL; local 149 struct user_namespace *user_ns = sbi->pipe->f_cred->user_ns; 171 pipe = get_file(sbi->pipe); 175 if (autofs4_write(sbi, pipe, &pkt, pktsz)) 177 fput(pipe);
|
H A D | dev-ioctl.c | 335 * Set the pipe fd for kernel communication to the daemon. 339 * to tell the autofs mount about the new kernel pipe fd. In 364 struct file *pipe; local 374 pipe = fget(pipefd); 375 if (!pipe) { 379 if (autofs_prepare_pipe(pipe) < 0) { 381 fput(pipe); 386 sbi->pipe = pipe; 397 * mount requests. Also closes the kernel pipe fil [all...] |
/fs/nfs/ |
H A D | idmap.c | 414 struct rpc_pipe *pipe = idmap->idmap_pipe; local 416 if (pipe->dentry) { 417 rpc_unlink(pipe->dentry); 418 pipe->dentry = NULL; 426 struct rpc_pipe *pipe = idmap->idmap_pipe; local 429 dentry = rpc_mkpipe_dentry(dir, "idmap", idmap, pipe); 432 pipe->dentry = dentry; 445 struct rpc_pipe *pipe; local 456 pipe = rpc_mkpipe_data(&idmap_upcall_ops, 0); 457 if (IS_ERR(pipe)) { [all...] |
H A D | file.c | 193 struct pipe_inode_info *pipe, size_t count, 204 res = generic_file_splice_read(filp, ppos, pipe, count, flags); 192 nfs_file_splice_read(struct file *filp, loff_t *ppos, struct pipe_inode_info *pipe, size_t count, unsigned int flags) argument
|
/fs/fuse/ |
H A D | dev.c | 645 struct pipe_inode_info *pipe; member in struct:fuse_copy_state 700 err = buf->ops->confirm(cs->pipe, buf); 712 if (cs->nr_segs == cs->pipe->buffers) 803 err = buf->ops->confirm(cs->pipe, buf); 816 if (buf->ops->steal(cs->pipe, buf) != 0) 891 if (cs->nr_segs == cs->pipe->buffers) 1299 struct pipe_inode_info *pipe, 1311 bufs = kmalloc(pipe->buffers * sizeof(struct pipe_buffer), GFP_KERNEL); 1317 cs.pipe = pipe; 1298 fuse_dev_splice_read(struct file *in, loff_t *ppos, struct pipe_inode_info *pipe, size_t len, unsigned int flags) argument 1901 fuse_dev_splice_write(struct pipe_inode_info *pipe, struct file *out, loff_t *ppos, size_t len, unsigned int flags) argument [all...] |
/fs/nfsd/ |
H A D | nfs4recover.c | 657 __cld_pipe_upcall(struct rpc_pipe *pipe, struct cld_msg *cmsg) argument 671 ret = rpc_queue_upcall(pipe, &msg); 686 cld_pipe_upcall(struct rpc_pipe *pipe, struct cld_msg *cmsg) argument 691 * -EAGAIN occurs when pipe is closed and reopened while there are 695 ret = __cld_pipe_upcall(pipe, cmsg); 769 nfsd4_cld_register_sb(struct super_block *sb, struct rpc_pipe *pipe) argument 776 dentry = rpc_mkpipe_dentry(dir, NFSD_CLD_PIPE, NULL, pipe); 782 nfsd4_cld_unregister_sb(struct rpc_pipe *pipe) argument 784 if (pipe->dentry) 785 rpc_unlink(pipe 789 nfsd4_cld_register_net(struct net *net, struct rpc_pipe *pipe) argument 803 nfsd4_cld_unregister_net(struct net *net, struct rpc_pipe *pipe) argument [all...] |
H A D | vfs.c | 805 nfsd_splice_actor(struct pipe_inode_info *pipe, struct pipe_buffer *buf, argument 833 static int nfsd_direct_splice_actor(struct pipe_inode_info *pipe, argument 836 return __splice_from_pipe(pipe, sd, nfsd_splice_actor);
|
/fs/coda/ |
H A D | file.c | 47 struct pipe_inode_info *pipe, size_t count, 63 return splice_read(host_file, ppos, pipe, count, flags); 46 coda_file_splice_read(struct file *coda_file, loff_t *ppos, struct pipe_inode_info *pipe, size_t count, unsigned int flags) argument
|
/fs/xfs/ |
H A D | xfs_file.c | 328 struct pipe_inode_info *pipe, 348 ret = generic_file_splice_read(infilp, ppos, pipe, count, flags); 325 xfs_file_splice_read( struct file *infilp, loff_t *ppos, struct pipe_inode_info *pipe, size_t count, unsigned int flags) argument
|
/fs/ocfs2/ |
H A D | file.c | 2434 struct pipe_inode_info *pipe, 2456 ret = generic_file_splice_read(in, ppos, pipe, len, flags); 2432 ocfs2_file_splice_read(struct file *in, loff_t *ppos, struct pipe_inode_info *pipe, size_t len, unsigned int flags) argument
|