| /fs/ |
| D | pipe.c | 64 static void pipe_lock_nested(struct pipe_inode_info *pipe, int subclass) in pipe_lock_nested() argument
66 if (pipe->files) in pipe_lock_nested()
67 mutex_lock_nested(&pipe->mutex, subclass); in pipe_lock_nested()
70 void pipe_lock(struct pipe_inode_info *pipe) in pipe_lock() argument
75 pipe_lock_nested(pipe, I_MUTEX_PARENT); in pipe_lock()
79 void pipe_unlock(struct pipe_inode_info *pipe) in pipe_unlock() argument
81 if (pipe->files) in pipe_unlock()
82 mutex_unlock(&pipe->mutex); in pipe_unlock()
86 static inline void __pipe_lock(struct pipe_inode_info *pipe) in __pipe_lock() argument
88 mutex_lock_nested(&pipe->mutex, I_MUTEX_PARENT); in __pipe_lock()
[all …]
|
| D | splice.c | 46 static int page_cache_pipe_buf_steal(struct pipe_inode_info *pipe, in page_cache_pipe_buf_steal() argument
91 static void page_cache_pipe_buf_release(struct pipe_inode_info *pipe, in page_cache_pipe_buf_release() argument
102 static int page_cache_pipe_buf_confirm(struct pipe_inode_info *pipe, in page_cache_pipe_buf_confirm() argument
148 static int user_page_pipe_buf_steal(struct pipe_inode_info *pipe, in user_page_pipe_buf_steal() argument
155 return generic_pipe_buf_steal(pipe, buf); in user_page_pipe_buf_steal()
166 static void wakeup_pipe_readers(struct pipe_inode_info *pipe) in wakeup_pipe_readers() argument
169 if (waitqueue_active(&pipe->wait)) in wakeup_pipe_readers()
170 wake_up_interruptible(&pipe->wait); in wakeup_pipe_readers()
171 kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN); in wakeup_pipe_readers()
185 ssize_t splice_to_pipe(struct pipe_inode_info *pipe, in splice_to_pipe() argument
[all …]
|
| D | coredump.c | 489 struct pipe_inode_info *pipe = file->private_data; in wait_for_dump_helpers() local
491 pipe_lock(pipe); in wait_for_dump_helpers()
492 pipe->readers++; in wait_for_dump_helpers()
493 pipe->writers--; in wait_for_dump_helpers()
494 wake_up_interruptible_sync(&pipe->wait); in wait_for_dump_helpers()
495 kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN); in wait_for_dump_helpers()
496 pipe_unlock(pipe); in wait_for_dump_helpers()
502 wait_event_interruptible(pipe->wait, pipe->readers == 1); in wait_for_dump_helpers()
504 pipe_lock(pipe); in wait_for_dump_helpers()
505 pipe->readers--; in wait_for_dump_helpers()
[all …]
|
| D | Makefile | 10 char_dev.o stat.o exec.o pipe.o namei.o fcntl.o \
|
| /fs/autofs4/ |
| D | inode.c | 95 if (sbi->pipe) in autofs4_show_options()
96 seq_printf(m, ",pipe_ino=%ld", file_inode(sbi->pipe)->i_ino); in autofs4_show_options()
212 struct file *pipe; in autofs4_fill_super() local
228 sbi->pipe = NULL; in autofs4_fill_super()
266 pipe = NULL; in autofs4_fill_super()
313 pipe = fget(pipefd); in autofs4_fill_super()
315 if (!pipe) { in autofs4_fill_super()
319 ret = autofs_prepare_pipe(pipe); in autofs4_fill_super()
322 sbi->pipe = pipe; in autofs4_fill_super()
337 fput(pipe); in autofs4_fill_super()
|
| D | autofs_i.h | 106 struct file *pipe; member
210 static inline int autofs_prepare_pipe(struct file *pipe) in autofs_prepare_pipe() argument
212 if (!(pipe->f_mode & FMODE_CAN_WRITE)) in autofs_prepare_pipe()
214 if (!S_ISFIFO(file_inode(pipe)->i_mode)) in autofs_prepare_pipe()
217 pipe->f_flags |= O_DIRECT; in autofs_prepare_pipe()
|
| D | waitq.c | 49 fput(sbi->pipe); /* Close the pipe */ in autofs4_catatonic_mode()
50 sbi->pipe = NULL; in autofs4_catatonic_mode()
97 struct file *pipe = NULL; in autofs4_notify_daemon() local
147 struct user_namespace *user_ns = sbi->pipe->f_cred->user_ns; in autofs4_notify_daemon()
169 pipe = get_file(sbi->pipe); in autofs4_notify_daemon()
173 switch (ret = autofs4_write(sbi, pipe, &pkt, pktsz)) { in autofs4_notify_daemon()
185 fput(pipe); in autofs4_notify_daemon()
|
| D | dev-ioctl.c | 386 struct file *pipe; in autofs_dev_ioctl_setpipefd() local
396 pipe = fget(pipefd); in autofs_dev_ioctl_setpipefd()
397 if (!pipe) { in autofs_dev_ioctl_setpipefd()
401 if (autofs_prepare_pipe(pipe) < 0) { in autofs_dev_ioctl_setpipefd()
403 fput(pipe); in autofs_dev_ioctl_setpipefd()
408 sbi->pipe = pipe; in autofs_dev_ioctl_setpipefd()
|
| /fs/nfs/blocklayout/ |
| D | rpc_pipefs.c | 146 struct rpc_pipe *pipe) in nfs4blocklayout_register_sb() argument
153 dentry = rpc_mkpipe_dentry(dir, "blocklayout", NULL, pipe); in nfs4blocklayout_register_sb()
159 struct rpc_pipe *pipe) in nfs4blocklayout_unregister_sb() argument
161 if (pipe->dentry) in nfs4blocklayout_unregister_sb()
162 rpc_unlink(pipe->dentry); in nfs4blocklayout_unregister_sb()
208 struct rpc_pipe *pipe) in nfs4blocklayout_register_net() argument
216 dentry = nfs4blocklayout_register_sb(pipefs_sb, pipe); in nfs4blocklayout_register_net()
222 struct rpc_pipe *pipe) in nfs4blocklayout_unregister_net() argument
228 nfs4blocklayout_unregister_sb(pipefs_sb, pipe); in nfs4blocklayout_unregister_net()
|
| /fs/fuse/ |
| D | dev.c | 707 struct pipe_inode_info *pipe; member
760 err = pipe_buf_confirm(cs->pipe, buf); in fuse_copy_fill()
772 if (cs->nr_segs == cs->pipe->buffers) in fuse_copy_fill()
859 err = pipe_buf_confirm(cs->pipe, buf); in fuse_try_move_page()
872 if (pipe_buf_steal(cs->pipe, buf) != 0) in fuse_try_move_page()
948 if (cs->nr_segs == cs->pipe->buffers) in fuse_ref_page()
1379 struct pipe_inode_info *pipe, in fuse_dev_splice_read() argument
1391 bufs = kmalloc(pipe->buffers * sizeof(struct pipe_buffer), GFP_KERNEL); in fuse_dev_splice_read()
1397 cs.pipe = pipe; in fuse_dev_splice_read()
1402 if (pipe->nrbufs + cs.nr_segs > pipe->buffers) { in fuse_dev_splice_read()
[all …]
|
| /fs/nfs/ |
| D | nfs4idmap.c | 417 struct rpc_pipe *pipe = idmap->idmap_pipe; in nfs_idmap_pipe_destroy() local
419 if (pipe->dentry) { in nfs_idmap_pipe_destroy()
420 rpc_unlink(pipe->dentry); in nfs_idmap_pipe_destroy()
421 pipe->dentry = NULL; in nfs_idmap_pipe_destroy()
429 struct rpc_pipe *pipe = idmap->idmap_pipe; in nfs_idmap_pipe_create() local
432 dentry = rpc_mkpipe_dentry(dir, "idmap", idmap, pipe); in nfs_idmap_pipe_create()
435 pipe->dentry = dentry; in nfs_idmap_pipe_create()
448 struct rpc_pipe *pipe; in nfs_idmap_new() local
459 pipe = rpc_mkpipe_data(&idmap_upcall_ops, 0); in nfs_idmap_new()
460 if (IS_ERR(pipe)) { in nfs_idmap_new()
[all …]
|
| /fs/nfsd/ |
| D | nfs4recover.c | 669 __cld_pipe_upcall(struct rpc_pipe *pipe, struct cld_msg *cmsg) in __cld_pipe_upcall() argument
679 ret = rpc_queue_upcall(pipe, &msg); in __cld_pipe_upcall()
693 cld_pipe_upcall(struct rpc_pipe *pipe, struct cld_msg *cmsg) in cld_pipe_upcall() argument
702 ret = __cld_pipe_upcall(pipe, cmsg); in cld_pipe_upcall()
776 nfsd4_cld_register_sb(struct super_block *sb, struct rpc_pipe *pipe) in nfsd4_cld_register_sb() argument
783 dentry = rpc_mkpipe_dentry(dir, NFSD_CLD_PIPE, NULL, pipe); in nfsd4_cld_register_sb()
789 nfsd4_cld_unregister_sb(struct rpc_pipe *pipe) in nfsd4_cld_unregister_sb() argument
791 if (pipe->dentry) in nfsd4_cld_unregister_sb()
792 rpc_unlink(pipe->dentry); in nfsd4_cld_unregister_sb()
796 nfsd4_cld_register_net(struct net *net, struct rpc_pipe *pipe) in nfsd4_cld_register_net() argument
[all …]
|
| D | vfs.c | 864 nfsd_splice_actor(struct pipe_inode_info *pipe, struct pipe_buffer *buf, in nfsd_splice_actor() argument
892 static int nfsd_direct_splice_actor(struct pipe_inode_info *pipe, in nfsd_direct_splice_actor() argument
895 return __splice_from_pipe(pipe, sd, nfsd_splice_actor); in nfsd_direct_splice_actor()
|
| /fs/gfs2/ |
| D | file.c | 966 static ssize_t gfs2_file_splice_write(struct pipe_inode_info *pipe, in gfs2_file_splice_write() argument
979 return iter_file_splice_write(pipe, out, ppos, len, flags); in gfs2_file_splice_write()
|