/fs/ |
D | pipe.c | 60 static void pipe_lock_nested(struct pipe_inode_info *pipe, int subclass) in pipe_lock_nested() argument 62 if (pipe->files) in pipe_lock_nested() 63 mutex_lock_nested(&pipe->mutex, subclass); in pipe_lock_nested() 66 void pipe_lock(struct pipe_inode_info *pipe) in pipe_lock() argument 71 pipe_lock_nested(pipe, I_MUTEX_PARENT); in pipe_lock() 75 void pipe_unlock(struct pipe_inode_info *pipe) in pipe_unlock() argument 77 if (pipe->files) in pipe_unlock() 78 mutex_unlock(&pipe->mutex); in pipe_unlock() 82 static inline void __pipe_lock(struct pipe_inode_info *pipe) in __pipe_lock() argument 84 mutex_lock_nested(&pipe->mutex, I_MUTEX_PARENT); in __pipe_lock() [all …]
|
D | splice.c | 47 static int page_cache_pipe_buf_steal(struct pipe_inode_info *pipe, in page_cache_pipe_buf_steal() argument 92 static void page_cache_pipe_buf_release(struct pipe_inode_info *pipe, in page_cache_pipe_buf_release() argument 103 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() 165 static void wakeup_pipe_readers(struct pipe_inode_info *pipe) in wakeup_pipe_readers() argument 168 if (waitqueue_active(&pipe->wait)) in wakeup_pipe_readers() 169 wake_up_interruptible(&pipe->wait); in wakeup_pipe_readers() 170 kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN); in wakeup_pipe_readers() 184 ssize_t splice_to_pipe(struct pipe_inode_info *pipe, in splice_to_pipe() argument [all …]
|
D | coredump.c | 515 struct pipe_inode_info *pipe = file->private_data; in wait_for_dump_helpers() local 517 pipe_lock(pipe); in wait_for_dump_helpers() 518 pipe->readers++; in wait_for_dump_helpers() 519 pipe->writers--; in wait_for_dump_helpers() 520 wake_up_interruptible_sync(&pipe->wait); in wait_for_dump_helpers() 521 kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN); in wait_for_dump_helpers() 522 pipe_unlock(pipe); in wait_for_dump_helpers() 528 wait_event_interruptible(pipe->wait, pipe->readers == 1); in wait_for_dump_helpers() 530 pipe_lock(pipe); in wait_for_dump_helpers() 531 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/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 | 39 fput(sbi->pipe); /* Close the pipe */ in autofs_catatonic_mode() 40 sbi->pipe = NULL; in autofs_catatonic_mode() 87 struct file *pipe = NULL; in autofs_notify_daemon() local 137 struct user_namespace *user_ns = sbi->pipe->f_cred->user_ns; in autofs_notify_daemon() 159 pipe = get_file(sbi->pipe); in autofs_notify_daemon() 163 switch (ret = autofs_write(sbi, pipe, &pkt, pktsz)) { in autofs_notify_daemon() 175 fput(pipe); in autofs_notify_daemon()
|
D | dev-ioctl.c | 354 struct file *pipe; in autofs_dev_ioctl_setpipefd() local 364 pipe = fget(pipefd); in autofs_dev_ioctl_setpipefd() 365 if (!pipe) { in autofs_dev_ioctl_setpipefd() 369 if (autofs_prepare_pipe(pipe) < 0) { in autofs_dev_ioctl_setpipefd() 371 fput(pipe); in autofs_dev_ioctl_setpipefd() 376 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 | 643 struct pipe_inode_info *pipe; member 696 err = pipe_buf_confirm(cs->pipe, buf); in fuse_copy_fill() 708 if (cs->nr_segs == cs->pipe->buffers) in fuse_copy_fill() 795 err = pipe_buf_confirm(cs->pipe, buf); in fuse_try_move_page() 808 if (pipe_buf_steal(cs->pipe, buf) != 0) in fuse_try_move_page() 884 if (cs->nr_segs == cs->pipe->buffers) in fuse_ref_page() 1334 struct pipe_inode_info *pipe, in fuse_dev_splice_read() argument 1346 bufs = kvmalloc_array(pipe->buffers, sizeof(struct pipe_buffer), in fuse_dev_splice_read() 1353 cs.pipe = pipe; in fuse_dev_splice_read() 1358 if (pipe->nrbufs + cs.nr_segs > pipe->buffers) { in fuse_dev_splice_read() [all …]
|
/fs/nfs/ |
D | nfs4idmap.c | 426 struct rpc_pipe *pipe = idmap->idmap_pipe; in nfs_idmap_pipe_destroy() local 428 if (pipe->dentry) { in nfs_idmap_pipe_destroy() 429 rpc_unlink(pipe->dentry); in nfs_idmap_pipe_destroy() 430 pipe->dentry = NULL; in nfs_idmap_pipe_destroy() 438 struct rpc_pipe *pipe = idmap->idmap_pipe; in nfs_idmap_pipe_create() local 441 dentry = rpc_mkpipe_dentry(dir, "idmap", idmap, pipe); in nfs_idmap_pipe_create() 444 pipe->dentry = dentry; in nfs_idmap_pipe_create() 457 struct rpc_pipe *pipe; in nfs_idmap_new() local 471 pipe = rpc_mkpipe_data(&idmap_upcall_ops, 0); in nfs_idmap_new() 472 if (IS_ERR(pipe)) { in nfs_idmap_new() [all …]
|
/fs/nfsd/ |
D | nfs4recover.c | 758 __cld_pipe_upcall(struct rpc_pipe *pipe, void *cmsg) in __cld_pipe_upcall() argument 763 struct nfsd_net *nn = net_generic(pipe->dentry->d_sb->s_fs_info, in __cld_pipe_upcall() 770 ret = rpc_queue_upcall(pipe, &msg); in __cld_pipe_upcall() 784 cld_pipe_upcall(struct rpc_pipe *pipe, void *cmsg) in cld_pipe_upcall() argument 793 ret = __cld_pipe_upcall(pipe, cmsg); in cld_pipe_upcall() 943 nfsd4_cld_register_sb(struct super_block *sb, struct rpc_pipe *pipe) in nfsd4_cld_register_sb() argument 950 dentry = rpc_mkpipe_dentry(dir, NFSD_CLD_PIPE, NULL, pipe); in nfsd4_cld_register_sb() 956 nfsd4_cld_unregister_sb(struct rpc_pipe *pipe) in nfsd4_cld_unregister_sb() argument 958 if (pipe->dentry) in nfsd4_cld_unregister_sb() 959 rpc_unlink(pipe->dentry); in nfsd4_cld_unregister_sb() [all …]
|
D | vfs.c | 809 nfsd_splice_actor(struct pipe_inode_info *pipe, struct pipe_buffer *buf, in nfsd_splice_actor() argument 837 static int nfsd_direct_splice_actor(struct pipe_inode_info *pipe, in nfsd_direct_splice_actor() argument 840 return __splice_from_pipe(pipe, sd, nfsd_splice_actor); in nfsd_direct_splice_actor()
|
/fs/gfs2/ |
D | file.c | 1167 static ssize_t gfs2_file_splice_write(struct pipe_inode_info *pipe, in gfs2_file_splice_write() argument 1180 return iter_file_splice_write(pipe, out, ppos, len, flags); in gfs2_file_splice_write()
|
/fs/cifs/ |
D | cifsglob.h | 1081 bool pipe:1; /* set if connection to pipe share */ member
|
D | connect.c | 4308 if (!tcon->pipe && server->ops->qfs_tcon) { in mount_get_conns() 5022 if (tcon->pipe || (ses->server->sec_mode & SECMODE_USER)) { in CIFSTCon() 5115 tcon->pipe = true; in CIFSTCon()
|
D | inode.c | 1114 if (rc && tcon->pipe) {
|
D | smb2pdu.c | 1761 tcon->pipe = true; in SMB2_tcon()
|