Lines Matching refs:cfd
71 int fd, cfd; in FIXTURE() local
102 self->cfd = accept(sfd, &addr, &len); in FIXTURE_SETUP()
103 ASSERT_GE(self->cfd, 0); in FIXTURE_SETUP()
115 ret = setsockopt(self->cfd, IPPROTO_TCP, TCP_ULP, "tls", sizeof("tls")); in FIXTURE_SETUP()
122 close(self->cfd); in FIXTURE_TEARDOWN()
135 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
141 int fd, cfd; in FIXTURE() local
218 self->cfd = accept(sfd, &addr, &len); in FIXTURE_SETUP()
219 ASSERT_GE(self->cfd, 0); in FIXTURE_SETUP()
222 ret = setsockopt(self->cfd, IPPROTO_TCP, TCP_ULP, "tls", in FIXTURE_SETUP()
226 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, in FIXTURE_SETUP()
237 close(self->cfd); in FIXTURE_TEARDOWN()
264 EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send); in TEST_F()
268 EXPECT_EQ(recv(self->cfd, buf, st.st_size, MSG_WAITALL), st.st_size); in TEST_F()
300 EXPECT_EQ(recv(self->cfd, buf, test_payload_size, MSG_WAITALL), in chunked_sendfile()
338 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
350 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
361 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
363 EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_WAITALL), in TEST_F()
375 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
393 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
418 EXPECT_EQ(recv(self->cfd, buf, SEND_LEN * frags, MSG_WAITALL), in TEST_F()
444 EXPECT_EQ(sendmsg(self->cfd, &msg, 0), send_len); in TEST_F()
477 EXPECT_EQ(sendmsg(self->cfd, &msg, 0), total_len); in TEST_F()
515 EXPECT_NE(recv(self->cfd, buf, total_len, 0), -1); in TEST_F()
534 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
552 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
568 EXPECT_EQ(recv(self->cfd, buf, send_len2, MSG_WAITALL), send_len2); in TEST_F()
574 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
587 EXPECT_GE(splice(self->cfd, NULL, p[1], NULL, send_len, 0), 0); in TEST_F()
606 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
626 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
653 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
673 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
674 EXPECT_NE(recv(self->cfd, recv_mem + send_len, send_len, 0), -1); in TEST_F()
688 EXPECT_EQ(recv(self->cfd, recv_mem, total_len, MSG_WAITALL), total_len); in TEST_F()
704 EXPECT_EQ(recv(self->cfd, recv_mem, recv_len, 0), recv_len); in TEST_F()
705 EXPECT_EQ(recv(self->cfd, recv_mem + recv_len, recv_len, 0), 5); in TEST_F()
719 EXPECT_NE(recv(self->cfd, recv_mem, strlen(test_str_first), in TEST_F()
723 EXPECT_NE(recv(self->cfd, recv_mem, strlen(test_str_second), in TEST_F()
734 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
746 EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1); in TEST_F()
749 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
763 EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1); in TEST_F()
767 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
787 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
795 EXPECT_EQ(recv(self->cfd, buf, len, MSG_WAITALL), len); in TEST_F()
814 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
836 EXPECT_NE((len = recv(self->cfd, buf, len, in TEST_F()
852 EXPECT_EQ(setsockopt(self->cfd, SOL_SOCKET, SO_RCVLOWAT, in TEST_F()
854 EXPECT_EQ(recv(self->cfd, recv_mem, 1, MSG_WAITALL), 1); in TEST_F()
855 EXPECT_EQ(recv(self->cfd, recv_mem + 1, 6, MSG_WAITALL), 6); in TEST_F()
856 EXPECT_EQ(recv(self->cfd, recv_mem + 7, 10, 0), 8); in TEST_F()
879 ret = setsockopt(self->cfd, SOL_TLS, TLS_TX, &tls12, in TEST_F()
887 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
892 EXPECT_EQ(send(self->cfd, test_str, send_len, 0), send_len); in TEST_F()
905 fd.fd = self->cfd; in TEST_F()
910 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
922 fd.fd = self->cfd; in TEST_F()
928 EXPECT_EQ(recv(self->cfd, recv_mem, send_len, MSG_WAITALL), send_len); in TEST_F()
937 fd.fd = self->cfd; in TEST_F()
945 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), MSG_WAITALL), in TEST_F()
949 fd.fd = self->cfd; in TEST_F()
953 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), 0), in TEST_F()
988 int res = recv(self->cfd, buf, in TEST_F()
1006 fcntl(self->cfd, F_SETFL, flags | O_NONBLOCK); in TEST_F()
1050 int res = recv(self->cfd, buf, in TEST_F()
1117 res = recv(self->cfd, rb, in test_mutliproc()
1205 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1208 EXPECT_EQ(recvmsg(self->cfd, &msg, MSG_WAITALL | MSG_PEEK), send_len); in TEST_F()
1222 EXPECT_EQ(recvmsg(self->cfd, &msg, MSG_WAITALL), send_len); in TEST_F()
1241 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1245 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1256 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1265 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1266 close(self->cfd); in TEST_F()
1338 int sfd, ret, fd, cfd; in TEST() local
1379 cfd = accept(sfd, &addr, &len); in TEST()
1380 ASSERT_GE(cfd, 0); in TEST()
1383 ret = setsockopt(cfd, IPPROTO_TCP, TCP_ULP, "tls", in TEST()
1387 ret = setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, in TEST()
1394 close(cfd); in TEST()