bpf/prog_tests/select_reuseport.c

36 static int sk_fds[REUSEPORT_ARRAY_SIZE];
428 	srv_fd = sk_fds[ev.data.u32];
446 		       "recv(sk_fds)",
511 	 * TCP-SYN: select sk_fds[tmp_index = 1] tmp_index is from the
513 	 * TCP-ACK: select sk_fds[reuseport_index = 0] reuseport_index
550 	err = setsockopt(sk_fds[0], SOL_SOCKET, SO_DETACH_REUSEPORT_BPF,
555 	err = setsockopt(sk_fds[1], SOL_SOCKET, SO_DETACH_REUSEPORT_BPF,
608 	 * The sk_fds[] is filled from the back such that the order
612 		sk_fds[i] = socket(family, type, 0);
613 		RET_IF(sk_fds[i] == -1, "socket()", "sk_fds[%d]:%d errno:%d\n",
614 		       i, sk_fds[i], errno);
615 		err = setsockopt(sk_fds[i], SOL_SOCKET, SO_REUSEPORT,
618 		       "sk_fds[%d] err:%d errno:%d\n",
622 			err = setsockopt(sk_fds[i], SOL_SOCKET,
630 		err = bind(sk_fds[i], (struct sockaddr *)&srv_sa, addrlen);
631 		RET_IF(err < 0, "bind()", "sk_fds[%d] err:%d errno:%d\n",
635 			err = listen(sk_fds[i], 10);
637 			       "sk_fds[%d] err:%d errno:%d\n",
641 		err = bpf_map_update_elem(reuseport_array, &i, &sk_fds[i],
644 		       "sk_fds[%d] err:%d errno:%d\n", i, err, errno);
649 			err = getsockname(sk_fds[i], (struct sockaddr *)&srv_sa,
652 			       "sk_fds[%d] err:%d errno:%d\n", i, err, errno);
663 		err = epoll_ctl(epfd, EPOLL_CTL_ADD, sk_fds[i], &ev);
664 		RET_IF(err, "epoll_ctl(EPOLL_CTL_ADD)", "sk_fds[%d]\n", i);
706 		close(sk_fds[i]);