| /fs/ |
| D | pipe.c | 78 static void pipe_lock_nested(struct pipe_inode_info *pipe, int subclass) in pipe_lock_nested() argument
80 if (pipe->files) in pipe_lock_nested()
81 mutex_lock_nested(&pipe->mutex, subclass); in pipe_lock_nested()
84 void pipe_lock(struct pipe_inode_info *pipe) in pipe_lock() argument
89 pipe_lock_nested(pipe, I_MUTEX_PARENT); in pipe_lock()
93 void pipe_unlock(struct pipe_inode_info *pipe) in pipe_unlock() argument
95 if (pipe->files) in pipe_unlock()
96 mutex_unlock(&pipe->mutex); in pipe_unlock()
100 static inline void __pipe_lock(struct pipe_inode_info *pipe) in __pipe_lock() argument
102 mutex_lock_nested(&pipe->mutex, I_MUTEX_PARENT); in __pipe_lock()
[all …]
|
| D | splice.c | 46 static bool page_cache_pipe_buf_try_steal(struct pipe_inode_info *pipe, in page_cache_pipe_buf_try_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
147 static bool user_page_pipe_buf_try_steal(struct pipe_inode_info *pipe, in user_page_pipe_buf_try_steal() argument
154 return generic_pipe_buf_try_steal(pipe, buf); in user_page_pipe_buf_try_steal()
163 static void wakeup_pipe_readers(struct pipe_inode_info *pipe) in wakeup_pipe_readers() argument
166 if (waitqueue_active(&pipe->rd_wait)) in wakeup_pipe_readers()
167 wake_up_interruptible(&pipe->rd_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 | 528 struct pipe_inode_info *pipe = file->private_data; in wait_for_dump_helpers() local
530 pipe_lock(pipe); in wait_for_dump_helpers()
531 pipe->readers++; in wait_for_dump_helpers()
532 pipe->writers--; in wait_for_dump_helpers()
533 wake_up_interruptible_sync(&pipe->rd_wait); in wait_for_dump_helpers()
534 kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN); in wait_for_dump_helpers()
535 pipe_unlock(pipe); in wait_for_dump_helpers()
541 wait_event_interruptible(pipe->rd_wait, pipe->readers == 1); in wait_for_dump_helpers()
543 pipe_lock(pipe); in wait_for_dump_helpers()
544 pipe->readers--; in wait_for_dump_helpers()
[all …]
|
| D | Makefile | 12 char_dev.o stat.o exec.o pipe.o namei.o fcntl.o \
|
| /fs/autofs/ |
| D | inode.c | 92 if (sbi->pipe) in autofs_show_options()
93 seq_printf(m, ",pipe_ino=%ld", file_inode(sbi->pipe)->i_ino); in autofs_show_options()
224 struct file *pipe; in autofs_fill_super() local
239 sbi->pipe = NULL; in autofs_fill_super()
277 pipe = NULL; in autofs_fill_super()
323 pipe = fget(sbi->pipefd); in autofs_fill_super()
325 if (!pipe) { in autofs_fill_super()
329 ret = autofs_prepare_pipe(pipe); in autofs_fill_super()
332 sbi->pipe = pipe; in autofs_fill_super()
346 fput(pipe); in autofs_fill_super()
|
| D | autofs_i.h | 110 struct file *pipe; member
208 static inline int autofs_prepare_pipe(struct file *pipe) in autofs_prepare_pipe() argument
210 if (!(pipe->f_mode & FMODE_CAN_WRITE)) in autofs_prepare_pipe()
212 if (!S_ISFIFO(file_inode(pipe)->i_mode)) in autofs_prepare_pipe()
215 pipe->f_flags |= O_DIRECT; in autofs_prepare_pipe()
217 pipe->f_flags &= ~O_NONBLOCK; in autofs_prepare_pipe()
|
| D | waitq.c | 40 fput(sbi->pipe); /* Close the pipe */ in autofs_catatonic_mode()
41 sbi->pipe = NULL; in autofs_catatonic_mode()
88 struct file *pipe = NULL; in autofs_notify_daemon() local
138 struct user_namespace *user_ns = sbi->pipe->f_cred->user_ns; in autofs_notify_daemon()
160 pipe = get_file(sbi->pipe); in autofs_notify_daemon()
164 switch (ret = autofs_write(sbi, pipe, &pkt, pktsz)) { in autofs_notify_daemon()
176 fput(pipe); in autofs_notify_daemon()
|
| D | dev-ioctl.c | 355 struct file *pipe; in autofs_dev_ioctl_setpipefd() local
365 pipe = fget(pipefd); in autofs_dev_ioctl_setpipefd()
366 if (!pipe) { in autofs_dev_ioctl_setpipefd()
370 if (autofs_prepare_pipe(pipe) < 0) { in autofs_dev_ioctl_setpipefd()
372 fput(pipe); in autofs_dev_ioctl_setpipefd()
377 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 | 427 struct rpc_pipe *pipe = idmap->idmap_pipe; in nfs_idmap_pipe_destroy() local
429 if (pipe->dentry) { in nfs_idmap_pipe_destroy()
430 rpc_unlink(pipe->dentry); in nfs_idmap_pipe_destroy()
431 pipe->dentry = NULL; in nfs_idmap_pipe_destroy()
439 struct rpc_pipe *pipe = idmap->idmap_pipe; in nfs_idmap_pipe_create() local
442 dentry = rpc_mkpipe_dentry(dir, "idmap", idmap, pipe); in nfs_idmap_pipe_create()
445 pipe->dentry = dentry; in nfs_idmap_pipe_create()
458 struct rpc_pipe *pipe; in nfs_idmap_new() local
472 pipe = rpc_mkpipe_data(&idmap_upcall_ops, 0); in nfs_idmap_new()
473 if (IS_ERR(pipe)) { in nfs_idmap_new()
[all …]
|
| /fs/fuse/ |
| D | dev.c | 660 struct pipe_inode_info *pipe; member
717 err = pipe_buf_confirm(cs->pipe, buf); in fuse_copy_fill()
729 if (cs->nr_segs >= cs->pipe->max_usage) in fuse_copy_fill()
817 err = pipe_buf_confirm(cs->pipe, buf); in fuse_try_move_page()
830 if (!pipe_buf_try_steal(cs->pipe, buf)) in fuse_try_move_page()
871 pipe_buf_release(cs->pipe, buf); in fuse_try_move_page()
917 if (cs->nr_segs >= cs->pipe->max_usage) in fuse_ref_page()
1388 struct pipe_inode_info *pipe, in fuse_dev_splice_read() argument
1400 bufs = kvmalloc_array(pipe->max_usage, sizeof(struct pipe_buffer), in fuse_dev_splice_read()
1407 cs.pipe = pipe; in fuse_dev_splice_read()
[all …]
|
| /fs/nfsd/ |
| D | nfs4recover.c | 750 __cld_pipe_upcall(struct rpc_pipe *pipe, void *cmsg, struct nfsd_net *nn) in __cld_pipe_upcall() argument
760 ret = rpc_queue_upcall(pipe, &msg); in __cld_pipe_upcall()
774 cld_pipe_upcall(struct rpc_pipe *pipe, void *cmsg, struct nfsd_net *nn) in cld_pipe_upcall() argument
783 ret = __cld_pipe_upcall(pipe, cmsg, nn); in cld_pipe_upcall()
935 nfsd4_cld_register_sb(struct super_block *sb, struct rpc_pipe *pipe) in nfsd4_cld_register_sb() argument
942 dentry = rpc_mkpipe_dentry(dir, NFSD_CLD_PIPE, NULL, pipe); in nfsd4_cld_register_sb()
948 nfsd4_cld_unregister_sb(struct rpc_pipe *pipe) in nfsd4_cld_unregister_sb() argument
950 if (pipe->dentry) in nfsd4_cld_unregister_sb()
951 rpc_unlink(pipe->dentry); in nfsd4_cld_unregister_sb()
955 nfsd4_cld_register_net(struct net *net, struct rpc_pipe *pipe) in nfsd4_cld_register_net() argument
[all …]
|
| D | vfs.c | 851 nfsd_splice_actor(struct pipe_inode_info *pipe, struct pipe_buffer *buf, in nfsd_splice_actor() argument
879 static int nfsd_direct_splice_actor(struct pipe_inode_info *pipe, in nfsd_direct_splice_actor() argument
882 return __splice_from_pipe(pipe, sd, nfsd_splice_actor); in nfsd_direct_splice_actor()
|
| /fs/overlayfs/ |
| D | file.c | 418 static ssize_t ovl_splice_write(struct pipe_inode_info *pipe, struct file *out, in ovl_splice_write() argument
441 ret = iter_file_splice_write(pipe, real.file, ppos, len, flags); in ovl_splice_write()
|
| /fs/gfs2/ |
| D | file.c | 1221 static ssize_t gfs2_file_splice_write(struct pipe_inode_info *pipe, in gfs2_file_splice_write() argument
1229 ret = iter_file_splice_write(pipe, out, ppos, len, flags); in gfs2_file_splice_write()
|
| /fs/cifs/ |
| D | cifsglob.h | 1141 bool pipe:1; /* set if connection to pipe share */ member
|
| D | connect.c | 4147 if (!tcon->pipe && server->ops->qfs_tcon) { in mount_get_conns()
4866 if (tcon->pipe || (ses->server->sec_mode & SECMODE_USER)) { in CIFSTCon()
4958 tcon->pipe = true; in CIFSTCon()
|
| D | inode.c | 1381 if (rc && tcon->pipe) {
|
| D | smb2pdu.c | 1805 tcon->pipe = true; in SMB2_tcon()
|