wpipe             108 kern/sys_pipe.c 	struct pipe *rpipe, *wpipe;
wpipe             117 kern/sys_pipe.c 	wpipe = pool_get(&pipe_pool, PR_WAITOK);
wpipe             118 kern/sys_pipe.c 	error = pipe_create(wpipe);
wpipe             136 kern/sys_pipe.c 	wf->f_data = wpipe;
wpipe             140 kern/sys_pipe.c 	rpipe->pipe_peer = wpipe;
wpipe             141 kern/sys_pipe.c 	wpipe->pipe_peer = rpipe;
wpipe             154 kern/sys_pipe.c 	(void)pipeclose(wpipe);
wpipe             388 kern/sys_pipe.c 	struct pipe *wpipe, *rpipe;
wpipe             391 kern/sys_pipe.c 	wpipe = rpipe->pipe_peer;
wpipe             396 kern/sys_pipe.c 	if ((wpipe == NULL) || (wpipe->pipe_state & PIPE_EOF)) {
wpipe             399 kern/sys_pipe.c 	++wpipe->pipe_busy;
wpipe             407 kern/sys_pipe.c 	    (wpipe->pipe_buffer.size <= PIPE_SIZE) &&
wpipe             408 kern/sys_pipe.c 	    (wpipe->pipe_buffer.cnt == 0)) {
wpipe             410 kern/sys_pipe.c 		if ((error = pipelock(wpipe)) == 0) {
wpipe             411 kern/sys_pipe.c 			if (pipespace(wpipe, BIG_PIPE_SIZE) == 0)
wpipe             413 kern/sys_pipe.c 			pipeunlock(wpipe);
wpipe             422 kern/sys_pipe.c 		--wpipe->pipe_busy;
wpipe             423 kern/sys_pipe.c 		if ((wpipe->pipe_busy == 0) &&
wpipe             424 kern/sys_pipe.c 		    (wpipe->pipe_state & PIPE_WANT)) {
wpipe             425 kern/sys_pipe.c 			wpipe->pipe_state &= ~(PIPE_WANT | PIPE_WANTR);
wpipe             426 kern/sys_pipe.c 			wakeup(wpipe);
wpipe             437 kern/sys_pipe.c 		if (wpipe->pipe_state & PIPE_EOF) {
wpipe             442 kern/sys_pipe.c 		space = wpipe->pipe_buffer.size - wpipe->pipe_buffer.cnt;
wpipe             449 kern/sys_pipe.c 			if ((error = pipelock(wpipe)) == 0) {
wpipe             460 kern/sys_pipe.c 				if (space > wpipe->pipe_buffer.size -
wpipe             461 kern/sys_pipe.c 				    wpipe->pipe_buffer.cnt) {
wpipe             462 kern/sys_pipe.c 					pipeunlock(wpipe);
wpipe             481 kern/sys_pipe.c 				segsize = wpipe->pipe_buffer.size -
wpipe             482 kern/sys_pipe.c 					wpipe->pipe_buffer.in;
wpipe             488 kern/sys_pipe.c 				error = uiomove(&wpipe->pipe_buffer.buffer[wpipe->pipe_buffer.in], 
wpipe             498 kern/sys_pipe.c 					if (wpipe->pipe_buffer.in + segsize !=
wpipe             499 kern/sys_pipe.c 					    wpipe->pipe_buffer.size)
wpipe             503 kern/sys_pipe.c 					error = uiomove(&wpipe->pipe_buffer.buffer[0],
wpipe             507 kern/sys_pipe.c 					wpipe->pipe_buffer.in += size;
wpipe             508 kern/sys_pipe.c 					if (wpipe->pipe_buffer.in >=
wpipe             509 kern/sys_pipe.c 					    wpipe->pipe_buffer.size) {
wpipe             511 kern/sys_pipe.c 						if (wpipe->pipe_buffer.in != size - segsize + wpipe->pipe_buffer.size)
wpipe             514 kern/sys_pipe.c 						wpipe->pipe_buffer.in = size - segsize;
wpipe             517 kern/sys_pipe.c 					wpipe->pipe_buffer.cnt += size;
wpipe             519 kern/sys_pipe.c 					if (wpipe->pipe_buffer.cnt > wpipe->pipe_buffer.size)
wpipe             523 kern/sys_pipe.c 				pipeunlock(wpipe);
wpipe             531 kern/sys_pipe.c 			if (wpipe->pipe_state & PIPE_WANTR) {
wpipe             532 kern/sys_pipe.c 				wpipe->pipe_state &= ~PIPE_WANTR;
wpipe             533 kern/sys_pipe.c 				wakeup(wpipe);
wpipe             548 kern/sys_pipe.c 			pipeselwakeup(wpipe);
wpipe             550 kern/sys_pipe.c 			wpipe->pipe_state |= PIPE_WANTW;
wpipe             551 kern/sys_pipe.c 			error = tsleep(wpipe, (PRIBIO + 1)|PCATCH,
wpipe             559 kern/sys_pipe.c 			if (wpipe->pipe_state & PIPE_EOF) {
wpipe             566 kern/sys_pipe.c 	--wpipe->pipe_busy;
wpipe             568 kern/sys_pipe.c 	if ((wpipe->pipe_busy == 0) && (wpipe->pipe_state & PIPE_WANT)) {
wpipe             569 kern/sys_pipe.c 		wpipe->pipe_state &= ~(PIPE_WANT | PIPE_WANTR);
wpipe             570 kern/sys_pipe.c 		wakeup(wpipe);
wpipe             571 kern/sys_pipe.c 	} else if (wpipe->pipe_buffer.cnt > 0) {
wpipe             576 kern/sys_pipe.c 		if (wpipe->pipe_state & PIPE_WANTR) {
wpipe             577 kern/sys_pipe.c 			wpipe->pipe_state &= ~PIPE_WANTR;
wpipe             578 kern/sys_pipe.c 			wakeup(wpipe);
wpipe             585 kern/sys_pipe.c 	if ((wpipe->pipe_buffer.cnt == 0) &&
wpipe             592 kern/sys_pipe.c 		nanotime(&wpipe->pipe_mtime);
wpipe             596 kern/sys_pipe.c 	if (wpipe->pipe_buffer.cnt)
wpipe             597 kern/sys_pipe.c 		pipeselwakeup(wpipe);
wpipe             643 kern/sys_pipe.c 	struct pipe *wpipe;
wpipe             646 kern/sys_pipe.c 	wpipe = rpipe->pipe_peer;
wpipe             655 kern/sys_pipe.c 	    (wpipe == NULL) ||
wpipe             656 kern/sys_pipe.c 	    (wpipe->pipe_state & PIPE_EOF))
wpipe             659 kern/sys_pipe.c 		if ((wpipe->pipe_buffer.size - wpipe->pipe_buffer.cnt) >= PIPE_BUF)
wpipe             669 kern/sys_pipe.c 			selrecord(p, &wpipe->pipe_sel);
wpipe             670 kern/sys_pipe.c 			wpipe->pipe_state |= PIPE_SEL;
wpipe             769 kern/sys_pipe.c 	struct pipe *wpipe = rpipe->pipe_peer;
wpipe             777 kern/sys_pipe.c 		if (wpipe == NULL)
wpipe             781 kern/sys_pipe.c 		SLIST_INSERT_HEAD(&wpipe->pipe_sel.si_note, kn, kn_selnext);
wpipe             794 kern/sys_pipe.c 	struct pipe *wpipe = rpipe->pipe_peer;
wpipe             801 kern/sys_pipe.c 		if (wpipe == NULL)
wpipe             803 kern/sys_pipe.c 		SLIST_REMOVE(&wpipe->pipe_sel.si_note, kn, knote, kn_selnext);
wpipe             813 kern/sys_pipe.c 	struct pipe *wpipe = rpipe->pipe_peer;
wpipe             818 kern/sys_pipe.c 	    (wpipe == NULL) || (wpipe->pipe_state & PIPE_EOF)) {
wpipe             830 kern/sys_pipe.c 	struct pipe *wpipe = rpipe->pipe_peer;
wpipe             832 kern/sys_pipe.c 	if ((wpipe == NULL) || (wpipe->pipe_state & PIPE_EOF)) {
wpipe             837 kern/sys_pipe.c 	kn->kn_data = wpipe->pipe_buffer.size - wpipe->pipe_buffer.cnt;