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()
398 pipe_named_ctor(struct pipe **ppipe, struct thread *td) in pipe_named_ctor()
412 pipe_dtor(struct pipe *dpipe) in pipe_dtor()
414 struct pipe *peer; in pipe_dtor()
448 struct pipe *rpipe, *wpipe; in kern_pipe()
538 pipespace_new(struct pipe *cpipe, int size) in pipespace_new()
603 pipespace(struct pipe *cpipe, int size) in pipespace()
615 pipelock(struct pipe *cpipe, int catch) in pipelock()
643 pipeunlock(struct pipe *cpipe) in pipeunlock()
659 pipeselwakeup(struct pipe *cpipe) in pipeselwakeup()
678 pipe_create(struct pipe *pipe, bool large_backing) in pipe_create() argument
682 error = pipespace_new(pipe, !large_backing || amountpipekva > in pipe_create()
685 pipe->pipe_ino = alloc_unr64(&pipeino_unr); in pipe_create()
694 struct pipe *rpipe; in pipe_read()
871 pipe_build_write_buffer(struct pipe *wpipe, struct uio *uio) in pipe_build_write_buffer()
916 pipe_destroy_write_buffer(struct pipe *wpipe) in pipe_destroy_write_buffer()
936 pipe_clone_write_buffer(struct pipe *wpipe) in pipe_clone_write_buffer()
978 pipe_direct_write(struct pipe *wpipe, struct uio *uio) in pipe_direct_write()
1064 struct pipe *wpipe, *rpipe; in pipe_write()
1329 struct pipe *cpipe; in pipe_truncate()
1347 struct pipe *mpipe = fp->f_data; in pipe_ioctl()
1418 struct pipe *rpipe; in pipe_poll()
1419 struct pipe *wpipe; in pipe_poll()
1495 struct pipe *pipe; in pipe_stat() local
1500 pipe = fp->f_data; in pipe_stat()
1503 PIPE_LOCK(pipe); in pipe_stat()
1504 error = mac_pipe_check_stat(active_cred, pipe->pipe_pair); in pipe_stat()
1505 PIPE_UNLOCK(pipe); in pipe_stat()
1513 if (pipe->pipe_type & PIPE_TYPE_NAMED) { in pipe_stat()
1520 if (pipe->pipe_pages.cnt != 0) in pipe_stat()
1521 ub->st_size = pipe->pipe_pages.cnt; in pipe_stat()
1523 ub->st_size = pipe->pipe_buffer.cnt; in pipe_stat()
1525 ub->st_atim = pipe->pipe_atime; in pipe_stat()
1526 ub->st_mtim = pipe->pipe_mtime; in pipe_stat()
1527 ub->st_ctim = pipe->pipe_ctime; in pipe_stat()
1531 ub->st_ino = pipe->pipe_ino; in pipe_stat()
1554 struct pipe *cpipe; in pipe_chmod()
1569 struct pipe *cpipe; in pipe_chown()
1583 struct pipe *pi; in pipe_fill_kinfo()
1596 pipe_free_kmem(struct pipe *cpipe) in pipe_free_kmem()
1622 pipeclose(struct pipe *cpipe) in pipeclose()
1625 struct pipe *ppipe; in pipeclose()
1698 struct pipe *cpipe; in pipe_kqfilter()
1742 struct pipe *cpipe = kn->kn_hook; in filt_pipedetach()
1754 struct pipe *rpipe = kn->kn_hook; in filt_piperead()
1775 struct pipe *wpipe = kn->kn_hook; in filt_pipewrite()