Lines Matching refs:c1
498 int n, err, map, verdict, c1 = -1, p1 = -1;
516 err = create_pair(AF_INET, SOCK_STREAM, &c1, &p1);
520 err = bpf_map_update_elem(map, &zero, &c1, BPF_NOEXIST);
527 ev.data.fd = c1;
532 err = epoll_ctl(epollfd, EPOLL_CTL_ADD, c1, &ev);
539 n = recv(c1, &b, 1, MSG_DONTWAIT);
542 close(c1);
551 int err, map, verdict, c0 = -1, c1 = -1, p0 = -1, p1 = -1;
583 err = create_socket_pairs(AF_INET, sotype, &c0, &c1, &p0, &p1);
587 err = bpf_map_update_elem(map, &zero, &c1, BPF_NOEXIST);
588 if (!ASSERT_OK(err, "bpf_map_update_elem(c1)"))
594 err = ioctl(c1, FIONREAD, &avail);
599 recvd = recv_timeout(c1, &buf, sizeof(buf), MSG_DONTWAIT, IO_TIMEOUT_SEC);
606 close(c1);
625 int c1, p1, sent, recvd;
638 err = create_pair(AF_INET, SOCK_STREAM, &c1, &p1);
641 err = bpf_map_update_elem(map, &zero, &c1, BPF_NOEXIST);
642 if (!ASSERT_OK(err, "bpf_map_update_elem(c1)"))
646 recvd = recv(c1, buf, 2, 0);
647 ASSERT_EQ(recvd, 1, "recv(c1)");
652 recvd = recv(c1, buf, 2, 0);
653 ASSERT_EQ(recvd, 2, "recv(c1)");
658 recvd = recv(c1, buf, 1, 0);
659 ASSERT_EQ(recvd, 1, "recv(c1)");
663 close(c1);
671 int err, c1, p1, zero = 0, sent, recvd, avail;
675 err = create_pair(AF_INET, SOCK_STREAM, &c1, &p1);
679 err = bpf_map_update_elem(map, &zero, &c1, BPF_NOEXIST);
680 if (!ASSERT_OK(err, "bpf_map_update_elem(c1)"))
685 recvd = recv(c1, rcv, sizeof(rcv), MSG_PEEK);
686 ASSERT_EQ(recvd, sizeof(rcv), "recv(c1)");
687 err = ioctl(c1, FIONREAD, &avail);
690 recvd = recv(c1, rcv, sizeof(rcv), 0);
692 err = ioctl(c1, FIONREAD, &avail);
697 close(c1);
1072 int c0 = -1, p0 = -1, c1 = -1, p1 = -1;
1081 if (create_socket_pairs(AF_INET, SOCK_STREAM, &c0, &c1, &p0, &p1))
1112 sent = xsend(c1, buf, sizeof(buf) - 1, 0);
1133 if (c1 >= 0)
1134 close(c1);
1145 int c0 = -1, p0 = -1, c1 = -1, p1 = -1;
1153 if (create_socket_pairs(AF_INET, SOCK_STREAM, &c0, &c1, &p0, &p1))
1202 sent = xsend(c1, buf, sizeof(buf), 0);
1203 if (!ASSERT_EQ(sent, sizeof(buf), "xsend(c1), native"))
1225 if (c1 >= 0)
1226 close(c1);
1254 int c0 = -1, p0 = -1, c1 = -1, p1 = -1;
1262 err = create_socket_pairs(AF_INET, sotype, &c0, &c1, &p0, &p1);
1282 sent = xsend(c1, buf, 2, 0);
1310 if (c1 >= 0)
1311 close(c1);