1 /*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
4 This file is part of systemd.
6 Copyright 2011 Lennart Poettering
8 systemd is free software; you can redistribute it and/or modify it
9 under the terms of the GNU Lesser General Public License as published by
10 the Free Software Foundation; either version 2.1 of the License, or
11 (at your option) any later version.
13 systemd is distributed in the hope that it will be useful, but
14 WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16 Lesser General Public License for more details.
18 You should have received a copy of the GNU Lesser General Public License
19 along with systemd; If not, see <http://www.gnu.org/licenses/>.
26 #include "sd-messages.h"
33 #include "unit-name.h"
35 #include "bus-error.h"
37 #include "machine-dbus.h"
39 Machine* machine_new(Manager *manager, const char *name) {
49 m->name = strdup(name);
53 m->state_file = strappend("/run/systemd/machines/", m->name);
57 if (hashmap_put(manager->machines, m->name, m) < 0)
60 m->class = _MACHINE_CLASS_INVALID;
73 void machine_free(Machine *m) {
77 machine_operation_unref(m->operations);
80 LIST_REMOVE(gc_queue, m->manager->machine_gc_queue, m);
83 hashmap_remove(m->manager->machine_units, m->unit);
89 hashmap_remove(m->manager->machines, m->name);
92 hashmap_remove_value(m->manager->machine_leaders, UINT_TO_PTR(m->leader), m);
94 sd_bus_message_unref(m->create_message);
99 free(m->root_directory);
104 int machine_save(Machine *m) {
105 _cleanup_free_ char *temp_path = NULL;
106 _cleanup_fclose_ FILE *f = NULL;
110 assert(m->state_file);
115 r = mkdir_safe_label("/run/systemd/machines", 0755, 0, 0);
119 r = fopen_temporary(m->state_file, &f, &temp_path);
123 fchmod(fileno(f), 0644);
126 "# This is private data. Do not parse.\n"
131 _cleanup_free_ char *escaped;
133 escaped = cescape(m->unit);
139 fprintf(f, "SCOPE=%s\n", escaped); /* We continue to call this "SCOPE=" because it is internal only, and we want to stay compatible with old files */
143 fprintf(f, "SCOPE_JOB=%s\n", m->scope_job);
146 _cleanup_free_ char *escaped;
148 escaped = cescape(m->service);
153 fprintf(f, "SERVICE=%s\n", escaped);
156 if (m->root_directory) {
157 _cleanup_free_ char *escaped;
159 escaped = cescape(m->root_directory);
164 fprintf(f, "ROOT=%s\n", escaped);
167 if (!sd_id128_equal(m->id, SD_ID128_NULL))
168 fprintf(f, "ID=" SD_ID128_FORMAT_STR "\n", SD_ID128_FORMAT_VAL(m->id));
171 fprintf(f, "LEADER="PID_FMT"\n", m->leader);
173 if (m->class != _MACHINE_CLASS_INVALID)
174 fprintf(f, "CLASS=%s\n", machine_class_to_string(m->class));
176 if (dual_timestamp_is_set(&m->timestamp))
178 "REALTIME="USEC_FMT"\n"
179 "MONOTONIC="USEC_FMT"\n",
180 m->timestamp.realtime,
181 m->timestamp.monotonic);
183 if (m->n_netif > 0) {
188 for (i = 0; i < m->n_netif; i++) {
192 fprintf(f, "%i", m->netif[i]);
198 r = fflush_and_check(f);
202 if (rename(temp_path, m->state_file) < 0) {
213 /* Create a symlink from the unit name to the machine
214 * name, so that we can quickly find the machine for
215 * each given unit. Ignore error. */
216 sl = strjoina("/run/systemd/machines/unit:", m->unit);
217 (void) symlink(m->name, sl);
225 log_error_errno(r, "Failed to save machine data %s: %m", m->state_file);
230 static void machine_unlink(Machine *m) {
237 sl = strjoina("/run/systemd/machines/unit:", m->unit);
242 unlink(m->state_file);
245 int machine_load(Machine *m) {
246 _cleanup_free_ char *realtime = NULL, *monotonic = NULL, *id = NULL, *leader = NULL, *class = NULL, *netif = NULL;
251 r = parse_env_file(m->state_file, NEWLINE,
253 "SCOPE_JOB", &m->scope_job,
254 "SERVICE", &m->service,
255 "ROOT", &m->root_directory,
259 "REALTIME", &realtime,
260 "MONOTONIC", &monotonic,
267 return log_error_errno(r, "Failed to read %s: %m", m->state_file);
271 sd_id128_from_string(id, &m->id);
274 parse_pid(leader, &m->leader);
279 c = machine_class_from_string(class);
285 unsigned long long l;
286 if (sscanf(realtime, "%llu", &l) > 0)
287 m->timestamp.realtime = l;
291 unsigned long long l;
292 if (sscanf(monotonic, "%llu", &l) > 0)
293 m->timestamp.monotonic = l;
297 size_t l, allocated = 0, nr = 0;
298 const char *word, *state;
301 FOREACH_WORD(word, l, netif, state) {
305 *(char*) (mempcpy(buf, word, l)) = 0;
307 if (safe_atoi(buf, &ifi) < 0)
312 if (!GREEDY_REALLOC(ni, allocated, nr+1)) {
328 static int machine_start_scope(Machine *m, sd_bus_message *properties, sd_bus_error *error) {
334 _cleanup_free_ char *escaped = NULL;
335 char *scope, *description, *job = NULL;
337 escaped = unit_name_escape(m->name);
341 scope = strjoin("machine-", escaped, ".scope", NULL);
345 description = strjoina(m->class == MACHINE_VM ? "Virtual Machine " : "Container ", m->name);
347 r = manager_start_scope(m->manager, scope, m->leader, SPECIAL_MACHINE_SLICE, description, properties, error, &job);
349 log_error("Failed to start machine scope: %s", bus_error_message(error, r));
361 hashmap_put(m->manager->machine_units, m->unit, m);
366 int machine_start(Machine *m, sd_bus_message *properties, sd_bus_error *error) {
374 r = hashmap_put(m->manager->machine_leaders, UINT_TO_PTR(m->leader), m);
379 r = machine_start_scope(m, properties, error);
384 LOG_MESSAGE_ID(SD_MESSAGE_MACHINE_START),
386 "LEADER="PID_FMT, m->leader,
387 LOG_MESSAGE("New machine %s.", m->name),
390 if (!dual_timestamp_is_set(&m->timestamp))
391 dual_timestamp_get(&m->timestamp);
395 /* Save new machine data */
398 machine_send_signal(m, true);
403 static int machine_stop_scope(Machine *m) {
404 _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL;
413 r = manager_stop_unit(m->manager, m->unit, &error, &job);
415 log_error("Failed to stop machine scope: %s", bus_error_message(&error, r));
425 int machine_stop(Machine *m) {
431 LOG_MESSAGE_ID(SD_MESSAGE_MACHINE_STOP),
433 "LEADER="PID_FMT, m->leader,
434 LOG_MESSAGE("Machine %s terminated.", m->name),
438 k = machine_stop_scope(m);
443 machine_add_to_gc_queue(m);
446 machine_send_signal(m, false);
453 bool machine_check_gc(Machine *m, bool drop_not_started) {
456 if (drop_not_started && !m->started)
459 if (m->scope_job && manager_job_is_active(m->manager, m->scope_job))
462 if (m->unit && manager_unit_is_active(m->manager, m->unit))
468 void machine_add_to_gc_queue(Machine *m) {
474 LIST_PREPEND(gc_queue, m->manager->machine_gc_queue, m);
475 m->in_gc_queue = true;
478 MachineState machine_get_state(Machine *s) {
482 return s->started ? MACHINE_OPENING : MACHINE_CLOSING;
484 return MACHINE_RUNNING;
487 int machine_kill(Machine *m, KillWho who, int signo) {
493 if (who == KILL_LEADER) {
494 /* If we shall simply kill the leader, do so directly */
496 if (kill(m->leader, signo) < 0)
502 /* Otherwise make PID 1 do it for us, for the entire cgroup */
503 return manager_kill_unit(m->manager, m->unit, signo, NULL);
506 MachineOperation *machine_operation_unref(MachineOperation *o) {
510 sd_event_source_unref(o->event_source);
512 safe_close(o->errno_fd);
515 (void) kill(o->pid, SIGKILL);
517 sd_bus_message_unref(o->message);
520 LIST_REMOVE(operations, o->machine->operations, o);
521 o->machine->n_operations--;
528 static const char* const machine_class_table[_MACHINE_CLASS_MAX] = {
529 [MACHINE_CONTAINER] = "container",
533 DEFINE_STRING_TABLE_LOOKUP(machine_class, MachineClass);
535 static const char* const machine_state_table[_MACHINE_STATE_MAX] = {
536 [MACHINE_OPENING] = "opening",
537 [MACHINE_RUNNING] = "running",
538 [MACHINE_CLOSING] = "closing"
541 DEFINE_STRING_TABLE_LOOKUP(machine_state, MachineState);
543 static const char* const kill_who_table[_KILL_WHO_MAX] = {
544 [KILL_LEADER] = "leader",
548 DEFINE_STRING_TABLE_LOOKUP(kill_who, KillWho);