Lennart Poettering
c5c74d85d3
Let's get networkd onto Varlink. This only adds the most basic of operations. I'd love to see networkd do Varlink for all its basic operations so that networkctl can use that, and work correctly before D-Bus is up. Right now, many of networkctls calls simply don't work before D-Bus, and I'd like to see that improved.
91 lines
3.7 KiB
C
91 lines
3.7 KiB
C
/* SPDX-License-Identifier: LGPL-2.1-or-later */
|
|
|
|
#include <unistd.h>
|
|
|
|
#include "networkd-manager-varlink.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 id;
|
|
|
|
assert(link);
|
|
|
|
if (json_variant_elements(parameters) > 0)
|
|
return varlink_error_invalid_parameter(link, parameters);
|
|
|
|
struct stat st;
|
|
if (stat("/proc/self/ns/net", &st) < 0) {
|
|
log_warning_errno(errno, "Failed to stat network namespace, ignoring: %m");
|
|
id = 0;
|
|
} else
|
|
id = st.st_ino;
|
|
|
|
return varlink_replyb(link,
|
|
JSON_BUILD_OBJECT(
|
|
JSON_BUILD_PAIR_UNSIGNED("NamespaceId", id)));
|
|
}
|
|
|
|
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);
|
|
|
|
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);
|
|
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");
|
|
|
|
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");
|
|
}
|