| /fs/ |
| D | pipe.c | 63 static void pipe_lock_nested(struct pipe_inode_info *pipe, int subclass) in pipe_lock_nested() argument
65 if (pipe->files) in pipe_lock_nested()
66 mutex_lock_nested(&pipe->mutex, subclass); in pipe_lock_nested()
69 void pipe_lock(struct pipe_inode_info *pipe) in pipe_lock() argument
74 pipe_lock_nested(pipe, I_MUTEX_PARENT); in pipe_lock()
78 void pipe_unlock(struct pipe_inode_info *pipe) in pipe_unlock() argument
80 if (pipe->files) in pipe_unlock()
81 mutex_unlock(&pipe->mutex); in pipe_unlock()
85 static inline void __pipe_lock(struct pipe_inode_info *pipe) in __pipe_lock() argument
87 mutex_lock_nested(&pipe->mutex, I_MUTEX_PARENT); in __pipe_lock()
[all …]
|
| D | splice.c | 43 static int page_cache_pipe_buf_steal(struct pipe_inode_info *pipe, in page_cache_pipe_buf_steal() argument
88 static void page_cache_pipe_buf_release(struct pipe_inode_info *pipe, in page_cache_pipe_buf_release() argument
99 static int page_cache_pipe_buf_confirm(struct pipe_inode_info *pipe, in page_cache_pipe_buf_confirm() argument
145 static int user_page_pipe_buf_steal(struct pipe_inode_info *pipe, in user_page_pipe_buf_steal() argument
152 return generic_pipe_buf_steal(pipe, buf); in user_page_pipe_buf_steal()
163 static void wakeup_pipe_readers(struct pipe_inode_info *pipe) in wakeup_pipe_readers() argument
166 if (waitqueue_active(&pipe->wait)) in wakeup_pipe_readers()
167 wake_up_interruptible(&pipe->wait); in wakeup_pipe_readers()
168 kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN); in wakeup_pipe_readers()
182 ssize_t splice_to_pipe(struct pipe_inode_info *pipe, in splice_to_pipe() argument
[all …]
|
| D | coredump.c | 486 struct pipe_inode_info *pipe = file->private_data; in wait_for_dump_helpers() local
488 pipe_lock(pipe); in wait_for_dump_helpers()
489 pipe->readers++; in wait_for_dump_helpers()
490 pipe->writers--; in wait_for_dump_helpers()
491 wake_up_interruptible_sync(&pipe->wait); in wait_for_dump_helpers()
492 kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN); in wait_for_dump_helpers()
493 pipe_unlock(pipe); in wait_for_dump_helpers()
499 wait_event_interruptible(pipe->wait, pipe->readers == 1); in wait_for_dump_helpers()
501 pipe_lock(pipe); in wait_for_dump_helpers()
502 pipe->readers--; in wait_for_dump_helpers()
[all …]
|
| D | Makefile | 9 char_dev.o stat.o exec.o pipe.o namei.o fcntl.o \
|
| /fs/autofs4/ |
| D | inode.c | 96 if (sbi->pipe) in autofs4_show_options()
97 seq_printf(m, ",pipe_ino=%ld", sbi->pipe->f_inode->i_ino); in autofs4_show_options()
213 struct file *pipe; in autofs4_fill_super() local
229 sbi->pipe = NULL; in autofs4_fill_super()
265 pipe = NULL; in autofs4_fill_super()
312 pipe = fget(pipefd); in autofs4_fill_super()
314 if (!pipe) { in autofs4_fill_super()
318 ret = autofs_prepare_pipe(pipe); in autofs4_fill_super()
321 sbi->pipe = pipe; in autofs4_fill_super()
336 fput(pipe); in autofs4_fill_super()
|
| D | autofs_i.h | 104 struct file *pipe; member
207 static inline int autofs_prepare_pipe(struct file *pipe) in autofs_prepare_pipe() argument
209 if (!(pipe->f_mode & FMODE_CAN_WRITE)) in autofs_prepare_pipe()
211 if (!S_ISFIFO(file_inode(pipe)->i_mode)) in autofs_prepare_pipe()
214 pipe->f_flags |= O_DIRECT; in autofs_prepare_pipe()
|
| D | waitq.c | 48 fput(sbi->pipe); /* Close the pipe */ in autofs4_catatonic_mode()
49 sbi->pipe = NULL; in autofs4_catatonic_mode()
103 struct file *pipe = NULL; in autofs4_notify_daemon() local
153 struct user_namespace *user_ns = sbi->pipe->f_cred->user_ns; in autofs4_notify_daemon()
175 pipe = get_file(sbi->pipe); in autofs4_notify_daemon()
179 switch (ret = autofs4_write(sbi, pipe, &pkt, pktsz)) { in autofs4_notify_daemon()
191 fput(pipe); in autofs4_notify_daemon()
|
| D | dev-ioctl.c | 382 struct file *pipe; in autofs_dev_ioctl_setpipefd() local
392 pipe = fget(pipefd); in autofs_dev_ioctl_setpipefd()
393 if (!pipe) { in autofs_dev_ioctl_setpipefd()
397 if (autofs_prepare_pipe(pipe) < 0) { in autofs_dev_ioctl_setpipefd()
399 fput(pipe); in autofs_dev_ioctl_setpipefd()
404 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/nfs/ |
| D | nfs4idmap.c | 415 struct rpc_pipe *pipe = idmap->idmap_pipe; in nfs_idmap_pipe_destroy() local
417 if (pipe->dentry) { in nfs_idmap_pipe_destroy()
418 rpc_unlink(pipe->dentry); in nfs_idmap_pipe_destroy()
419 pipe->dentry = NULL; in nfs_idmap_pipe_destroy()
427 struct rpc_pipe *pipe = idmap->idmap_pipe; in nfs_idmap_pipe_create() local
430 dentry = rpc_mkpipe_dentry(dir, "idmap", idmap, pipe); in nfs_idmap_pipe_create()
433 pipe->dentry = dentry; in nfs_idmap_pipe_create()
446 struct rpc_pipe *pipe; in nfs_idmap_new() local
457 pipe = rpc_mkpipe_data(&idmap_upcall_ops, 0); in nfs_idmap_new()
458 if (IS_ERR(pipe)) { in nfs_idmap_new()
[all …]
|
| /fs/fuse/ |
| D | dev.c | 686 struct pipe_inode_info *pipe; member
739 err = pipe_buf_confirm(cs->pipe, buf); in fuse_copy_fill()
751 if (cs->nr_segs == cs->pipe->buffers) in fuse_copy_fill()
838 err = pipe_buf_confirm(cs->pipe, buf); in fuse_try_move_page()
851 if (pipe_buf_steal(cs->pipe, buf) != 0) in fuse_try_move_page()
927 if (cs->nr_segs == cs->pipe->buffers) in fuse_ref_page()
1349 struct pipe_inode_info *pipe, in fuse_dev_splice_read() argument
1361 bufs = kmalloc(pipe->buffers * sizeof(struct pipe_buffer), GFP_KERNEL); in fuse_dev_splice_read()
1367 cs.pipe = pipe; in fuse_dev_splice_read()
1372 if (pipe->nrbufs + cs.nr_segs > pipe->buffers) { in fuse_dev_splice_read()
[all …]
|
| /fs/nfsd/ |
| D | nfs4recover.c | 669 __cld_pipe_upcall(struct rpc_pipe *pipe, struct cld_msg *cmsg) in __cld_pipe_upcall() argument
683 ret = rpc_queue_upcall(pipe, &msg); in __cld_pipe_upcall()
698 cld_pipe_upcall(struct rpc_pipe *pipe, struct cld_msg *cmsg) in cld_pipe_upcall() argument
707 ret = __cld_pipe_upcall(pipe, cmsg); in cld_pipe_upcall()
781 nfsd4_cld_register_sb(struct super_block *sb, struct rpc_pipe *pipe) in nfsd4_cld_register_sb() argument
788 dentry = rpc_mkpipe_dentry(dir, NFSD_CLD_PIPE, NULL, pipe); in nfsd4_cld_register_sb()
794 nfsd4_cld_unregister_sb(struct rpc_pipe *pipe) in nfsd4_cld_unregister_sb() argument
796 if (pipe->dentry) in nfsd4_cld_unregister_sb()
797 rpc_unlink(pipe->dentry); in nfsd4_cld_unregister_sb()
801 nfsd4_cld_register_net(struct net *net, struct rpc_pipe *pipe) in nfsd4_cld_register_net() argument
[all …]
|
| D | vfs.c | 850 nfsd_splice_actor(struct pipe_inode_info *pipe, struct pipe_buffer *buf, in nfsd_splice_actor() argument
878 static int nfsd_direct_splice_actor(struct pipe_inode_info *pipe, in nfsd_direct_splice_actor() argument
881 return __splice_from_pipe(pipe, sd, nfsd_splice_actor); in nfsd_direct_splice_actor()
|
| /fs/gfs2/ |
| D | file.c | 959 static ssize_t gfs2_file_splice_write(struct pipe_inode_info *pipe, in gfs2_file_splice_write() argument
972 return iter_file_splice_write(pipe, out, ppos, len, flags); in gfs2_file_splice_write()
|