Lines Matching refs:cfd

94 			  int *fd, int *cfd, bool *notls)  in ulp_sock_pair()  argument
121 	*cfd = accept(sfd, &addr, &len);  in ulp_sock_pair()
122 	ASSERT_GE(*cfd, 0);  in ulp_sock_pair()
134 	ret = setsockopt(*cfd, IPPROTO_TCP, TCP_ULP, "tls", sizeof("tls"));  in ulp_sock_pair()
199 	int fd, cfd;  in FIXTURE()  local
205 	ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls);  in FIXTURE_SETUP()
211 	close(self->cfd);  in FIXTURE_TEARDOWN()
224 	EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
230 	int fd, cfd;  in FIXTURE()  local
308 	ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls);  in FIXTURE_SETUP()
316 	ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len);  in FIXTURE_SETUP()
323 	close(self->cfd);  in FIXTURE_TEARDOWN()
350 	EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send);  in TEST_F()
354 	EXPECT_EQ(recv(self->cfd, buf, st.st_size, MSG_WAITALL), st.st_size);  in TEST_F()
386 	EXPECT_EQ(recv(self->cfd, buf, test_payload_size, MSG_WAITALL),  in chunked_sendfile()
424 	EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1);  in TEST_F()
436 	EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
447 	EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1);  in TEST_F()
449 	EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_WAITALL),  in TEST_F()
461 	EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1);  in TEST_F()
479 	EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len);  in TEST_F()
504 		EXPECT_EQ(recv(self->cfd, buf, SEND_LEN * frags, MSG_WAITALL),  in TEST_F()
530 		EXPECT_EQ(sendmsg(self->cfd, &msg, 0), send_len);  in TEST_F()
563 	EXPECT_EQ(sendmsg(self->cfd, &msg, 0), total_len);  in TEST_F()
601 	EXPECT_NE(recv(self->cfd, buf, total_len, 0), -1);  in TEST_F()
620 	EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len);  in TEST_F()
638 	EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len);  in TEST_F()
654 	EXPECT_EQ(recv(self->cfd, buf, send_len2, MSG_WAITALL), send_len2);  in TEST_F()
660 	EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len);  in TEST_F()
673 	EXPECT_GE(splice(self->cfd, NULL, p[1], NULL, send_len, 0), 0);  in TEST_F()
688 	EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), -1);  in TEST_F()
690 	EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
692 	EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type,  in TEST_F()
708 	EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
710 	EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), -1);  in TEST_F()
712 	EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type,  in TEST_F()
729 	EXPECT_EQ(recv(self->cfd, mem_recv, half, MSG_WAITALL), half);  in TEST_F()
730 	EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, half, SPLICE_F_NONBLOCK),  in TEST_F()
751 	EXPECT_EQ(recv(self->cfd, mem_recv, chunk * 5 / 2,  in TEST_F()
758 		i = splice(self->cfd, NULL, p[1], NULL, send_len - n, 0);  in TEST_F()
781 	EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1);  in TEST_F()
801 	EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1);  in TEST_F()
827 	EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1);  in TEST_F()
845 	EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1);  in TEST_F()
846 	EXPECT_NE(recv(self->cfd, recv_mem + send_len, send_len, 0), -1);  in TEST_F()
860 	EXPECT_EQ(recv(self->cfd, recv_mem, total_len, MSG_WAITALL), total_len);  in TEST_F()
876 	EXPECT_EQ(recv(self->cfd, recv_mem, recv_len, 0), recv_len);  in TEST_F()
877 	EXPECT_EQ(recv(self->cfd, recv_mem + recv_len, recv_len, 0), 5);  in TEST_F()
891 	EXPECT_NE(recv(self->cfd, recv_mem, strlen(test_str_first),  in TEST_F()
895 	EXPECT_NE(recv(self->cfd, recv_mem, strlen(test_str_second),  in TEST_F()
906 	EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1);  in TEST_F()
918 	EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1);  in TEST_F()
921 	EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
935 		EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1);  in TEST_F()
939 	EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
959 	EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len);  in TEST_F()
967 	EXPECT_EQ(recv(self->cfd, buf, len, MSG_WAITALL), len);  in TEST_F()
986 	EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len);  in TEST_F()
1008 	EXPECT_NE((len = recv(self->cfd, buf, len,  in TEST_F()
1024 	EXPECT_EQ(setsockopt(self->cfd, SOL_SOCKET, SO_RCVLOWAT,  in TEST_F()
1026 	EXPECT_EQ(recv(self->cfd, recv_mem, 1, MSG_WAITALL), 1);  in TEST_F()
1027 	EXPECT_EQ(recv(self->cfd, recv_mem + 1, 6, MSG_WAITALL), 6);  in TEST_F()
1028 	EXPECT_EQ(recv(self->cfd, recv_mem + 7, 10, 0), 8);  in TEST_F()
1051 		ret = setsockopt(self->cfd, SOL_TLS, TLS_TX, &tls12,  in TEST_F()
1059 	EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
1064 	EXPECT_EQ(send(self->cfd, test_str, send_len, 0), send_len);  in TEST_F()
1077 	fd.fd = self->cfd;  in TEST_F()
1082 	EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len);  in TEST_F()
1094 	fd.fd = self->cfd;  in TEST_F()
1100 	EXPECT_EQ(recv(self->cfd, recv_mem, send_len, MSG_WAITALL), send_len);  in TEST_F()
1109 	fd.fd = self->cfd;  in TEST_F()
1117 	EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), MSG_WAITALL),  in TEST_F()
1121 	fd.fd = self->cfd;  in TEST_F()
1125 	EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), 0),  in TEST_F()
1160 			int res = recv(self->cfd, buf,  in TEST_F()
1178 	fcntl(self->cfd, F_SETFL, flags | O_NONBLOCK);  in TEST_F()
1222 			int res = recv(self->cfd, buf,  in TEST_F()
1289 			res = recv(self->cfd, rb,  in test_mutliproc()
1358 	EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
1360 	EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type,  in TEST_F()
1368 	EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type,  in TEST_F()
1383 	EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1);  in TEST_F()
1387 	shutdown(self->cfd, SHUT_RDWR);  in TEST_F()
1398 	shutdown(self->cfd, SHUT_RDWR);  in TEST_F()
1407 	shutdown(self->cfd, SHUT_RDWR);  in TEST_F()
1408 	close(self->cfd);  in TEST_F()
1427 	int fd, cfd;  in FIXTURE()  local
1455 	ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls);  in FIXTURE_SETUP()
1470 	close(self->cfd);  in FIXTURE_TEARDOWN()
1500 	n = recv(self->cfd, buf, sizeof(buf), 0);  in TEST_F()
1527 		n = recv(self->cfd, cip[i], sizeof(cip[i]), 0);  in TEST_F()
1561 	n = recv(self->cfd, cip, sizeof(cip), 0);  in TEST_F()
1566 	n = recv(self->cfd, cip, sizeof(cip), 0);  in TEST_F()
1633 	int ret, fd, cfd;  in TEST()  local
1640 	ulp_sock_pair(_metadata, &fd, &cfd, &notls);  in TEST()
1647 		ret = setsockopt(cfd, SOL_TLS, TLS_RX, &tls12,  in TEST()
1653 	close(cfd);  in TEST()