mirror of
https://github.com/morgan9e/systemd
synced 2026-04-15 08:56:15 +09:00
core: Common code for DBus methods that Cancel a job
Both ofs.Job.Cancel() and ofs.Manager.CancelJob() now use same implementation. So we can add caller verify logic appropriately.
This commit is contained in:
@@ -52,7 +52,7 @@ static int property_get_unit(
|
||||
return sd_bus_message_append(reply, "(so)", j->unit->id, p);
|
||||
}
|
||||
|
||||
static int method_cancel(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
|
||||
int bus_job_method_cancel(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
|
||||
Job *j = userdata;
|
||||
int r;
|
||||
|
||||
@@ -71,7 +71,7 @@ static int method_cancel(sd_bus *bus, sd_bus_message *message, void *userdata, s
|
||||
|
||||
const sd_bus_vtable bus_job_vtable[] = {
|
||||
SD_BUS_VTABLE_START(0),
|
||||
SD_BUS_METHOD("Cancel", NULL, NULL, method_cancel, 0),
|
||||
SD_BUS_METHOD("Cancel", NULL, NULL, bus_job_method_cancel, 0),
|
||||
SD_BUS_PROPERTY("Id", "u", NULL, offsetof(Job, id), SD_BUS_VTABLE_PROPERTY_CONST),
|
||||
SD_BUS_PROPERTY("Unit", "(so)", property_get_unit, 0, SD_BUS_VTABLE_PROPERTY_CONST),
|
||||
SD_BUS_PROPERTY("JobType", "s", property_get_type, offsetof(Job, type), SD_BUS_VTABLE_PROPERTY_CONST),
|
||||
|
||||
@@ -26,5 +26,7 @@
|
||||
|
||||
extern const sd_bus_vtable bus_job_vtable[];
|
||||
|
||||
int bus_job_method_cancel(sd_bus *bus, sd_bus_message *message, void *job, sd_bus_error *error);
|
||||
|
||||
void bus_job_send_change_signal(Job *j);
|
||||
void bus_job_send_removed_signal(Job *j);
|
||||
|
||||
@@ -34,6 +34,7 @@
|
||||
#include "architecture.h"
|
||||
#include "env-util.h"
|
||||
#include "dbus.h"
|
||||
#include "dbus-job.h"
|
||||
#include "dbus-manager.h"
|
||||
#include "dbus-unit.h"
|
||||
#include "dbus-snapshot.h"
|
||||
@@ -685,13 +686,7 @@ static int method_cancel_job(sd_bus *bus, sd_bus_message *message, void *userdat
|
||||
if (!j)
|
||||
return sd_bus_error_setf(error, BUS_ERROR_NO_SUCH_JOB, "Job %u does not exist.", (unsigned) id);
|
||||
|
||||
r = selinux_unit_access_check(j->unit, message, "stop", error);
|
||||
if (r < 0)
|
||||
return r;
|
||||
|
||||
job_finish_and_invalidate(j, JOB_CANCELED, true);
|
||||
|
||||
return sd_bus_reply_method_return(message, NULL);
|
||||
return bus_job_method_cancel(bus, message, j, error);
|
||||
}
|
||||
|
||||
static int method_clear_jobs(sd_bus *bus, sd_bus_message *message, void *userdata, sd_bus_error *error) {
|
||||
|
||||
Reference in New Issue
Block a user