Searched refs:cpipe (Results 1 – 4 of 4) sorted by relevance
631 if (cpipe->pipe_buffer.in <= cpipe->pipe_buffer.out) { in pipespace_new()632 firstseg = cpipe->pipe_buffer.size - cpipe->pipe_buffer.out; in pipespace_new()633 bcopy(&cpipe->pipe_buffer.buffer[cpipe->pipe_buffer.out], in pipespace_new()639 bcopy(&cpipe->pipe_buffer.buffer[cpipe->pipe_buffer.out], in pipespace_new()683 error = msleep(&cpipe->pipe_waiters, PIPE_MTX(cpipe), prio, in pipelock()721 if ((cpipe->pipe_state & PIPE_ASYNC) && cpipe->pipe_sigio) in pipeselwakeup()1710 PIPE_LOCK(cpipe); in pipeclose()1722 wakeup(cpipe); in pipeclose()1725 msleep(cpipe, PIPE_MTX(cpipe), PRIBIO, "pipecl", 0); in pipeclose()1749 PIPE_LOCK(cpipe); in pipeclose()[all …]
267 struct pipe *cpipe; in fifo_close() local284 cpipe = fip->fi_pipe; in fifo_close()288 PIPE_LOCK(cpipe); in fifo_close()292 wakeup(cpipe); in fifo_close()294 pipeselwakeup(cpipe); in fifo_close()295 PIPE_UNLOCK(cpipe); in fifo_close()301 PIPE_LOCK(cpipe); in fifo_close()305 wakeup(cpipe); in fifo_close()307 cpipe->pipe_wgen++; in fifo_close()308 pipeselwakeup(cpipe); in fifo_close()[all …]
235 close(cpipe[0]); in ATF_TC_BODY()242 close(cpipe[1]); in ATF_TC_BODY()253 close(cpipe[0]); in ATF_TC_BODY()283 close(cpipe[0]); in ATF_TC_BODY()291 close(cpipe[1]); in ATF_TC_BODY()333 close(cpipe[0]); in ATF_TC_BODY()379 close(cpipe[0]); in ATF_TC_BODY()387 close(cpipe[1]); in ATF_TC_BODY()450 close(cpipe[0]); in ATF_TC_BODY()800 close(cpipe[0]); in attach_fork_parent()[all …]
150 void pipeselwakeup(struct pipe *cpipe);