265 	tcprb_t *rb;  in mtcp_setsockopt()  local
309 			rb = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ?  in mtcp_setsockopt()
312 			if (rb == NULL) {  in mtcp_setsockopt()
316 			if (tcprb_setpolicy(rb, *(uint8_t *)optval) < 0) {  in mtcp_setsockopt()
323 			rb = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ?  in mtcp_setsockopt()
326 			if (rb == NULL) {  in mtcp_setsockopt()
330 			if (tcprb_setpolicy(rb, *(uint8_t *)optval) < 0) {  in mtcp_setsockopt()
347 				rb = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ?  in mtcp_setsockopt()
350 				if (rb) {  in mtcp_setsockopt()
351 					tcprb_resize_meta(rb, 0);  in mtcp_setsockopt()
352 					tcprb_resize(rb, 0);  in mtcp_setsockopt()
357 			rb = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ?  in mtcp_setsockopt()
360 			if (tcprb_resize_meta(rb, *(int *)optval) < 0)  in mtcp_setsockopt()
362 			return tcprb_resize(rb,  in mtcp_setsockopt()
363 					(((int)rb->metalen - 1) / UNITBUFSIZE + 1) * UNITBUFSIZE);  in mtcp_setsockopt()
376 				rb = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ?  in mtcp_setsockopt()
379 				if (rb) {  in mtcp_setsockopt()
380 					tcprb_resize_meta(rb, 0);  in mtcp_setsockopt()
381 					tcprb_resize(rb, 0);  in mtcp_setsockopt()
386 			rb = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ?  in mtcp_setsockopt()
389 			if (tcprb_resize_meta(rb, *(int *)optval) < 0)  in mtcp_setsockopt()
391 			return tcprb_resize(rb,  in mtcp_setsockopt()
392 					(((int)rb->metalen - 1) / UNITBUFSIZE + 1) * UNITBUFSIZE);  in mtcp_setsockopt()
405 				rb = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ?  in mtcp_setsockopt()
408 				if (rb)  in mtcp_setsockopt()
409 					tcprb_resize(rb, 0);  in mtcp_setsockopt()
413 			rb = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ?  in mtcp_setsockopt()
416 			if (rb->len == 0)  in mtcp_setsockopt()
417 				return tcprb_resize_meta(rb, *(int *)optval);  in mtcp_setsockopt()
432 				rb = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ?  in mtcp_setsockopt()
435 				if (rb)  in mtcp_setsockopt()
436 					tcprb_resize(rb, 0);  in mtcp_setsockopt()
440 			rb = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ?  in mtcp_setsockopt()
443 			if (rb->len == 0)  in mtcp_setsockopt()
444 				return tcprb_resize_meta(rb, *(int *)optval);  in mtcp_setsockopt()
1459 	tcprb_t *rb = rcvvar->rcvbuf;  in PeekForUser()  local
1461 	if ((copylen = tcprb_ppeek(rb, (uint8_t *)buf, len, rb->pile)) <= 0) {  in PeekForUser()
1474 	tcprb_t *rb = rcvvar->rcvbuf;  in CopyToUser()  local
1475 	if ((copylen = tcprb_ppeek(rb, (uint8_t *)buf, len, rb->pile)) <= 0) {  in CopyToUser()
1479 	tcprb_setpile(rb, rb->pile + copylen);  in CopyToUser()
1481 	rcvvar->rcv_wnd = rb->len - tcprb_cflen(rb);  in CopyToUser()