14895667988

Committed 07 May 2025 08:57PM UTC coverage: 72.225% (-0.007%) from 72.232%

Build # 14895667988

Build Type

push

github

Committed by

yuwata

Commit Message

network: log_link_message_debug_errno() automatically append %m if necessary

Follow-up for d28746ef5.
Fixes CID#1609753.

Coverage Stats

0 of 1 new or added line in 1 file covered. (0.0%)

20297 existing lines in 338 files now uncovered.

297407 of 411780 relevant lines covered (72.22%)

695716.85 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

87.04

/src/network/networkd-serialize.c

/* SPDX-License-Identifier: LGPL-2.1-or-later */

#include "af-list.h"
#include "alloc-util.h"
#include "daemon-util.h"
#include "fd-util.h"
#include "fileio.h"
#include "iovec-util.h"
#include "json-util.h"
#include "memfd-util.h"
#include "networkd-address.h"
#include "networkd-json.h"
#include "networkd-link.h"
#include "networkd-manager.h"
#include "networkd-nexthop.h"
#include "networkd-route.h"
#include "networkd-serialize.h"

int manager_serialize(Manager *manager) {
        _cleanup_(sd_json_variant_unrefp) sd_json_variant *v = NULL, *array = NULL;
        int r;

        assert(manager);

        log_debug("Serializing...");

        Link *link;
        HASHMAP_FOREACH(link, manager->links_by_index) {
                _cleanup_(sd_json_variant_unrefp) sd_json_variant *e = NULL;

                /* ignore unmanaged, failed, or removed interfaces. */
                if (!IN_SET(link->state, LINK_STATE_PENDING, LINK_STATE_INITIALIZED, LINK_STATE_CONFIGURING, LINK_STATE_CONFIGURED))
                        continue;

                r = sd_json_buildo(
                                &e,
                                SD_JSON_BUILD_PAIR_INTEGER("Index", link->ifindex));
                if (r < 0)
                        return r;

                r = addresses_append_json(link, /* serializing = */ true, &e);
                if (r < 0)
                        return r;

                r = sd_json_variant_append_array(&array, e);
                if (r < 0)
                        return r;
        }

        r = json_variant_set_field_non_null(&v, "Interfaces", array);
        if (r < 0)
                return r;

        r = nexthops_append_json(manager, /* ifindex = */ -1, &v);
        if (r < 0)
                return r;

        r = routes_append_json(manager, /* ifindex = */ -1, &v);
        if (r < 0)
                return r;

        if (!v) {
                log_debug("There is nothing to serialize.");
                return 0;
        }

        _cleanup_free_ char *dump = NULL;
        r = sd_json_variant_format(v, /* flags = */ 0, &dump);
        if (r < 0)
                return r;

        _cleanup_close_ int fd = -EBADF;
        fd = memfd_new_and_seal_string("serialization", dump);
        if (fd < 0)
                return fd;

        r = notify_push_fd(fd, "manager-serialization");
        if (r < 0)
                return log_debug_errno(r, "Failed to push serialization file descriptor: %m");

        log_debug("Serialization completed.");
        return 0;
}

int manager_set_serialization_fd(Manager *manager, int fd, const char *name) {
        assert(manager);
        assert(fd >= 0);
        assert(name);

        if (!startswith(name, "manager-serialization"))
                return -EINVAL;

        if (manager->serialization_fd >= 0)
                return -EEXIST;

        manager->serialization_fd = fd;
        return 0;
}

static JSON_DISPATCH_ENUM_DEFINE(json_dispatch_network_config_source, NetworkConfigSource, network_config_source_from_string);

static int json_dispatch_address_family(const char *name, sd_json_variant *variant, sd_json_dispatch_flags_t flags, void *userdata) {
        int r, *i = ASSERT_PTR(userdata);
        int64_t i64;

        assert_return(variant, -EINVAL);

        if (FLAGS_SET(flags, SD_JSON_RELAX) && sd_json_variant_is_null(variant)) {
                *i = AF_UNSPEC;
                return 0;
        }

        r = sd_json_dispatch_int64(name, variant, flags, &i64);
        if (r < 0)
                return r;

        if (!IN_SET(i64, AF_INET, AF_INET6) && !(FLAGS_SET(flags, SD_JSON_RELAX) && i64 == AF_UNSPEC))
                return json_log(variant, flags, SYNTHETIC_ERRNO(ERANGE), "JSON field '%s' out of bounds for an address family.", strna(name));

        *i = (int) i64;
        return 0;
}

typedef struct AddressParam {
        int family;
        struct iovec address;
        struct iovec peer;
        uint8_t prefixlen;
        NetworkConfigSource source;
        struct iovec provider;
} AddressParam;

static void address_param_done(AddressParam *p) {
        assert(p);

        iovec_done(&p->address);
        iovec_done(&p->peer);
        iovec_done(&p->provider);
}

