488 	int n, err, map, verdict, c1 = -1, p1 = -1;  in test_sockmap_skb_verdict_shutdown()  local
506 	err = create_pair(AF_INET, SOCK_STREAM, &c1, &p1);  in test_sockmap_skb_verdict_shutdown()
510 	err = bpf_map_update_elem(map, &zero, &c1, BPF_NOEXIST);  in test_sockmap_skb_verdict_shutdown()
517 	ev.data.fd = c1;  in test_sockmap_skb_verdict_shutdown()
522 	err = epoll_ctl(epollfd, EPOLL_CTL_ADD, c1, &ev);  in test_sockmap_skb_verdict_shutdown()
529 	n = recv(c1, &b, 1, MSG_DONTWAIT);  in test_sockmap_skb_verdict_shutdown()
532 	close(c1);  in test_sockmap_skb_verdict_shutdown()
541 	int err, map, verdict, c0 = -1, c1 = -1, p0 = -1, p1 = -1;  in test_sockmap_skb_verdict_fionread()  local
569 	err = create_socket_pairs(AF_INET, SOCK_STREAM, &c0, &c1, &p0, &p1);  in test_sockmap_skb_verdict_fionread()
573 	err = bpf_map_update_elem(map, &zero, &c1, BPF_NOEXIST);  in test_sockmap_skb_verdict_fionread()
574 	if (!ASSERT_OK(err, "bpf_map_update_elem(c1)"))  in test_sockmap_skb_verdict_fionread()
579 	err = ioctl(c1, FIONREAD, &avail);  in test_sockmap_skb_verdict_fionread()
584 		recvd = recv_timeout(c1, &buf, sizeof(buf), MSG_DONTWAIT, IO_TIMEOUT_SEC);  in test_sockmap_skb_verdict_fionread()
591 	close(c1);  in test_sockmap_skb_verdict_fionread()
604 	int c1, p1, sent, recvd;  in test_sockmap_skb_verdict_change_tail()  local
617 	err = create_pair(AF_INET, SOCK_STREAM, &c1, &p1);  in test_sockmap_skb_verdict_change_tail()
620 	err = bpf_map_update_elem(map, &zero, &c1, BPF_NOEXIST);  in test_sockmap_skb_verdict_change_tail()
621 	if (!ASSERT_OK(err, "bpf_map_update_elem(c1)"))  in test_sockmap_skb_verdict_change_tail()
625 	recvd = recv(c1, buf, 2, 0);  in test_sockmap_skb_verdict_change_tail()
626 	ASSERT_EQ(recvd, 1, "recv(c1)");  in test_sockmap_skb_verdict_change_tail()
631 	recvd = recv(c1, buf, 2, 0);  in test_sockmap_skb_verdict_change_tail()
632 	ASSERT_EQ(recvd, 2, "recv(c1)");  in test_sockmap_skb_verdict_change_tail()
637 	recvd = recv(c1, buf, 1, 0);  in test_sockmap_skb_verdict_change_tail()
638 	ASSERT_EQ(recvd, 1, "recv(c1)");  in test_sockmap_skb_verdict_change_tail()
642 	close(c1);  in test_sockmap_skb_verdict_change_tail()
650 	int err, c1, p1, zero = 0, sent, recvd, avail;  in test_sockmap_skb_verdict_peek_helper()  local
654 	err = create_pair(AF_INET, SOCK_STREAM, &c1, &p1);  in test_sockmap_skb_verdict_peek_helper()
658 	err = bpf_map_update_elem(map, &zero, &c1, BPF_NOEXIST);  in test_sockmap_skb_verdict_peek_helper()
659 	if (!ASSERT_OK(err, "bpf_map_update_elem(c1)"))  in test_sockmap_skb_verdict_peek_helper()
664 	recvd = recv(c1, rcv, sizeof(rcv), MSG_PEEK);  in test_sockmap_skb_verdict_peek_helper()
665 	ASSERT_EQ(recvd, sizeof(rcv), "recv(c1)");  in test_sockmap_skb_verdict_peek_helper()
666 	err = ioctl(c1, FIONREAD, &avail);  in test_sockmap_skb_verdict_peek_helper()
669 	recvd = recv(c1, rcv, sizeof(rcv), 0);  in test_sockmap_skb_verdict_peek_helper()
671 	err = ioctl(c1, FIONREAD, &avail);  in test_sockmap_skb_verdict_peek_helper()
676 	close(c1);  in test_sockmap_skb_verdict_peek_helper()