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 "log.h"
  23 #include "sd-bus.h"
  24 #include "selinux-access.h"
  25 #include "job.h"
  26 #include "dbus-job.h"
  27 #include "dbus.h"
  28
  29 static BUS_DEFINE_PROPERTY_GET_ENUM(property_get_type, job_type, JobType);
  30 static BUS_DEFINE_PROPERTY_GET_ENUM(property_get_state, job_state, JobState);
  31
  32 static int property_get_unit(
  33                 sd_bus *bus,
  34                 const char *path,
  35                 const char *interface,
  36                 const char *property,
  37                 sd_bus_message *reply,
  38                 void *userdata,
  39                 sd_bus_error *error) {
  40
  41         _cleanup_free_ char *p = NULL;
  42         Job *j = userdata;
  43
  44         assert(bus);
  45         assert(reply);
  46         assert(j);
  47
  48         p = unit_dbus_path(j->unit);
  49         if (!p)
  50                 return -ENOMEM;
  51
  52         return sd_bus_message_append(reply, "(so)", j->unit->id, p);
  53 }
  54
  55 static int method_cancel(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
  56         Job *j = userdata;
  57         int r;
  58
  59         assert(bus);
  60         assert(message);
  61         assert(j);
  62
  63         r = selinux_unit_access_check(j->unit, message, "stop", error);
  64         if (r < 0)
  65                 return r;
  66
  67         job_finish_and_invalidate(j, JOB_CANCELED, true);
  68
  69         return sd_bus_reply_method_return(message, NULL);
  70 }
  71
  72 const sd_bus_vtable bus_job_vtable[] = {
  73         SD_BUS_VTABLE_START(0),
  74         SD_BUS_METHOD("Cancel", NULL, NULL, method_cancel, 0),
  75         SD_BUS_PROPERTY("Id", "u", NULL, offsetof(Job, id), SD_BUS_VTABLE_PROPERTY_CONST),
  76         SD_BUS_PROPERTY("Unit", "(so)", property_get_unit, 0, SD_BUS_VTABLE_PROPERTY_CONST),
  77         SD_BUS_PROPERTY("JobType", "s", property_get_type, offsetof(Job, type), SD_BUS_VTABLE_PROPERTY_CONST),
  78         SD_BUS_PROPERTY("State", "s", property_get_state, offsetof(Job, state), SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
  79         SD_BUS_VTABLE_END
  80 };
  81
  82 static int send_new_signal(sd_bus *bus, void *userdata) {
  83         _cleanup_bus_message_unref_ sd_bus_message *m = NULL;
  84         _cleanup_free_ char *p = NULL;
  85         Job *j = userdata;
  86         int r;
  87
  88         assert(bus);
  89         assert(j);
  90
  91         p = job_dbus_path(j);
  92         if (!p)
  93                 return -ENOMEM;
  94
  95         r = sd_bus_message_new_signal(
  96                         bus,
  97                         &m,
  98                         "/org/freedesktop/systemd1",
  99                         "org.freedesktop.systemd1.Manager",
 100                         "JobNew");
 101         if (r < 0)
 102                 return r;
 103
 104         r = sd_bus_message_append(m, "uos", j->id, p, j->unit->id);
 105         if (r < 0)
 106                 return r;
 107
 108         return sd_bus_send(bus, m, NULL);
 109 }
 110
 111 static int send_changed_signal(sd_bus *bus, void *userdata) {
 112         _cleanup_free_ char *p = NULL;
 113         Job *j = userdata;
 114
 115         assert(bus);
 116         assert(j);
 117
 118         p = job_dbus_path(j);
 119         if (!p)
 120                 return -ENOMEM;
 121
 122         return sd_bus_emit_properties_changed(bus, p, "org.freedesktop.systemd1.Job", "State", NULL);
 123 }
 124
 125 void bus_job_send_change_signal(Job *j) {
 126         int r;
 127
 128         assert(j);
 129
 130         if (j->in_dbus_queue) {
 131                 LIST_REMOVE(dbus_queue, j->manager->dbus_job_queue, j);
 132                 j->in_dbus_queue = false;
 133         }
 134
 135         r = bus_foreach_bus(j->manager, j->subscribed, j->sent_dbus_new_signal ? send_changed_signal : send_new_signal, j);
 136         if (r < 0)
 137                 log_debug("Failed to send job change signal for %u: %s", j->id, strerror(-r));
 138
 139         j->sent_dbus_new_signal = true;
 140 }
 141
 142 static int send_removed_signal(sd_bus *bus, void *userdata) {
 143         _cleanup_bus_message_unref_ sd_bus_message *m = NULL;
 144         _cleanup_free_ char *p = NULL;
 145         Job *j = userdata;
 146         int r;
 147
 148         assert(bus);
 149         assert(j);
 150
 151         p = job_dbus_path(j);
 152         if (!p)
 153                 return -ENOMEM;
 154
 155         r = sd_bus_message_new_signal(
 156                         bus,
 157                         &m,
 158                         "/org/freedesktop/systemd1",
 159                         "org.freedesktop.systemd1.Manager",
 160                         "JobRemoved");
 161         if (r < 0)
 162                 return r;
 163
 164         r = sd_bus_message_append(m, "uoss", j->id, p, j->unit->id, job_result_to_string(j->result));
 165         if (r < 0)
 166                 return r;
 167
 168         return sd_bus_send(bus, m, NULL);
 169 }
 170
 171 void bus_job_send_removed_signal(Job *j) {
 172         int r;
 173
 174         assert(j);
 175
 176         if (!j->sent_dbus_new_signal)
 177                 bus_job_send_change_signal(j);
 178
 179         r = bus_foreach_bus(j->manager, j->subscribed, send_removed_signal, j);
 180         if (r < 0)
 181                 log_debug("Failed to send job remove signal for %u: %s", j->id, strerror(-r));
 182 }