static int link_deserialize_address(Link *link, sd_json_variant *v) {
        static const sd_json_dispatch_field dispatch_table[] = {
                { "Family",         _SD_JSON_VARIANT_TYPE_INVALID, json_dispatch_address_family,        offsetof(AddressParam, family),    SD_JSON_MANDATORY },
                { "Address",        SD_JSON_VARIANT_ARRAY,         json_dispatch_byte_array_iovec,      offsetof(AddressParam, address),   SD_JSON_MANDATORY },
                { "Peer",           SD_JSON_VARIANT_ARRAY,         json_dispatch_byte_array_iovec,      offsetof(AddressParam, peer),      0                 },
                { "PrefixLength",   _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint8,              offsetof(AddressParam, prefixlen), SD_JSON_MANDATORY },
                { "ConfigSource",   SD_JSON_VARIANT_STRING,        json_dispatch_network_config_source, offsetof(AddressParam, source),    SD_JSON_MANDATORY },
                { "ConfigProvider", SD_JSON_VARIANT_ARRAY,         json_dispatch_byte_array_iovec,      offsetof(AddressParam, provider),  0                 },
                {},
        };

        int r;

        assert(link);
        assert(v);

        _cleanup_(address_param_done) AddressParam p = {};
        r = sd_json_dispatch(v, dispatch_table, SD_JSON_ALLOW_EXTENSIONS, &p);
        if (r < 0)
                return log_link_debug_errno(link, r, "Failed to dispatch address from json variant: %m");

        if (p.address.iov_len != FAMILY_ADDRESS_SIZE(p.family))
                return log_link_debug_errno(link, SYNTHETIC_ERRNO(EINVAL),
                                            "Dispatched address size (%zu) is incompatible with the family (%s).",
                                            p.address.iov_len, af_to_ipv4_ipv6(p.family));

        if (p.peer.iov_len != 0 && p.peer.iov_len != FAMILY_ADDRESS_SIZE(p.family))
                return log_link_debug_errno(link, SYNTHETIC_ERRNO(EINVAL),
                                            "Dispatched peer address size (%zu) is incompatible with the family (%s).",
                                            p.peer.iov_len, af_to_ipv4_ipv6(p.family));

        if (p.provider.iov_len != 0 && p.provider.iov_len != FAMILY_ADDRESS_SIZE(p.family))
                return log_link_debug_errno(link, SYNTHETIC_ERRNO(EINVAL),
                                            "Dispatched provider address size (%zu) is incompatible with the family (%s).",
                                            p.provider.iov_len, af_to_ipv4_ipv6(p.family));

        Address tmp = {
                .family = p.family,
                .prefixlen = p.prefixlen,
        };

        memcpy_safe(&tmp.in_addr, p.address.iov_base, p.address.iov_len);
        memcpy_safe(&tmp.in_addr_peer, p.peer.iov_base, p.peer.iov_len);

        Address *address;
        r = address_get(link, &tmp, &address);
        if (r < 0) {
                log_link_debug_errno(link, r, "Cannot find deserialized address %s: %m",
                                     IN_ADDR_PREFIX_TO_STRING(tmp.family, &tmp.in_addr, tmp.prefixlen));
                return 0; /* Already removed? */
        }

        if (address->source != NETWORK_CONFIG_SOURCE_FOREIGN)
                return 0; /* Huh?? Already deserialized?? */

        address->source = p.source;
        memcpy_safe(&address->provider, p.provider.iov_base, p.provider.iov_len);

        log_address_debug(address, "Deserialized", link);
        return 0;
}

static int manager_deserialize_link(Manager *manager, sd_json_variant *v) {
        typedef struct LinkParam {
                int ifindex;
                sd_json_variant *addresses;
        } LinkParam;

        static const sd_json_dispatch_field dispatch_table[] = {
                { "Index",     _SD_JSON_VARIANT_TYPE_INVALID, json_dispatch_ifindex,          offsetof(LinkParam, ifindex),   SD_JSON_MANDATORY | SD_JSON_REFUSE_NULL },
                { "Addresses", SD_JSON_VARIANT_ARRAY,         sd_json_dispatch_variant_noref, offsetof(LinkParam, addresses), 0                                       },
                {},
        };

        int r, ret = 0;

        assert(manager);
        assert(v);

        LinkParam p = {};
        r = sd_json_dispatch(v, dispatch_table, SD_JSON_ALLOW_EXTENSIONS, &p);
        if (r < 0)
                return log_debug_errno(r, "Failed to dispatch interface from json variant: %m");

        Link *link;
        r = link_get_by_index(manager, p.ifindex, &link);
        if (r < 0) {
                log_debug_errno(r, "No interface with deserialized ifindex (%i) found: %m", p.ifindex);
                return 0; /* Already removed? */
        }

        sd_json_variant *i;
        JSON_VARIANT_ARRAY_FOREACH(i, p.addresses)
                RET_GATHER(ret, link_deserialize_address(link, i));

        return ret;
}

typedef struct NextHopParam {
        uint32_t id;
        int family;
        NetworkConfigSource source;
        struct iovec provider;
} NextHopParam;

static void nexthop_param_done(NextHopParam *p) {
        assert(p);

        iovec_done(&p->provider);
}

static int manager_deserialize_nexthop(Manager *manager, sd_json_variant *v) {
        static const sd_json_dispatch_field dispatch_table[] = {
                { "ID",             _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint32,             offsetof(NextHopParam, id),        SD_JSON_MANDATORY },
                { "Family",         _SD_JSON_VARIANT_TYPE_INVALID, json_dispatch_address_family,        offsetof(NextHopParam, family),    SD_JSON_MANDATORY },
                { "ConfigSource",   SD_JSON_VARIANT_STRING,        json_dispatch_network_config_source, offsetof(NextHopParam, source),    SD_JSON_MANDATORY },
                { "ConfigProvider", SD_JSON_VARIANT_ARRAY,         json_dispatch_byte_array_iovec,      offsetof(NextHopParam, provider),  0                 },
                {},
        };

        int r;

        assert(manager);
        assert(v);

        _cleanup_(nexthop_param_done) NextHopParam p = {};
        r = sd_json_dispatch(v, dispatch_table, SD_JSON_ALLOW_EXTENSIONS, &p);
        if (r < 0)
                return log_debug_errno(r, "Failed to dispatch nexthop from json variant: %m");

        if (p.id == 0)
                return log_debug_errno(SYNTHETIC_ERRNO(EINVAL), "Dispatched nexthop ID is zero.");

        if (p.provider.iov_len != 0 && p.provider.iov_len != FAMILY_ADDRESS_SIZE(p.family))
                return log_debug_errno(SYNTHETIC_ERRNO(EINVAL),
                                       "Dispatched provider address size (%zu) is incompatible with the family (%s).",
                                       p.provider.iov_len, af_to_ipv4_ipv6(p.family));

        NextHop *nexthop;
        r = nexthop_get_by_id(manager, p.id, &nexthop);
        if (r < 0) {
                log_debug_errno(r, "Cannot find deserialized nexthop (ID=%"PRIu32"): %m", p.id);
                return 0; /* Already removed? */
        }

        if (nexthop->source != NETWORK_CONFIG_SOURCE_FOREIGN)
                return 0; /* Huh?? Already deserialized?? */

        nexthop->source = p.source;
        memcpy_safe(&nexthop->provider, p.provider.iov_base, p.provider.iov_len);

        log_nexthop_debug(nexthop, "Deserialized", manager);
        return 0;
}

