110 			  int *fd, int *cfd, bool *notls)  in ulp_sock_pair()  argument
137 	*cfd = accept(sfd, &addr, &len);  in ulp_sock_pair()
138 	ASSERT_GE(*cfd, 0);  in ulp_sock_pair()
150 	ret = setsockopt(*cfd, IPPROTO_TCP, TCP_ULP, "tls", sizeof("tls"));  in ulp_sock_pair()
215 	int fd, cfd;  in FIXTURE()  local
221 	ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls);  in FIXTURE_SETUP()
227 	close(self->cfd);  in FIXTURE_TEARDOWN()
240 	EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
271 	int fd, cfd;  in FIXTURE()  local
377 	ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls);  in FIXTURE_SETUP()
385 	ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len);  in FIXTURE_SETUP()
389 		ret = setsockopt(self->cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD,  in FIXTURE_SETUP()
398 	close(self->cfd);  in FIXTURE_TEARDOWN()
425 	EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send);  in TEST_F()
429 	EXPECT_EQ(recv(self->cfd, buf, st.st_size, MSG_WAITALL), st.st_size);  in TEST_F()
461 	EXPECT_EQ(recv(self->cfd, buf, test_payload_size, MSG_WAITALL),  in chunked_sendfile()
499 	EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1);  in TEST_F()
511 	EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
522 	EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1);  in TEST_F()
524 	EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_WAITALL),  in TEST_F()
536 	EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1);  in TEST_F()
546 	EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len);  in TEST_F()
565 	EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len);  in TEST_F()
590 		EXPECT_EQ(recv(self->cfd, buf, SEND_LEN * frags, MSG_WAITALL),  in TEST_F()
620 		EXPECT_NE(recv(self->cfd, mem, send_len, 0), -1);  in TEST_F()
651 	EXPECT_NE(recv(self->cfd, buf, total_len, 0), -1);  in TEST_F()
687 	EXPECT_NE(recv(self->cfd, buf, total_len, 0), -1);  in TEST_F()
706 	EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len);  in TEST_F()
726 	EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len);  in TEST_F()
742 	EXPECT_EQ(recv(self->cfd, buf, send_len2, MSG_WAITALL), send_len2);  in TEST_F()
748 	EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len);  in TEST_F()
763 	EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), send_len);  in TEST_F()
781 	EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), -1);  in TEST_F()
783 	EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
785 	EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type,  in TEST_F()
804 	EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
806 	EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), -1);  in TEST_F()
808 	EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type,  in TEST_F()
825 	EXPECT_EQ(recv(self->cfd, mem_recv, half, MSG_WAITALL), half);  in TEST_F()
826 	EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, half, SPLICE_F_NONBLOCK),  in TEST_F()
847 	EXPECT_EQ(recv(self->cfd, mem_recv, chunk * 5 / 2,  in TEST_F()
854 		i = splice(self->cfd, NULL, p[1], NULL, send_len - n, 0);  in TEST_F()
877 	EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1);  in TEST_F()
897 	EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1);  in TEST_F()
923 	EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1);  in TEST_F()
941 	EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1);  in TEST_F()
942 	EXPECT_NE(recv(self->cfd, recv_mem + send_len, send_len, 0), -1);  in TEST_F()
958 	EXPECT_EQ(recv(self->cfd, recv_mem, total_len, MSG_WAITALL), total_len);  in TEST_F()
976 	EXPECT_EQ(recv(self->cfd, recv_mem, recv_len, 0), recv_len);  in TEST_F()
977 	EXPECT_EQ(recv(self->cfd, recv_mem + recv_len, recv_len, 0), 5);  in TEST_F()
991 	EXPECT_NE(recv(self->cfd, recv_mem, strlen(test_str_first),  in TEST_F()
995 	EXPECT_NE(recv(self->cfd, recv_mem, strlen(test_str_second),  in TEST_F()
1006 	EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1);  in TEST_F()
1018 	EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_PEEK), send_len);  in TEST_F()
1021 	EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len);  in TEST_F()
1035 		EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1);  in TEST_F()
1039 	EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
1059 	EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len);  in TEST_F()
1067 	EXPECT_EQ(recv(self->cfd, buf, len, MSG_WAITALL), len);  in TEST_F()
1086 	EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len);  in TEST_F()
1108 	EXPECT_NE((len = recv(self->cfd, buf, len,  in TEST_F()
1124 	EXPECT_EQ(setsockopt(self->cfd, SOL_SOCKET, SO_RCVLOWAT,  in TEST_F()
1126 	EXPECT_EQ(recv(self->cfd, recv_mem, 1, MSG_WAITALL), 1);  in TEST_F()
1127 	EXPECT_EQ(recv(self->cfd, recv_mem + 1, 6, MSG_WAITALL), 6);  in TEST_F()
1128 	EXPECT_EQ(recv(self->cfd, recv_mem + 7, 10, 0), 8);  in TEST_F()
1151 		ret = setsockopt(self->cfd, SOL_TLS, TLS_TX, &tls12,  in TEST_F()
1159 	EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
1164 	EXPECT_EQ(send(self->cfd, test_str, send_len, 0), send_len);  in TEST_F()
1177 	fd.fd = self->cfd;  in TEST_F()
1182 	EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len);  in TEST_F()
1194 	fd.fd = self->cfd;  in TEST_F()
1200 	EXPECT_EQ(recv(self->cfd, recv_mem, send_len, MSG_WAITALL), send_len);  in TEST_F()
1209 	fd.fd = self->cfd;  in TEST_F()
1217 	EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), MSG_WAITALL),  in TEST_F()
1221 	fd.fd = self->cfd;  in TEST_F()
1225 	EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), 0),  in TEST_F()
1260 			int res = recv(self->cfd, buf,  in TEST_F()
1278 	fcntl(self->cfd, F_SETFL, flags | O_NONBLOCK);  in TEST_F()
1322 			int res = recv(self->cfd, buf,  in TEST_F()
1389 			res = recv(self->cfd, rb,  in test_mutliproc()
1458 	EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
1460 	EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type,  in TEST_F()
1468 	EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type,  in TEST_F()
1483 	EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
1487 	shutdown(self->cfd, SHUT_RDWR);  in TEST_F()
1498 	shutdown(self->cfd, SHUT_RDWR);  in TEST_F()
1507 	shutdown(self->cfd, SHUT_RDWR);  in TEST_F()
1508 	close(self->cfd);  in TEST_F()
1561 	int fd, cfd;  in FIXTURE()  local
1589 	ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls);  in FIXTURE_SETUP()
1604 	close(self->cfd);  in FIXTURE_TEARDOWN()
1634 	n = recv(self->cfd, buf, sizeof(buf), 0);  in TEST_F()
1661 		n = recv(self->cfd, cip[i], sizeof(cip[i]), 0);  in TEST_F()
1695 	n = recv(self->cfd, cip, sizeof(cip), 0);  in TEST_F()
1700 	n = recv(self->cfd, cip, sizeof(cip), 0);  in TEST_F()
1761 	rec_len = recv(self->cfd, rec, sizeof(rec), 0);  in TEST_F()
1802 	rec_len = recv(self->cfd, rec, sizeof(rec), 0);  in TEST_F()
1835 	rec_len = recv(self->cfd, rec, sizeof(rec), 0);  in TEST_F()
1929 	int ret, fd, cfd;  in TEST()  local
1936 	ulp_sock_pair(_metadata, &fd, &cfd, &notls);  in TEST()
1943 		ret = setsockopt(cfd, SOL_TLS, TLS_RX, &tls12,  in TEST()
1949 	close(cfd);  in TEST()
1954 	int ret, fd, cfd, val;  in TEST()  local
1962 	ulp_sock_pair(_metadata, &fd, &cfd, &notls);  in TEST()
1970 	ret = setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, sizeof(tls12));  in TEST()
1974 	ret = setsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD,  in TEST()
1980 	ret = getsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD,  in TEST()
1987 	ret = setsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD,  in TEST()
1993 	ret = getsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD,  in TEST()
2000 	close(cfd);  in TEST()
2062 	int sfd, cfd, ret, fd;  in TEST()  local
2081 	ASSERT_GE(cfd = accept(sfd, &addr, &len), 0);  in TEST()
2093 	ASSERT_EQ(setsockopt(cfd, IPPROTO_TCP, TCP_ULP, "tls", sizeof("tls")), 0);  in TEST()
2094 	ASSERT_EQ(setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0);  in TEST()
2095 	EXPECT_EQ(recv(cfd, buf2, sizeof(buf2), MSG_WAITALL), sizeof(buf2));  in TEST()
2100 	close(cfd);  in TEST()