[Tarantool-patches] [PATCH 14/15] sio: introduce and use sio_snprintf()

Vladislav Shpilevoy v.shpilevoy at tarantool.org
Thu Mar 25 00:24:26 MSK 2021


sio_strfaddr() can't be used in the places where static buffer
is not acceptable - in any code which wants to push the value to
Lua, or the address string must be long living.

The patch introduces sio_snprintf(), which does the same, but
saves the result into a provided buffer with a limited size.

In the Lua C code the patch saves the address string on the stack
which makes it safe against Lua GC interruptions.

Part of #5632

(cherry picked from commit fde44b569bf920a08469b9569eab1701d4e57299)
---
 src/box/lua/session.c |  7 +++++--
 src/sio.cc            | 38 +++++++++++++++++++++++++-------------
 src/sio.h             |  5 +++++
 3 files changed, 35 insertions(+), 15 deletions(-)

diff --git a/src/box/lua/session.c b/src/box/lua/session.c
index d1d0da2d2..26315bc4b 100644
--- a/src/box/lua/session.c
+++ b/src/box/lua/session.c
@@ -264,10 +264,13 @@ lbox_session_peer(struct lua_State *L)
 
 	struct sockaddr_storage addr;
 	socklen_t addrlen = sizeof(addr);
-	if (sio_getpeername(fd, (struct sockaddr *)&addr, &addrlen) < 0)
+	struct sockaddr *addr_base = (struct sockaddr *)&addr;
+	if (sio_getpeername(fd, addr_base, &addrlen) < 0)
 		luaL_error(L, "session.peer(): getpeername() failed");
 
-	lua_pushstring(L, sio_strfaddr((struct sockaddr *)&addr, addrlen));
+	char addrbuf[SERVICE_NAME_MAXLEN];
+	sio_addr_snprintf(addrbuf, sizeof(addrbuf), addr_base, addrlen);
+	lua_pushstring(L, addrbuf);
 	return 1;
 }
 
diff --git a/src/sio.cc b/src/sio.cc
index a425b8383..1f7800d6d 100644
--- a/src/sio.cc
+++ b/src/sio.cc
@@ -62,16 +62,17 @@ sio_socketname_to_buffer(int fd, char *buf, int size)
 		return 0;
 	struct sockaddr_storage addr;
 	socklen_t addrlen = sizeof(addr);
-	int rc = getsockname(fd, (struct sockaddr *) &addr, &addrlen);
+	struct sockaddr *base_addr = (struct sockaddr *)&addr;
+	int rc = getsockname(fd, base_addr, &addrlen);
 	if (rc == 0) {
-		SNPRINT(n, snprintf, buf, size, ", aka %s",
-			sio_strfaddr((struct sockaddr *)&addr, addrlen));
+		SNPRINT(n, snprintf, buf, size, ", aka ");
+		SNPRINT(n, sio_addr_snprintf, buf, size, base_addr, addrlen);
 	}
 	addrlen = sizeof(addr);
 	rc = getpeername(fd, (struct sockaddr *) &addr, &addrlen);
 	if (rc == 0) {
-		SNPRINT(n, snprintf, buf, size, ", peer of %s",
-			sio_strfaddr((struct sockaddr *)&addr, addrlen));
+		SNPRINT(n, snprintf, buf, size, ", peer of ");
+		SNPRINT(n, sio_addr_snprintf, buf, size, base_addr, addrlen);
 	}
 	return 0;
 }
@@ -510,26 +511,37 @@ sio_getpeername(int fd, struct sockaddr *addr, socklen_t *addrlen)
 }
 
 /** Pretty print a peer address. */
-const char *
-sio_strfaddr(struct sockaddr *addr, socklen_t addrlen)
+int
+sio_addr_snprintf(char *buf, size_t size, const struct sockaddr *addr,
+		  socklen_t addrlen)
 {
-	static __thread char name[NI_MAXHOST + _POSIX_PATH_MAX + 2];
+	int res;
 	if (addr->sa_family == AF_UNIX) {
 		struct sockaddr_un *u = (struct sockaddr_un *)addr;
 		if (addrlen >= sizeof(*u))
-			snprintf(name, sizeof(name), "unix/:%s", u->sun_path);
+			res = snprintf(buf, size, "unix/:%s", u->sun_path);
 		else
-			snprintf(name, sizeof(name), "unix/:(socket)");
+			res = snprintf(buf, size, "unix/:(socket)");
 	} else {
 		char host[NI_MAXHOST], serv[NI_MAXSERV];
 		int flags = NI_NUMERICHOST | NI_NUMERICSERV;
 		if (getnameinfo(addr, addrlen, host, sizeof(host),
 				serv, sizeof(serv), flags) != 0)
-			snprintf(name, sizeof(name), "(host):(port)");
+			res = snprintf(buf, size, "(host):(port)");
 		else if (addr->sa_family == AF_INET)
-			snprintf(name, sizeof(name), "%s:%s", host, serv);
+			res = snprintf(buf, size, "%s:%s", host, serv);
 		else
-			snprintf(name, sizeof(name), "[%s]:%s", host, serv);
+			res = snprintf(buf, size, "[%s]:%s", host, serv);
 	}
+	assert(res + 1 < SERVICE_NAME_MAXLEN);
+	assert(res >= 0);
+	return res;
+}
+
+const char *
+sio_strfaddr(struct sockaddr *addr, socklen_t addrlen)
+{
+	static __thread char name[SERVICE_NAME_MAXLEN];
+	sio_addr_snprintf(name, sizeof(name), addr, addrlen);
 	return name;
 }
diff --git a/src/sio.h b/src/sio.h
index 3b91f7eee..262bfcab8 100644
--- a/src/sio.h
+++ b/src/sio.h
@@ -57,6 +57,11 @@ enum {
 	SERVICE_NAME_MAXLEN = 200,
 };
 
+/** Format the address into the given buffer. Behaves like snprintf(). */
+int
+sio_addr_snprintf(char *buf, size_t size, const struct sockaddr *addr,
+		  socklen_t addrlen);
+
 const char *
 sio_strfaddr(struct sockaddr *addr, socklen_t addrlen);
 
-- 
2.24.3 (Apple Git-128)



More information about the Tarantool-patches mailing list