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
317 ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls); in FIXTURE_SETUP()
325 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, tls12.len); in FIXTURE_SETUP()
329 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in FIXTURE_SETUP()
338 close(self->cfd); in FIXTURE_TEARDOWN()
365 EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send); in TEST_F()
369 EXPECT_EQ(recv(self->cfd, buf, st.st_size, MSG_WAITALL), st.st_size); in TEST_F()
401 EXPECT_EQ(recv(self->cfd, buf, test_payload_size, MSG_WAITALL), in chunked_sendfile()
439 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
451 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
462 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
464 EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_WAITALL), in TEST_F()
476 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
494 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
519 EXPECT_EQ(recv(self->cfd, buf, SEND_LEN * frags, MSG_WAITALL), in TEST_F()
545 EXPECT_EQ(sendmsg(self->cfd, &msg, 0), send_len); in TEST_F()
578 EXPECT_EQ(sendmsg(self->cfd, &msg, 0), total_len); in TEST_F()
616 EXPECT_NE(recv(self->cfd, buf, total_len, 0), -1); in TEST_F()
635 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
655 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
671 EXPECT_EQ(recv(self->cfd, buf, send_len2, MSG_WAITALL), send_len2); in TEST_F()
677 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
692 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), send_len); in TEST_F()
710 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), -1); in TEST_F()
712 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
714 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
733 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
735 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, send_len, 0), -1); in TEST_F()
737 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
754 EXPECT_EQ(recv(self->cfd, mem_recv, half, MSG_WAITALL), half); in TEST_F()
755 EXPECT_EQ(splice(self->cfd, NULL, p[1], NULL, half, SPLICE_F_NONBLOCK), in TEST_F()
776 EXPECT_EQ(recv(self->cfd, mem_recv, chunk * 5 / 2, in TEST_F()
783 i = splice(self->cfd, NULL, p[1], NULL, send_len - n, 0); in TEST_F()
806 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
826 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
852 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
870 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
871 EXPECT_NE(recv(self->cfd, recv_mem + send_len, send_len, 0), -1); in TEST_F()
887 EXPECT_EQ(recv(self->cfd, recv_mem, total_len, MSG_WAITALL), total_len); in TEST_F()
905 EXPECT_EQ(recv(self->cfd, recv_mem, recv_len, 0), recv_len); in TEST_F()
906 EXPECT_EQ(recv(self->cfd, recv_mem + recv_len, recv_len, 0), 5); in TEST_F()
920 EXPECT_NE(recv(self->cfd, recv_mem, strlen(test_str_first), in TEST_F()
924 EXPECT_NE(recv(self->cfd, recv_mem, strlen(test_str_second), in TEST_F()
935 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
947 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_PEEK), send_len); in TEST_F()
950 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), send_len); in TEST_F()
964 EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1); in TEST_F()
968 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
988 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
996 EXPECT_EQ(recv(self->cfd, buf, len, MSG_WAITALL), len); in TEST_F()
1015 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
1037 EXPECT_NE((len = recv(self->cfd, buf, len, in TEST_F()
1053 EXPECT_EQ(setsockopt(self->cfd, SOL_SOCKET, SO_RCVLOWAT, in TEST_F()
1055 EXPECT_EQ(recv(self->cfd, recv_mem, 1, MSG_WAITALL), 1); in TEST_F()
1056 EXPECT_EQ(recv(self->cfd, recv_mem + 1, 6, MSG_WAITALL), 6); in TEST_F()
1057 EXPECT_EQ(recv(self->cfd, recv_mem + 7, 10, 0), 8); in TEST_F()
1080 ret = setsockopt(self->cfd, SOL_TLS, TLS_TX, &tls12, in TEST_F()
1088 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1093 EXPECT_EQ(send(self->cfd, test_str, send_len, 0), send_len); in TEST_F()
1106 fd.fd = self->cfd; in TEST_F()
1111 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
1123 fd.fd = self->cfd; in TEST_F()
1129 EXPECT_EQ(recv(self->cfd, recv_mem, send_len, MSG_WAITALL), send_len); in TEST_F()
1138 fd.fd = self->cfd; in TEST_F()
1146 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), MSG_WAITALL), in TEST_F()
1150 fd.fd = self->cfd; in TEST_F()
1154 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), 0), in TEST_F()
1189 int res = recv(self->cfd, buf, in TEST_F()
1207 fcntl(self->cfd, F_SETFL, flags | O_NONBLOCK); in TEST_F()
1251 int res = recv(self->cfd, buf, in TEST_F()
1318 res = recv(self->cfd, rb, in test_mutliproc()
1387 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1389 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
1397 EXPECT_EQ(tls_recv_cmsg(_metadata, self->cfd, record_type, in TEST_F()
1412 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1416 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1427 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1436 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1437 close(self->cfd); in TEST_F()
1456 int fd, cfd; in FIXTURE() local
1484 ulp_sock_pair(_metadata, &self->fd, &self->cfd, &self->notls); in FIXTURE_SETUP()
1499 close(self->cfd); in FIXTURE_TEARDOWN()
1529 n = recv(self->cfd, buf, sizeof(buf), 0); in TEST_F()
1556 n = recv(self->cfd, cip[i], sizeof(cip[i]), 0); in TEST_F()
1590 n = recv(self->cfd, cip, sizeof(cip), 0); in TEST_F()
1595 n = recv(self->cfd, cip, sizeof(cip), 0); in TEST_F()
1694 int ret, fd, cfd; in TEST() local
1701 ulp_sock_pair(_metadata, &fd, &cfd, &notls); in TEST()
1708 ret = setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, in TEST()
1714 close(cfd); in TEST()
1719 int ret, fd, cfd, val; in TEST() local
1727 ulp_sock_pair(_metadata, &fd, &cfd, &notls); in TEST()
1735 ret = setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, sizeof(tls12)); in TEST()
1739 ret = setsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
1745 ret = getsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
1752 ret = setsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
1758 ret = getsockopt(cfd, SOL_TLS, TLS_RX_EXPECT_NO_PAD, in TEST()
1765 close(cfd); in TEST()