| /fs/ |
| D | fifo.c | 36 struct pipe_inode_info *pipe; in fifo_open() local
40 pipe = inode->i_pipe; in fifo_open()
41 if (!pipe) { in fifo_open()
43 pipe = alloc_pipe_info(inode); in fifo_open()
44 if (!pipe) in fifo_open()
46 inode->i_pipe = pipe; in fifo_open()
61 pipe->r_counter++; in fifo_open()
62 if (pipe->readers++ == 0) in fifo_open()
65 if (!pipe->writers) { in fifo_open()
69 filp->f_version = pipe->w_counter; in fifo_open()
[all …]
|
| D | pipe.c | 41 void pipe_wait(struct pipe_inode_info *pipe) in pipe_wait() argument
49 prepare_to_wait(&pipe->wait, &wait, TASK_INTERRUPTIBLE); in pipe_wait()
50 if (pipe->inode) in pipe_wait()
51 mutex_unlock(&pipe->inode->i_mutex); in pipe_wait()
53 finish_wait(&pipe->wait, &wait); in pipe_wait()
54 if (pipe->inode) in pipe_wait()
55 mutex_lock(&pipe->inode->i_mutex); in pipe_wait()
151 static void anon_pipe_buf_release(struct pipe_inode_info *pipe, in anon_pipe_buf_release() argument
161 if (page_count(page) == 1 && !pipe->tmp_page) in anon_pipe_buf_release()
162 pipe->tmp_page = page; in anon_pipe_buf_release()
[all …]
|
| D | splice.c | 40 static int page_cache_pipe_buf_steal(struct pipe_inode_info *pipe, in page_cache_pipe_buf_steal() argument
84 static void page_cache_pipe_buf_release(struct pipe_inode_info *pipe, in page_cache_pipe_buf_release() argument
95 static int page_cache_pipe_buf_confirm(struct pipe_inode_info *pipe, in page_cache_pipe_buf_confirm() argument
143 static int user_page_pipe_buf_steal(struct pipe_inode_info *pipe, in user_page_pipe_buf_steal() argument
150 return generic_pipe_buf_steal(pipe, buf); in user_page_pipe_buf_steal()
174 ssize_t splice_to_pipe(struct pipe_inode_info *pipe, in splice_to_pipe() argument
184 if (pipe->inode) in splice_to_pipe()
185 mutex_lock(&pipe->inode->i_mutex); in splice_to_pipe()
188 if (!pipe->readers) { in splice_to_pipe()
195 if (pipe->nrbufs < PIPE_BUFFERS) { in splice_to_pipe()
[all …]
|
| D | bad_inode.c | 140 static ssize_t bad_file_splice_write(struct pipe_inode_info *pipe, in bad_file_splice_write() argument
148 struct pipe_inode_info *pipe, size_t len, in bad_file_splice_read() argument
|
| D | Makefile | 9 char_dev.o stat.o exec.o pipe.o namei.o fcntl.o \
|
| /fs/autofs/ |
| D | inode.c | 138 struct file * pipe; in autofs_fill_super() local
153 sbi->pipe = NULL; in autofs_fill_super()
171 pipe = NULL; in autofs_fill_super()
199 pipe = fget(pipefd); in autofs_fill_super()
201 if (!pipe) { in autofs_fill_super()
206 if (!pipe->f_op || !pipe->f_op->write) in autofs_fill_super()
208 sbi->pipe = pipe; in autofs_fill_super()
219 fput(pipe); in autofs_fill_super()
|
| D | waitq.c | 43 fput(sbi->pipe); /* Close the pipe */ in autofs_catatonic_mode()
44 sbi->pipe = NULL; in autofs_catatonic_mode()
99 if ( autofs_write(sbi->pipe,&pkt,sizeof(struct autofs_packet_missing)) ) in autofs_notify_daemon()
|
| D | autofs_i.h | 103 struct file *pipe; member
|
| /fs/autofs4/ |
| D | inode.c | 321 struct file * pipe; in autofs4_fill_super() local
334 sbi->pipe = NULL; in autofs4_fill_super()
369 pipe = NULL; in autofs4_fill_super()
405 pipe = fget(pipefd); in autofs4_fill_super()
407 if (!pipe) { in autofs4_fill_super()
411 if (!pipe->f_op || !pipe->f_op->write) in autofs4_fill_super()
413 sbi->pipe = pipe; in autofs4_fill_super()
428 fput(pipe); in autofs4_fill_super()
|
| D | waitq.c | 53 fput(sbi->pipe); /* Close the pipe */ in autofs4_catatonic_mode()
54 sbi->pipe = NULL; in autofs4_catatonic_mode()
103 struct file *pipe = NULL; in autofs4_notify_daemon() local
172 pipe = sbi->pipe; in autofs4_notify_daemon()
173 get_file(pipe); in autofs4_notify_daemon()
177 if (pipe) { in autofs4_notify_daemon()
178 if (autofs4_write(pipe, &pkt, pktsz)) in autofs4_notify_daemon()
180 fput(pipe); in autofs4_notify_daemon()
|
| D | dev-ioctl.c | 426 struct file *pipe = fget(pipefd); in autofs_dev_ioctl_setpipefd() local
427 if (!pipe->f_op || !pipe->f_op->write) { in autofs_dev_ioctl_setpipefd()
429 fput(pipe); in autofs_dev_ioctl_setpipefd()
434 sbi->pipe = pipe; in autofs_dev_ioctl_setpipefd()
|
| D | autofs_i.h | 121 struct file *pipe; member
|
| /fs/xfs/linux-2.6/ |
| D | xfs_file.c | 90 struct pipe_inode_info *pipe, in xfs_file_splice_read() argument
100 infilp, ppos, pipe, len, flags, ioflags); in xfs_file_splice_read()
105 struct pipe_inode_info *pipe, in xfs_file_splice_write() argument
117 pipe, outfilp, ppos, len, flags, ioflags); in xfs_file_splice_write()
|
| D | xfs_lrw.c | 273 struct pipe_inode_info *pipe, in xfs_splice_read() argument
299 pipe, count, *ppos, ioflags); in xfs_splice_read()
300 ret = generic_file_splice_read(infilp, ppos, pipe, count, flags); in xfs_splice_read()
311 struct pipe_inode_info *pipe, in xfs_splice_write() argument
349 pipe, count, *ppos, ioflags); in xfs_splice_write()
350 ret = generic_file_splice_write(pipe, outfilp, ppos, count, flags); in xfs_splice_write()
|
| /fs/xfs/ |
| D | xfs_vnodeops.h | 60 loff_t *ppos, struct pipe_inode_info *pipe, size_t count,
63 struct pipe_inode_info *pipe, struct file *outfilp,
|
| /fs/coda/ |
| D | file.c | 47 struct pipe_inode_info *pipe, size_t count, in coda_file_splice_read() argument
60 return host_file->f_op->splice_read(host_file, ppos, pipe, count,flags); in coda_file_splice_read()
|
| /fs/ocfs2/ |
| D | file.c | 1915 static ssize_t ocfs2_file_splice_write(struct pipe_inode_info *pipe, in ocfs2_file_splice_write() argument
1924 mlog_entry("(0x%p, 0x%p, %u, '%.*s')\n", out, pipe, in ocfs2_file_splice_write()
1929 inode_double_lock(inode, pipe->inode); in ocfs2_file_splice_write()
1944 ret = generic_file_splice_write_nolock(pipe, out, ppos, len, flags); in ocfs2_file_splice_write()
1949 inode_double_unlock(inode, pipe->inode); in ocfs2_file_splice_write()
1957 struct pipe_inode_info *pipe, in ocfs2_file_splice_read() argument
1964 mlog_entry("(0x%p, 0x%p, %u, '%.*s')\n", in, pipe, in ocfs2_file_splice_read()
1979 ret = generic_file_splice_read(in, ppos, pipe, len, flags); in ocfs2_file_splice_read()
|
| /fs/smbfs/ |
| D | file.c | 266 struct pipe_inode_info *pipe, size_t count, in smb_file_splice_read() argument
281 status = generic_file_splice_read(file, ppos, pipe, count, flags); in smb_file_splice_read()
|
| /fs/nfs/ |
| D | file.c | 46 struct pipe_inode_info *pipe,
280 struct pipe_inode_info *pipe, size_t count, in nfs_file_splice_read() argument
293 res = generic_file_splice_read(filp, ppos, pipe, count, flags); in nfs_file_splice_read()
|
| /fs/nfsd/ |
| D | vfs.c | 840 nfsd_splice_actor(struct pipe_inode_info *pipe, struct pipe_buffer *buf, in nfsd_splice_actor() argument
849 ret = buf->ops->confirm(pipe, buf); in nfsd_splice_actor()
875 static int nfsd_direct_splice_actor(struct pipe_inode_info *pipe, in nfsd_direct_splice_actor() argument
878 return __splice_from_pipe(pipe, sd, nfsd_splice_actor); in nfsd_direct_splice_actor()
|