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()
229 int fd, cfd; in FIXTURE() local
235 ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls); in FIXTURE_SETUP()
241 close(self->cfd); in FIXTURE_TEARDOWN()
254 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
296 ASSERT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
304 int fd, cfd; in FIXTURE() local
410 ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls); in FIXTURE_SETUP()
418 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len); in FIXTURE_SETUP()
422 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in FIXTURE_SETUP()
431 close(self->cfd); in FIXTURE_TEARDOWN()
460 EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send); in TEST_F()
464 EXPECT_EQ(recv(self->cfd, buf, st.st_size, MSG_WAITALL), st.st_size); in TEST_F()
499 EXPECT_EQ(recv(self->cfd, buf, test_payload_size, MSG_WAITALL), in chunked_sendfile()
537 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
549 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
560 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
562 EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_WAITALL), in TEST_F()
588 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
594 EXPECT_EQ(recv(self->cfd, buf, send_len * 2, 0), send_len); in TEST_F()
596 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
608 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
618 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
637 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
662 EXPECT_EQ(recv(self->cfd, buf, SEND_LEN * frags, MSG_WAITALL), in TEST_F()
692 EXPECT_NE(recv(self->cfd, mem, send_len, 0), -1); in TEST_F()
723 EXPECT_NE(recv(self->cfd, buf, total_len, 0), -1); in TEST_F()
759 EXPECT_NE(recv(self->cfd, buf, total_len, 0), -1); in TEST_F()
778 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
812 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
828 EXPECT_EQ(recv(self->cfd, buf, send_len2, MSG_WAITALL), send_len2); in TEST_F()
834 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
849 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), send_len); in TEST_F()
867 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), -1); in TEST_F()
869 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
871 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
890 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
892 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), -1); in TEST_F()
894 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
911 EXPECT_EQ(recv(self->cfd, mem_recv, half, MSG_WAITALL), half); in TEST_F()
912 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, half, SPLICE_F_NONBLOCK), in TEST_F()
933 EXPECT_EQ(recv(self->cfd, mem_recv, chunk * 5 / 2, in TEST_F()
940 i = splice(self->cfd, NULL, p[1], NULL, send_len - n, 0); in TEST_F()
974 EXPECT_EQ(recv(self->cfd, read_buf, sizeof(read_buf), 0), MAX_FRAGS + sizeof(sendbuf)); in TEST_F()
975 EXPECT_EQ(recv(self->cfd, read_buf, sizeof(read_buf), MSG_DONTWAIT), -1); in TEST_F()
994 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
1014 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
1040 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
1058 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
1059 EXPECT_NE(recv(self->cfd, recv_mem + send_len, send_len, 0), -1); in TEST_F()
1075 EXPECT_EQ(recv(self->cfd, recv_mem, total_len, MSG_WAITALL), total_len); in TEST_F()
1093 EXPECT_EQ(recv(self->cfd, recv_mem, recv_len, 0), recv_len); in TEST_F()
1094 EXPECT_EQ(recv(self->cfd, recv_mem + recv_len, recv_len, 0), 5); in TEST_F()
1108 EXPECT_EQ(recv(self->cfd, recv_mem, strlen(test_str_first), in TEST_F()
1112 EXPECT_EQ(recv(self->cfd, recv_mem, strlen(test_str_second), in TEST_F()
1123 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
1135 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_PEEK), send_len); in TEST_F()
1138 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
1152 EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1); in TEST_F()
1156 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1176 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
1184 EXPECT_EQ(recv(self->cfd, buf, len, MSG_WAITALL), len); in TEST_F()
1203 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
1225 EXPECT_NE((len = recv(self->cfd, buf, len, in TEST_F()
1241 EXPECT_EQ(setsockopt(self->cfd, SOL_SOCKET, SO_RCVLOWAT, in TEST_F()
1243 EXPECT_EQ(recv(self->cfd, recv_mem, 1, MSG_WAITALL), 1); in TEST_F()
1244 EXPECT_EQ(recv(self->cfd, recv_mem + 1, 6, MSG_WAITALL), 6); in TEST_F()
1245 EXPECT_EQ(recv(self->cfd, recv_mem + 7, 10, 0), 8); in TEST_F()
1268 ret = setsockopt(self->cfd, SOL_TLS, TLS_TX, &tls12, in TEST_F()
1276 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1281 EXPECT_EQ(send(self->cfd, test_str, send_len, 0), send_len); in TEST_F()
1294 fd.fd = self->cfd; in TEST_F()
1299 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
1311 fd.fd = self->cfd; in TEST_F()
1317 EXPECT_EQ(recv(self->cfd, recv_mem, send_len, MSG_WAITALL), send_len); in TEST_F()
1326 fd.fd = self->cfd; in TEST_F()
1334 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), MSG_WAITALL), in TEST_F()
1338 fd.fd = self->cfd; in TEST_F()
1342 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), 0), in TEST_F()
1377 int res = recv(self->cfd, buf, in TEST_F()
1395 fcntl(self->cfd, F_SETFL, flags | O_NONBLOCK); in TEST_F()
1439 int res = recv(self->cfd, buf, in TEST_F()
1506 res = recv(self->cfd, rb, in test_mutliproc()
1575 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1577 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
1585 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
1604 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1607 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1610 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), 0), send_len); in TEST_F()
1613 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, 100, buf, sizeof(buf), 0), send_len); in TEST_F()
1632 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1633 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
1645 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1649 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1660 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1669 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1670 close(self->cfd); in TEST_F()
1744 EXPECT_EQ(recv(self->cfd, recv_mem, 1, 0), 1); in TEST_F()
1747 ret = recvmsg(self->cfd, &hdr, 0); in TEST_F()
1796 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12_0, tls12_0.len); in TEST_F()
1799 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12_1, tls12_1.len); in TEST_F()
1803 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
1827 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12_1, tls12_1.len); in TEST_F()
1834 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
1861 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &key, key.len); in TEST_F()
1867 ret = connect(self->cfd, &addr, sizeof(addr)); in TEST_F()
1871 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
1888 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
1901 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1904 tls_recv_keyupdate(_metadata, self->cfd, 0); in TEST_F()
1907 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), 0), -1); in TEST_F()
1911 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
1915 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
1918 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1933 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
1958 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), -1); in TEST_F()
1974 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1977 tls_recv_keyupdate(_metadata, self->cfd, 0); in TEST_F()
1980 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), 0), -1); in TEST_F()
1984 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
1989 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
1992 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
2014 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
2017 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
2021 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_PEEK), -1); in TEST_F()
2024 tls_recv_keyupdate(_metadata, self->cfd, MSG_PEEK); in TEST_F()
2027 tls_recv_keyupdate(_metadata, self->cfd, 0); in TEST_F()
2030 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
2056 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, TLS_PAYLOAD_MAX_LEN, 0), send_len); in TEST_F()
2061 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, TLS_PAYLOAD_MAX_LEN, 0), -1); in TEST_F()
2065 tls_recv_keyupdate(_metadata, self->cfd, MSG_PEEK); in TEST_F()
2068 tls_recv_keyupdate(_metadata, self->cfd, 0); in TEST_F()
2071 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, TLS_PAYLOAD_MAX_LEN, 0), -1); in TEST_F()
2075 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
2077 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, TLS_PAYLOAD_MAX_LEN, 0), send_len); in TEST_F()
2104 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_PEEK), send_len); in TEST_F()
2107 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, TLS_PAYLOAD_MAX_LEN, 0), send_len); in TEST_F()
2126 EXPECT_EQ(getsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12_get, &len), 0); in TEST_F()
2137 tls_recv_keyupdate(_metadata, self->cfd, 0); in TEST_F()
2138 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
2146 EXPECT_EQ(getsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12_get, &len), 0); in TEST_F()
2168 tls_recv_keyupdate(_metadata, self->cfd, 0); in TEST_F()
2175 pfd.fd = self->cfd; in TEST_F()
2189 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
2195 pfd.fd = self->cfd; in TEST_F()
2220 tls_recv_keyupdate(_metadata, self->cfd, 0); in TEST_F()
2232 EXPECT_EQ(setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST_F()
2242 pfd.fd = self->cfd; in TEST_F()
2410 int fd, cfd; in FIXTURE() local
2476 ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls); in FIXTURE_SETUP()
2481 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len); in FIXTURE_SETUP()
2488 close(self->cfd); in FIXTURE_TEARDOWN()
2509 EXPECT_EQ(__tls_recv_cmsg(_metadata, self->cfd, NULL, in TEST_F()
2529 int fd, cfd; in FIXTURE() local
2557 ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls); in FIXTURE_SETUP()
2572 close(self->cfd); in FIXTURE_TEARDOWN()
2602 n = recv(self->cfd, buf, sizeof(buf), 0); in TEST_F()
2629 n = recv(self->cfd, cip[i], sizeof(cip[i]), 0); in TEST_F()
2663 n = recv(self->cfd, cip, sizeof(cip), 0); in TEST_F()
2668 n = recv(self->cfd, cip, sizeof(cip), 0); in TEST_F()
2729 rec_len = recv(self->cfd, rec, sizeof(rec), 0); in TEST_F()
2770 rec_len = recv(self->cfd, rec, sizeof(rec), 0); in TEST_F()
2803 rec_len = recv(self->cfd, rec, sizeof(rec), 0); in TEST_F()
2898 int cfd, ret, fd, overhead; in TEST() local
2909 ulp_sock_pair(_metadata, &fd, &cfd, ¬ls); in TEST()
2915 ret = setsockopt(cfd, SOL_TLS, TLS_TX, &tls12, tls12.len); in TEST()
2918 ret = setsockopt(cfd, SOL_TLS, TLS_TX_MAX_PAYLOAD_LEN, &limit, in TEST()
2922 ret = getsockopt(cfd, SOL_TLS, TLS_TX_MAX_PAYLOAD_LEN, &opt, &optlen); in TEST()
2928 ASSERT_EQ(send(cfd, tx, sizeof(tx), 0), sizeof(tx)); in TEST()
2929 close(cfd); in TEST()
2948 int cfd, ret, fd, overhead; in TEST() local
2958 ulp_sock_pair(_metadata, &fd, &cfd, ¬ls); in TEST()
2964 ret = setsockopt(cfd, SOL_TLS, TLS_TX, &tls12, tls12.len); in TEST()
2967 ret = setsockopt(cfd, SOL_TLS, TLS_TX_MAX_PAYLOAD_LEN, &og_limit, in TEST()
2972 ASSERT_EQ(send(cfd, tx, tx_partial, MSG_MORE), tx_partial); in TEST()
2978 ret = setsockopt(cfd, SOL_TLS, TLS_TX_MAX_PAYLOAD_LEN, &limit, in TEST()
2983 ASSERT_EQ(send(cfd, tx + tx_partial, sizeof(tx) - tx_partial, MSG_EOR), in TEST()
2985 close(cfd); in TEST()
3054 int ret, fd, cfd; in TEST() local
3061 ulp_sock_pair(_metadata, &fd, &cfd, ¬ls); in TEST()
3068 ret = setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, in TEST()
3074 close(cfd); in TEST()
3079 int ret, fd, cfd, val; in TEST() local
3087 ulp_sock_pair(_metadata, &fd, &cfd, ¬ls); in TEST()
3095 ret = setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, sizeof(tls12)); in TEST()
3099 ret = setsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
3105 ret = getsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
3112 ret = setsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
3118 ret = getsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
3125 close(cfd); in TEST()
3187 int sfd, cfd, ret, fd; in TEST() local
3206 ASSERT_GE(cfd = accept(sfd, &addr, &len), 0); in TEST()
3218 ASSERT_EQ(setsockopt(cfd, IPPROTO_TCP, TCP_ULP, "tls", sizeof("tls")), 0); in TEST()
3219 ASSERT_EQ(setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, tls12.len), 0); in TEST()
3220 EXPECT_EQ(recv(cfd, buf2, sizeof(buf2), MSG_WAITALL), sizeof(buf2)); in TEST()
3225 close(cfd); in TEST()
3232 int sfd, cfd, ret, fd; in TEST() local
3252 ASSERT_GE(cfd = accept(sfd, &addr, &len), 0); in TEST()
3260 ASSERT_EQ(setsockopt(cfd, IPPROTO_TCP, TCP_ULP, "tls", sizeof("tls")), 0); in TEST()
3268 EXPECT_EQ(recv(cfd, buf, sizeof(buf) / 2 + 1, MSG_WAITALL), in TEST()
3279 } while (recv(cfd, buf, 1, MSG_PEEK | MSG_DONTWAIT) == 1); in TEST()
3283 ASSERT_EQ(setsockopt(cfd, SOL_TLS, TLS_RX, &tls, tls.len), 0); in TEST()
3288 EXPECT_EQ(recv(cfd, buf2, sizeof(buf2), MSG_DONTWAIT), -1); in TEST()
3294 close(cfd); in TEST()