Lines Matching refs:pipe
142 #define PIPE_PEER(pipe) \ argument
143 (((pipe)->pipe_state & PIPE_NAMED) ? (pipe) : ((pipe)->pipe_peer))
227 static void pipeclose(struct pipe *cpipe);
228 static void pipe_free_kmem(struct pipe *cpipe);
229 static void pipe_create(struct pipe *pipe, int backing);
231 static __inline int pipelock(struct pipe *cpipe, int catch);
232 static __inline void pipeunlock(struct pipe *cpipe);
234 static int pipe_build_write_buffer(struct pipe *wpipe, struct uio *uio);
235 static void pipe_destroy_write_buffer(struct pipe *wpipe);
236 static int pipe_direct_write(struct pipe *wpipe, struct uio *uio);
237 static void pipe_clone_write_buffer(struct pipe *wpipe);
239 static int pipespace(struct pipe *cpipe, int size);
240 static int pipespace_new(struct pipe *cpipe, int size);
269 struct pipe *rpipe, *wpipe; in pipe_zone_ctor()
342 struct pipe *rpipe, *wpipe; in pipe_paircreate()
369 pipe_named_ctor(struct pipe **ppipe, struct thread *td) in pipe_named_ctor()
379 pipe_dtor(struct pipe *dpipe) in pipe_dtor()
381 struct pipe *peer; in pipe_dtor()
403 struct pipe *rpipe, *wpipe; in kern_pipe()
491 pipespace_new(struct pipe *cpipe, int size) in pipespace_new()
556 pipespace(struct pipe *cpipe, int size) in pipespace()
568 pipelock(struct pipe *cpipe, int catch) in pipelock()
589 pipeunlock(struct pipe *cpipe) in pipeunlock()
603 pipeselwakeup(struct pipe *cpipe) in pipeselwakeup()
622 pipe_create(struct pipe *pipe, int backing) in pipe_create() argument
634 (void)pipespace_new(pipe, SMALL_PIPE_SIZE); in pipe_create()
636 (void)pipespace_new(pipe, PIPE_SIZE); in pipe_create()
639 pipe->pipe_ino = alloc_unr64(&pipeino_unr); in pipe_create()
647 struct pipe *rpipe; in pipe_read()
817 pipe_build_write_buffer(struct pipe *wpipe, struct uio *uio) in pipe_build_write_buffer()
862 pipe_destroy_write_buffer(struct pipe *wpipe) in pipe_destroy_write_buffer()
882 pipe_clone_write_buffer(struct pipe *wpipe) in pipe_clone_write_buffer()
924 pipe_direct_write(struct pipe *wpipe, struct uio *uio) in pipe_direct_write()
1022 struct pipe *wpipe, *rpipe; in pipe_write()
1298 struct pipe *cpipe; in pipe_truncate()
1316 struct pipe *mpipe = fp->f_data; in pipe_ioctl()
1388 struct pipe *rpipe; in pipe_poll()
1389 struct pipe *wpipe; in pipe_poll()
1460 struct pipe *pipe; in pipe_stat() local
1465 pipe = fp->f_data; in pipe_stat()
1466 PIPE_LOCK(pipe); in pipe_stat()
1468 error = mac_pipe_check_stat(active_cred, pipe->pipe_pair); in pipe_stat()
1470 PIPE_UNLOCK(pipe); in pipe_stat()
1476 if (pipe->pipe_state & PIPE_NAMED) { in pipe_stat()
1477 PIPE_UNLOCK(pipe); in pipe_stat()
1481 PIPE_UNLOCK(pipe); in pipe_stat()
1486 if (pipe->pipe_map.cnt != 0) in pipe_stat()
1487 ub->st_size = pipe->pipe_map.cnt; in pipe_stat()
1489 ub->st_size = pipe->pipe_buffer.cnt; in pipe_stat()
1491 ub->st_atim = pipe->pipe_atime; in pipe_stat()
1492 ub->st_mtim = pipe->pipe_mtime; in pipe_stat()
1493 ub->st_ctim = pipe->pipe_ctime; in pipe_stat()
1497 ub->st_ino = pipe->pipe_ino; in pipe_stat()
1520 struct pipe *cpipe; in pipe_chmod()
1535 struct pipe *cpipe; in pipe_chown()
1549 struct pipe *pi; in pipe_fill_kinfo()
1562 pipe_free_kmem(struct pipe *cpipe) in pipe_free_kmem()
1588 pipeclose(struct pipe *cpipe) in pipeclose()
1591 struct pipe *ppipe; in pipeclose()
1667 struct pipe *cpipe; in pipe_kqfilter()
1711 struct pipe *cpipe = kn->kn_hook; in filt_pipedetach()
1722 struct pipe *rpipe = kn->kn_hook; in filt_piperead()
1723 struct pipe *wpipe = rpipe->pipe_peer; in filt_piperead()
1745 struct pipe *wpipe; in filt_pipewrite()