Attachment 18639 Details for Bug 15851 – Patch for v4-21-test

Patch for v4-21-test

bfixes-tmp421.txt (text/plain), 5.05 KB, created by Stefan Metzmacher on 2025-04-28 14:36:25 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Stefan Metzmacher

Created: 2025-04-28 14:36:25 UTC

Size: 5.05 KB

patch

obsolete

>From 2790a3b90a78295001e353c40c654be6a4413269 Mon Sep 17 00:00:00 2001
>From: Stefan Metzmacher <metze@samba.org>
>Date: Wed, 23 Apr 2025 10:58:55 +0200
>Subject: [PATCH] s3:rpc_server: make sure we can bind to the same port on all
> ip addresses
>
>BUG: https://bugzilla.samba.org/show_bug.cgi?id=15851
>
>Signed-off-by: Stefan Metzmacher <metze@samba.org>
>Reviewed-by: Andreas Schneider <asn@samba.org>
>(cherry picked from commit 783ca9dc434bd1d18b762185ee936fcbcf292124)
>---
> source3/rpc_server/rpc_sock_helper.c | 114 +++++++++++++++++++--------
> 1 file changed, 81 insertions(+), 33 deletions(-)
>
>diff --git a/source3/rpc_server/rpc_sock_helper.c b/source3/rpc_server/rpc_sock_helper.c
>index 364b889d9b78..cc11e1221db0 100644
>--- a/source3/rpc_server/rpc_sock_helper.c
>+++ b/source3/rpc_server/rpc_sock_helper.c
>@@ -110,32 +110,16 @@ out:
>  ********************************************************************/
> 
> static NTSTATUS dcesrv_create_ncacn_ip_tcp_socket(
>-	const struct sockaddr_storage *ifss, uint16_t *port, int *out_fd)
>+	const struct sockaddr_storage *ifss,
>+	uint16_t port,
>+	bool rebind,
>+	int *out_fd)
> {
> 	int fd = -1;
> 
>-	if (*port == 0) {
>-		static uint16_t low = 0;
>-		uint16_t i;
>-
>-		if (low == 0) {
>-			low = lp_rpc_low_port();
>-		}
>-
>-		for (i = low; i <= lp_rpc_high_port(); i++) {
>-			fd = open_socket_in(SOCK_STREAM, ifss, i, false);
>-			if (fd >= 0) {
>-				*port = i;
>-				low = i+1;
>-				break;
>-			}
>-		}
>-	} else {
>-		fd = open_socket_in(SOCK_STREAM, ifss, *port, true);
>-	}
>-
>+	fd = open_socket_in(SOCK_STREAM, ifss, port, rebind);
> 	if (fd < 0) {
>-		DBG_ERR("Failed to create socket on port %u!\n", *port);
>+		DBG_ERR("Failed to create socket on port %u!\n", port);
> 		return map_nt_error_from_unix(-fd);
> 	}
> 
>@@ -143,7 +127,7 @@ static NTSTATUS dcesrv_create_ncacn_ip_tcp_socket(
> 	set_socket_options(fd, "SO_KEEPALIVE");
> 	set_socket_options(fd, lp_socket_options());
> 
>-	DBG_DEBUG("Opened ncacn_ip_tcp socket fd %d for port %u\n", fd, *port);
>+	DBG_DEBUG("Opened ncacn_ip_tcp socket fd %d for port %u\n", fd, port);
> 
> 	*out_fd = fd;
> 
>@@ -156,15 +140,24 @@ static NTSTATUS dcesrv_create_ncacn_ip_tcp_sockets(
> 	size_t *pnum_fds,
> 	int **pfds)
> {
>+	static uint16_t next_low_port;
>+	static uint16_t conf_high_port;
> 	uint16_t port = 0;
>+	uint16_t highest_port = 0;
> 	char port_str[11];
> 	const char *endpoint = NULL;
> 	size_t i = 0, num_fds;
> 	int *fds = NULL;
> 	struct samba_sockaddr *addrs = NULL;
> 	NTSTATUS status = NT_STATUS_INVALID_PARAMETER;
>+	bool rebind = false;
> 	bool ok;
> 
>+	if (next_low_port == 0) {
>+		next_low_port = lp_rpc_low_port();
>+		conf_high_port = lp_rpc_high_port();
>+	}
>+
> 	endpoint = dcerpc_binding_get_string_option(b, "endpoint");
> 	if (endpoint != NULL) {
> 		port = atoi(endpoint);
>@@ -181,15 +174,21 @@ static NTSTATUS dcesrv_create_ncacn_ip_tcp_sockets(
> 
> 	addrs = talloc_array(mem_ctx, struct samba_sockaddr, num_fds);
> 	if (addrs == NULL) {
>+		num_fds = 0; /* nothing to close */
> 		status = NT_STATUS_NO_MEMORY;
> 		goto fail;
> 	}
> 	fds = talloc_array(mem_ctx, int, num_fds);
> 	if (fds == NULL) {
>+		num_fds = 0; /* nothing to close */
> 		status = NT_STATUS_NO_MEMORY;
> 		goto fail;
> 	}
> 
>+	for (i=0; i<num_fds; i++) {
>+		fds[i] = -1;
>+	}
>+
> 	/*
> 	 * Fill "addrs"
> 	 */
>@@ -202,7 +201,6 @@ static NTSTATUS dcesrv_create_ncacn_ip_tcp_sockets(
> 			ok = sockaddr_storage_to_samba_sockaddr(
> 				&addrs[i], ifss);
> 			if (!ok) {
>-				i = 0; /* nothing to close */
> 				goto fail;
> 			}
> 		}
>@@ -234,13 +232,60 @@ static NTSTATUS dcesrv_create_ncacn_ip_tcp_sockets(
> 		}
> 	}
> 
>-	for (i=0; i<num_fds; i++) {
>-		status = dcesrv_create_ncacn_ip_tcp_socket(
>-			&addrs[i].u.ss, &port, &fds[i]);
>-		if (!NT_STATUS_IS_OK(status)) {
>-			goto fail;
>+	if (port != 0) {
>+		rebind = true;
>+		highest_port = port;
>+	} else {
>+		rebind = false;
>+		port = next_low_port;
>+		highest_port = conf_high_port;
>+	}
>+
>+	for (; port <= highest_port; port += 1) {
>+		for (i=0; i<num_fds; i++) {
>+			status = dcesrv_create_ncacn_ip_tcp_socket(
>+						&addrs[i].u.ss,
>+						port,
>+						rebind,
>+						&fds[i]);
>+			if (NT_STATUS_EQUAL(status,
>+			    NT_STATUS_ADDRESS_ALREADY_ASSOCIATED))
>+			{
>+				break;
>+			}
>+			if (!NT_STATUS_IS_OK(status)) {
>+				goto fail;
>+			}
>+			samba_sockaddr_set_port(&addrs[i], port);
> 		}
>-		samba_sockaddr_set_port(&addrs[i], port);
>+
>+		if (port == next_low_port) {
>+			next_low_port += 1;
>+		}
>+
>+		if (i == num_fds) {
>+			/*
>+			 * We were able to bind to the same port on all
>+			 * addresses
>+			 */
>+			break;
>+		}
>+
>+		/*
>+		 * The port was not available on at least one address, so close
>+		 * them all and try the next port or return the error.
>+		 */
>+		for (i=0; i<num_fds; i++) {
>+			if (fds[i] == -1) {
>+				continue;
>+			}
>+			close(fds[i]);
>+			fds[i] = -1;
>+		}
>+	}
>+
>+	if (!NT_STATUS_IS_OK(status)) {
>+		goto fail;
> 	}
> 
> 	/* Set the port in the endpoint */
>@@ -261,9 +306,12 @@ static NTSTATUS dcesrv_create_ncacn_ip_tcp_sockets(
> 	return NT_STATUS_OK;
> 
> fail:
>-	while (i > 0) {
>-		close(fds[i-1]);
>-		i -= 1;
>+	for (i=0; i<num_fds; i++) {
>+		if (fds[i] == -1) {
>+			continue;
>+		}
>+		close(fds[i]);
>+		fds[i] = -1;
> 	}
> 	TALLOC_FREE(fds);
> 	TALLOC_FREE(addrs);
>-- 
>2.34.1
>

Flags:

asn: review+

Actions: View

Attachments on bug 15851: 18638 | 18639