/* SPDX-License-Identifier: LGPL-2.1-or-later */ #include #include "bus-polkit.h" #include "fd-util.h" #include "lldp-rx-internal.h" #include "networkd-dhcp-server.h" #include "networkd-manager-varlink.h" #include "stat-util.h" #include "varlink.h" #include "varlink-io.systemd.Network.h" static int vl_method_get_states(Varlink *link, JsonVariant *parameters, VarlinkMethodFlags flags, void *userdata) { Manager *m = ASSERT_PTR(userdata); assert(link); if (json_variant_elements(parameters) > 0) return varlink_error_invalid_parameter(link, parameters); return varlink_replyb(link, JSON_BUILD_OBJECT( JSON_BUILD_PAIR_STRING("AddressState", link_address_state_to_string(m->address_state)), JSON_BUILD_PAIR_STRING("IPv4AddressState", link_address_state_to_string(m->ipv4_address_state)), JSON_BUILD_PAIR_STRING("IPv6AddressState", link_address_state_to_string(m->ipv6_address_state)), JSON_BUILD_PAIR_STRING("CarrierState", link_carrier_state_to_string(m->carrier_state)), JSON_BUILD_PAIR_CONDITION(m->online_state >= 0, "OnlineState", JSON_BUILD_STRING(link_online_state_to_string(m->online_state))), JSON_BUILD_PAIR_STRING("OperationalState", link_operstate_to_string(m->operational_state)))); } static int vl_method_get_namespace_id(Varlink *link, JsonVariant *parameters, VarlinkMethodFlags flags, void *userdata) { uint64_t inode = 0; uint32_t nsid = UINT32_MAX; int r; assert(link); if (json_variant_elements(parameters) > 0) return varlink_error_invalid_parameter(link, parameters); /* Network namespaces have two identifiers: the inode number (which all namespace types have), and * the "nsid" (aka the "cookie"), which only network namespaces know as a concept, and which is not * assigned by default, but once it is, is fixed. Let's return both, to avoid any confusion which one * this is. */ struct stat st; if (stat("/proc/self/ns/net", &st) < 0) log_warning_errno(errno, "Failed to stat network namespace, ignoring: %m"); else inode = st.st_ino; r = netns_get_nsid(/* netnsfd= */ -EBADF, &nsid); if (r < 0) log_full_errno(r == -ENODATA ? LOG_DEBUG : LOG_WARNING, r, "Failed to query network nsid, ignoring: %m"); return varlink_replyb(link, JSON_BUILD_OBJECT( JSON_BUILD_PAIR_UNSIGNED("NamespaceId", inode), JSON_BUILD_PAIR_CONDITION(nsid == UINT32_MAX, "NamespaceNSID", JSON_BUILD_NULL), JSON_BUILD_PAIR_CONDITION(nsid != UINT32_MAX, "NamespaceNSID", JSON_BUILD_UNSIGNED(nsid)))); } typedef struct InterfaceInfo { int ifindex; const char *ifname; } InterfaceInfo; static int dispatch_interface(Varlink *vlink, JsonVariant *parameters, Manager *manager, Link **ret) { static const JsonDispatch dispatch_table[] = { { "InterfaceIndex", _JSON_VARIANT_TYPE_INVALID, json_dispatch_int, offsetof(InterfaceInfo, ifindex), 0 }, { "InterfaceName", JSON_VARIANT_STRING, json_dispatch_const_string, offsetof(InterfaceInfo, ifname), 0 }, {} }; InterfaceInfo info = {}; Link *link = NULL; int r; assert(vlink); assert(manager); r = varlink_dispatch(vlink, parameters, dispatch_table, &info); if (r != 0) return r; if (info.ifindex < 0) return varlink_error_invalid_parameter(vlink, JSON_VARIANT_STRING_CONST("InterfaceIndex")); if (info.ifindex > 0 && link_get_by_index(manager, info.ifindex, &link) < 0) return varlink_error_invalid_parameter(vlink, JSON_VARIANT_STRING_CONST("InterfaceIndex")); if (info.ifname) { Link *link_by_name; if (link_get_by_name(manager, info.ifname, &link_by_name) < 0) return varlink_error_invalid_parameter(vlink, JSON_VARIANT_STRING_CONST("InterfaceName")); if (link && link_by_name != link) /* If both arguments are specified, then these must be consistent. */ return varlink_error_invalid_parameter(vlink, JSON_VARIANT_STRING_CONST("InterfaceName")); link = link_by_name; } /* If neither InterfaceIndex nor InterfaceName specified, this function returns NULL. */ *ret = link; return 0; } static int link_append_lldp_neighbors(Link *link, JsonVariant *v, JsonVariant **array) { assert(link); assert(array); return json_variant_append_arrayb(array, JSON_BUILD_OBJECT( JSON_BUILD_PAIR_INTEGER("InterfaceIndex", link->ifindex), JSON_BUILD_PAIR_STRING("InterfaceName", link->ifname), JSON_BUILD_PAIR_STRV_NON_EMPTY("InterfaceAlternativeNames", link->alternative_names), JSON_BUILD_PAIR_CONDITION(json_variant_is_blank_array(v), "Neighbors", JSON_BUILD_EMPTY_ARRAY), JSON_BUILD_PAIR_CONDITION(!json_variant_is_blank_array(v), "Neighbors", JSON_BUILD_VARIANT(v)))); } static int vl_method_get_lldp_neighbors(Varlink *vlink, JsonVariant *parameters, VarlinkMethodFlags flags, Manager *manager) { _cleanup_(json_variant_unrefp) JsonVariant *array = NULL; Link *link = NULL; int r; assert(vlink); assert(manager); r = dispatch_interface(vlink, parameters, manager, &link); if (r != 0) return r; if (link) { _cleanup_(json_variant_unrefp) JsonVariant *v = NULL; if (link->lldp_rx) { r = lldp_rx_build_neighbors_json(link->lldp_rx, &v); if (r < 0) return r; } r = link_append_lldp_neighbors(link, v, &array); if (r < 0) return r; } else HASHMAP_FOREACH(link, manager->links_by_index) { _cleanup_(json_variant_unrefp) JsonVariant *v = NULL; if (!link->lldp_rx) continue; r = lldp_rx_build_neighbors_json(link->lldp_rx, &v); if (r < 0) return r; if (json_variant_is_blank_array(v)) continue; r = link_append_lldp_neighbors(link, v, &array); if (r < 0) return r; } return varlink_replyb(vlink, JSON_BUILD_OBJECT( JSON_BUILD_PAIR_CONDITION(json_variant_is_blank_array(array), "Neighbors", JSON_BUILD_EMPTY_ARRAY), JSON_BUILD_PAIR_CONDITION(!json_variant_is_blank_array(array), "Neighbors", JSON_BUILD_VARIANT(array)))); } static int vl_method_set_persistent_storage(Varlink *vlink, JsonVariant *parameters, VarlinkMethodFlags flags, void *userdata) { static const JsonDispatch dispatch_table[] = { { "Ready", JSON_VARIANT_BOOLEAN, json_dispatch_boolean, 0, 0 }, {} }; Manager *manager = ASSERT_PTR(userdata); bool ready; int r; assert(vlink); r = varlink_dispatch(vlink, parameters, dispatch_table, &ready); if (r != 0) return r; if (ready) { struct stat st, st_prev; int fd; fd = varlink_peek_fd(vlink, 0); if (fd < 0) return log_warning_errno(fd, "Failed to peek file descriptor of the persistent storage: %m"); r = fd_verify_safe_flags_full(fd, O_DIRECTORY); if (r == -EREMOTEIO) return log_warning_errno(r, "Passed persistent storage fd has unexpected flags, refusing."); if (r < 0) return log_warning_errno(r, "Failed to verify flags of passed persistent storage fd: %m"); r = fd_is_read_only_fs(fd); if (r < 0) return log_warning_errno(r, "Failed to check if the persistent storage is writable: %m"); if (r > 0) { log_warning("The persistent storage is on read-only filesystem."); return varlink_error(vlink, "io.systemd.Network.StorageReadOnly", NULL); } if (fstat(fd, &st) < 0) return log_warning_errno(errno, "Failed to stat the passed persistent storage fd: %m"); r = stat_verify_directory(&st); if (r < 0) return log_warning_errno(r, "The passed persistent storage fd is not a directory, refusing: %m"); if (manager->persistent_storage_fd >= 0 && fstat(manager->persistent_storage_fd, &st_prev) >= 0 && stat_inode_same(&st, &st_prev)) return varlink_reply(vlink, NULL); } else { if (manager->persistent_storage_fd < 0) return varlink_reply(vlink, NULL); } r = varlink_verify_polkit_async( vlink, manager->bus, "org.freedesktop.network1.set-persistent-storage", /* details= */ NULL, &manager->polkit_registry); if (r <= 0) return r; if (ready) { _cleanup_close_ int fd = -EBADF; fd = varlink_take_fd(vlink, 0); if (fd < 0) return log_warning_errno(fd, "Failed to take file descriptor of the persistent storage: %m"); close_and_replace(manager->persistent_storage_fd, fd); } else manager->persistent_storage_fd = safe_close(manager->persistent_storage_fd); manager_toggle_dhcp4_server_state(manager, ready); return varlink_reply(vlink, NULL); } static int on_connect(VarlinkServer *s, Varlink *vlink, void *userdata) { int r; assert(vlink); r = varlink_set_allow_fd_passing_input(vlink, true); if (r < 0) return log_warning_errno(r, "Failed to allow receiving file descriptor through varlink: %m"); return 0; } int manager_connect_varlink(Manager *m) { _cleanup_(varlink_server_unrefp) VarlinkServer *s = NULL; int r; assert(m); if (m->varlink_server) return 0; r = varlink_server_new(&s, VARLINK_SERVER_ACCOUNT_UID|VARLINK_SERVER_INHERIT_USERDATA); if (r < 0) return log_error_errno(r, "Failed to allocate varlink server object: %m"); varlink_server_set_userdata(s, m); (void) varlink_server_set_description(s, "varlink-api-network"); r = varlink_server_add_interface(s, &vl_interface_io_systemd_Network); if (r < 0) return log_error_errno(r, "Failed to add Network interface to varlink server: %m"); r = varlink_server_bind_method_many( s, "io.systemd.Network.GetStates", vl_method_get_states, "io.systemd.Network.GetNamespaceId", vl_method_get_namespace_id, "io.systemd.Network.GetLLDPNeighbors", vl_method_get_lldp_neighbors, "io.systemd.Network.SetPersistentStorage", vl_method_set_persistent_storage); if (r < 0) return log_error_errno(r, "Failed to register varlink methods: %m"); r = varlink_server_listen_address(s, "/run/systemd/netif/io.systemd.Network", 0666); if (r < 0) return log_error_errno(r, "Failed to bind to varlink socket: %m"); r = varlink_server_attach_event(s, m->event, SD_EVENT_PRIORITY_NORMAL); if (r < 0) return log_error_errno(r, "Failed to attach varlink connection to event loop: %m"); r = varlink_server_bind_connect(s, on_connect); if (r < 0) return log_error_errno(r, "Failed to set on-connect callback for varlink: %m"); m->varlink_server = TAKE_PTR(s); return 0; } void manager_varlink_done(Manager *m) { assert(m); m->varlink_server = varlink_server_unref(m->varlink_server); (void) unlink("/run/systemd/netif/io.systemd.Network"); }