rpipe             108 kern/sys_pipe.c 	struct pipe *rpipe, *wpipe;
rpipe             113 kern/sys_pipe.c 	rpipe = pool_get(&pipe_pool, PR_WAITOK);
rpipe             114 kern/sys_pipe.c 	error = pipe_create(rpipe);
rpipe             127 kern/sys_pipe.c 	rf->f_data = rpipe;
rpipe             140 kern/sys_pipe.c 	rpipe->pipe_peer = wpipe;
rpipe             141 kern/sys_pipe.c 	wpipe->pipe_peer = rpipe;
rpipe             152 kern/sys_pipe.c 	rpipe = NULL;
rpipe             156 kern/sys_pipe.c 	if (rpipe != NULL)
rpipe             157 kern/sys_pipe.c 		(void)pipeclose(rpipe);
rpipe             268 kern/sys_pipe.c 	struct pipe *rpipe = (struct pipe *) fp->f_data;
rpipe             273 kern/sys_pipe.c 	error = pipelock(rpipe);
rpipe             277 kern/sys_pipe.c 	++rpipe->pipe_busy;
rpipe             283 kern/sys_pipe.c 		if (rpipe->pipe_buffer.cnt > 0) {
rpipe             284 kern/sys_pipe.c 			size = rpipe->pipe_buffer.size - rpipe->pipe_buffer.out;
rpipe             285 kern/sys_pipe.c 			if (size > rpipe->pipe_buffer.cnt)
rpipe             286 kern/sys_pipe.c 				size = rpipe->pipe_buffer.cnt;
rpipe             289 kern/sys_pipe.c 			error = uiomove(&rpipe->pipe_buffer.buffer[rpipe->pipe_buffer.out],
rpipe             294 kern/sys_pipe.c 			rpipe->pipe_buffer.out += size;
rpipe             295 kern/sys_pipe.c 			if (rpipe->pipe_buffer.out >= rpipe->pipe_buffer.size)
rpipe             296 kern/sys_pipe.c 				rpipe->pipe_buffer.out = 0;
rpipe             298 kern/sys_pipe.c 			rpipe->pipe_buffer.cnt -= size;
rpipe             304 kern/sys_pipe.c 			if (rpipe->pipe_buffer.cnt == 0) {
rpipe             305 kern/sys_pipe.c 				rpipe->pipe_buffer.in = 0;
rpipe             306 kern/sys_pipe.c 				rpipe->pipe_buffer.out = 0;
rpipe             314 kern/sys_pipe.c 			if (rpipe->pipe_state & PIPE_EOF)
rpipe             320 kern/sys_pipe.c 			if (rpipe->pipe_state & PIPE_WANTW) {
rpipe             321 kern/sys_pipe.c 				rpipe->pipe_state &= ~PIPE_WANTW;
rpipe             322 kern/sys_pipe.c 				wakeup(rpipe);
rpipe             336 kern/sys_pipe.c 			pipeunlock(rpipe);
rpipe             345 kern/sys_pipe.c 				rpipe->pipe_state |= PIPE_WANTR;
rpipe             346 kern/sys_pipe.c 				if ((error = tsleep(rpipe, PRIBIO|PCATCH, "piperd", 0)) == 0)
rpipe             347 kern/sys_pipe.c 					error = pipelock(rpipe);
rpipe             353 kern/sys_pipe.c 	pipeunlock(rpipe);
rpipe             356 kern/sys_pipe.c 		nanotime(&rpipe->pipe_atime);
rpipe             358 kern/sys_pipe.c 	--rpipe->pipe_busy;
rpipe             363 kern/sys_pipe.c 	if ((rpipe->pipe_busy == 0) && (rpipe->pipe_state & PIPE_WANT)) {
rpipe             364 kern/sys_pipe.c 		rpipe->pipe_state &= ~(PIPE_WANT|PIPE_WANTW);
rpipe             365 kern/sys_pipe.c 		wakeup(rpipe);
rpipe             366 kern/sys_pipe.c 	} else if (rpipe->pipe_buffer.cnt < MINPIPESIZE) {
rpipe             370 kern/sys_pipe.c 		if (rpipe->pipe_state & PIPE_WANTW) {
rpipe             371 kern/sys_pipe.c 			rpipe->pipe_state &= ~PIPE_WANTW;
rpipe             372 kern/sys_pipe.c 			wakeup(rpipe);
rpipe             376 kern/sys_pipe.c 	if ((rpipe->pipe_buffer.size - rpipe->pipe_buffer.cnt) >= PIPE_BUF)
rpipe             377 kern/sys_pipe.c 		pipeselwakeup(rpipe);
rpipe             388 kern/sys_pipe.c 	struct pipe *wpipe, *rpipe;
rpipe             390 kern/sys_pipe.c 	rpipe = (struct pipe *) fp->f_data;
rpipe             391 kern/sys_pipe.c 	wpipe = rpipe->pipe_peer;
rpipe             642 kern/sys_pipe.c 	struct pipe *rpipe = (struct pipe *)fp->f_data;
rpipe             646 kern/sys_pipe.c 	wpipe = rpipe->pipe_peer;
rpipe             648 kern/sys_pipe.c 		if ((rpipe->pipe_buffer.cnt > 0) ||
rpipe             649 kern/sys_pipe.c 		    (rpipe->pipe_state & PIPE_EOF))
rpipe             654 kern/sys_pipe.c 	if ((rpipe->pipe_state & PIPE_EOF) ||
rpipe             665 kern/sys_pipe.c 			selrecord(p, &rpipe->pipe_sel);
rpipe             666 kern/sys_pipe.c 			rpipe->pipe_state |= PIPE_SEL;
rpipe             768 kern/sys_pipe.c 	struct pipe *rpipe = (struct pipe *)kn->kn_fp->f_data;
rpipe             769 kern/sys_pipe.c 	struct pipe *wpipe = rpipe->pipe_peer;
rpipe             774 kern/sys_pipe.c 		SLIST_INSERT_HEAD(&rpipe->pipe_sel.si_note, kn, kn_selnext);
rpipe             793 kern/sys_pipe.c 	struct pipe *rpipe = (struct pipe *)kn->kn_fp->f_data;
rpipe             794 kern/sys_pipe.c 	struct pipe *wpipe = rpipe->pipe_peer;
rpipe             798 kern/sys_pipe.c 		SLIST_REMOVE(&rpipe->pipe_sel.si_note, kn, knote, kn_selnext);
rpipe             812 kern/sys_pipe.c 	struct pipe *rpipe = (struct pipe *)kn->kn_fp->f_data;
rpipe             813 kern/sys_pipe.c 	struct pipe *wpipe = rpipe->pipe_peer;
rpipe             815 kern/sys_pipe.c 	kn->kn_data = rpipe->pipe_buffer.cnt;
rpipe             817 kern/sys_pipe.c 	if ((rpipe->pipe_state & PIPE_EOF) ||
rpipe             829 kern/sys_pipe.c 	struct pipe *rpipe = (struct pipe *)kn->kn_fp->f_data;
rpipe             830 kern/sys_pipe.c 	struct pipe *wpipe = rpipe->pipe_peer;