Lines Matching refs:pipe
142 #define PIPE_PEER(pipe) \ argument
143 (((pipe)->pipe_type & PIPE_TYPE_NAMED) ? (pipe) : ((pipe)->pipe_peer))
227 static void pipeclose(struct pipe *cpipe);
228 static void pipe_free_kmem(struct pipe *cpipe);
229 static int pipe_create(struct pipe *pipe, bool backing);
231 static __inline int pipelock(struct pipe *cpipe, int catch);
232 static __inline void pipeunlock(struct pipe *cpipe);
235 static int pipe_build_write_buffer(struct pipe *wpipe, struct uio *uio);
236 static void pipe_destroy_write_buffer(struct pipe *wpipe);
237 static int pipe_direct_write(struct pipe *wpipe, struct uio *uio);
238 static void pipe_clone_write_buffer(struct pipe *wpipe);
240 static int pipespace(struct pipe *cpipe, int size);
241 static int pipespace_new(struct pipe *cpipe, int size);
270 struct pipe *rpipe, *wpipe; in pipe_zone_ctor()
343 struct pipe *rpipe, *wpipe; in pipe_paircreate()
399 pipe_named_ctor(struct pipe **ppipe, struct thread *td) in pipe_named_ctor()
413 pipe_dtor(struct pipe *dpipe) in pipe_dtor()
415 struct pipe *peer; in pipe_dtor()
449 struct pipe *rpipe, *wpipe; in kern_pipe()
539 pipespace_new(struct pipe *cpipe, int size) in pipespace_new()
604 pipespace(struct pipe *cpipe, int size) in pipespace()
616 pipelock(struct pipe *cpipe, int catch) in pipelock()
644 pipeunlock(struct pipe *cpipe) in pipeunlock()
660 pipeselwakeup(struct pipe *cpipe) in pipeselwakeup()
679 pipe_create(struct pipe *pipe, bool large_backing) in pipe_create() argument
683 error = pipespace_new(pipe, !large_backing || amountpipekva > in pipe_create()
686 pipe->pipe_ino = alloc_unr64(&pipeino_unr); in pipe_create()
695 struct pipe *rpipe; in pipe_read()
872 pipe_build_write_buffer(struct pipe *wpipe, struct uio *uio) in pipe_build_write_buffer()
917 pipe_destroy_write_buffer(struct pipe *wpipe) in pipe_destroy_write_buffer()
937 pipe_clone_write_buffer(struct pipe *wpipe) in pipe_clone_write_buffer()
979 pipe_direct_write(struct pipe *wpipe, struct uio *uio) in pipe_direct_write()
1065 struct pipe *wpipe, *rpipe; in pipe_write()
1330 struct pipe *cpipe; in pipe_truncate()
1348 struct pipe *mpipe = fp->f_data; in pipe_ioctl()
1419 struct pipe *rpipe; in pipe_poll()
1420 struct pipe *wpipe; in pipe_poll()
1497 struct pipe *pipe; in pipe_stat() local
1502 pipe = fp->f_data; in pipe_stat()
1505 PIPE_LOCK(pipe); in pipe_stat()
1506 error = mac_pipe_check_stat(active_cred, pipe->pipe_pair); in pipe_stat()
1507 PIPE_UNLOCK(pipe); in pipe_stat()
1515 if (pipe->pipe_type & PIPE_TYPE_NAMED) { in pipe_stat()
1522 if (pipe->pipe_pages.cnt != 0) in pipe_stat()
1523 ub->st_size = pipe->pipe_pages.cnt; in pipe_stat()
1525 ub->st_size = pipe->pipe_buffer.cnt; in pipe_stat()
1527 ub->st_atim = pipe->pipe_atime; in pipe_stat()
1528 ub->st_mtim = pipe->pipe_mtime; in pipe_stat()
1529 ub->st_ctim = pipe->pipe_ctime; in pipe_stat()
1533 ub->st_ino = pipe->pipe_ino; in pipe_stat()
1556 struct pipe *cpipe; in pipe_chmod()
1571 struct pipe *cpipe; in pipe_chown()
1585 struct pipe *pi; in pipe_fill_kinfo()
1598 pipe_free_kmem(struct pipe *cpipe) in pipe_free_kmem()
1624 pipeclose(struct pipe *cpipe) in pipeclose()
1627 struct pipe *ppipe; in pipeclose()
1700 struct pipe *cpipe; in pipe_kqfilter()
1744 struct pipe *cpipe = kn->kn_hook; in filt_pipedetach()
1756 struct pipe *rpipe = kn->kn_hook; in filt_piperead()
1777 struct pipe *wpipe = kn->kn_hook; in filt_pipewrite()