Lines Matching refs:pipe

139 #define PIPE_PEER(pipe)	\  argument
140 (((pipe)->pipe_type & PIPE_TYPE_NAMED) ? (pipe) : ((pipe)->pipe_peer))
230 static void pipeclose(struct pipe *cpipe);
231 static void pipe_free_kmem(struct pipe *cpipe);
232 static int pipe_create(struct pipe *pipe, bool backing);
234 static __inline int pipelock(struct pipe *cpipe, int catch);
235 static __inline void pipeunlock(struct pipe *cpipe);
238 static int pipe_build_write_buffer(struct pipe *wpipe, struct uio *uio);
239 static void pipe_destroy_write_buffer(struct pipe *wpipe);
240 static int pipe_direct_write(struct pipe *wpipe, struct uio *uio);
241 static void pipe_clone_write_buffer(struct pipe *wpipe);
243 static int pipespace(struct pipe *cpipe, int size);
244 static int pipespace_new(struct pipe *cpipe, int size);
296 struct pipe *rpipe, *wpipe; in pipe_zone_ctor()
369 struct pipe *rpipe, *wpipe; in pipe_paircreate()
427 pipe_named_ctor(struct pipe **ppipe, struct thread *td) in pipe_named_ctor()
441 pipe_dtor(struct pipe *dpipe) in pipe_dtor()
443 struct pipe *peer; in pipe_dtor()
477 struct pipe *rpipe, *wpipe; in kern_pipe()
567 pipespace_new(struct pipe *cpipe, int size) in pipespace_new()
657 pipespace(struct pipe *cpipe, int size) in pipespace()
669 pipelock(struct pipe *cpipe, int catch) in pipelock()
697 pipeunlock(struct pipe *cpipe) in pipeunlock()
712 pipeselwakeup(struct pipe *cpipe) in pipeselwakeup()
731 pipe_create(struct pipe *pipe, bool large_backing) in pipe_create() argument
735 error = pipespace_new(pipe, !large_backing || amountpipekva > in pipe_create()
738 pipe->pipe_ino = alloc_unr64(&pipeino_unr); in pipe_create()
747 struct pipe *rpipe; in pipe_read()
943 pipe_build_write_buffer(struct pipe *wpipe, struct uio *uio) in pipe_build_write_buffer()
990 pipe_destroy_write_buffer(struct pipe *wpipe) in pipe_destroy_write_buffer()
1010 pipe_clone_write_buffer(struct pipe *wpipe) in pipe_clone_write_buffer()
1052 pipe_direct_write(struct pipe *wpipe, struct uio *uio) in pipe_direct_write()
1138 struct pipe *wpipe, *rpipe; in pipe_write()
1403 struct pipe *cpipe; in pipe_truncate()
1421 struct pipe *mpipe = fp->f_data; in pipe_ioctl()
1492 struct pipe *rpipe; in pipe_poll()
1493 struct pipe *wpipe; in pipe_poll()
1569 struct pipe *pipe; in pipe_stat() local
1574 pipe = fp->f_data; in pipe_stat()
1577 PIPE_LOCK(pipe); in pipe_stat()
1578 error = mac_pipe_check_stat(active_cred, pipe->pipe_pair); in pipe_stat()
1579 PIPE_UNLOCK(pipe); in pipe_stat()
1587 if (pipe->pipe_type & PIPE_TYPE_NAMED) { in pipe_stat()
1594 if (pipe->pipe_pages.cnt != 0) in pipe_stat()
1595 ub->st_size = pipe->pipe_pages.cnt; in pipe_stat()
1597 ub->st_size = pipe->pipe_buffer.cnt; in pipe_stat()
1599 ub->st_atim = pipe->pipe_atime; in pipe_stat()
1600 ub->st_mtim = pipe->pipe_mtime; in pipe_stat()
1601 ub->st_ctim = pipe->pipe_ctime; in pipe_stat()
1605 ub->st_ino = pipe->pipe_ino; in pipe_stat()
1628 struct pipe *cpipe; in pipe_chmod()
1643 struct pipe *cpipe; in pipe_chown()
1657 struct pipe *pi; in pipe_fill_kinfo()
1673 pipe_free_kmem(struct pipe *cpipe) in pipe_free_kmem()
1701 pipeclose(struct pipe *cpipe) in pipeclose()
1706 struct pipe *ppipe; in pipeclose()
1782 struct pipe *cpipe; in pipe_kqfilter()
1830 struct pipe *cpipe = kn->kn_hook; in filt_pipedetach()
1842 struct pipe *rpipe = kn->kn_hook; in filt_piperead()
1863 struct pipe *wpipe = kn->kn_hook; in filt_pipewrite()