]> git.ipfire.org Git - thirdparty/systemd.git/blob - src/nspawn/nspawn-register.c
bus-util: unify loop around bus_append_unit_property_assignment()
[thirdparty/systemd.git] / src / nspawn / nspawn-register.c
1 /***
2 This file is part of systemd.
3
4 Copyright 2015 Lennart Poettering
5
6 systemd is free software; you can redistribute it and/or modify it
7 under the terms of the GNU Lesser General Public License as published by
8 the Free Software Foundation; either version 2.1 of the License, or
9 (at your option) any later version.
10
11 systemd is distributed in the hope that it will be useful, but
12 WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 Lesser General Public License for more details.
15
16 You should have received a copy of the GNU Lesser General Public License
17 along with systemd; If not, see <http://www.gnu.org/licenses/>.
18 ***/
19
20 #include "sd-bus.h"
21
22 #include "bus-error.h"
23 #include "bus-unit-util.h"
24 #include "bus-util.h"
25 #include "nspawn-register.h"
26 #include "stat-util.h"
27 #include "strv.h"
28 #include "util.h"
29
30 int register_machine(
31 const char *machine_name,
32 pid_t pid,
33 const char *directory,
34 sd_id128_t uuid,
35 int local_ifindex,
36 const char *slice,
37 CustomMount *mounts,
38 unsigned n_mounts,
39 int kill_signal,
40 char **properties,
41 bool keep_unit,
42 const char *service) {
43
44 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
45 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
46 int r;
47
48 r = sd_bus_default_system(&bus);
49 if (r < 0)
50 return log_error_errno(r, "Failed to open system bus: %m");
51
52 if (keep_unit) {
53 r = sd_bus_call_method(
54 bus,
55 "org.freedesktop.machine1",
56 "/org/freedesktop/machine1",
57 "org.freedesktop.machine1.Manager",
58 "RegisterMachineWithNetwork",
59 &error,
60 NULL,
61 "sayssusai",
62 machine_name,
63 SD_BUS_MESSAGE_APPEND_ID128(uuid),
64 service,
65 "container",
66 (uint32_t) pid,
67 strempty(directory),
68 local_ifindex > 0 ? 1 : 0, local_ifindex);
69 } else {
70 _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
71 unsigned j;
72
73 r = sd_bus_message_new_method_call(
74 bus,
75 &m,
76 "org.freedesktop.machine1",
77 "/org/freedesktop/machine1",
78 "org.freedesktop.machine1.Manager",
79 "CreateMachineWithNetwork");
80 if (r < 0)
81 return bus_log_create_error(r);
82
83 r = sd_bus_message_append(
84 m,
85 "sayssusai",
86 machine_name,
87 SD_BUS_MESSAGE_APPEND_ID128(uuid),
88 service,
89 "container",
90 (uint32_t) pid,
91 strempty(directory),
92 local_ifindex > 0 ? 1 : 0, local_ifindex);
93 if (r < 0)
94 return bus_log_create_error(r);
95
96 r = sd_bus_message_open_container(m, 'a', "(sv)");
97 if (r < 0)
98 return bus_log_create_error(r);
99
100 if (!isempty(slice)) {
101 r = sd_bus_message_append(m, "(sv)", "Slice", "s", slice);
102 if (r < 0)
103 return bus_log_create_error(r);
104 }
105
106 r = sd_bus_message_append(m, "(sv)", "DevicePolicy", "s", "closed");
107 if (r < 0)
108 return bus_log_create_error(r);
109
110 /* If you make changes here, also make sure to update
111 * systemd-nspawn@.service, to keep the device
112 * policies in sync regardless if we are run with or
113 * without the --keep-unit switch. */
114 r = sd_bus_message_append(m, "(sv)", "DeviceAllow", "a(ss)", 2,
115 /* Allow the container to
116 * access and create the API
117 * device nodes, so that
118 * PrivateDevices= in the
119 * container can work
120 * fine */
121 "/dev/net/tun", "rwm",
122 /* Allow the container
123 * access to ptys. However,
124 * do not permit the
125 * container to ever create
126 * these device nodes. */
127 "char-pts", "rw");
128 if (r < 0)
129 return bus_log_create_error(r);
130
131 for (j = 0; j < n_mounts; j++) {
132 CustomMount *cm = mounts + j;
133
134 if (cm->type != CUSTOM_MOUNT_BIND)
135 continue;
136
137 r = is_device_node(cm->source);
138 if (r < 0)
139 return log_error_errno(r, "Failed to stat %s: %m", cm->source);
140
141 if (r) {
142 r = sd_bus_message_append(m, "(sv)", "DeviceAllow", "a(ss)", 1,
143 cm->source, cm->read_only ? "r" : "rw");
144 if (r < 0)
145 return log_error_errno(r, "Failed to append message arguments: %m");
146 }
147 }
148
149 if (kill_signal != 0) {
150 r = sd_bus_message_append(m, "(sv)", "KillSignal", "i", kill_signal);
151 if (r < 0)
152 return bus_log_create_error(r);
153
154 r = sd_bus_message_append(m, "(sv)", "KillMode", "s", "mixed");
155 if (r < 0)
156 return bus_log_create_error(r);
157 }
158
159 r = bus_append_unit_property_assignment_many(m, properties);
160 if (r < 0)
161 return r;
162
163 r = sd_bus_message_close_container(m);
164 if (r < 0)
165 return bus_log_create_error(r);
166
167 r = sd_bus_call(bus, m, 0, &error, NULL);
168 }
169
170 if (r < 0) {
171 log_error("Failed to register machine: %s", bus_error_message(&error, r));
172 return r;
173 }
174
175 return 0;
176 }
177
178 int terminate_machine(pid_t pid) {
179 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
180 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
181 _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
182 const char *path;
183 int r;
184
185 r = sd_bus_default_system(&bus);
186 if (r < 0)
187 return log_error_errno(r, "Failed to open system bus: %m");
188
189 r = sd_bus_call_method(
190 bus,
191 "org.freedesktop.machine1",
192 "/org/freedesktop/machine1",
193 "org.freedesktop.machine1.Manager",
194 "GetMachineByPID",
195 &error,
196 &reply,
197 "u",
198 (uint32_t) pid);
199 if (r < 0) {
200 /* Note that the machine might already have been
201 * cleaned up automatically, hence don't consider it a
202 * failure if we cannot get the machine object. */
203 log_debug("Failed to get machine: %s", bus_error_message(&error, r));
204 return 0;
205 }
206
207 r = sd_bus_message_read(reply, "o", &path);
208 if (r < 0)
209 return bus_log_parse_error(r);
210
211 r = sd_bus_call_method(
212 bus,
213 "org.freedesktop.machine1",
214 path,
215 "org.freedesktop.machine1.Machine",
216 "Terminate",
217 &error,
218 NULL,
219 NULL);
220 if (r < 0) {
221 log_debug("Failed to terminate machine: %s", bus_error_message(&error, r));
222 return 0;
223 }
224
225 return 0;
226 }