Home
last modified time | relevance | path

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

/fs/
Dpipe.c60 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 …]
Dsplice.c47 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 …]
Dcoredump.c515 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 …]
DMakefile10 char_dev.o stat.o exec.o pipe.o namei.o fcntl.o \
/fs/autofs/
Dinode.c92 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()
Dautofs_i.h110 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()
Dwaitq.c39 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()
Ddev-ioctl.c354 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/
Drpc_pipefs.c146 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/
Ddev.c643 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/
Dnfs4idmap.c426 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/
Dnfs4recover.c758 __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 …]
Dvfs.c809 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/
Dfile.c1167 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/
Dcifsglob.h1081 bool pipe:1; /* set if connection to pipe share */ member
Dconnect.c4308 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()
Dinode.c1114 if (rc && tcon->pipe) {
Dsmb2pdu.c1761 tcon->pipe = true; in SMB2_tcon()