| /fs/ |
| A D | pipe.c | 508 if (!pipe_full(head, pipe->tail, pipe->max_usage)) { in anon_pipe_write()
689 if (!pipe->writers && filp->f_pipe != pipe->w_counter) in pipe_poll()
734 if (!pipe->readers != !pipe->writers) { in pipe_release()
821 pipe->r_counter = pipe->w_counter = 1; in alloc_pipe_info()
895 if (!pipe) in get_pipe_inode()
900 pipe->readers = pipe->writers = 1; in get_pipe_inode()
1174 if (wait_for_partner(pipe, &pipe->w_counter)) in fifo_open()
1195 if (wait_for_partner(pipe, &pipe->r_counter)) in fifo_open()
1212 if (pipe->readers == 1 || pipe->writers == 1) in fifo_open()
1417 if (!pipe) in get_pipe_info()
[all …]
|
| A D | splice.c | 393 pipe->head++; in copy_splice_read()
641 pipe_lock(pipe); in splice_from_pipe()
683 pipe_lock(pipe); in iter_file_splice_write()
807 pipe_lock(pipe); in splice_to_socket()
968 p_space = pipe->max_usage - pipe_buf_usage(pipe); in do_splice_read()
1050 if (!pipe) in splice_direct_to_actor()
1122 pipe->tail = pipe->head = 0; in splice_direct_to_actor()
1514 if (!pipe) in vmsplice_to_user()
1547 if (!pipe) in vmsplice_to_pipe()
1552 pipe_lock(pipe); in vmsplice_to_pipe()
[all …]
|
| A D | coredump.c | 589 struct pipe_inode_info *pipe = file->private_data; in wait_for_dump_helpers() local
591 pipe_lock(pipe); in wait_for_dump_helpers()
592 pipe->readers++; in wait_for_dump_helpers()
593 pipe->writers--; in wait_for_dump_helpers()
594 wake_up_interruptible_sync(&pipe->rd_wait); in wait_for_dump_helpers()
596 pipe_unlock(pipe); in wait_for_dump_helpers()
602 wait_event_interruptible(pipe->rd_wait, pipe->readers == 1); in wait_for_dump_helpers()
604 pipe_lock(pipe); in wait_for_dump_helpers()
605 pipe->readers--; in wait_for_dump_helpers()
606 pipe->writers++; in wait_for_dump_helpers()
[all …]
|
| A D | backing-file.c | 274 struct pipe_inode_info *pipe, size_t len, in backing_file_splice_read() argument
285 ret = vfs_splice_read(in, &iocb->ki_pos, pipe, len, flags); in backing_file_splice_read()
295 ssize_t backing_file_splice_write(struct pipe_inode_info *pipe, in backing_file_splice_write() argument
315 ret = out->f_op->splice_write(pipe, out, &iocb->ki_pos, len, flags); in backing_file_splice_write()
|
| A D | Makefile | 11 char_dev.o stat.o exec.o pipe.o namei.o fcntl.o \
|
| /fs/autofs/ |
| A D | autofs_i.h | 115 struct file *pipe; member
219 static inline int autofs_check_pipe(struct file *pipe) in autofs_check_pipe() argument
221 if (pipe->f_mode & FMODE_PATH) in autofs_check_pipe()
223 if (!(pipe->f_mode & FMODE_CAN_WRITE)) in autofs_check_pipe()
225 if (!S_ISFIFO(file_inode(pipe)->i_mode)) in autofs_check_pipe()
230 static inline void autofs_set_packet_pipe_flags(struct file *pipe) in autofs_set_packet_pipe_flags() argument
233 pipe->f_flags |= O_DIRECT; in autofs_set_packet_pipe_flags()
235 pipe->f_flags &= ~O_NONBLOCK; in autofs_set_packet_pipe_flags()
238 static inline int autofs_prepare_pipe(struct file *pipe) in autofs_prepare_pipe() argument
240 int ret = autofs_check_pipe(pipe); in autofs_prepare_pipe()
[all …]
|
| A D | inode.c | 94 if (sbi->pipe) in autofs_show_options()
159 struct file *pipe; in autofs_parse_fd() local
164 pipe = param->file; in autofs_parse_fd()
167 pipe = fget(result->uint_32); in autofs_parse_fd()
169 if (!pipe) { in autofs_parse_fd()
177 fput(pipe); in autofs_parse_fd()
183 if (sbi->pipe) in autofs_parse_fd()
184 fput(sbi->pipe); in autofs_parse_fd()
187 sbi->pipe = pipe; in autofs_parse_fd()
386 if (sbi->pipe) in autofs_free_fc()
[all …]
|
| A 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()
|
| A D | dev-ioctl.c | 361 struct file *pipe; in autofs_dev_ioctl_setpipefd() local
371 pipe = fget(pipefd); in autofs_dev_ioctl_setpipefd()
372 if (!pipe) { in autofs_dev_ioctl_setpipefd()
376 if (autofs_prepare_pipe(pipe) < 0) { in autofs_dev_ioctl_setpipefd()
378 fput(pipe); in autofs_dev_ioctl_setpipefd()
383 sbi->pipe = pipe; in autofs_dev_ioctl_setpipefd()
|
| /fs/nfs/blocklayout/ |
| A D | rpc_pipefs.c | 145 struct rpc_pipe *pipe) in nfs4blocklayout_register_sb() argument
153 err = rpc_mkpipe_dentry(dir, "blocklayout", NULL, pipe); in nfs4blocklayout_register_sb()
193 static int nfs4blocklayout_register_net(struct net *net, struct rpc_pipe *pipe) in nfs4blocklayout_register_net() argument
201 ret = nfs4blocklayout_register_sb(pipefs_sb, pipe); in nfs4blocklayout_register_net()
207 struct rpc_pipe *pipe) in nfs4blocklayout_unregister_net() argument
213 rpc_unlink(pipe); in nfs4blocklayout_unregister_net()
|
| /fs/fuse/ |
| A D | dev.c | 1568 cs.pipe = pipe; in fuse_dev_splice_read()
1573 if (pipe_buf_usage(pipe) + cs.nr_segs > pipe->max_usage) { in fuse_dev_splice_read()
2262 pipe_lock(pipe); in fuse_dev_splice_write()
2264 head = pipe->head; in fuse_dev_splice_write()
2265 tail = pipe->tail; in fuse_dev_splice_write()
2270 pipe_unlock(pipe); in fuse_dev_splice_write()
2298 pipe->tail = tail; in fuse_dev_splice_write()
2312 pipe_unlock(pipe); in fuse_dev_splice_write()
2317 cs.pipe = pipe; in fuse_dev_splice_write()
2324 pipe_lock(pipe); in fuse_dev_splice_write()
[all …]
|
| A D | passthrough.c | 82 struct pipe_inode_info *pipe, in fuse_passthrough_splice_read() argument
99 ret = backing_file_splice_read(backing_file, &iocb, pipe, len, flags, &ctx); in fuse_passthrough_splice_read()
105 ssize_t fuse_passthrough_splice_write(struct pipe_inode_info *pipe, in fuse_passthrough_splice_write() argument
125 ret = backing_file_splice_write(pipe, backing_file, &iocb, len, flags, &ctx); in fuse_passthrough_splice_write()
|
| A D | fuse_dev_i.h | 27 struct pipe_inode_info *pipe; member
|
| /fs/nfsd/ |
| A D | nfs4recover.c | 768 ret = rpc_queue_upcall(pipe, &msg); in __cld_pipe_upcall()
782 cld_pipe_upcall(struct rpc_pipe *pipe, void *cmsg, struct nfsd_net *nn) in cld_pipe_upcall() argument
791 ret = __cld_pipe_upcall(pipe, cmsg, nn); in cld_pipe_upcall()
954 nfsd4_cld_register_sb(struct super_block *sb, struct rpc_pipe *pipe) in nfsd4_cld_register_sb() argument
962 err = rpc_mkpipe_dentry(dir, NFSD_CLD_PIPE, NULL, pipe); in nfsd4_cld_register_sb()
968 nfsd4_cld_register_net(struct net *net, struct rpc_pipe *pipe) in nfsd4_cld_register_net() argument
976 err = nfsd4_cld_register_sb(sb, pipe); in nfsd4_cld_register_net()
982 nfsd4_cld_unregister_net(struct net *net, struct rpc_pipe *pipe) in nfsd4_cld_unregister_net() argument
988 rpc_unlink(pipe); in nfsd4_cld_unregister_net()
1496 struct rpc_pipe *pipe = cn->cn_pipe; in cld_running() local
[all …]
|
| /fs/nfs/ |
| A D | nfs4idmap.c | 448 struct rpc_pipe *pipe; in nfs_idmap_new() local
462 pipe = rpc_mkpipe_data(&idmap_upcall_ops, 0); in nfs_idmap_new()
463 if (IS_ERR(pipe)) { in nfs_idmap_new()
464 error = PTR_ERR(pipe); in nfs_idmap_new()
467 idmap->idmap_pipe = pipe; in nfs_idmap_new()
|
| /fs/overlayfs/ |
| A D | file.c | 386 struct pipe_inode_info *pipe, size_t len, in ovl_splice_read() argument
403 ret = backing_file_splice_read(realfile, &iocb, pipe, len, flags, &ctx); in ovl_splice_read()
417 static ssize_t ovl_splice_write(struct pipe_inode_info *pipe, struct file *out, in ovl_splice_write() argument
440 ret = backing_file_splice_write(pipe, realfile, &iocb, len, flags, &ctx); in ovl_splice_write()
|
| /fs/9p/ |
| A D | vfs_file.c | 376 struct pipe_inode_info *pipe, in v9fs_file_splice_read() argument
385 return copy_splice_read(in, ppos, pipe, len, flags); in v9fs_file_splice_read()
386 return filemap_splice_read(in, ppos, pipe, len, flags); in v9fs_file_splice_read()
|
| /fs/afs/ |
| A D | file.c | 26 struct pipe_inode_info *pipe,
550 struct pipe_inode_info *pipe, in afs_file_splice_read() argument
563 ret = filemap_splice_read(in, ppos, pipe, len, flags); in afs_file_splice_read()
|
| /fs/coda/ |
| A D | file.c | 98 struct pipe_inode_info *pipe, in coda_file_splice_read() argument
113 ret = vfs_splice_read(in, ppos, pipe, len, flags); in coda_file_splice_read()
|
| /fs/ecryptfs/ |
| A D | file.c | 58 struct pipe_inode_info *pipe, in ecryptfs_splice_read_update_atime() argument
64 rc = filemap_splice_read(in, ppos, pipe, len, flags); in ecryptfs_splice_read_update_atime()
|
| /fs/orangefs/ |
| A D | file.c | 341 struct pipe_inode_info *pipe, in orangefs_file_splice_read() argument
354 ret = filemap_splice_read(in, ppos, pipe, len, flags); in orangefs_file_splice_read()
|
| /fs/ntfs3/ |
| A D | file.c | 873 struct pipe_inode_info *pipe, size_t len, in ntfs_file_splice_read() argument
883 return filemap_splice_read(in, ppos, pipe, len, flags); in ntfs_file_splice_read()
1336 static ssize_t ntfs_file_splice_write(struct pipe_inode_info *pipe, in ntfs_file_splice_write() argument
1347 return iter_file_splice_write(pipe, file, ppos, len, flags); in ntfs_file_splice_write()
|
| /fs/zonefs/ |
| A D | file.c | 687 struct pipe_inode_info *pipe, in zonefs_file_splice_read() argument
715 ret = filemap_splice_read(in, ppos, pipe, len, flags); in zonefs_file_splice_read()
|
| /fs/exfat/ |
| A D | file.c | 697 struct pipe_inode_info *pipe, size_t len, unsigned int flags) in exfat_splice_read() argument
702 return filemap_splice_read(in, ppos, pipe, len, flags); in exfat_splice_read()
|
| /fs/ext4/ |
| A D | file.c | 151 struct pipe_inode_info *pipe, in ext4_file_splice_read() argument
158 return filemap_splice_read(in, ppos, pipe, len, flags); in ext4_file_splice_read()
|