Lines Matching refs:cfd
30 int fd, cfd; in FIXTURE() local
61 self->cfd = accept(sfd, &addr, &len); in FIXTURE_SETUP()
62 ASSERT_GE(self->cfd, 0); in FIXTURE_SETUP()
74 ret = setsockopt(self->cfd, IPPROTO_TCP, TCP_ULP, "tls", sizeof("tls")); in FIXTURE_SETUP()
81 close(self->cfd); in FIXTURE_TEARDOWN()
94 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
100 int fd, cfd; in FIXTURE() local
163 self->cfd = accept(sfd, &addr, &len); in FIXTURE_SETUP()
164 ASSERT_GE(self->cfd, 0); in FIXTURE_SETUP()
167 ret = setsockopt(self->cfd, IPPROTO_TCP, TCP_ULP, "tls", in FIXTURE_SETUP()
171 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, in FIXTURE_SETUP()
182 close(self->cfd); in FIXTURE_TEARDOWN()
209 EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send); in TEST_F()
213 EXPECT_EQ(recv(self->cfd, buf, st.st_size, MSG_WAITALL), st.st_size); in TEST_F()
245 EXPECT_EQ(recv(self->cfd, buf, test_payload_size, MSG_WAITALL), in chunked_sendfile()
281 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
293 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
304 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
306 EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_WAITALL), in TEST_F()
318 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
336 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
361 EXPECT_EQ(recv(self->cfd, buf, SEND_LEN * frags, MSG_WAITALL), in TEST_F()
387 EXPECT_EQ(sendmsg(self->cfd, &msg, 0), send_len); in TEST_F()
419 EXPECT_EQ(sendmsg(self->cfd, &msg, 0), total_len); in TEST_F()
457 EXPECT_NE(recv(self->cfd, buf, total_len, 0), -1); in TEST_F()
476 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
494 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
510 EXPECT_EQ(recv(self->cfd, buf, send_len2, MSG_WAITALL), send_len2); in TEST_F()
516 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
529 EXPECT_GE(splice(self->cfd, NULL, p[1], NULL, send_len, 0), 0); in TEST_F()
548 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
566 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
591 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
609 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
610 EXPECT_NE(recv(self->cfd, recv_mem + send_len, send_len, 0), -1); in TEST_F()
624 EXPECT_EQ(recv(self->cfd, recv_mem, total_len, MSG_WAITALL), total_len); in TEST_F()
640 EXPECT_EQ(recv(self->cfd, recv_mem, recv_len, 0), recv_len); in TEST_F()
641 EXPECT_EQ(recv(self->cfd, recv_mem + recv_len, recv_len, 0), 5); in TEST_F()
655 EXPECT_NE(recv(self->cfd, recv_mem, strlen(test_str_first), in TEST_F()
659 EXPECT_NE(recv(self->cfd, recv_mem, strlen(test_str_second), in TEST_F()
670 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
682 EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1); in TEST_F()
685 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
699 EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1); in TEST_F()
703 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
723 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
731 EXPECT_EQ(recv(self->cfd, buf, len, MSG_WAITALL), len); in TEST_F()
750 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
772 EXPECT_NE((len = recv(self->cfd, buf, len, in TEST_F()
788 EXPECT_EQ(setsockopt(self->cfd, SOL_SOCKET, SO_RCVLOWAT, in TEST_F()
790 EXPECT_EQ(recv(self->cfd, recv_mem, 1, MSG_WAITALL), 1); in TEST_F()
791 EXPECT_EQ(recv(self->cfd, recv_mem + 1, 6, MSG_WAITALL), 6); in TEST_F()
792 EXPECT_EQ(recv(self->cfd, recv_mem + 7, 10, 0), 8); in TEST_F()
816 ret = setsockopt(self->cfd, SOL_TLS, TLS_TX, &tls12, in TEST_F()
824 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
829 EXPECT_EQ(send(self->cfd, test_str, send_len, 0), send_len); in TEST_F()
842 fd.fd = self->cfd; in TEST_F()
847 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
859 fd.fd = self->cfd; in TEST_F()
865 EXPECT_EQ(recv(self->cfd, recv_mem, send_len, MSG_WAITALL), send_len); in TEST_F()
874 fd.fd = self->cfd; in TEST_F()
882 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), MSG_WAITALL), in TEST_F()
886 fd.fd = self->cfd; in TEST_F()
890 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), 0), in TEST_F()
925 int res = recv(self->cfd, buf, in TEST_F()
943 fcntl(self->cfd, F_SETFL, flags | O_NONBLOCK); in TEST_F()
987 int res = recv(self->cfd, buf, in TEST_F()
1054 res = recv(self->cfd, rb, in test_mutliproc()
1142 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1145 EXPECT_EQ(recvmsg(self->cfd, &msg, MSG_WAITALL | MSG_PEEK), send_len); in TEST_F()
1159 EXPECT_EQ(recvmsg(self->cfd, &msg, MSG_WAITALL), send_len); in TEST_F()
1178 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1182 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1193 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1202 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1203 close(self->cfd); in TEST_F()
1275 int sfd, ret, fd, cfd; in TEST() local
1316 cfd = accept(sfd, &addr, &len); in TEST()
1317 ASSERT_GE(cfd, 0); in TEST()
1320 ret = setsockopt(cfd, IPPROTO_TCP, TCP_ULP, "tls", in TEST()
1324 ret = setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, in TEST()
1331 close(cfd); in TEST()