src/core/dbus-job.c

   1 /*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
   2
   3 /***
   4   This file is part of systemd.
   5
   6   Copyright 2010 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 "sd-bus.h"
  23
  24 #include "alloc-util.h"
  25 #include "dbus-job.h"
  26 #include "dbus.h"
  27 #include "job.h"
  28 #include "log.h"
  29 #include "selinux-access.h"
  30 #include "string-util.h"
  31
  32 static BUS_DEFINE_PROPERTY_GET_ENUM(property_get_type, job_type, JobType);
  33 static BUS_DEFINE_PROPERTY_GET_ENUM(property_get_state, job_state, JobState);
  34
  35 static int property_get_unit(
  36                 sd_bus *bus,
  37                 const char *path,
  38                 const char *interface,
  39                 const char *property,
  40                 sd_bus_message *reply,
  41                 void *userdata,
  42                 sd_bus_error *error) {
  43
  44         _cleanup_free_ char *p = NULL;
  45         Job *j = userdata;
  46
  47         assert(bus);
  48         assert(reply);
  49         assert(j);
  50
  51         p = unit_dbus_path(j->unit);
  52         if (!p)
  53                 return -ENOMEM;
  54
  55         return sd_bus_message_append(reply, "(so)", j->unit->id, p);
  56 }
  57
  58 int bus_job_method_cancel(sd_bus_message *message, void *userdata, sd_bus_error *error) {
  59         Job *j = userdata;
  60         int r;
  61
  62         assert(message);
  63         assert(j);
  64
  65         r = mac_selinux_unit_access_check(j->unit, message, "stop", error);
  66         if (r < 0)
  67                 return r;
  68
  69         /* Access is granted to the job owner */
  70         if (!sd_bus_track_contains(j->clients, sd_bus_message_get_sender(message))) {
  71
  72                 /* And for everybody else consult PolicyKit */
  73                 r = bus_verify_manage_units_async(j->unit->manager, message, error);
  74                 if (r < 0)
  75                         return r;
  76                 if (r == 0)
  77                         return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
  78         }
  79
  80         job_finish_and_invalidate(j, JOB_CANCELED, true);
  81
  82         return sd_bus_reply_method_return(message, NULL);
  83 }
  84
  85 const sd_bus_vtable bus_job_vtable[] = {
  86         SD_BUS_VTABLE_START(0),
  87         SD_BUS_METHOD("Cancel", NULL, NULL, bus_job_method_cancel, SD_BUS_VTABLE_UNPRIVILEGED),
  88         SD_BUS_PROPERTY("Id", "u", NULL, offsetof(Job, id), SD_BUS_VTABLE_PROPERTY_CONST),
  89         SD_BUS_PROPERTY("Unit", "(so)", property_get_unit, 0, SD_BUS_VTABLE_PROPERTY_CONST),
  90         SD_BUS_PROPERTY("JobType", "s", property_get_type, offsetof(Job, type), SD_BUS_VTABLE_PROPERTY_CONST),
  91         SD_BUS_PROPERTY("State", "s", property_get_state, offsetof(Job, state), SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
  92         SD_BUS_VTABLE_END
  93 };
  94
  95 static int send_new_signal(sd_bus *bus, void *userdata) {
  96         _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
  97         _cleanup_free_ char *p = NULL;
  98         Job *j = userdata;
  99         int r;
 100
 101         assert(bus);
 102         assert(j);
 103
 104         p = job_dbus_path(j);
 105         if (!p)
 106                 return -ENOMEM;
 107
 108         r = sd_bus_message_new_signal(
 109                         bus,
 110                         &m,
 111                         "/org/freedesktop/systemd1",
 112                         "org.freedesktop.systemd1.Manager",
 113                         "JobNew");
 114         if (r < 0)
 115                 return r;
 116
 117         r = sd_bus_message_append(m, "uos", j->id, p, j->unit->id);
 118         if (r < 0)
 119                 return r;
 120
 121         return sd_bus_send(bus, m, NULL);
 122 }
 123
 124 static int send_changed_signal(sd_bus *bus, void *userdata) {
 125         _cleanup_free_ char *p = NULL;
 126         Job *j = userdata;
 127
 128         assert(bus);
 129         assert(j);
 130
 131         p = job_dbus_path(j);
 132         if (!p)
 133                 return -ENOMEM;
 134
 135         return sd_bus_emit_properties_changed(bus, p, "org.freedesktop.systemd1.Job", "State", NULL);
 136 }
 137
 138 void bus_job_send_change_signal(Job *j) {
 139         int r;
 140
 141         assert(j);
 142
 143         if (j->in_dbus_queue) {
 144                 LIST_REMOVE(dbus_queue, j->manager->dbus_job_queue, j);
 145                 j->in_dbus_queue = false;
 146         }
 147
 148         r = bus_foreach_bus(j->manager, j->clients, j->sent_dbus_new_signal ? send_changed_signal : send_new_signal, j);
 149         if (r < 0)
 150                 log_debug_errno(r, "Failed to send job change signal for %u: %m", j->id);
 151
 152         j->sent_dbus_new_signal = true;
 153 }
 154
 155 static int send_removed_signal(sd_bus *bus, void *userdata) {
 156         _cleanup_(sd_bus_message_unrefp) sd_bus_message *m = NULL;
 157         _cleanup_free_ char *p = NULL;
 158         Job *j = userdata;
 159         int r;
 160
 161         assert(bus);
 162         assert(j);
 163
 164         p = job_dbus_path(j);
 165         if (!p)
 166                 return -ENOMEM;
 167
 168         r = sd_bus_message_new_signal(
 169                         bus,
 170                         &m,
 171                         "/org/freedesktop/systemd1",
 172                         "org.freedesktop.systemd1.Manager",
 173                         "JobRemoved");
 174         if (r < 0)
 175                 return r;
 176
 177         r = sd_bus_message_append(m, "uoss", j->id, p, j->unit->id, job_result_to_string(j->result));
 178         if (r < 0)
 179                 return r;
 180
 181         return sd_bus_send(bus, m, NULL);
 182 }
 183
 184 void bus_job_send_removed_signal(Job *j) {
 185         int r;
 186
 187         assert(j);
 188
 189         if (!j->sent_dbus_new_signal)
 190                 bus_job_send_change_signal(j);
 191
 192         r = bus_foreach_bus(j->manager, j->clients, send_removed_signal, j);
 193         if (r < 0)
 194                 log_debug_errno(r, "Failed to send job remove signal for %u: %m", j->id);
 195 }