typedef struct RouteParam {
        Route route;

        struct iovec dst;
        struct iovec src;
        struct iovec prefsrc;
        struct iovec gw;
        struct iovec metrics;
        struct iovec provider;
} RouteParam;

static void route_param_done(RouteParam *p) {
        assert(p);

        free(p->route.metric.metrics);

        iovec_done(&p->dst);
        iovec_done(&p->src);
        iovec_done(&p->prefsrc);
        iovec_done(&p->gw);
        iovec_done(&p->metrics);
        iovec_done(&p->provider);
}

static int manager_deserialize_route(Manager *manager, sd_json_variant *v) {
        static const sd_json_dispatch_field dispatch_table[] = {
                /* rtmsg header */
                { "Family",                        _SD_JSON_VARIANT_TYPE_INVALID, json_dispatch_address_family,        offsetof(RouteParam, route.family),                             SD_JSON_MANDATORY                 },
                { "DestinationPrefixLength",       _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint8,              offsetof(RouteParam, route.dst_prefixlen),                      SD_JSON_MANDATORY                 },
                { "SourcePrefixLength",            _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint8,              offsetof(RouteParam, route.src_prefixlen),                      0                                 },
                { "TOS",                           _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint8,              offsetof(RouteParam, route.tos),                                SD_JSON_MANDATORY                 },
                { "Protocol",                      _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint8,              offsetof(RouteParam, route.protocol),                           SD_JSON_MANDATORY                 },
                { "Scope",                         _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint8,              offsetof(RouteParam, route.scope),                              SD_JSON_MANDATORY                 },
                { "Type",                          _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint8,              offsetof(RouteParam, route.type),                               SD_JSON_MANDATORY                 },
                { "Flags",                         _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint32,             offsetof(RouteParam, route.flags),                              SD_JSON_MANDATORY                 },
                /* attributes */
                { "Destination",                   SD_JSON_VARIANT_ARRAY,         json_dispatch_byte_array_iovec,      offsetof(RouteParam, dst),                                      SD_JSON_MANDATORY                 },
                { "Source",                        SD_JSON_VARIANT_ARRAY,         json_dispatch_byte_array_iovec,      offsetof(RouteParam, src),                                      0                                 },
                { "Priority",                      _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint32,             offsetof(RouteParam, route.priority),                           SD_JSON_MANDATORY                 },
                { "PreferredSource",               SD_JSON_VARIANT_ARRAY,         json_dispatch_byte_array_iovec,      offsetof(RouteParam, prefsrc),                                  0                                 },
                { "Table",                         _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint32,             offsetof(RouteParam, route.table),                              SD_JSON_MANDATORY                 },
                /* nexthops */
                { "Gateway",                       SD_JSON_VARIANT_ARRAY,         json_dispatch_byte_array_iovec,      offsetof(RouteParam, gw),                                       0                                 },
                { "InterfaceIndex",                _SD_JSON_VARIANT_TYPE_INVALID, json_dispatch_ifindex,               offsetof(RouteParam, route.nexthop.ifindex),                    SD_JSON_MANDATORY | SD_JSON_RELAX },
                { "NextHopID",                     _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint32,             offsetof(RouteParam, route.nexthop_id),                         0                                 },
                /* metrics */
                { "Metrics",                       SD_JSON_VARIANT_ARRAY,         json_dispatch_byte_array_iovec,      offsetof(RouteParam, metrics),                                  0                                 },
                { "TCPCongestionControlAlgorithm", SD_JSON_VARIANT_STRING,        sd_json_dispatch_const_string,       offsetof(RouteParam, route.metric.tcp_congestion_control_algo), 0                                 },
                /* config */
                { "ConfigSource",                  SD_JSON_VARIANT_STRING,        json_dispatch_network_config_source, offsetof(RouteParam, route.source),                             SD_JSON_MANDATORY                 },
                { "ConfigProvider",                SD_JSON_VARIANT_ARRAY,         json_dispatch_byte_array_iovec,      offsetof(RouteParam, provider),                                 0                                 },
                {},
        };

        int r;

        assert(manager);
        assert(v);

        _cleanup_(route_param_done) RouteParam p = {};
        r = sd_json_dispatch(v, dispatch_table, SD_JSON_ALLOW_EXTENSIONS, &p);
        if (r < 0)
                return log_debug_errno(r, "Failed to dispatch route from json variant: %m");

        if (p.dst.iov_len != FAMILY_ADDRESS_SIZE(p.route.family))
                return log_debug_errno(SYNTHETIC_ERRNO(EINVAL),
                                       "Dispatched destination address size (%zu) is incompatible with the family (%s).",
                                       p.dst.iov_len, af_to_ipv4_ipv6(p.route.family));

        if (p.src.iov_len != 0 && p.src.iov_len != FAMILY_ADDRESS_SIZE(p.route.family))
                return log_debug_errno(SYNTHETIC_ERRNO(EINVAL),
                                       "Dispatched source address size (%zu) is incompatible with the family (%s).",
                                       p.src.iov_len, af_to_ipv4_ipv6(p.route.family));

        if (p.prefsrc.iov_len != 0 && p.prefsrc.iov_len != FAMILY_ADDRESS_SIZE(p.route.family))
                return log_debug_errno(SYNTHETIC_ERRNO(EINVAL),
                                       "Dispatched preferred source address size (%zu) is incompatible with the family (%s).",
                                       p.prefsrc.iov_len, af_to_ipv4_ipv6(p.route.family));

        switch (p.gw.iov_len) {
        case 0:
                p.route.nexthop.family = AF_UNSPEC;
                break;
        case sizeof(struct in_addr):
                p.route.nexthop.family = AF_INET;
                break;
        case sizeof(struct in6_addr):
                p.route.nexthop.family = AF_INET6;
                break;
        default:
                return log_debug_errno(SYNTHETIC_ERRNO(EINVAL),
                                       "Dispatched gateway address size (%zu) is invalid.",
                                       p.prefsrc.iov_len);
        }

        if (p.metrics.iov_len % sizeof(uint32_t) != 0)
                return log_debug_errno(SYNTHETIC_ERRNO(EINVAL),
                                       "Dispatched route metric size (%zu) is invalid.",
                                       p.metrics.iov_len);

        if (p.provider.iov_len != 0 && p.provider.iov_len != FAMILY_ADDRESS_SIZE(p.route.family))
                return log_debug_errno(SYNTHETIC_ERRNO(EINVAL),
                                       "Dispatched provider address size (%zu) is incompatible with the family (%s).",
                                       p.provider.iov_len, af_to_ipv4_ipv6(p.route.family));

        memcpy_safe(&p.route.dst, p.dst.iov_base, p.dst.iov_len);
        memcpy_safe(&p.route.src, p.src.iov_base, p.src.iov_len);
        memcpy_safe(&p.route.prefsrc, p.prefsrc.iov_base, p.prefsrc.iov_len);
        memcpy_safe(&p.route.nexthop.gw, p.gw.iov_base, p.gw.iov_len);

        p.route.metric.n_metrics = p.metrics.iov_len / sizeof(uint32_t);
        p.route.metric.metrics = new(uint32_t, p.route.metric.n_metrics);
        if (!p.route.metric.metrics)
                return log_oom_debug();

        memcpy_safe(p.route.metric.metrics, p.metrics.iov_base, p.metrics.iov_len);

        Route *route;
        r = route_get(manager, &p.route, &route);
        if (r < 0) {
                log_route_debug(&p.route, "Cannot find deserialized", manager);
                return 0; /* Already removed? */
        }

        if (route->source != NETWORK_CONFIG_SOURCE_FOREIGN)
                return 0; /* Huh?? Already deserialized?? */

        route->source = p.route.source;
        memcpy_safe(&route->provider, p.provider.iov_base, p.provider.iov_len);

        log_route_debug(route, "Deserialized", manager);
        return 0;
}

