Lines Matching refs:cfd
34 int fd, cfd; in FIXTURE() local
65 self->cfd = accept(sfd, &addr, &len); in FIXTURE_SETUP()
66 ASSERT_GE(self->cfd, 0); in FIXTURE_SETUP()
78 ret = setsockopt(self->cfd, IPPROTO_TCP, TCP_ULP, "tls", sizeof("tls")); in FIXTURE_SETUP()
85 close(self->cfd); in FIXTURE_TEARDOWN()
98 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
104 int fd, cfd; in FIXTURE() local
152 self->cfd = accept(sfd, &addr, &len); in FIXTURE_SETUP()
153 ASSERT_GE(self->cfd, 0); in FIXTURE_SETUP()
156 ret = setsockopt(self->cfd, IPPROTO_TCP, TCP_ULP, "tls", in FIXTURE_SETUP()
160 ret = setsockopt(self->cfd, SOL_TLS, TLS_RX, &tls12, in FIXTURE_SETUP()
171 close(self->cfd); in FIXTURE_TEARDOWN()
198 EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send); in TEST_F()
202 EXPECT_EQ(recv(self->cfd, buf, st.st_size, MSG_WAITALL), st.st_size); in TEST_F()
212 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
224 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
235 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
237 EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_WAITALL), in TEST_F()
249 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
267 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
286 EXPECT_EQ(sendmsg(self->cfd, &msg, 0), send_len); in TEST_F()
318 EXPECT_EQ(sendmsg(self->cfd, &msg, 0), total_len); in TEST_F()
356 EXPECT_NE(recv(self->cfd, buf, total_len, 0), -1); in TEST_F()
375 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
393 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
409 EXPECT_EQ(recv(self->cfd, buf, send_len2, MSG_WAITALL), send_len2); in TEST_F()
415 EXPECT_EQ(recv(self->cfd, mem_recv, send_len, MSG_WAITALL), send_len); in TEST_F()
428 EXPECT_GE(splice(self->cfd, NULL, p[1], NULL, send_len, 0), 0); in TEST_F()
447 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
465 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
490 EXPECT_NE(recvmsg(self->cfd, &hdr, 0), -1); in TEST_F()
508 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
509 EXPECT_NE(recv(self->cfd, recv_mem + send_len, send_len, 0), -1); in TEST_F()
523 EXPECT_EQ(recv(self->cfd, recv_mem, total_len, MSG_WAITALL), total_len); in TEST_F()
539 EXPECT_EQ(recv(self->cfd, recv_mem, recv_len, 0), recv_len); in TEST_F()
540 EXPECT_EQ(recv(self->cfd, recv_mem + recv_len, recv_len, 0), 5); in TEST_F()
554 EXPECT_NE(recv(self->cfd, recv_mem, strlen(test_str_first), in TEST_F()
558 EXPECT_NE(recv(self->cfd, recv_mem, strlen(test_str_second), in TEST_F()
569 EXPECT_EQ(recv(self->cfd, buf, sizeof(buf), MSG_DONTWAIT), -1); in TEST_F()
581 EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1); in TEST_F()
584 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
598 EXPECT_NE(recv(self->cfd, buf, send_len, MSG_PEEK), -1); in TEST_F()
602 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
622 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
630 EXPECT_EQ(recv(self->cfd, buf, len, MSG_WAITALL), len); in TEST_F()
649 EXPECT_EQ(recv(self->cfd, buf, len, MSG_PEEK | MSG_WAITALL), len); in TEST_F()
671 EXPECT_NE((len = recv(self->cfd, buf, len, in TEST_F()
687 EXPECT_EQ(setsockopt(self->cfd, SOL_SOCKET, SO_RCVLOWAT, in TEST_F()
689 EXPECT_EQ(recv(self->cfd, recv_mem, 1, MSG_WAITALL), 1); in TEST_F()
690 EXPECT_EQ(recv(self->cfd, recv_mem + 1, 6, MSG_WAITALL), 6); in TEST_F()
691 EXPECT_EQ(recv(self->cfd, recv_mem + 7, 10, 0), 8); in TEST_F()
715 ret = setsockopt(self->cfd, SOL_TLS, TLS_TX, &tls12, in TEST_F()
723 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
728 EXPECT_EQ(send(self->cfd, test_str, send_len, 0), send_len); in TEST_F()
741 fd.fd = self->cfd; in TEST_F()
746 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_WAITALL), send_len); in TEST_F()
758 fd.fd = self->cfd; in TEST_F()
764 EXPECT_EQ(recv(self->cfd, recv_mem, send_len, MSG_WAITALL), send_len); in TEST_F()
773 fd.fd = self->cfd; in TEST_F()
781 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), MSG_WAITALL), in TEST_F()
785 fd.fd = self->cfd; in TEST_F()
789 EXPECT_EQ(recv(self->cfd, recv_mem, sizeof(recv_mem), 0), in TEST_F()
824 int res = recv(self->cfd, buf, in TEST_F()
842 fcntl(self->cfd, F_SETFL, flags | O_NONBLOCK); in TEST_F()
886 int res = recv(self->cfd, buf, in TEST_F()
953 res = recv(self->cfd, rb, in test_mutliproc()
1041 EXPECT_EQ(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1044 EXPECT_EQ(recvmsg(self->cfd, &msg, MSG_WAITALL | MSG_PEEK), send_len); in TEST_F()
1058 EXPECT_EQ(recvmsg(self->cfd, &msg, MSG_WAITALL), send_len); in TEST_F()
1077 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
1081 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1092 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1101 shutdown(self->cfd, SHUT_RDWR); in TEST_F()
1102 close(self->cfd); in TEST_F()
1174 int sfd, ret, fd, cfd; in TEST() local
1215 cfd = accept(sfd, &addr, &len); in TEST()
1216 ASSERT_GE(cfd, 0); in TEST()
1219 ret = setsockopt(cfd, IPPROTO_TCP, TCP_ULP, "tls", in TEST()
1223 ret = setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, in TEST()
1230 close(cfd); in TEST()
1234 int fd, cfd; in TEST() local
1279 cfd = accept(sfd, &addr, &len); in TEST()
1280 ASSERT_GE(cfd, 0); in TEST()
1283 ret = setsockopt(cfd, IPPROTO_TCP, TCP_ULP, "tls", in TEST()
1287 ret = setsockopt(cfd, SOL_TLS, TLS_RX, &tls12, in TEST()
1300 EXPECT_NE(recv(cfd, buf, send_len, 0), -1); in TEST()
1304 close(cfd); in TEST()