138 #define PIPE_PEER(pipe)	\  argument
139 	(((pipe)->pipe_type & PIPE_TYPE_NAMED) ? (pipe) : ((pipe)->pipe_peer))
234 static void pipeclose(struct pipe *cpipe);
235 static void pipe_free_kmem(struct pipe *cpipe);
236 static int pipe_create(struct pipe *pipe, bool backing);
238 static __inline int pipelock(struct pipe *cpipe, bool catch);
239 static __inline void pipeunlock(struct pipe *cpipe);
242 static int pipe_build_write_buffer(struct pipe *wpipe, struct uio *uio);
243 static void pipe_destroy_write_buffer(struct pipe *wpipe);
244 static int pipe_direct_write(struct pipe *wpipe, struct uio *uio);
245 static void pipe_clone_write_buffer(struct pipe *wpipe);
247 static int pipespace(struct pipe *cpipe, int size);
248 static int pipespace_new(struct pipe *cpipe, int size);
300 	struct pipe *rpipe, *wpipe;  in pipe_zone_ctor()
373 	struct pipe *rpipe, *wpipe;  in pipe_paircreate()
431 pipe_named_ctor(struct pipe **ppipe, struct thread *td)  in pipe_named_ctor()
445 pipe_dtor(struct pipe *dpipe)  in pipe_dtor()
447 	struct pipe *peer;  in pipe_dtor()
481 	struct pipe *rpipe, *wpipe;  in kern_pipe()
571 pipespace_new(struct pipe *cpipe, int size)  in pipespace_new()
661 pipespace(struct pipe *cpipe, int size)  in pipespace()
673 pipelock(struct pipe *cpipe, bool catch)  in pipelock()
701 pipeunlock(struct pipe *cpipe)  in pipeunlock()
716 pipeselwakeup(struct pipe *cpipe)  in pipeselwakeup()
735 pipe_create(struct pipe *pipe, bool large_backing)  in pipe_create()  argument
739 	error = pipespace_new(pipe, !large_backing || amountpipekva >  in pipe_create()
742 		pipe->pipe_ino = alloc_unr64(&pipeino_unr);  in pipe_create()
751 	struct pipe *rpipe;  in pipe_read()
947 pipe_build_write_buffer(struct pipe *wpipe, struct uio *uio)  in pipe_build_write_buffer()
994 pipe_destroy_write_buffer(struct pipe *wpipe)  in pipe_destroy_write_buffer()
1014 pipe_clone_write_buffer(struct pipe *wpipe)  in pipe_clone_write_buffer()
1056 pipe_direct_write(struct pipe *wpipe, struct uio *uio)  in pipe_direct_write()
1142 	struct pipe *wpipe, *rpipe;  in pipe_write()
1407 	struct pipe *cpipe;  in pipe_truncate()
1425 	struct pipe *mpipe = fp->f_data;  in pipe_ioctl()
1496 	struct pipe *rpipe;  in pipe_poll()
1497 	struct pipe *wpipe;  in pipe_poll()
1573 	struct pipe *pipe;  in pipe_stat()  local
1578 	pipe = fp->f_data;  in pipe_stat()
1581 		PIPE_LOCK(pipe);  in pipe_stat()
1582 		error = mac_pipe_check_stat(active_cred, pipe->pipe_pair);  in pipe_stat()
1583 		PIPE_UNLOCK(pipe);  in pipe_stat()
1591 	if (pipe->pipe_type & PIPE_TYPE_NAMED) {  in pipe_stat()
1598 	if (pipe->pipe_pages.cnt != 0)  in pipe_stat()
1599 		ub->st_size = pipe->pipe_pages.cnt;  in pipe_stat()
1601 		ub->st_size = pipe->pipe_buffer.cnt;  in pipe_stat()
1603 	ub->st_atim = pipe->pipe_atime;  in pipe_stat()
1604 	ub->st_mtim = pipe->pipe_mtime;  in pipe_stat()
1605 	ub->st_ctim = pipe->pipe_ctime;  in pipe_stat()
1609 	ub->st_ino = pipe->pipe_ino;  in pipe_stat()
1632 	struct pipe *cpipe;  in pipe_chmod()
1647 	struct pipe *cpipe;  in pipe_chown()
1661 	struct pipe *pi;  in pipe_fill_kinfo()
1677 pipe_free_kmem(struct pipe *cpipe)  in pipe_free_kmem()
1705 pipeclose(struct pipe *cpipe)  in pipeclose()
1710 	struct pipe *ppipe;  in pipeclose()
1786 	struct pipe *cpipe;  in pipe_kqfilter()
1834 	struct pipe *cpipe = kn->kn_hook;  in filt_pipedetach()
1846 	struct pipe *rpipe = kn->kn_hook;  in filt_piperead()
1867 	struct pipe *wpipe = kn->kn_hook;  in filt_pipewrite()
1913 	struct pipe *pipe = kn->kn_hook;  in filt_pipedump()  local
1916 	kin->knt_pipe.knt_pipe_ino = pipe->pipe_ino;  in filt_pipedump()