50 do_socketpair(int *sv)  in do_socketpair()  argument
54 	s = socketpair(PF_LOCAL, SOCK_SEQPACKET, 0, sv);  in do_socketpair()
56 	ATF_REQUIRE(sv[0] >= 0);  in do_socketpair()
57 	ATF_REQUIRE(sv[1] >= 0);  in do_socketpair()
58 	ATF_REQUIRE(sv[0] != sv[1]);  in do_socketpair()
62 do_socketpair_nonblocking(int *sv)  in do_socketpair_nonblocking()  argument
66 	s = socketpair(PF_LOCAL, SOCK_SEQPACKET, 0, sv);  in do_socketpair_nonblocking()
68 	ATF_REQUIRE(sv[0] >= 0);  in do_socketpair_nonblocking()
69 	ATF_REQUIRE(sv[1] >= 0);  in do_socketpair_nonblocking()
70 	ATF_REQUIRE(sv[0] != sv[1]);  in do_socketpair_nonblocking()
71 	ATF_REQUIRE(-1 != fcntl(sv[0], F_SETFL, O_NONBLOCK));  in do_socketpair_nonblocking()
72 	ATF_REQUIRE(-1 != fcntl(sv[1], F_SETFL, O_NONBLOCK));  in do_socketpair_nonblocking()
80 mk_listening_socket(int *sv)  in mk_listening_socket()  argument
98 	if (sv != NULL)  in mk_listening_socket()
99 		*sv = s;  in mk_listening_socket()
109 mk_pair_of_sockets(int *sv)  in mk_pair_of_sockets()  argument
132 	sv[0] = s1;  in mk_pair_of_sockets()
133 	sv[1] = s2;  in mk_pair_of_sockets()
154 	int sv[2];  in test_eagain()  local
162 	do_socketpair_nonblocking(sv);  in test_eagain()
164 	ATF_REQUIRE_EQ(0, setsockopt(sv[0], SOL_SOCKET, SO_SNDBUF, &sndbufsize,  in test_eagain()
166 	ATF_REQUIRE_EQ(0, setsockopt(sv[1], SOL_SOCKET, SO_RCVBUF, &rcvbufsize,  in test_eagain()
172 		ssize = send(sv[0], sndbuf, pktsize, MSG_EOR);  in test_eagain()
175 				close(sv[0]);  in test_eagain()
176 				close(sv[1]);  in test_eagain()
191 	int sv[2];  in test_sendrecv_symmetric_buffers()  local
199 		do_socketpair(sv);  in test_sendrecv_symmetric_buffers()
201 		do_socketpair_nonblocking(sv);  in test_sendrecv_symmetric_buffers()
204 	s = setsockopt(sv[0], SOL_SOCKET, SO_SNDBUF, &bufsize, sizeof(bufsize));  in test_sendrecv_symmetric_buffers()
206 	s = setsockopt(sv[1], SOL_SOCKET, SO_RCVBUF, &bufsize, sizeof(bufsize));  in test_sendrecv_symmetric_buffers()
213 	ssize = send(sv[0], sndbuf, pktsize, MSG_EOR);  in test_sendrecv_symmetric_buffers()
221 	rsize = recv(sv[1], recv_buf, pktsize, MSG_WAITALL);  in test_sendrecv_symmetric_buffers()
228 	close(sv[0]);  in test_sendrecv_symmetric_buffers()
229 	close(sv[1]);  in test_sendrecv_symmetric_buffers()
236 	int sv[2];  in test_pipe_simulator()  local
246 	do_socketpair_nonblocking(sv);  in test_pipe_simulator()
248 	ATF_REQUIRE_EQ(0, setsockopt(sv[0], SOL_SOCKET, SO_SNDBUF, &sndbufsize,  in test_pipe_simulator()
250 	ATF_REQUIRE_EQ(0, setsockopt(sv[1], SOL_SOCKET, SO_RCVBUF, &rcvbufsize,  in test_pipe_simulator()
261 			ssize = send(sv[0], sndbuf, pktsize, MSG_EOR);  in test_pipe_simulator()
277 			rsize = recv(sv[1], rcvbuf, pktsize, MSG_WAITALL);  in test_pipe_simulator()
300 	close(sv[0]);  in test_pipe_simulator()
301 	close(sv[1]);  in test_pipe_simulator()
364 	int sv[2];  in test_pipe()  local
369 	do_socketpair(sv);  in test_pipe()
371 	ATF_REQUIRE_EQ(0, setsockopt(sv[0], SOL_SOCKET, SO_SNDBUF, &sndbufsize,  in test_pipe()
373 	ATF_REQUIRE_EQ(0, setsockopt(sv[1], SOL_SOCKET, SO_RCVBUF, &rcvbufsize,  in test_pipe()
382 	writer_data.so = sv[0];  in test_pipe()
385 	reader_data.so = sv[1];  in test_pipe()
400 	close(sv[0]);  in test_pipe()
401 	close(sv[1]);  in test_pipe()
424 	int sv[2];  in ATF_TC_BODY()  local
427 	s = socketpair(PF_LOCAL, SOCK_SEQPACKET, 0, sv);  in ATF_TC_BODY()
429 	ATF_CHECK(sv[0] >= 0);  in ATF_TC_BODY()
430 	ATF_CHECK(sv[1] >= 0);  in ATF_TC_BODY()
431 	ATF_CHECK(sv[0] != sv[1]);  in ATF_TC_BODY()
432 	close(sv[0]);  in ATF_TC_BODY()
433 	close(sv[1]);  in ATF_TC_BODY()
596 	int sv[2];  in ATF_TC_BODY()  local
598 	mk_pair_of_sockets(sv);  in ATF_TC_BODY()
599 	close(sv[0]);  in ATF_TC_BODY()
600 	close(sv[1]);  in ATF_TC_BODY()
663 	int sv[2];  in ATF_TC_BODY()  local
671 	do_socketpair(sv);  in ATF_TC_BODY()
676 	ATF_CHECK_EQ(0, getsockopt(sv[0], SOL_SOCKET, SO_SNDBUF, &ls, &sl));  in ATF_TC_BODY()
677 	ATF_CHECK_EQ(0, getsockopt(sv[0], SOL_SOCKET, SO_RCVBUF, &lr, &sl));  in ATF_TC_BODY()
678 	ATF_CHECK_EQ(0, getsockopt(sv[1], SOL_SOCKET, SO_SNDBUF, &rs, &sl));  in ATF_TC_BODY()
679 	ATF_CHECK_EQ(0, getsockopt(sv[1], SOL_SOCKET, SO_RCVBUF, &rr, &sl));  in ATF_TC_BODY()
684 	err = setsockopt(sv[0], SOL_SOCKET, SO_SNDBUF, &sndbuf, sizeof(sndbuf));  in ATF_TC_BODY()
690 	ATF_CHECK_EQ(0, getsockopt(sv[0], SOL_SOCKET, SO_SNDBUF, &ls, &sl));  in ATF_TC_BODY()
691 	ATF_CHECK_EQ(0, getsockopt(sv[0], SOL_SOCKET, SO_RCVBUF, &lr, &sl));  in ATF_TC_BODY()
692 	ATF_CHECK_EQ(0, getsockopt(sv[1], SOL_SOCKET, SO_SNDBUF, &rs, &sl));  in ATF_TC_BODY()
693 	ATF_CHECK_EQ(0, getsockopt(sv[1], SOL_SOCKET, SO_RCVBUF, &rr, &sl));  in ATF_TC_BODY()
698 	err = setsockopt(sv[0], SOL_SOCKET, SO_RCVBUF, &rcvbuf, sizeof(rcvbuf));  in ATF_TC_BODY()
704 	ATF_CHECK_EQ(0, getsockopt(sv[0], SOL_SOCKET, SO_SNDBUF, &ls, &sl));  in ATF_TC_BODY()
705 	ATF_CHECK_EQ(0, getsockopt(sv[0], SOL_SOCKET, SO_RCVBUF, &lr, &sl));  in ATF_TC_BODY()
706 	ATF_CHECK_EQ(0, getsockopt(sv[1], SOL_SOCKET, SO_SNDBUF, &rs, &sl));  in ATF_TC_BODY()
707 	ATF_CHECK_EQ(0, getsockopt(sv[1], SOL_SOCKET, SO_RCVBUF, &rr, &sl));  in ATF_TC_BODY()
710 	close(sv[0]);  in ATF_TC_BODY()
711 	close(sv[1]);  in ATF_TC_BODY()
719 	int sv[2];  in ATF_TC_BODY()  local
727 	do_socketpair(sv);  in ATF_TC_BODY()
731 	ssize = send(sv[0], data, datalen, MSG_EOR);  in ATF_TC_BODY()
739 	rsize = recv(sv[1], recv_buf, bufsize, MSG_WAITALL);  in ATF_TC_BODY()
741 	close(sv[0]);  in ATF_TC_BODY()
742 	close(sv[1]);  in ATF_TC_BODY()
759 	int sv[2];  in ATF_TC_BODY()  local
771 		mk_pair_of_sockets(sv);  in ATF_TC_BODY()
775 	ssize = sendto(sv[0], data, datalen, MSG_EOR, NULL, 0);  in ATF_TC_BODY()
784 	rsize = recvfrom(sv[1], recv_buf, bufsize, MSG_WAITALL,  in ATF_TC_BODY()
802 	close(sv[0]);  in ATF_TC_BODY()
803 	close(sv[1]);  in ATF_TC_BODY()
813 	int sv[2];  in ATF_TC_BODY()  local
820 	mk_pair_of_sockets(sv);  in ATF_TC_BODY()
824 	ssize = send(sv[0], data, datalen, MSG_EOR);  in ATF_TC_BODY()
832 	rsize = recv(sv[1], recv_buf, bufsize, MSG_WAITALL);  in ATF_TC_BODY()
834 	close(sv[0]);  in ATF_TC_BODY()
835 	close(sv[1]);  in ATF_TC_BODY()
901 	int sv[2];  in ATF_TC_BODY()  local
909 	do_socketpair_nonblocking(sv);  in ATF_TC_BODY()
912 	rsize = recv(sv[1], recv_buf, bufsize, MSG_WAITALL);  in ATF_TC_BODY()
918 	ssize = send(sv[0], data, datalen, MSG_EOR);  in ATF_TC_BODY()
926 	rsize = recv(sv[1], recv_buf, bufsize, MSG_WAITALL);  in ATF_TC_BODY()
928 	close(sv[0]);  in ATF_TC_BODY()
929 	close(sv[1]);  in ATF_TC_BODY()
966 	int sv[2];  in ATF_TC_BODY()  local
977 	do_socketpair_nonblocking(sv);  in ATF_TC_BODY()
978 	ATF_REQUIRE_EQ(0, setsockopt(sv[0], SOL_SOCKET, SO_SNDBUF, &sndbufsize,  in ATF_TC_BODY()
980 	ATF_REQUIRE_EQ(0, setsockopt(sv[1], SOL_SOCKET, SO_RCVBUF, &rcvbufsize,  in ATF_TC_BODY()
992 		ssize = send(sv[0], sndbuf, pktsize, MSG_EOR);  in ATF_TC_BODY()
1002 		rsize = recv(sv[1], recv_buf, pktsize, MSG_WAITALL);  in ATF_TC_BODY()
1016 	rsize = recv(sv[1], recv_buf, pktsize, MSG_WAITALL);  in ATF_TC_BODY()
1019 	close(sv[0]);  in ATF_TC_BODY()
1020 	close(sv[1]);  in ATF_TC_BODY()