mirror of
https://github.com/systemd/systemd.git
synced 2026-08-05 23:50:42 +00:00
socket: verify socket type properly when desrializing
This commit is contained in:
@@ -443,7 +443,7 @@ bool socket_address_equal(const SocketAddress *a, const SocketAddress *b) {
|
||||
return true;
|
||||
}
|
||||
|
||||
bool socket_address_is(const SocketAddress *a, const char *s) {
|
||||
bool socket_address_is(const SocketAddress *a, const char *s, int type) {
|
||||
struct SocketAddress b;
|
||||
|
||||
assert(a);
|
||||
@@ -452,6 +452,8 @@ bool socket_address_is(const SocketAddress *a, const char *s) {
|
||||
if (socket_address_parse(&b, s) < 0)
|
||||
return false;
|
||||
|
||||
b.type = type;
|
||||
|
||||
return socket_address_equal(a, &b);
|
||||
}
|
||||
|
||||
|
||||
@@ -72,7 +72,7 @@ int socket_address_listen(
|
||||
mode_t socket_mode,
|
||||
int *ret);
|
||||
|
||||
bool socket_address_is(const SocketAddress *a, const char *s);
|
||||
bool socket_address_is(const SocketAddress *a, const char *s, int type);
|
||||
|
||||
bool socket_address_equal(const SocketAddress *a, const SocketAddress *b);
|
||||
|
||||
|
||||
@@ -1067,7 +1067,7 @@ static int socket_serialize(Unit *u, FILE *f, FDSet *fds) {
|
||||
if ((r = socket_address_print(&p->address, &t)) < 0)
|
||||
return r;
|
||||
|
||||
unit_serialize_item_format(u, f, "socket", "%i %s", copy, t);
|
||||
unit_serialize_item_format(u, f, "socket", "%i %i %s", copy, p->address.type, t);
|
||||
free(t);
|
||||
} else {
|
||||
assert(p->type == SOCKET_FIFO);
|
||||
@@ -1145,15 +1145,15 @@ static int socket_deserialize_item(Unit *u, const char *key, const char *value,
|
||||
}
|
||||
|
||||
} else if (streq(key, "socket")) {
|
||||
int fd, skip = 0;
|
||||
int fd, type, skip = 0;
|
||||
SocketPort *p;
|
||||
|
||||
if (sscanf(value, "%i %n", &fd, &skip) < 1 || fd < 0 || !fdset_contains(fds, fd))
|
||||
if (sscanf(value, "%i %i %n", &fd, &type, &skip) < 2 || fd < 0 || type < 0 || !fdset_contains(fds, fd))
|
||||
log_debug("Failed to parse socket value %s", value);
|
||||
else {
|
||||
|
||||
LIST_FOREACH(port, p, s->ports)
|
||||
if (socket_address_is(&p->address, value+skip))
|
||||
if (socket_address_is(&p->address, value+skip, type))
|
||||
break;
|
||||
|
||||
if (p) {
|
||||
|
||||
Reference in New Issue
Block a user