Lines Matching refs:cfd
112 int *fd, int *cfd, bool *notls) in ulp_sock_pair() argument
139 *cfd = accept(sfd, &addr, &len); in ulp_sock_pair()
140 ASSERT_GE(*cfd, 0); in ulp_sock_pair()
152 ret = setsockopt(*cfd, IPPROTO_TCP, TCP_ULP, "tls", sizeof("tls")); in ulp_sock_pair()
217 int fd, cfd; in FIXTURE() local
223 ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls); in FIXTURE_SETUP()
229 close(self->cfd); in FIXTURE_TEARDOWN()
242 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
284 ASSERT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
292 int fd, cfd; in FIXTURE() local
398 ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls); in FIXTURE_SETUP()
406 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len); in FIXTURE_SETUP()
410 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in FIXTURE_SETUP()
419 close(self->cfd); in FIXTURE_TEARDOWN()
446 EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send); in TEST_F()
450 EXPECT_EQ(recv(self->cfd, buf, st.st_size, MSG_WAITALL), st.st_size); in TEST_F()
482 EXPECT_EQ(recv(self->cfd, buf, test_payload_size, MSG_WAITALL), in chunked_sendfile()
520 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
532 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
543 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
545 EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_WAITALL), in TEST_F()
557 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
567 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
586 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
611 EXPECT_EQ(recv(self->cfd, buf, SEND_LEN * frags, MSG_WAITALL), in TEST_F()
641 EXPECT_NE(recv(self->cfd, mem, send_len, 0), -1); in TEST_F()
672 EXPECT_NE(recv(self->cfd, buf, total_len, 0), -1); in TEST_F()
708 EXPECT_NE(recv(self->cfd, buf, total_len, 0), -1); in TEST_F()
727 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
761 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
777 EXPECT_EQ(recv(self->cfd, buf, send_len2, MSG_WAITALL), send_len2); in TEST_F()
783 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
798 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), send_len); in TEST_F()
816 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), -1); in TEST_F()
818 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
820 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
839 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
841 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), -1); in TEST_F()
843 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
860 EXPECT_EQ(recv(self->cfd, mem_recv, half, MSG_WAITALL), half); in TEST_F()
861 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, half, SPLICE_F_NONBLOCK), in TEST_F()
882 EXPECT_EQ(recv(self->cfd, mem_recv, chunk * 5 / 2, in TEST_F()
889 i = splice(self->cfd, NULL, p[1], NULL, send_len - n, 0); in TEST_F()
912 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
932 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
958 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
976 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
977 EXPECT_NE(recv(self->cfd, recv_mem + send_len, send_len, 0), -1); in TEST_F()
993 EXPECT_EQ(recv(self->cfd, recv_mem, total_len, MSG_WAITALL), total_len); in TEST_F()
1011 EXPECT_EQ(recv(self->cfd, recv_mem, recv_len, 0), recv_len); in TEST_F()
1012 EXPECT_EQ(recv(self->cfd, recv_mem + recv_len, recv_len, 0), 5); in TEST_F()
1026 EXPECT_EQ(recv(self->cfd, recv_mem, strlen(test_str_first), in TEST_F()
1030 EXPECT_EQ(recv(self->cfd, recv_mem, strlen(test_str_second), in TEST_F()
1041 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
1053 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_PEEK), send_len); in TEST_F()
1056 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
1070 EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1); in TEST_F()
1074 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1094 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
1102 EXPECT_EQ(recv(self->cfd, buf, len, MSG_WAITALL), len); in TEST_F()
1121 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
1143 EXPECT_NE((len = recv(self->cfd, buf, len, in TEST_F()
1159 EXPECT_EQ(setsockopt(self->cfd, SOL_SOCKET, SO_RCVLOWAT, in TEST_F()
1161 EXPECT_EQ(recv(self->cfd, recv_mem, 1, MSG_WAITALL), 1); in TEST_F()
1162 EXPECT_EQ(recv(self->cfd, recv_mem + 1, 6, MSG_WAITALL), 6); in TEST_F()
1163 EXPECT_EQ(recv(self->cfd, recv_mem + 7, 10, 0), 8); in TEST_F()
1186 ret = setsockopt(self->cfd, SOL_TLS, TLS_TX, &tls12, in TEST_F()
1194 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1199 EXPECT_EQ(send(self->cfd, test_str, send_len, 0), send_len); in TEST_F()
1212 fd.fd = self->cfd; in TEST_F()
1217 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
1229 fd.fd = self->cfd; in TEST_F()
1235 EXPECT_EQ(recv(self->cfd, recv_mem, send_len, MSG_WAITALL), send_len); in TEST_F()
1244 fd.fd = self->cfd; in TEST_F()
1252 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), MSG_WAITALL), in TEST_F()
1256 fd.fd = self->cfd; in TEST_F()
1260 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), 0), in TEST_F()
1295 int res = recv(self->cfd, buf, in TEST_F()
1313 fcntl(self->cfd, F_SETFL, flags | O_NONBLOCK); in TEST_F()
1357 int res = recv(self->cfd, buf, in TEST_F()
1424 res = recv(self->cfd, rb, in test_mutliproc()
1493 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1495 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
1503 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
1522 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1525 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1528 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), 0), send_len); in TEST_F()
1531 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), 0), send_len); in TEST_F()
1550 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1551 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1563 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1567 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1578 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1587 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1588 close(self->cfd); in TEST_F()
1662 EXPECT_EQ(recv(self->cfd, recv_mem, 1, 0), 1); in TEST_F()
1665 ret = recvmsg(self->cfd, &hdr, 0); in TEST_F()
1714 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12_0, tls12_0.len); in TEST_F()
1717 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12_1, tls12_1.len); in TEST_F()
1721 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
1745 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12_1, tls12_1.len); in TEST_F()
1752 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
1779 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &key, key.len); in TEST_F()
1785 ret = connect(self->cfd, &addr, sizeof(addr)); in TEST_F()
1789 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
1806 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
1819 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1822 tls_recv_keyupdate(_metadata, self->cfd, 0); in TEST_F()
1825 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), 0), -1); in TEST_F()
1829 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
1833 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
1836 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1851 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
1876 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), -1); in TEST_F()
1892 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1895 tls_recv_keyupdate(_metadata, self->cfd, 0); in TEST_F()
1898 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), 0), -1); in TEST_F()
1902 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
1907 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
1910 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1932 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1935 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
1939 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_PEEK), -1); in TEST_F()
1942 tls_recv_keyupdate(_metadata, self->cfd, MSG_PEEK); in TEST_F()
1945 tls_recv_keyupdate(_metadata, self->cfd, 0); in TEST_F()
1948 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
1974 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, TLS_PAYLOAD_MAX_LEN, 0), send_len); in TEST_F()
1979 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, TLS_PAYLOAD_MAX_LEN, 0), -1); in TEST_F()
1983 tls_recv_keyupdate(_metadata, self->cfd, MSG_PEEK); in TEST_F()
1986 tls_recv_keyupdate(_metadata, self->cfd, 0); in TEST_F()
1989 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, TLS_PAYLOAD_MAX_LEN, 0), -1); in TEST_F()
1993 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
1995 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, TLS_PAYLOAD_MAX_LEN, 0), send_len); in TEST_F()
2022 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
2025 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, TLS_PAYLOAD_MAX_LEN, 0), send_len); in TEST_F()
2044 EXPECT_EQ(getsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12_get, &len), 0); in TEST_F()
2055 tls_recv_keyupdate(_metadata, self->cfd, 0); in TEST_F()
2056 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
2064 EXPECT_EQ(getsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12_get, &len), 0); in TEST_F()
2086 tls_recv_keyupdate(_metadata, self->cfd, 0); in TEST_F()
2093 pfd.fd = self->cfd; in TEST_F()
2107 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
2113 pfd.fd = self->cfd; in TEST_F()
2138 tls_recv_keyupdate(_metadata, self->cfd, 0); in TEST_F()
2150 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
2160 pfd.fd = self->cfd; in TEST_F()
2169 int fd, cfd; in FIXTURE() local
2197 ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls); in FIXTURE_SETUP()
2212 close(self->cfd); in FIXTURE_TEARDOWN()
2242 n = recv(self->cfd, buf, sizeof(buf), 0); in TEST_F()
2269 n = recv(self->cfd, cip[i], sizeof(cip[i]), 0); in TEST_F()
2303 n = recv(self->cfd, cip, sizeof(cip), 0); in TEST_F()
2308 n = recv(self->cfd, cip, sizeof(cip), 0); in TEST_F()
2369 rec_len = recv(self->cfd, rec, sizeof(rec), 0); in TEST_F()
2410 rec_len = recv(self->cfd, rec, sizeof(rec), 0); in TEST_F()
2443 rec_len = recv(self->cfd, rec, sizeof(rec), 0); in TEST_F()
2537 int ret, fd, cfd; in TEST() local
2544 ulp_sock_pair(_metadata, &fd, &cfd, ¬ls); in TEST()
2551 ret = setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, in TEST()
2557 close(cfd); in TEST()
2562 int ret, fd, cfd, val; in TEST() local
2570 ulp_sock_pair(_metadata, &fd, &cfd, ¬ls); in TEST()
2578 ret = setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, sizeof(tls12)); in TEST()
2582 ret = setsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
2588 ret = getsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
2595 ret = setsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
2601 ret = getsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
2608 close(cfd); in TEST()
2670 int sfd, cfd, ret, fd; in TEST() local
2689 ASSERT_GE(cfd = accept(sfd, &addr, &len), 0); in TEST()
2701 ASSERT_EQ(setsockopt(cfd, IPPROTO_TCP, TCP_ULP, "tls", sizeof("tls")), 0); in TEST()
2702 ASSERT_EQ(setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST()
2703 EXPECT_EQ(recv(cfd, buf2, sizeof(buf2), MSG_WAITALL), sizeof(buf2)); in TEST()
2708 close(cfd); in TEST()
2715 int sfd, cfd, ret, fd; in TEST() local
2735 ASSERT_GE(cfd = accept(sfd, &addr, &len), 0); in TEST()
2743 ASSERT_EQ(setsockopt(cfd, IPPROTO_TCP, TCP_ULP, "tls", sizeof("tls")), 0); in TEST()
2751 EXPECT_EQ(recv(cfd, buf, sizeof(buf), MSG_WAITALL), in TEST()
2758 ASSERT_EQ(setsockopt(cfd, SOL_TLS, TLS_RX, &tls, tls.len), 0); in TEST()
2762 EXPECT_EQ(recv(cfd, buf2, sizeof(buf2), MSG_DONTWAIT), -1); in TEST()
2768 close(cfd); in TEST()