Lines Matching refs:pipe_state

179           pipe->pipe_state = PIPE_SIGNALR;  in pipe_ctor()
338 while (pipe->pipe_state & PIPE_LOCKFL) { in pipelock()
348 pipe->pipe_state |= PIPE_LOCKFL; in pipelock()
360 KASSERT(pipe->pipe_state & PIPE_LOCKFL); in pipeunlock()
362 pipe->pipe_state &= ~PIPE_LOCKFL; in pipeunlock()
398 if (sigp == NULL || (sigp->pipe_state & PIPE_ASYNC) == 0) in pipeselwakeup()
430 (atomic_load_relaxed(&rpipe->pipe_state) & PIPE_EOF) == 0) in pipe_read()
489 if (rpipe->pipe_state & PIPE_EOF) in pipe_read()
528 wakeup_state = rpipe->pipe_state; in pipe_read()
539 rpipe->pipe_state &= ~PIPE_RESTART; in pipe_read()
552 && (ocnt != bp->cnt || (rpipe->pipe_state & PIPE_SIGNALR))) { in pipe_read()
554 rpipe->pipe_state &= ~PIPE_SIGNALR; in pipe_read()
582 if (wpipe == NULL || (wpipe->pipe_state & PIPE_EOF) != 0) { in pipe_write()
592 wpipe->pipe_state &= ~PIPE_RESTART; in pipe_write()
702 if (wpipe->pipe_state & PIPE_EOF) { in pipe_write()
712 wakeup_state = wpipe->pipe_state; in pipe_write()
718 wpipe->pipe_state &= ~PIPE_RESTART; in pipe_write()
743 wpipe->pipe_state |= PIPE_SIGNALR; in pipe_write()
767 pipe->pipe_state |= PIPE_ASYNC; in pipe_ioctl()
769 pipe->pipe_state &= ~PIPE_ASYNC; in pipe_ioctl()
828 (rpipe->pipe_state & PIPE_EOF)) in pipe_poll()
831 eof |= (rpipe->pipe_state & PIPE_EOF); in pipe_poll()
837 if ((wpipe->pipe_state & PIPE_EOF) || ( in pipe_poll()
841 eof |= (wpipe->pipe_state & PIPE_EOF); in pipe_poll()
907 pipe->pipe_state |= PIPE_RESTART; in pipe_restart()
983 pipe->pipe_state |= PIPE_EOF; in pipeclose()
996 ppipe->pipe_state |= PIPE_EOF; in pipeclose()
1010 KASSERT((pipe->pipe_state & PIPE_LOCKFL) == 0); in pipeclose()
1019 pipe->pipe_state = PIPE_SIGNALR; in pipeclose()
1076 if ((rpipe->pipe_state & PIPE_EOF) || in filt_piperead()
1077 (wpipe == NULL) || (wpipe->pipe_state & PIPE_EOF)) { in filt_piperead()
1102 if ((wpipe == NULL) || (wpipe->pipe_state & PIPE_EOF)) { in filt_pipewrite()