273 #define MAX_PIPESIZE(pipe)              ( MAX(PIPE_SIZE, (pipe)->pipe_buffer.size) )
351 	tmp.pipe_buffer.buffer = 0;  in expand_pipespace()
353 	if (p->pipe_buffer.size >= (unsigned) target_size) {  in expand_pipespace()
363 	oldpipe.pipe_buffer.buffer = p->pipe_buffer.buffer;  in expand_pipespace()
364 	oldpipe.pipe_buffer.size = p->pipe_buffer.size;  in expand_pipespace()
366 	memcpy(tmp.pipe_buffer.buffer, p->pipe_buffer.buffer, p->pipe_buffer.size);  in expand_pipespace()
367 	if (p->pipe_buffer.cnt > 0 && p->pipe_buffer.in <= p->pipe_buffer.out) {  in expand_pipespace()
369 		memcpy(&tmp.pipe_buffer.buffer[p->pipe_buffer.size], p->pipe_buffer.buffer, p->pipe_buffer.size);  in expand_pipespace()
370 		p->pipe_buffer.in += p->pipe_buffer.size;  in expand_pipespace()
373 	p->pipe_buffer.buffer = tmp.pipe_buffer.buffer;  in expand_pipespace()
374 	p->pipe_buffer.size = tmp.pipe_buffer.size;  in expand_pipespace()
478 	if (cpipe->pipe_buffer.buffer == 0) {  in pipe_stat()
483 			pipe_count = cpipe->pipe_peer->pipe_buffer.cnt;  in pipe_stat()
489 		pipe_count = cpipe->pipe_buffer.cnt;  in pipe_stat()
595 	cpipe->pipe_buffer.buffer = (caddr_t)buffer;  in pipespace()
596 	cpipe->pipe_buffer.size = size;  in pipespace()
597 	cpipe->pipe_buffer.in = 0;  in pipespace()
598 	cpipe->pipe_buffer.out = 0;  in pipespace()
599 	cpipe->pipe_buffer.cnt = 0;  in pipespace()
602 	OSAddAtomic(cpipe->pipe_buffer.size, &amountpipekva);  in pipespace()
638 	int error = pipespace(rpipe, choose_pipespace(rpipe->pipe_buffer.size, 0));  in pipepair_alloc()
732 	caddr_t start = cpipe->pipe_buffer.buffer;  in pipe_check_bounds_panic()
733 	u_int size = cpipe->pipe_buffer.size;  in pipe_check_bounds_panic()
734 	u_int in = cpipe->pipe_buffer.in;  in pipe_check_bounds_panic()
735 	u_int out = cpipe->pipe_buffer.out;  in pipe_check_bounds_panic()
777 		if (rpipe->pipe_buffer.cnt > 0) {  in pipe_read()
783 			size = rpipe->pipe_buffer.size - rpipe->pipe_buffer.out;  in pipe_read()
784 			if (size > rpipe->pipe_buffer.cnt) {  in pipe_read()
785 				size = rpipe->pipe_buffer.cnt;  in pipe_read()
794 				&rpipe->pipe_buffer.buffer[rpipe->pipe_buffer.out],  in pipe_read()
801 			rpipe->pipe_buffer.out += size;  in pipe_read()
802 			if (rpipe->pipe_buffer.out >= rpipe->pipe_buffer.size) {  in pipe_read()
803 				rpipe->pipe_buffer.out = 0;  in pipe_read()
806 			rpipe->pipe_buffer.cnt -= size;  in pipe_read()
813 			if (rpipe->pipe_buffer.cnt == 0) {  in pipe_read()
814 				rpipe->pipe_buffer.in = 0;  in pipe_read()
815 				rpipe->pipe_buffer.out = 0;  in pipe_read()
882 	} else if (rpipe->pipe_buffer.cnt < rpipe->pipe_buffer.size) {  in pipe_read()
892 	if ((rpipe->pipe_buffer.size - rpipe->pipe_buffer.cnt) > 0) {  in pipe_read()
956 	if (wpipe->pipe_buffer.buffer == 0 || (  in pipe_write()
957 		    (unsigned)orig_resid > wpipe->pipe_buffer.size - wpipe->pipe_buffer.cnt &&  in pipe_write()
959 		pipe_size = choose_pipespace(wpipe->pipe_buffer.size, wpipe->pipe_buffer.cnt + orig_resid);  in pipe_write()
967 			if (wpipe->pipe_buffer.cnt == 0) {  in pipe_write()
976 			if (wpipe->pipe_buffer.buffer == 0) {  in pipe_write()
998 		space = wpipe->pipe_buffer.size - wpipe->pipe_buffer.cnt;  in pipe_write()
1021 				if (space > (int)(wpipe->pipe_buffer.size -  in pipe_write()
1022 				    wpipe->pipe_buffer.cnt)) {  in pipe_write()
1047 				segsize = wpipe->pipe_buffer.size -  in pipe_write()
1048 				    wpipe->pipe_buffer.in;  in pipe_write()
1057 				error = uiomove(&wpipe->pipe_buffer.buffer[wpipe->pipe_buffer.in],  in pipe_write()
1067 					if (wpipe->pipe_buffer.in + segsize !=  in pipe_write()
1068 					    wpipe->pipe_buffer.size) {  in pipe_write()
1076 						&wpipe->pipe_buffer.buffer[0],  in pipe_write()
1084 					wpipe->pipe_buffer.in += size;  in pipe_write()
1085 					if (wpipe->pipe_buffer.in >  in pipe_write()
1086 					    wpipe->pipe_buffer.size) {  in pipe_write()
1087 						if (wpipe->pipe_buffer.in !=  in pipe_write()
1089 						    wpipe->pipe_buffer.size) {  in pipe_write()
1093 						wpipe->pipe_buffer.in = (unsigned int)(size -  in pipe_write()
1097 					wpipe->pipe_buffer.cnt += size;  in pipe_write()
1098 					if (wpipe->pipe_buffer.cnt >  in pipe_write()
1099 					    wpipe->pipe_buffer.size) {  in pipe_write()
1157 	if (wpipe->pipe_buffer.cnt > 0) {  in pipe_write()
1221 		*(int *)data = mpipe->pipe_buffer.cnt;  in pipe_ioctl()
1272 		    (rpipe->pipe_buffer.cnt > 0) ||  in pipe_select()
1288 		    (MAX_PIPESIZE(wpipe) - wpipe->pipe_buffer.cnt) >= PIPE_BUF)) {  in pipe_select()
1324 	if (cpipe->pipe_buffer.buffer != NULL) {  in pipe_free_kmem()
1325 		OSAddAtomic(-(cpipe->pipe_buffer.size), &amountpipekva);  in pipe_free_kmem()
1327 		kfree_data(cpipe->pipe_buffer.buffer, cpipe->pipe_buffer.size);  in pipe_free_kmem()
1328 		cpipe->pipe_buffer.buffer = NULL;  in pipe_free_kmem()
1329 		cpipe->pipe_buffer.size = 0;  in pipe_free_kmem()
1397 	if (rpipe->pipe_buffer.size && kn->kn_sdata > MAX_PIPESIZE(rpipe)) {  in filt_pipelowwat()
1466 	int64_t data = rpipe->pipe_buffer.cnt;  in filt_piperead_common()
1532 		data = MAX_PIPESIZE(rpipe) - rpipe->pipe_buffer.cnt;  in filt_pipewrite_common()
1690 	if (cpipe->pipe_buffer.buffer == 0) {  in fill_pipeinfo()
1699 			pipe_count = cpipe->pipe_peer->pipe_buffer.cnt;  in fill_pipeinfo()
1705 		pipe_count = cpipe->pipe_buffer.cnt;  in fill_pipeinfo()