Lines Matching refs:pipe_state
384 rpipe->pipe_state |= PIPE_DIRECTOK; in pipe_paircreate()
385 wpipe->pipe_state |= PIPE_DIRECTOK; in pipe_paircreate()
547 KASSERT(!(cpipe->pipe_state & PIPE_DIRECTW), in pipespace_new()
607 KASSERT(cpipe->pipe_state & PIPE_LOCKFL, in pipespace()
625 while (cpipe->pipe_state & PIPE_LOCKFL) { in pipelock()
636 cpipe->pipe_state |= PIPE_LOCKFL; in pipelock()
648 KASSERT(cpipe->pipe_state & PIPE_LOCKFL, in pipeunlock()
653 cpipe->pipe_state &= ~PIPE_LOCKFL; in pipeunlock()
664 if (cpipe->pipe_state & PIPE_SEL) { in pipeselwakeup()
667 cpipe->pipe_state &= ~PIPE_SEL; in pipeselwakeup()
669 if ((cpipe->pipe_state & PIPE_ASYNC) && cpipe->pipe_sigio) in pipeselwakeup()
713 if ((rpipe->pipe_state & PIPE_DIRECTW) == 0 && in pipe_read()
775 rpipe->pipe_state &= ~PIPE_WANTW; in pipe_read()
784 if (rpipe->pipe_state & PIPE_EOF) in pipe_read()
790 if (rpipe->pipe_state & PIPE_WANTW) { in pipe_read()
791 rpipe->pipe_state &= ~PIPE_WANTW; in pipe_read()
815 rpipe->pipe_state |= PIPE_WANTR; in pipe_read()
839 if ((rpipe->pipe_busy == 0) && (rpipe->pipe_state & PIPE_WANT)) { in pipe_read()
840 rpipe->pipe_state &= ~(PIPE_WANT|PIPE_WANTW); in pipe_read()
846 if (rpipe->pipe_state & PIPE_WANTW) { in pipe_read()
847 rpipe->pipe_state &= ~PIPE_WANTW; in pipe_read()
878 KASSERT((wpipe->pipe_state & PIPE_DIRECTW) == 0, in pipe_build_write_buffer()
888 wpipe->pipe_state |= PIPE_DIRECTW; in pipe_build_write_buffer()
895 wpipe->pipe_state &= ~PIPE_DIRECTW; in pipe_build_write_buffer()
921 KASSERT((wpipe->pipe_state & PIPE_DIRECTW) != 0, in pipe_destroy_write_buffer()
926 wpipe->pipe_state &= ~PIPE_DIRECTW; in pipe_destroy_write_buffer()
945 KASSERT((wpipe->pipe_state & PIPE_DIRECTW) != 0, in pipe_clone_write_buffer()
985 if ((wpipe->pipe_state & PIPE_EOF) != 0) { in pipe_direct_write()
989 if (wpipe->pipe_state & PIPE_DIRECTW) { in pipe_direct_write()
990 if (wpipe->pipe_state & PIPE_WANTR) { in pipe_direct_write()
991 wpipe->pipe_state &= ~PIPE_WANTR; in pipe_direct_write()
995 wpipe->pipe_state |= PIPE_WANTW; in pipe_direct_write()
1005 if (wpipe->pipe_state & PIPE_WANTR) { in pipe_direct_write()
1006 wpipe->pipe_state &= ~PIPE_WANTR; in pipe_direct_write()
1010 wpipe->pipe_state |= PIPE_WANTW; in pipe_direct_write()
1026 (wpipe->pipe_state & PIPE_EOF) == 0) { in pipe_direct_write()
1027 if (wpipe->pipe_state & PIPE_WANTR) { in pipe_direct_write()
1028 wpipe->pipe_state &= ~PIPE_WANTR; in pipe_direct_write()
1032 wpipe->pipe_state |= PIPE_WANTW; in pipe_direct_write()
1041 if ((wpipe->pipe_state & PIPE_EOF) != 0) { in pipe_direct_write()
1051 KASSERT((wpipe->pipe_state & PIPE_DIRECTW) == 0, in pipe_direct_write()
1081 (wpipe->pipe_state & PIPE_EOF)) { in pipe_write()
1117 (wpipe->pipe_state & PIPE_DIRECTW) == 0) { in pipe_write()
1129 if (wpipe->pipe_state & PIPE_EOF) { in pipe_write()
1162 if (wpipe->pipe_state & PIPE_WANTR) { in pipe_write()
1163 wpipe->pipe_state &= ~PIPE_WANTR; in pipe_write()
1167 wpipe->pipe_state |= PIPE_WANTW; in pipe_write()
1253 if (wpipe->pipe_state & PIPE_WANTR) { in pipe_write()
1254 wpipe->pipe_state &= ~PIPE_WANTR; in pipe_write()
1272 wpipe->pipe_state |= PIPE_WANTW; in pipe_write()
1285 if ((wpipe->pipe_busy == 0) && (wpipe->pipe_state & PIPE_WANT)) { in pipe_write()
1286 wpipe->pipe_state &= ~(PIPE_WANT | PIPE_WANTR); in pipe_write()
1293 if (wpipe->pipe_state & PIPE_WANTR) { in pipe_write()
1294 wpipe->pipe_state &= ~PIPE_WANTR; in pipe_write()
1368 mpipe->pipe_state |= PIPE_ASYNC; in pipe_ioctl()
1370 mpipe->pipe_state &= ~PIPE_ASYNC; in pipe_ioctl()
1441 (wpipe->pipe_state & PIPE_EOF) || in pipe_poll()
1442 ((wpipe->pipe_state & PIPE_DIRECTW) == 0 && in pipe_poll()
1454 if (rpipe->pipe_state & PIPE_EOF) { in pipe_poll()
1458 (wpipe->pipe_state & PIPE_EOF)) in pipe_poll()
1471 rpipe->pipe_state |= PIPE_SEL; in pipe_poll()
1478 wpipe->pipe_state |= PIPE_SEL; in pipe_poll()
1639 cpipe->pipe_state |= PIPE_EOF; in pipeclose()
1642 cpipe->pipe_state |= PIPE_WANT; in pipeclose()
1655 ppipe->pipe_state |= PIPE_EOF; in pipeclose()
1763 if ((rpipe->pipe_state & PIPE_EOF) != 0 && in filt_piperead()
1787 if (wpipe->pipe_state & PIPE_DIRECTW) { in filt_pipewrite()
1798 (wpipe->pipe_state & PIPE_EOF)) { in filt_pipewrite()