1 /*-*- Mode: C; c-basic-offset: 8 -*-*/
4 This file is part of systemd.
6 Copyright 2010 Lennart Poettering
8 systemd is free software; you can redistribute it and/or modify it
9 under the terms of the GNU General Public License as published by
10 the Free Software Foundation; either version 2 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 General Public License for more details.
18 You should have received a copy of the GNU General Public License
19 along with systemd; If not, see <http://www.gnu.org/licenses/>.
23 #include <dbus/dbus.h>
24 #include <sys/prctl.h>
26 #include "dbus-execute.h"
31 DEFINE_BUS_PROPERTY_APPEND_ENUM(bus_execute_append_input, exec_input, ExecInput);
32 DEFINE_BUS_PROPERTY_APPEND_ENUM(bus_execute_append_output, exec_output, ExecOutput);
34 int bus_execute_append_oom_adjust(Manager *m, DBusMessageIter *i, const char *property, void *data) {
35 ExecContext *c = data;
43 if (c->oom_adjust_set)
49 if (read_one_line_file("/proc/self/oom_adj", &t) >= 0) {
55 if (!dbus_message_iter_append_basic(i, DBUS_TYPE_INT32, &n))
61 int bus_execute_append_nice(Manager *m, DBusMessageIter *i, const char *property, void *data) {
62 ExecContext *c = data;
73 n = getpriority(PRIO_PROCESS, 0);
75 if (!dbus_message_iter_append_basic(i, DBUS_TYPE_INT32, &n))
81 int bus_execute_append_ioprio(Manager *m, DBusMessageIter *i, const char *property, void *data) {
82 ExecContext *c = data;
93 n = ioprio_get(IOPRIO_WHO_PROCESS, 0);
95 if (!dbus_message_iter_append_basic(i, DBUS_TYPE_INT32, &n))
101 int bus_execute_append_cpu_sched_policy(Manager *m, DBusMessageIter *i, const char *property, void *data) {
102 ExecContext *c = data;
110 if (c->cpu_sched_set)
111 n = c->cpu_sched_policy;
113 n = sched_getscheduler(0);
115 if (!dbus_message_iter_append_basic(i, DBUS_TYPE_INT32, &n))
121 int bus_execute_append_cpu_sched_priority(Manager *m, DBusMessageIter *i, const char *property, void *data) {
122 ExecContext *c = data;
130 if (c->cpu_sched_set)
131 n = c->cpu_sched_priority;
133 struct sched_param p;
137 if (sched_getparam(0, &p) >= 0)
138 n = p.sched_priority;
141 if (!dbus_message_iter_append_basic(i, DBUS_TYPE_INT32, &n))
147 int bus_execute_append_affinity(Manager *m, DBusMessageIter *i, const char *property, void *data) {
148 ExecContext *c = data;
157 if (!dbus_message_iter_open_container(i, DBUS_TYPE_ARRAY, "y", &sub))
161 b = dbus_message_iter_append_fixed_array(&sub, DBUS_TYPE_BYTE, &c->cpuset, CPU_ALLOC_SIZE(c->cpuset_ncpus));
163 b = dbus_message_iter_append_fixed_array(&sub, DBUS_TYPE_BYTE, &c->cpuset, 0);
168 if (!dbus_message_iter_close_container(i, &sub))
174 int bus_execute_append_timer_slack_nsec(Manager *m, DBusMessageIter *i, const char *property, void *data) {
175 ExecContext *c = data;
183 if (c->timer_slack_nsec_set)
184 u = (uint64_t) c->timer_slack_nsec;
186 u = (uint64_t) prctl(PR_GET_TIMERSLACK);
188 if (!dbus_message_iter_append_basic(i, DBUS_TYPE_UINT64, &u))
194 int bus_execute_append_capabilities(Manager *m, DBusMessageIter *i, const char *property, void *data) {
195 ExecContext *c = data;
206 s = t = cap_to_text(c->capabilities, NULL);
213 b = dbus_message_iter_append_basic(i, DBUS_TYPE_STRING, &s);
222 int bus_execute_append_rlimits(Manager *m, DBusMessageIter *i, const char *property, void *data) {
223 ExecContext *c = data;
232 assert_se((r = rlimit_from_string(property)) >= 0);
235 u = (uint64_t) c->rlimit[r]->rlim_max;
242 u = (uint64_t) rl.rlim_max;
245 if (!dbus_message_iter_append_basic(i, DBUS_TYPE_UINT64, &u))
251 int bus_execute_append_command(Manager *m, DBusMessageIter *i, const char *property, void *data) {
252 ExecCommand *c = data;
253 DBusMessageIter sub, sub2, sub3;
259 if (!dbus_message_iter_open_container(i, DBUS_TYPE_ARRAY, "(sasttuii)", &sub))
262 LIST_FOREACH(command, c, c) {
265 int32_t code, status;
270 if (!dbus_message_iter_open_container(&sub, DBUS_TYPE_STRUCT, NULL, &sub2) ||
271 !dbus_message_iter_append_basic(&sub2, DBUS_TYPE_STRING, &c->path) ||
272 !dbus_message_iter_open_container(&sub2, DBUS_TYPE_ARRAY, "s", &sub3))
275 STRV_FOREACH(l, c->argv)
276 if (!dbus_message_iter_append_basic(&sub3, DBUS_TYPE_STRING, l))
279 pid = (uint32_t) c->exec_status.pid;
280 code = (int32_t) c->exec_status.code;
281 status = (int32_t) c->exec_status.status;
283 if (!dbus_message_iter_close_container(&sub2, &sub3) ||
284 !dbus_message_iter_append_basic(&sub2, DBUS_TYPE_UINT64, &c->exec_status.start_timestamp.realtime) ||
285 !dbus_message_iter_append_basic(&sub2, DBUS_TYPE_UINT64, &c->exec_status.exit_timestamp.realtime) ||
286 !dbus_message_iter_append_basic(&sub2, DBUS_TYPE_UINT32, &c->exec_status.pid) ||
287 !dbus_message_iter_append_basic(&sub2, DBUS_TYPE_INT32, &c->exec_status.code) ||
288 !dbus_message_iter_append_basic(&sub2, DBUS_TYPE_INT32, &c->exec_status.status))
291 if (!dbus_message_iter_close_container(&sub, &sub2))
295 if (!dbus_message_iter_close_container(i, &sub))