1 files changed, 46 insertions, 0 deletions

diff --git a/tests/sys/netinet/so_reuseport_lb_test.c b/tests/sys/netinet/so_reuseport_lb_test.c
index 09d8e0ce8f83..aaadaead5e23 100644
--- a/tests/sys/netinet/so_reuseport_lb_test.c
+++ b/tests/sys/netinet/so_reuseport_lb_test.c
@@ -433,6 +433,51 @@ ATF_TC_BODY(double_listen_ipv6, tc)
 	ATF_REQUIRE_MSG(error == 0, "close() failed: %s", strerror(errno));
 }
 
+/*
+ * Try binding many sockets to the same lbgroup without calling listen(2) on
+ * them.
+ */
+ATF_TC_WITHOUT_HEAD(bind_without_listen);
+ATF_TC_BODY(bind_without_listen, tc)
+{
+	const int nsockets = 100;
+	struct sockaddr_in sin;
+	socklen_t socklen;
+	int error, s, s2[nsockets];
+
+	s = lb_listen_socket(PF_INET, 0);
+
+	memset(&sin, 0, sizeof(sin));
+	sin.sin_len = sizeof(sin);
+	sin.sin_family = AF_INET;
+	sin.sin_port = htons(0);
+	sin.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
+	error = bind(s, (struct sockaddr *)&sin, sizeof(sin));
+	ATF_REQUIRE_MSG(error == 0, "bind() failed: %s", strerror(errno));
+
+	socklen = sizeof(sin);
+	error = getsockname(s, (struct sockaddr *)&sin, &socklen);
+	ATF_REQUIRE_MSG(error == 0, "getsockname() failed: %s",
+	    strerror(errno));
+
+	for (int i = 0; i < nsockets; i++) {
+		s2[i] = lb_listen_socket(PF_INET, 0);
+		error = bind(s2[i], (struct sockaddr *)&sin, sizeof(sin));
+		ATF_REQUIRE_MSG(error == 0, "bind() failed: %s", strerror(errno));
+	}
+	for (int i = 0; i < nsockets; i++) {
+		error = listen(s2[i], 1);
+		ATF_REQUIRE_MSG(error == 0, "listen() failed: %s", strerror(errno));
+	}
+	for (int i = 0; i < nsockets; i++) {
+		error = close(s2[i]);
+		ATF_REQUIRE_MSG(error == 0, "close() failed: %s", strerror(errno));
+	}
+
+	error = close(s);
+	ATF_REQUIRE_MSG(error == 0, "close() failed: %s", strerror(errno));
+}
+
 ATF_TP_ADD_TCS(tp)
 {
 	ATF_TP_ADD_TC(tp, basic_ipv4);
@@ -440,6 +485,7 @@ ATF_TP_ADD_TCS(tp)
 	ATF_TP_ADD_TC(tp, concurrent_add);
 	ATF_TP_ADD_TC(tp, double_listen_ipv4);
 	ATF_TP_ADD_TC(tp, double_listen_ipv6);
+	ATF_TP_ADD_TC(tp, bind_without_listen);
 
 	return (atf_no_error());
 }