Searched refs:pipe (Results 1 - 18 of 18) sorted by relevance

/fs/
H A Dpipe.c2 * 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 Dsplice.c4 * 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 Dcoredump.c450 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 Dbad_inode.c134 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 DMakefile9 char_dev.o stat.o exec.o pipe.o namei.o fcntl.o \
/fs/nfs/blocklayout/
H A Drpc_pipefs.c146 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 Dinode.c60 /* 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 Dautofs_i.h110 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 Dwaitq.c51 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 Ddev-ioctl.c335 * 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 Didmap.c414 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 Dfile.c193 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 Ddev.c645 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 Dnfs4recover.c657 __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 Dvfs.c805 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 Dfile.c47 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 Dxfs_file.c328 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 Dfile.c2434 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

Completed in 956 milliseconds