Lines Matching refs:cfd
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()
740 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
756 EXPECT_EQ(recv(self->cfd, buf, send_len2, MSG_WAITALL), send_len2); in TEST_F()
762 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
777 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), send_len); in TEST_F()
795 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), -1); in TEST_F()
797 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
799 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
818 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
820 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), -1); in TEST_F()
822 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
839 EXPECT_EQ(recv(self->cfd, mem_recv, half, MSG_WAITALL), half); in TEST_F()
840 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, half, SPLICE_F_NONBLOCK), in TEST_F()
861 EXPECT_EQ(recv(self->cfd, mem_recv, chunk * 5 / 2, in TEST_F()
868 i = splice(self->cfd, NULL, p[1], NULL, send_len - n, 0); in TEST_F()
891 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
911 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
937 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
955 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
956 EXPECT_NE(recv(self->cfd, recv_mem + send_len, send_len, 0), -1); in TEST_F()
972 EXPECT_EQ(recv(self->cfd, recv_mem, total_len, MSG_WAITALL), total_len); in TEST_F()
990 EXPECT_EQ(recv(self->cfd, recv_mem, recv_len, 0), recv_len); in TEST_F()
991 EXPECT_EQ(recv(self->cfd, recv_mem + recv_len, recv_len, 0), 5); in TEST_F()
1005 EXPECT_EQ(recv(self->cfd, recv_mem, strlen(test_str_first), in TEST_F()
1009 EXPECT_EQ(recv(self->cfd, recv_mem, strlen(test_str_second), in TEST_F()
1020 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
1032 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_PEEK), send_len); in TEST_F()
1035 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
1049 EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1); in TEST_F()
1053 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1073 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
1081 EXPECT_EQ(recv(self->cfd, buf, len, MSG_WAITALL), len); in TEST_F()
1100 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
1122 EXPECT_NE((len = recv(self->cfd, buf, len, in TEST_F()
1138 EXPECT_EQ(setsockopt(self->cfd, SOL_SOCKET, SO_RCVLOWAT, in TEST_F()
1140 EXPECT_EQ(recv(self->cfd, recv_mem, 1, MSG_WAITALL), 1); in TEST_F()
1141 EXPECT_EQ(recv(self->cfd, recv_mem + 1, 6, MSG_WAITALL), 6); in TEST_F()
1142 EXPECT_EQ(recv(self->cfd, recv_mem + 7, 10, 0), 8); in TEST_F()
1165 ret = setsockopt(self->cfd, SOL_TLS, TLS_TX, &tls12, in TEST_F()
1173 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1178 EXPECT_EQ(send(self->cfd, test_str, send_len, 0), send_len); in TEST_F()
1191 fd.fd = self->cfd; in TEST_F()
1196 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
1208 fd.fd = self->cfd; in TEST_F()
1214 EXPECT_EQ(recv(self->cfd, recv_mem, send_len, MSG_WAITALL), send_len); in TEST_F()
1223 fd.fd = self->cfd; in TEST_F()
1231 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), MSG_WAITALL), in TEST_F()
1235 fd.fd = self->cfd; in TEST_F()
1239 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), 0), in TEST_F()
1274 int res = recv(self->cfd, buf, in TEST_F()
1292 fcntl(self->cfd, F_SETFL, flags | O_NONBLOCK); in TEST_F()
1336 int res = recv(self->cfd, buf, in TEST_F()
1403 res = recv(self->cfd, rb, in test_mutliproc()
1472 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1474 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
1482 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
1501 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1504 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1507 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), 0), send_len); in TEST_F()
1510 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), 0), send_len); in TEST_F()
1529 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1530 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1542 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1546 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1557 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1566 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1567 close(self->cfd); in TEST_F()
1641 EXPECT_EQ(recv(self->cfd, recv_mem, 1, 0), 1); in TEST_F()
1644 ret = recvmsg(self->cfd, &hdr, 0); in TEST_F()
1654 int fd, cfd; in FIXTURE() local
1682 ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls); in FIXTURE_SETUP()
1697 close(self->cfd); in FIXTURE_TEARDOWN()
1727 n = recv(self->cfd, buf, sizeof(buf), 0); in TEST_F()
1754 n = recv(self->cfd, cip[i], sizeof(cip[i]), 0); in TEST_F()
1788 n = recv(self->cfd, cip, sizeof(cip), 0); in TEST_F()
1793 n = recv(self->cfd, cip, sizeof(cip), 0); in TEST_F()
1854 rec_len = recv(self->cfd, rec, sizeof(rec), 0); in TEST_F()
1895 rec_len = recv(self->cfd, rec, sizeof(rec), 0); in TEST_F()
1928 rec_len = recv(self->cfd, rec, sizeof(rec), 0); in TEST_F()
2022 int ret, fd, cfd; in TEST() local
2029 ulp_sock_pair(_metadata, &fd, &cfd, ¬ls); in TEST()
2036 ret = setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, in TEST()
2042 close(cfd); in TEST()
2047 int ret, fd, cfd, val; in TEST() local
2055 ulp_sock_pair(_metadata, &fd, &cfd, ¬ls); in TEST()
2063 ret = setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, sizeof(tls12)); in TEST()
2067 ret = setsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
2073 ret = getsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
2080 ret = setsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
2086 ret = getsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
2093 close(cfd); in TEST()
2155 int sfd, cfd, ret, fd; in TEST() local
2174 ASSERT_GE(cfd = accept(sfd, &addr, &len), 0); in TEST()
2186 ASSERT_EQ(setsockopt(cfd, IPPROTO_TCP, TCP_ULP, "tls", sizeof("tls")), 0); in TEST()
2187 ASSERT_EQ(setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST()
2188 EXPECT_EQ(recv(cfd, buf2, sizeof(buf2), MSG_WAITALL), sizeof(buf2)); in TEST()
2193 close(cfd); in TEST()