src/core/dbus-scope.c

   1 /*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
   2
   3 /***
   4   This file is part of systemd.
   5
   6   Copyright 2013 Lennart Poettering
   7
   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.
  12
  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.
  17
  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/>.
  20 ***/
  21
  22 #include "unit.h"
  23 #include "scope.h"
  24 #include "dbus-unit.h"
  25 #include "dbus-cgroup.h"
  26 #include "dbus-kill.h"
  27 #include "dbus-scope.h"
  28 #include "bus-util.h"
  29
  30 static BUS_DEFINE_PROPERTY_GET_ENUM(property_get_result, scope_result, ScopeResult);
  31
  32 const sd_bus_vtable bus_scope_vtable[] = {
  33         SD_BUS_VTABLE_START(0),
  34         SD_BUS_PROPERTY("TimeoutStopUSec", "t", bus_property_get_usec, offsetof(Scope, timeout_stop_usec), SD_BUS_VTABLE_PROPERTY_CONST),
  35         SD_BUS_PROPERTY("Result", "s", property_get_result, offsetof(Scope, result), SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
  36         SD_BUS_VTABLE_END
  37 };
  38
  39 static int bus_scope_set_transient_property(
  40                 Scope *s,
  41                 const char *name,
  42                 sd_bus_message *message,
  43                 UnitSetPropertiesMode mode,
  44                 sd_bus_error *error) {
  45
  46         int r;
  47
  48         assert(s);
  49         assert(name);
  50         assert(message);
  51
  52         if (streq(name, "PIDs")) {
  53                 unsigned n = 0;
  54                 uint32_t pid;
  55
  56                 r = set_ensure_allocated(&s->pids, trivial_hash_func, trivial_compare_func);
  57                 if (r < 0)
  58                         return r;
  59
  60                 r = sd_bus_message_enter_container(message, 'a', "u");
  61                 if (r < 0)
  62                         return r;
  63
  64                 while ((r = sd_bus_message_read(message, "u", &pid)) > 0) {
  65
  66                         if (pid <= 1)
  67                                 return -EINVAL;
  68
  69                         if (mode != UNIT_CHECK) {
  70                                 r = set_put(s->pids, LONG_TO_PTR(pid));
  71                                 if (r < 0 && r != -EEXIST)
  72                                         return r;
  73                         }
  74
  75                         n++;
  76                 }
  77                 if (r < 0)
  78                         return r;
  79
  80                 r = sd_bus_message_exit_container(message);
  81                 if (r < 0)
  82                         return r;
  83
  84                 if (n <= 0)
  85                         return -EINVAL;
  86
  87                 return 1;
  88
  89         } else if (streq(name, "TimeoutStopUSec")) {
  90
  91                 if (mode != UNIT_CHECK) {
  92                         r = sd_bus_message_read(message, "t", &s->timeout_stop_usec);
  93                         if (r < 0)
  94                                 return r;
  95
  96                         unit_write_drop_in_format(UNIT(s), mode, name, "[Scope]\nTimeoutStopSec=%lluus\n", (unsigned long long) s->timeout_stop_usec);
  97                 } else {
  98                         r = sd_bus_message_skip(message, "t");
  99                         if (r < 0)
 100                                 return r;
 101                 }
 102
 103                 return 1;
 104         }
 105
 106         return 0;
 107 }
 108
 109 int bus_scope_set_property(
 110                 Unit *u,
 111                 const char *name,
 112                 sd_bus_message *message,
 113                 UnitSetPropertiesMode mode,
 114                 sd_bus_error *error) {
 115
 116         Scope *s = SCOPE(u);
 117         int r;
 118
 119         assert(s);
 120         assert(name);
 121         assert(message);
 122
 123         r = bus_cgroup_set_property(u, &s->cgroup_context, name, message, mode, error);
 124         if (r != 0)
 125                 return r;
 126
 127         if (u->load_state == UNIT_STUB) {
 128                 /* While we are created we still accept PIDs */
 129
 130                 r = bus_scope_set_transient_property(s, name, message, mode, error);
 131                 if (r != 0)
 132                         return r;
 133
 134                 r = bus_kill_context_set_transient_property(u, &s->kill_context, name, message, mode, error);
 135                 if (r != 0)
 136                         return r;
 137         }
 138
 139         return 0;
 140 }
 141
 142 int bus_scope_commit_properties(Unit *u) {
 143         assert(u);
 144
 145         unit_realize_cgroup(u);
 146         return 0;
 147 }