143 	(((pipe)->pipe_state & PIPE_NAMED) ? (pipe) : ((pipe)->pipe_peer))
364 	rpipe->pipe_state |= PIPE_DIRECTOK;  in pipe_paircreate()
365 	wpipe->pipe_state |= PIPE_DIRECTOK;  in pipe_paircreate()
374 	pp->pp_rpipe.pipe_state |= PIPE_NAMED;  in pipe_named_ctor()
385 	peer = (dpipe->pipe_state & PIPE_NAMED) != 0 ? dpipe->pipe_peer : NULL;  in pipe_dtor()
499 	KASSERT(!(cpipe->pipe_state & PIPE_DIRECTW),  in pipespace_new()
559 	KASSERT(cpipe->pipe_state & PIPE_LOCKFL,  in pipespace()
573 	while (cpipe->pipe_state & PIPE_LOCKFL) {  in pipelock()
574 		cpipe->pipe_state |= PIPE_LWANT;  in pipelock()
581 	cpipe->pipe_state |= PIPE_LOCKFL;  in pipelock()
593 	KASSERT(cpipe->pipe_state & PIPE_LOCKFL,  in pipeunlock()
595 	cpipe->pipe_state &= ~PIPE_LOCKFL;  in pipeunlock()
596 	if (cpipe->pipe_state & PIPE_LWANT) {  in pipeunlock()
597 		cpipe->pipe_state &= ~PIPE_LWANT;  in pipeunlock()
607 	if (cpipe->pipe_state & PIPE_SEL) {  in pipeselwakeup()
610 			cpipe->pipe_state &= ~PIPE_SEL;  in pipeselwakeup()
612 	if ((cpipe->pipe_state & PIPE_ASYNC) && cpipe->pipe_sigio)  in pipeselwakeup()
665 		if (!(rpipe->pipe_state & PIPE_DIRECTW) &&  in pipe_read()
727 				rpipe->pipe_state &= ~PIPE_WANTW;  in pipe_read()
736 			if (rpipe->pipe_state & PIPE_EOF)  in pipe_read()
742 			if (rpipe->pipe_state & PIPE_WANTW) {  in pipe_read()
743 				rpipe->pipe_state &= ~PIPE_WANTW;  in pipe_read()
767 				rpipe->pipe_state |= PIPE_WANTR;  in pipe_read()
791 	if ((rpipe->pipe_busy == 0) && (rpipe->pipe_state & PIPE_WANT)) {  in pipe_read()
792 		rpipe->pipe_state &= ~(PIPE_WANT|PIPE_WANTW);  in pipe_read()
798 		if (rpipe->pipe_state & PIPE_WANTW) {  in pipe_read()
799 			rpipe->pipe_state &= ~PIPE_WANTW;  in pipe_read()
823 	KASSERT((wpipe->pipe_state & PIPE_DIRECTW) == 0,  in pipe_build_write_buffer()
833 	wpipe->pipe_state |= PIPE_DIRECTW;  in pipe_build_write_buffer()
840 		wpipe->pipe_state &= ~PIPE_DIRECTW;  in pipe_build_write_buffer()
866 	KASSERT((wpipe->pipe_state & PIPE_DIRECTW) != 0,  in pipe_destroy_write_buffer()
871 	wpipe->pipe_state &= ~PIPE_DIRECTW;  in pipe_destroy_write_buffer()
890 	KASSERT((wpipe->pipe_state & PIPE_DIRECTW) != 0,  in pipe_clone_write_buffer()
933 	if ((wpipe->pipe_state & PIPE_EOF) != 0) {  in pipe_direct_write()
938 	if (wpipe->pipe_state & PIPE_DIRECTW) {  in pipe_direct_write()
939 		if (wpipe->pipe_state & PIPE_WANTR) {  in pipe_direct_write()
940 			wpipe->pipe_state &= ~PIPE_WANTR;  in pipe_direct_write()
944 		wpipe->pipe_state |= PIPE_WANTW;  in pipe_direct_write()
954 		if (wpipe->pipe_state & PIPE_WANTR) {  in pipe_direct_write()
955 			wpipe->pipe_state &= ~PIPE_WANTR;  in pipe_direct_write()
959 		wpipe->pipe_state |= PIPE_WANTW;  in pipe_direct_write()
976 		if (wpipe->pipe_state & PIPE_EOF) {  in pipe_direct_write()
984 		if (wpipe->pipe_state & PIPE_WANTR) {  in pipe_direct_write()
985 			wpipe->pipe_state &= ~PIPE_WANTR;  in pipe_direct_write()
989 		wpipe->pipe_state |= PIPE_WANTW;  in pipe_direct_write()
998 	if (wpipe->pipe_state & PIPE_EOF)  in pipe_direct_write()
1005 	KASSERT((wpipe->pipe_state & PIPE_DIRECTW) == 0,  in pipe_direct_write()
1036 	    (wpipe->pipe_state & PIPE_EOF)) {  in pipe_write()
1072 		((wpipe->pipe_state & PIPE_DIRECTW) == 0)) {  in pipe_write()
1097 		if (wpipe->pipe_state & PIPE_EOF) {  in pipe_write()
1132 			if (wpipe->pipe_state & PIPE_WANTR) {  in pipe_write()
1133 				wpipe->pipe_state &= ~PIPE_WANTR;  in pipe_write()
1137 			wpipe->pipe_state |= PIPE_WANTW;  in pipe_write()
1223 			if (wpipe->pipe_state & PIPE_WANTR) {  in pipe_write()
1224 				wpipe->pipe_state &= ~PIPE_WANTR;  in pipe_write()
1243 			wpipe->pipe_state |= PIPE_WANTW;  in pipe_write()
1255 	if ((wpipe->pipe_busy == 0) && (wpipe->pipe_state & PIPE_WANT)) {  in pipe_write()
1256 		wpipe->pipe_state &= ~(PIPE_WANT | PIPE_WANTR);  in pipe_write()
1263 		if (wpipe->pipe_state & PIPE_WANTR) {  in pipe_write()
1264 			wpipe->pipe_state &= ~PIPE_WANTR;  in pipe_write()
1302 	if (cpipe->pipe_state & PIPE_NAMED)  in pipe_truncate()
1337 			mpipe->pipe_state |= PIPE_ASYNC;  in pipe_ioctl()
1339 			mpipe->pipe_state &= ~PIPE_ASYNC;  in pipe_ioctl()
1410 		    (wpipe->pipe_state & PIPE_EOF) ||  in pipe_poll()
1411 		    ((wpipe->pipe_state & PIPE_DIRECTW) == 0 &&  in pipe_poll()
1418 	if (rpipe->pipe_state & PIPE_NAMED && fp->f_flag & FREAD && levents &&  in pipe_poll()
1423 		if (rpipe->pipe_state & PIPE_EOF) {  in pipe_poll()
1426 			    (wpipe->pipe_state & PIPE_EOF))  in pipe_poll()
1435 				rpipe->pipe_state |= PIPE_SEL;  in pipe_poll()
1441 				wpipe->pipe_state |= PIPE_SEL;  in pipe_poll()
1476 	if (pipe->pipe_state & PIPE_NAMED) {  in pipe_stat()
1524 	if (cpipe->pipe_state & PIPE_NAMED)  in pipe_chmod()
1539 	if (cpipe->pipe_state & PIPE_NAMED)  in pipe_chown()
1605 	cpipe->pipe_state |= PIPE_EOF;  in pipeclose()
1608 		cpipe->pipe_state |= PIPE_WANT;  in pipeclose()
1622 		ppipe->pipe_state |= PIPE_EOF;  in pipeclose()
1731 	if ((rpipe->pipe_state & PIPE_EOF) ||  in filt_piperead()
1733 	    (wpipe->pipe_state & PIPE_EOF)) {  in filt_piperead()
1753 	    (wpipe->pipe_state & PIPE_EOF)) {  in filt_pipewrite()
1761 	if (wpipe->pipe_state & PIPE_DIRECTW)  in filt_pipewrite()