hdr.msg_controllen = sizeof(cmsg_buf);
if (recvmsg(fd, &hdr, 0) < 0)
- error(-1, errno, "recvmsg");
+ error(1, errno, "recvmsg");
for (cmsg = CMSG_FIRSTHDR(&hdr); cmsg != NULL;
cmsg = CMSG_NXTHDR(&hdr, cmsg)) {
fd = socket(AF_UNIX, SOCK_DGRAM, 0);
if (fd < 0)
- error(-1, errno, "socket");
+ error(1, errno, "socket");
ret = ioctl(fd, SIOCETHTOOL, &ifr);
if (ret < 0)
- error(-1, errno, "ioctl(SIOCETHTOOL)");
+ error(1, errno, "ioctl(SIOCETHTOOL)");
close(fd);
fd = socket(AF_UNIX, SOCK_DGRAM, 0);
if (fd < 0)
- error(-1, errno, "socket");
+ error(1, errno, "socket");
ret = ioctl(fd, op, &ifr);
if (ret < 0)
- error(-1, errno, "ioctl(%d)", op);
+ error(1, errno, "ioctl(%d)", op);
close(fd);
}
ret = setsockopt(fd, SOL_SOCKET, SO_TIMESTAMPING, &val, sizeof(val));
if (ret < 0)
- error(-1, errno, "setsockopt(SO_TIMESTAMPING)");
+ error(1, errno, "setsockopt(SO_TIMESTAMPING)");
}
int main(int argc, char *argv[])
rx_xsk = malloc(sizeof(struct xsk) * rxq);
if (!rx_xsk)
- error(-1, ENOMEM, "malloc");
+ error(1, ENOMEM, "malloc");
for (i = 0; i < rxq; i++) {
printf("open_xsk(%s, %p, %d)\n", ifname, &rx_xsk[i], i);
ret = open_xsk(ifindex, &rx_xsk[i], i);
if (ret)
- error(-1, -ret, "open_xsk");
+ error(1, -ret, "open_xsk");
printf("xsk_socket__fd() -> %d\n", xsk_socket__fd(rx_xsk[i].socket));
}
printf("open bpf program...\n");
bpf_obj = xdp_hw_metadata__open();
if (libbpf_get_error(bpf_obj))
- error(-1, libbpf_get_error(bpf_obj), "xdp_hw_metadata__open");
+ error(1, libbpf_get_error(bpf_obj), "xdp_hw_metadata__open");
prog = bpf_object__find_program_by_name(bpf_obj->obj, "rx");
bpf_program__set_ifindex(prog, ifindex);
printf("load bpf program...\n");
ret = xdp_hw_metadata__load(bpf_obj);
if (ret)
- error(-1, -ret, "xdp_hw_metadata__load");
+ error(1, -ret, "xdp_hw_metadata__load");
printf("prepare skb endpoint...\n");
server_fd = start_server(AF_INET6, SOCK_DGRAM, NULL, 9092, 1000);
if (server_fd < 0)
- error(-1, errno, "start_server");
+ error(1, errno, "start_server");
timestamping_enable(server_fd,
SOF_TIMESTAMPING_SOFTWARE |
SOF_TIMESTAMPING_RAW_HARDWARE);
printf("map[%d] = %d\n", queue_id, sock_fd);
ret = bpf_map_update_elem(bpf_map__fd(bpf_obj->maps.xsk), &queue_id, &sock_fd, 0);
if (ret)
- error(-1, -ret, "bpf_map_update_elem");
+ error(1, -ret, "bpf_map_update_elem");
}
printf("attach bpf program...\n");
bpf_program__fd(bpf_obj->progs.rx),
XDP_FLAGS, NULL);
if (ret)
- error(-1, -ret, "bpf_xdp_attach");
+ error(1, -ret, "bpf_xdp_attach");
signal(SIGINT, handle_signal);
ret = verify_metadata(rx_xsk, rxq, server_fd);
close(server_fd);
cleanup();
if (ret)
- error(-1, -ret, "verify_metadata");
+ error(1, -ret, "verify_metadata");
}