226 	int sockfd = *(int *)arg;  in dut_echo_thread()  local
234 		n = recvfrom(sockfd, buf, sizeof(buf), MSG_WAITALL,  in dut_echo_thread()
242 		sendto(sockfd, buf, sizeof(buf), MSG_NOSIGNAL | MSG_CONFIRM,  in dut_echo_thread()
247 	close(sockfd);  in dut_echo_thread()
252 static int dut_run_echo_thread(pthread_t *t, int *sockfd)  in dut_run_echo_thread()  argument
256 	sockfd = start_reuseport_server(AF_INET6, SOCK_DGRAM, NULL,  in dut_run_echo_thread()
258 	if (!sockfd) {  in dut_run_echo_thread()
266 	err = pthread_create(t, NULL, dut_echo_thread, sockfd);  in dut_run_echo_thread()
271 		free_fds(sockfd, 1);  in dut_run_echo_thread()
339 static int recv_msg(int sockfd, void *buf, size_t bufsize, void *val,  in recv_msg()  argument
345 	len = recv(sockfd, buf, bufsize, 0);  in recv_msg()
363 	int state, err, *sockfd, ctrl_sockfd, echo_sockfd;  in dut_run()  local
368 	sockfd = start_reuseport_server(AF_INET6, SOCK_STREAM, NULL,  in dut_run()
370 	if (!sockfd) {  in dut_run()
376 	ctrl_sockfd = accept(*sockfd, (struct sockaddr *)&ctrl_addr, &addrlen);  in dut_run()
381 		free_fds(sockfd, 1);  in dut_run()
490 	free_fds(sockfd, 1);  in dut_run()
528 static int send_and_recv_msg(int sockfd, enum test_commands cmd, void *val,  in send_and_recv_msg()  argument
538 	err = send(sockfd, buf, sizeof(*tlv), 0);  in send_and_recv_msg()
542 	err = recv_msg(sockfd, buf, BUFSIZE, val, val_size);  in send_and_recv_msg()
553 	int sockfd, n;  in send_echo_msg()  local
555 	sockfd = socket(AF_INET6, SOCK_DGRAM, 0);  in send_echo_msg()
556 	if (sockfd < 0) {  in send_echo_msg()
566 	n = sendto(sockfd, buf, sizeof(*tlv), MSG_NOSIGNAL | MSG_CONFIRM,  in send_echo_msg()
568 	close(sockfd);  in send_echo_msg()
579 	int i, err, sockfd;  in tester_run()  local
582 	sockfd = socket(AF_INET6, SOCK_STREAM, 0);  in tester_run()
583 	if (sockfd < 0) {  in tester_run()
589 	if (settimeo(sockfd, 1000) < 0)  in tester_run()
592 	err = connect(sockfd, (struct sockaddr *)&env.dut_ctrl_addr,  in tester_run()
600 	err = send_and_recv_msg(sockfd, CMD_GET_XDP_CAP, &advertised_feature,  in tester_run()
603 		close(sockfd);  in tester_run()
622 	err = send_and_recv_msg(sockfd, CMD_START, NULL, 0);  in tester_run()
634 	err = send_and_recv_msg(sockfd, CMD_GET_STATS, &stats, sizeof(stats));  in tester_run()
639 	err = send_and_recv_msg(sockfd, CMD_STOP, NULL, 0);  in tester_run()
651 	close(sockfd);  in tester_run()