int manager_deserialize(Manager *manager) {
        int r, ret = 0;

        assert(manager);

        _cleanup_close_ int fd = TAKE_FD(manager->serialization_fd);
        if (fd < 0)
                return 0;

        log_debug("Deserializing...");

        _cleanup_fclose_ FILE *f = take_fdopen(&fd, "r");
        if (!f)
                return log_debug_errno(errno, "Failed to fdopen() serialization file descriptor: %m");

        _cleanup_(sd_json_variant_unrefp) sd_json_variant *v = NULL;
        unsigned err_line = 0, err_column = 0;
        r = sd_json_parse_file(
                        f,
                        /* path = */ NULL,
                        /* flags = */ 0,
                        &v,
                        &err_line,
                        &err_column);
        if (r < 0)
                return log_debug_errno(r, "Failed to parse json (line=%u, column=%u): %m", err_line, err_column);

        sd_json_variant *i;
        JSON_VARIANT_ARRAY_FOREACH(i, sd_json_variant_by_key(v, "Interfaces"))
                RET_GATHER(ret, manager_deserialize_link(manager, i));

        JSON_VARIANT_ARRAY_FOREACH(i, sd_json_variant_by_key(v, "NextHops"))
                RET_GATHER(ret, manager_deserialize_nexthop(manager, i));

        JSON_VARIANT_ARRAY_FOREACH(i, sd_json_variant_by_key(v, "Routes"))
                RET_GATHER(ret, manager_deserialize_route(manager, i));

        log_debug("Deserialization completed.");
        return ret;
}

