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