1	/* SPDX-License-Identifier: LGPL-2.1-or-later */
2
3	#include "af-list.h"
4	#include "alloc-util.h"
5	#include "daemon-util.h"
6	#include "fd-util.h"
7	#include "fileio.h"
8	#include "iovec-util.h"
9	#include "json-util.h"
10	#include "memfd-util.h"
11	#include "networkd-address.h"
12	#include "networkd-json.h"
13	#include "networkd-link.h"
14	#include "networkd-manager.h"
15	#include "networkd-nexthop.h"
16	#include "networkd-route.h"
17	#include "networkd-serialize.h"
18
19	int manager_serialize(Manager *manager) {	417✔
20	_cleanup_(sd_json_variant_unrefp) sd_json_variant v = NULL, array = NULL;	451✔
21	int r;	417✔
22
23	assert(manager);	417✔
24
25	log_debug("Serializing...");	417✔
26
27	Link *link;	417✔
28	HASHMAP_FOREACH(link, manager->links_by_index) {	2,216✔
29	_cleanup_(sd_json_variant_unrefp) sd_json_variant *e = NULL;	51✔
30
31	/* ignore unmanaged, failed, or removed interfaces. */
32	if (!IN_SET(link->state, LINK_STATE_PENDING, LINK_STATE_INITIALIZED, LINK_STATE_CONFIGURING, LINK_STATE_CONFIGURED))	1,799✔
33	continue;	1,748✔
34
35	r = sd_json_buildo(	51✔
36	&e,
37	SD_JSON_BUILD_PAIR_INTEGER("Index", link->ifindex));
38	if (r < 0)	51✔
39	return r;
40
41	r = addresses_append_json(link, /* serializing = */ true, &e);	51✔
42	if (r < 0)	51✔
43	return r;
44
45	r = sd_json_variant_append_array(&array, e);	51✔
46	if (r < 0)	51✔
47	return r;
48	}
49
50	r = json_variant_set_field_non_null(&v, "Interfaces", array);	417✔
51	if (r < 0)	417✔
52	return r;
53
54	r = nexthops_append_json(manager, /* ifindex = */ -1, &v);	417✔
55	if (r < 0)	417✔
56	return r;
57
58	r = routes_append_json(manager, /* ifindex = */ -1, &v);	417✔
59	if (r < 0)	417✔
60	return r;
61
62	if (!v) {	417✔
63	log_debug("There is nothing to serialize.");	383✔
64	return 0;	383✔
65	}
66
67	_cleanup_free_ char *dump = NULL;	34✔
68	r = sd_json_variant_format(v, /* flags = */ 0, &dump);	34✔
69	if (r < 0)	34✔
70	return r;
71
72	_cleanup_close_ int fd = -EBADF;	34✔
73	fd = memfd_new_and_seal_string("serialization", dump);	34✔
74	if (fd < 0)	34✔
75	return fd;
76
77	r = notify_push_fd(fd, "manager-serialization");	34✔
78	if (r < 0)	34✔
UNCOV 79	return log_debug_errno(r, "Failed to push serialization file descriptor: %m");	×
80
81	log_debug("Serialization completed.");	34✔
82	return 0;
83	}
84
85	int manager_set_serialization_fd(Manager manager, int fd, const char name) {	30✔
86	assert(manager);	30✔
87	assert(fd >= 0);	30✔
88	assert(name);	30✔
89
90	if (!startswith(name, "manager-serialization"))	30✔
91	return -EINVAL;
92
93	if (manager->serialization_fd >= 0)	26✔
94	return -EEXIST;
95
96	manager->serialization_fd = fd;	26✔
97	return 0;	26✔
98	}
99
100	static JSON_DISPATCH_ENUM_DEFINE(json_dispatch_network_config_source, NetworkConfigSource, network_config_source_from_string);	101✔
101
102	static int json_dispatch_address_family(const char name, sd_json_variant variant, sd_json_dispatch_flags_t flags, void *userdata) {	101✔
103	int r, *i = ASSERT_PTR(userdata);	101✔
104	int64_t i64;	101✔
105
106	assert_return(variant, -EINVAL);	101✔
107
108	if (FLAGS_SET(flags, SD_JSON_RELAX) && sd_json_variant_is_null(variant)) {	101✔
109	*i = AF_UNSPEC;	×
UNCOV 110	return 0;	×
111	}
112
113	r = sd_json_dispatch_int64(name, variant, flags, &i64);	101✔
114	if (r < 0)	101✔
115	return r;
116
117	if (!IN_SET(i64, AF_INET, AF_INET6) && !(FLAGS_SET(flags, SD_JSON_RELAX) && i64 == AF_UNSPEC))	101✔
UNCOV 118	return json_log(variant, flags, SYNTHETIC_ERRNO(ERANGE), "JSON field '%s' out of bounds for an address family.", strna(name));	×
119
120	*i = (int) i64;	101✔
121	return 0;	101✔
122	}
123
124	typedef struct AddressParam {
125	int family;
126	struct iovec address;
127	struct iovec peer;
128	uint8_t prefixlen;
129	NetworkConfigSource source;
130	struct iovec provider;
131	} AddressParam;
132
133	static void address_param_done(AddressParam *p) {	68✔
134	assert(p);	68✔
135
136	iovec_done(&p->address);	68✔
137	iovec_done(&p->peer);	68✔
138	iovec_done(&p->provider);	68✔
139	}	68✔
140
141	static int link_deserialize_address(Link link, sd_json_variant v) {	68✔
142	static const sd_json_dispatch_field dispatch_table[] = {	68✔
143	{ "Family", _SD_JSON_VARIANT_TYPE_INVALID, json_dispatch_address_family, offsetof(AddressParam, family), SD_JSON_MANDATORY },
144	{ "Address", SD_JSON_VARIANT_ARRAY, json_dispatch_byte_array_iovec, offsetof(AddressParam, address), SD_JSON_MANDATORY },
145	{ "Peer", SD_JSON_VARIANT_ARRAY, json_dispatch_byte_array_iovec, offsetof(AddressParam, peer), 0 },
146	{ "PrefixLength", _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint8, offsetof(AddressParam, prefixlen), SD_JSON_MANDATORY },
147	{ "ConfigSource", SD_JSON_VARIANT_STRING, json_dispatch_network_config_source, offsetof(AddressParam, source), SD_JSON_MANDATORY },
148	{ "ConfigProvider", SD_JSON_VARIANT_ARRAY, json_dispatch_byte_array_iovec, offsetof(AddressParam, provider), 0 },
149	{},
150	};
151
152	int r;	68✔
153
154	assert(link);	68✔
155	assert(v);	68✔
156
157	_cleanup_(address_param_done) AddressParam p = {};	68✔
158	r = sd_json_dispatch(v, dispatch_table, SD_JSON_ALLOW_EXTENSIONS, &p);	68✔
159	if (r < 0)	68✔
UNCOV 160	return log_link_debug_errno(link, r, "Failed to dispatch address from json variant: %m");	×
161
162	if (p.address.iov_len != FAMILY_ADDRESS_SIZE(p.family))	68✔
UNCOV 163	return log_link_debug_errno(link, SYNTHETIC_ERRNO(EINVAL),	×
164	"Dispatched address size (%zu) is incompatible with the family (%s).",
165	p.address.iov_len, af_to_ipv4_ipv6(p.family));
166
167	if (p.peer.iov_len != 0 && p.peer.iov_len != FAMILY_ADDRESS_SIZE(p.family))	68✔
UNCOV 168	return log_link_debug_errno(link, SYNTHETIC_ERRNO(EINVAL),	×
169	"Dispatched peer address size (%zu) is incompatible with the family (%s).",
170	p.peer.iov_len, af_to_ipv4_ipv6(p.family));
171
172	if (p.provider.iov_len != 0 && p.provider.iov_len != FAMILY_ADDRESS_SIZE(p.family))	68✔
UNCOV 173	return log_link_debug_errno(link, SYNTHETIC_ERRNO(EINVAL),	×
174	"Dispatched provider address size (%zu) is incompatible with the family (%s).",
175	p.provider.iov_len, af_to_ipv4_ipv6(p.family));
176
177	Address tmp = {	68✔
178	.family = p.family,	68✔
179	.prefixlen = p.prefixlen,	68✔
180	};
181
182	memcpy_safe(&tmp.in_addr, p.address.iov_base, p.address.iov_len);	68✔
183	memcpy_safe(&tmp.in_addr_peer, p.peer.iov_base, p.peer.iov_len);	68✔
184
185	Address *address;	68✔
186	r = address_get(link, &tmp, &address);	68✔
187	if (r < 0) {	68✔
UNCOV 188	log_link_debug_errno(link, r, "Cannot find deserialized address %s: %m",	×
189	IN_ADDR_PREFIX_TO_STRING(tmp.family, &tmp.in_addr, tmp.prefixlen));
UNCOV 190	return 0; /* Already removed? */	×
191	}
192
193	if (address->source != NETWORK_CONFIG_SOURCE_FOREIGN)	68✔
194	return 0; /* Huh?? Already deserialized?? */
195
196	address->source = p.source;	68✔
197	memcpy_safe(&address->provider, p.provider.iov_base, p.provider.iov_len);	68✔
198
199	log_address_debug(address, "Deserialized", link);	68✔
200	return 0;
201	}
202
203	static int manager_deserialize_link(Manager manager, sd_json_variant v) {	37✔
204	typedef struct LinkParam {	37✔
205	int ifindex;
206	sd_json_variant *addresses;
207	} LinkParam;
208
209	static const sd_json_dispatch_field dispatch_table[] = {	37✔
210	{ "Index", _SD_JSON_VARIANT_TYPE_INVALID, json_dispatch_ifindex, offsetof(LinkParam, ifindex), SD_JSON_MANDATORY \| SD_JSON_REFUSE_NULL },
211	{ "Addresses", SD_JSON_VARIANT_ARRAY, sd_json_dispatch_variant_noref, offsetof(LinkParam, addresses), 0 },
212	{},
213	};
214
215	int r, ret = 0;	37✔
216
217	assert(manager);	37✔
218	assert(v);	37✔
219
220	LinkParam p = {};	37✔
221	r = sd_json_dispatch(v, dispatch_table, SD_JSON_ALLOW_EXTENSIONS, &p);	37✔
222	if (r < 0)	37✔
UNCOV 223	return log_debug_errno(r, "Failed to dispatch interface from json variant: %m");	×
224
225	Link *link;	37✔
226	r = link_get_by_index(manager, p.ifindex, &link);	37✔
227	if (r < 0) {	37✔
228	log_debug_errno(r, "No interface with deserialized ifindex (%i) found: %m", p.ifindex);	×
UNCOV 229	return 0; /* Already removed? */	×
230	}
231
232	sd_json_variant *i;	37✔
233	JSON_VARIANT_ARRAY_FOREACH(i, p.addresses)	105✔
234	RET_GATHER(ret, link_deserialize_address(link, i));	68✔
235
236	return ret;	37✔
237	}
238
239	typedef struct NextHopParam {
240	uint32_t id;
241	int family;
242	NetworkConfigSource source;
243	struct iovec provider;
244	} NextHopParam;
245
246	static void nexthop_param_done(NextHopParam *p) {	5✔
247	assert(p);	5✔
248
249	iovec_done(&p->provider);	5✔
250	}	5✔
251
252	static int manager_deserialize_nexthop(Manager manager, sd_json_variant v) {	5✔
253	static const sd_json_dispatch_field dispatch_table[] = {	5✔
254	{ "ID", _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint32, offsetof(NextHopParam, id), SD_JSON_MANDATORY },
255	{ "Family", _SD_JSON_VARIANT_TYPE_INVALID, json_dispatch_address_family, offsetof(NextHopParam, family), SD_JSON_MANDATORY },
256	{ "ConfigSource", SD_JSON_VARIANT_STRING, json_dispatch_network_config_source, offsetof(NextHopParam, source), SD_JSON_MANDATORY },
257	{ "ConfigProvider", SD_JSON_VARIANT_ARRAY, json_dispatch_byte_array_iovec, offsetof(NextHopParam, provider), 0 },
258	{},
259	};
260
261	int r;	5✔
262
263	assert(manager);	5✔
264	assert(v);	5✔
265
266	_cleanup_(nexthop_param_done) NextHopParam p = {};	5✔
267	r = sd_json_dispatch(v, dispatch_table, SD_JSON_ALLOW_EXTENSIONS, &p);	5✔
268	if (r < 0)	5✔
UNCOV 269	return log_debug_errno(r, "Failed to dispatch nexthop from json variant: %m");	×
270
271	if (p.id == 0)	5✔
UNCOV 272	return log_debug_errno(SYNTHETIC_ERRNO(EINVAL), "Dispatched nexthop ID is zero.");	×
273
274	if (p.provider.iov_len != 0 && p.provider.iov_len != FAMILY_ADDRESS_SIZE(p.family))	5✔
UNCOV 275	return log_debug_errno(SYNTHETIC_ERRNO(EINVAL),	×
276	"Dispatched provider address size (%zu) is incompatible with the family (%s).",
277	p.provider.iov_len, af_to_ipv4_ipv6(p.family));
278
279	NextHop *nexthop;	5✔
280	r = nexthop_get_by_id(manager, p.id, &nexthop);	5✔
281	if (r < 0) {	5✔
282	log_debug_errno(r, "Cannot find deserialized nexthop (ID=%"PRIu32"): %m", p.id);	×
UNCOV 283	return 0; /* Already removed? */	×
284	}
285
286	if (nexthop->source != NETWORK_CONFIG_SOURCE_FOREIGN)	5✔
287	return 0; /* Huh?? Already deserialized?? */
288
289	nexthop->source = p.source;	5✔
290	memcpy_safe(&nexthop->provider, p.provider.iov_base, p.provider.iov_len);	5✔
291
292	log_nexthop_debug(nexthop, "Deserialized", manager);	5✔
293	return 0;
294	}
295
296	typedef struct RouteParam {
297	Route route;
298
299	struct iovec dst;
300	struct iovec src;
301	struct iovec prefsrc;
302	struct iovec gw;
303	struct iovec metrics;
304	struct iovec provider;
305	} RouteParam;
306
307	static void route_param_done(RouteParam *p) {	28✔
308	assert(p);	28✔
309
310	free(p->route.metric.metrics);	28✔
311
312	iovec_done(&p->dst);	28✔
313	iovec_done(&p->src);	28✔
314	iovec_done(&p->prefsrc);	28✔
315	iovec_done(&p->gw);	28✔
316	iovec_done(&p->metrics);	28✔
317	iovec_done(&p->provider);	28✔
318	}	28✔
319
320	static int manager_deserialize_route(Manager manager, sd_json_variant v) {	28✔
321	static const sd_json_dispatch_field dispatch_table[] = {	28✔
322	/* rtmsg header */
323	{ "Family", _SD_JSON_VARIANT_TYPE_INVALID, json_dispatch_address_family, offsetof(RouteParam, route.family), SD_JSON_MANDATORY },
324	{ "DestinationPrefixLength", _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint8, offsetof(RouteParam, route.dst_prefixlen), SD_JSON_MANDATORY },
325	{ "SourcePrefixLength", _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint8, offsetof(RouteParam, route.src_prefixlen), 0 },
326	{ "TOS", _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint8, offsetof(RouteParam, route.tos), SD_JSON_MANDATORY },
327	{ "Protocol", _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint8, offsetof(RouteParam, route.protocol), SD_JSON_MANDATORY },
328	{ "Scope", _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint8, offsetof(RouteParam, route.scope), SD_JSON_MANDATORY },
329	{ "Type", _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint8, offsetof(RouteParam, route.type), SD_JSON_MANDATORY },
330	{ "Flags", _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint32, offsetof(RouteParam, route.flags), SD_JSON_MANDATORY },
331	/* attributes */
332	{ "Destination", SD_JSON_VARIANT_ARRAY, json_dispatch_byte_array_iovec, offsetof(RouteParam, dst), SD_JSON_MANDATORY },
333	{ "Source", SD_JSON_VARIANT_ARRAY, json_dispatch_byte_array_iovec, offsetof(RouteParam, src), 0 },
334	{ "Priority", _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint32, offsetof(RouteParam, route.priority), SD_JSON_MANDATORY },
335	{ "PreferredSource", SD_JSON_VARIANT_ARRAY, json_dispatch_byte_array_iovec, offsetof(RouteParam, prefsrc), 0 },
336	{ "Table", _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint32, offsetof(RouteParam, route.table), SD_JSON_MANDATORY },
337	/* nexthops */
338	{ "Gateway", SD_JSON_VARIANT_ARRAY, json_dispatch_byte_array_iovec, offsetof(RouteParam, gw), 0 },
339	{ "InterfaceIndex", _SD_JSON_VARIANT_TYPE_INVALID, json_dispatch_ifindex, offsetof(RouteParam, route.nexthop.ifindex), SD_JSON_MANDATORY \| SD_JSON_RELAX },
340	{ "NextHopID", _SD_JSON_VARIANT_TYPE_INVALID, sd_json_dispatch_uint32, offsetof(RouteParam, route.nexthop_id), 0 },
341	/* metrics */
342	{ "Metrics", SD_JSON_VARIANT_ARRAY, json_dispatch_byte_array_iovec, offsetof(RouteParam, metrics), 0 },
343	{ "TCPCongestionControlAlgorithm", SD_JSON_VARIANT_STRING, sd_json_dispatch_const_string, offsetof(RouteParam, route.metric.tcp_congestion_control_algo), 0 },
344	/* config */
345	{ "ConfigSource", SD_JSON_VARIANT_STRING, json_dispatch_network_config_source, offsetof(RouteParam, route.source), SD_JSON_MANDATORY },
346	{ "ConfigProvider", SD_JSON_VARIANT_ARRAY, json_dispatch_byte_array_iovec, offsetof(RouteParam, provider), 0 },
347	{},
348	};
349
350	int r;	28✔
351
352	assert(manager);	28✔
353	assert(v);	28✔
354
355	_cleanup_(route_param_done) RouteParam p = {};	28✔
356	r = sd_json_dispatch(v, dispatch_table, SD_JSON_ALLOW_EXTENSIONS, &p);	28✔
357	if (r < 0)	28✔
UNCOV 358	return log_debug_errno(r, "Failed to dispatch route from json variant: %m");	×
359
360	if (p.dst.iov_len != FAMILY_ADDRESS_SIZE(p.route.family))	28✔
UNCOV 361	return log_debug_errno(SYNTHETIC_ERRNO(EINVAL),	×
362	"Dispatched destination address size (%zu) is incompatible with the family (%s).",
363	p.dst.iov_len, af_to_ipv4_ipv6(p.route.family));
364
365	if (p.src.iov_len != 0 && p.src.iov_len != FAMILY_ADDRESS_SIZE(p.route.family))	28✔
UNCOV 366	return log_debug_errno(SYNTHETIC_ERRNO(EINVAL),	×
367	"Dispatched source address size (%zu) is incompatible with the family (%s).",
368	p.src.iov_len, af_to_ipv4_ipv6(p.route.family));
369
370	if (p.prefsrc.iov_len != 0 && p.prefsrc.iov_len != FAMILY_ADDRESS_SIZE(p.route.family))	28✔
UNCOV 371	return log_debug_errno(SYNTHETIC_ERRNO(EINVAL),	×
372	"Dispatched preferred source address size (%zu) is incompatible with the family (%s).",
373	p.prefsrc.iov_len, af_to_ipv4_ipv6(p.route.family));
374
375	switch (p.gw.iov_len) {	28✔
376	case 0:	20✔
377	p.route.nexthop.family = AF_UNSPEC;	20✔
378	break;	20✔
379	case sizeof(struct in_addr):	7✔
380	p.route.nexthop.family = AF_INET;	7✔
381	break;	7✔
382	case sizeof(struct in6_addr):	1✔
383	p.route.nexthop.family = AF_INET6;	1✔
384	break;	1✔
385	default:
UNCOV 386	return log_debug_errno(SYNTHETIC_ERRNO(EINVAL),	×
387	"Dispatched gateway address size (%zu) is invalid.",
388	p.prefsrc.iov_len);
389	}
390
391	if (p.metrics.iov_len % sizeof(uint32_t) != 0)	28✔
UNCOV 392	return log_debug_errno(SYNTHETIC_ERRNO(EINVAL),	×
393	"Dispatched route metric size (%zu) is invalid.",
394	p.metrics.iov_len);
395
396	if (p.provider.iov_len != 0 && p.provider.iov_len != FAMILY_ADDRESS_SIZE(p.route.family))	28✔
UNCOV 397	return log_debug_errno(SYNTHETIC_ERRNO(EINVAL),	×
398	"Dispatched provider address size (%zu) is incompatible with the family (%s).",
399	p.provider.iov_len, af_to_ipv4_ipv6(p.route.family));
400
401	memcpy_safe(&p.route.dst, p.dst.iov_base, p.dst.iov_len);	28✔
402	memcpy_safe(&p.route.src, p.src.iov_base, p.src.iov_len);	28✔
403	memcpy_safe(&p.route.prefsrc, p.prefsrc.iov_base, p.prefsrc.iov_len);	28✔
404	memcpy_safe(&p.route.nexthop.gw, p.gw.iov_base, p.gw.iov_len);	28✔
405
406	p.route.metric.n_metrics = p.metrics.iov_len / sizeof(uint32_t);	28✔
407	p.route.metric.metrics = new(uint32_t, p.route.metric.n_metrics);	28✔
408	if (!p.route.metric.metrics)	28✔
UNCOV 409	return log_oom_debug();	×
410
411	memcpy_safe(p.route.metric.metrics, p.metrics.iov_base, p.metrics.iov_len);	28✔
412
413	Route *route;	28✔
414	r = route_get(manager, &p.route, &route);	28✔
415	if (r < 0) {	28✔
UNCOV 416	log_route_debug(&p.route, "Cannot find deserialized", manager);	×
417	return 0; /* Already removed? */
418	}
419
420	if (route->source != NETWORK_CONFIG_SOURCE_FOREIGN)	28✔
421	return 0; /* Huh?? Already deserialized?? */
422
423	route->source = p.route.source;	28✔
424	memcpy_safe(&route->provider, p.provider.iov_base, p.provider.iov_len);	28✔
425
426	log_route_debug(route, "Deserialized", manager);	28✔
427	return 0;
428	}
429
430	int manager_deserialize(Manager *manager) {	417✔
431	int r, ret = 0;	417✔
432
433	assert(manager);	417✔
434
435	_cleanup_close_ int fd = TAKE_FD(manager->serialization_fd);	417✔
436	if (fd < 0)	417✔
437	return 0;
438
439	log_debug("Deserializing...");	26✔
440
441	_cleanup_fclose_ FILE *f = take_fdopen(&fd, "r");	443✔
442	if (!f)	26✔
UNCOV 443	return log_debug_errno(errno, "Failed to fdopen() serialization file descriptor: %m");	×
444
445	_cleanup_(sd_json_variant_unrefp) sd_json_variant *v = NULL;	26✔
446	unsigned err_line = 0, err_column = 0;	26✔
447	r = sd_json_parse_file(	26✔
448	f,
449	/* path = */ NULL,
450	/* flags = */ 0,
451	&v,
452	&err_line,
453	&err_column);
454	if (r < 0)	26✔
455	return log_debug_errno(r, "Failed to parse json (line=%u, column=%u): %m", err_line, err_column);	1✔
456
457	sd_json_variant *i;	25✔
458	JSON_VARIANT_ARRAY_FOREACH(i, sd_json_variant_by_key(v, "Interfaces"))	62✔
459	RET_GATHER(ret, manager_deserialize_link(manager, i));	37✔
460
461	JSON_VARIANT_ARRAY_FOREACH(i, sd_json_variant_by_key(v, "NextHops"))	30✔
462	RET_GATHER(ret, manager_deserialize_nexthop(manager, i));	5✔
463
464	JSON_VARIANT_ARRAY_FOREACH(i, sd_json_variant_by_key(v, "Routes"))	53✔
465	RET_GATHER(ret, manager_deserialize_route(manager, i));	28✔
466
467	log_debug("Deserialization completed.");	25✔
468	return ret;
469	}

systemd / systemd / 14895667988

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous