#include <errno.h>

#include <signal.h>

#include <dirent.h>

#include <unistd.h>

#include <sys/reboot.h>

#include "manager.h"

#include "unit.h"

#include "service.h"

#include "load-fragment.h"

#include "load-dropin.h"

#include "log.h"

#include "strv.h"

#include "unit-name.h"

#include "dbus-service.h"

#include "special.h"

#include "bus-errors.h"

#include "exit-status.h"

#include "def.h"

#include "path-util.h"

#include "util.h"

#include "utf8.h"

#ifdef HAVE_SYSV_COMPAT

#define DEFAULT_SYSV_TIMEOUT_USEC (5*USEC_PER_MINUTE)

typedef enum RunlevelType {

RUNLEVEL_UP,

RUNLEVEL_DOWN,

RUNLEVEL_SYSINIT

} RunlevelType;

static const struct {

const char *path;

const char *target;

const RunlevelType type;

} rcnd_table[] = {

/* Standard SysV runlevels for start-up */

{ "rc1.d", SPECIAL_RESCUE_TARGET, RUNLEVEL_UP },

{ "rc2.d", SPECIAL_RUNLEVEL2_TARGET, RUNLEVEL_UP },

{ "rc3.d", SPECIAL_RUNLEVEL3_TARGET, RUNLEVEL_UP },

{ "rc4.d", SPECIAL_RUNLEVEL4_TARGET, RUNLEVEL_UP },

{ "rc5.d", SPECIAL_RUNLEVEL5_TARGET, RUNLEVEL_UP },

#ifdef TARGET_SUSE

/* SUSE style boot.d */

{ "boot.d", SPECIAL_SYSINIT_TARGET, RUNLEVEL_SYSINIT },

#endif

#if defined(TARGET_DEBIAN) || defined(TARGET_UBUNTU) || defined(TARGET_ANGSTROM)

/* Debian style rcS.d */

{ "rcS.d", SPECIAL_SYSINIT_TARGET, RUNLEVEL_SYSINIT },

#endif

/* Standard SysV runlevels for shutdown */

{ "rc0.d", SPECIAL_POWEROFF_TARGET, RUNLEVEL_DOWN },

{ "rc6.d", SPECIAL_REBOOT_TARGET, RUNLEVEL_DOWN }

/* Note that the order here matters, as we read the

};

#define RUNLEVELS_UP "12345"

#define RUNLEVELS_BOOT "bBsS"

#endif

static const UnitActiveState state_translation_table[_SERVICE_STATE_MAX] = {

[SERVICE_DEAD] = UNIT_INACTIVE,

[SERVICE_START_PRE] = UNIT_ACTIVATING,

[SERVICE_START] = UNIT_ACTIVATING,

[SERVICE_START_POST] = UNIT_ACTIVATING,

[SERVICE_RUNNING] = UNIT_ACTIVE,

[SERVICE_EXITED] = UNIT_ACTIVE,

[SERVICE_RELOAD] = UNIT_RELOADING,

[SERVICE_STOP] = UNIT_DEACTIVATING,

[SERVICE_STOP_SIGTERM] = UNIT_DEACTIVATING,

[SERVICE_STOP_SIGKILL] = UNIT_DEACTIVATING,

[SERVICE_STOP_POST] = UNIT_DEACTIVATING,

[SERVICE_FINAL_SIGTERM] = UNIT_DEACTIVATING,

[SERVICE_FINAL_SIGKILL] = UNIT_DEACTIVATING,

[SERVICE_FAILED] = UNIT_FAILED,

[SERVICE_AUTO_RESTART] = UNIT_ACTIVATING

};

static const UnitActiveState state_translation_table_idle[_SERVICE_STATE_MAX] = {

[SERVICE_DEAD] = UNIT_INACTIVE,

[SERVICE_START_PRE] = UNIT_ACTIVE,

[SERVICE_START] = UNIT_ACTIVE,

[SERVICE_START_POST] = UNIT_ACTIVE,

[SERVICE_RUNNING] = UNIT_ACTIVE,

[SERVICE_EXITED] = UNIT_ACTIVE,

[SERVICE_RELOAD] = UNIT_RELOADING,

[SERVICE_STOP] = UNIT_DEACTIVATING,

[SERVICE_STOP_SIGTERM] = UNIT_DEACTIVATING,

[SERVICE_STOP_SIGKILL] = UNIT_DEACTIVATING,

[SERVICE_STOP_POST] = UNIT_DEACTIVATING,

[SERVICE_FINAL_SIGTERM] = UNIT_DEACTIVATING,

[SERVICE_FINAL_SIGKILL] = UNIT_DEACTIVATING,

[SERVICE_FAILED] = UNIT_FAILED,

[SERVICE_AUTO_RESTART] = UNIT_ACTIVATING

};

static void service_init(Unit *u) {

Service *s = SERVICE(u);

int i;

assert(u);

assert(u->load_state == UNIT_STUB);

s->timeout_usec = DEFAULT_TIMEOUT_USEC;

s->restart_usec = DEFAULT_RESTART_USEC;

s->type = _SERVICE_TYPE_INVALID;

s->watchdog_watch.type = WATCH_INVALID;

s->timer_watch.type = WATCH_INVALID;

#ifdef HAVE_SYSV_COMPAT

s->sysv_start_priority = -1;

s->sysv_start_priority_from_rcnd = -1;

#endif

s->socket_fd = -1;

s->guess_main_pid = true;

exec_context_init(&s->exec_context);

for (i = 0; i < RLIMIT_NLIMITS; i++)

if (UNIT(s)->manager->rlimit[i])

s->exec_context.rlimit[i] = newdup(struct rlimit, UNIT(s)->manager->rlimit[i], 1);

kill_context_init(&s->kill_context);

RATELIMIT_INIT(s->start_limit, 10*USEC_PER_SEC, 5);

s->control_command_id = _SERVICE_EXEC_COMMAND_INVALID;

}

static void service_unwatch_control_pid(Service *s) {

assert(s);

if (s->control_pid <= 0)

return;

unit_unwatch_pid(UNIT(s), s->control_pid);

s->control_pid = 0;

}

static void service_unwatch_main_pid(Service *s) {

assert(s);

if (s->main_pid <= 0)

return;

unit_unwatch_pid(UNIT(s), s->main_pid);

s->main_pid = 0;

}

static void service_unwatch_pid_file(Service *s) {

if (!s->pid_file_pathspec)

return;

log_debug("Stopping watch for %s's PID file %s", UNIT(s)->id, s->pid_file_pathspec->path);

path_spec_unwatch(s->pid_file_pathspec, UNIT(s));

path_spec_done(s->pid_file_pathspec);

free(s->pid_file_pathspec);

s->pid_file_pathspec = NULL;

}

static int service_set_main_pid(Service *s, pid_t pid) {

pid_t ppid;

assert(s);

if (pid <= 1)

return -EINVAL;

if (pid == getpid())

return -EINVAL;

s->main_pid = pid;

s->main_pid_known = true;

if (get_parent_of_pid(pid, &ppid) >= 0 && ppid != getpid()) {

log_warning("%s: Supervising process %lu which is not our child. We'll most likely not notice when it exits.",

UNIT(s)->id, (unsigned long) pid);

s->main_pid_alien = true;

} else

s->main_pid_alien = false;

exec_status_start(&s->main_exec_status, pid);

return 0;

}

static void service_close_socket_fd(Service *s) {

assert(s);

if (s->socket_fd < 0)

return;

close_nointr_nofail(s->socket_fd);

s->socket_fd = -1;

}

static void service_connection_unref(Service *s) {

assert(s);

if (!UNIT_DEREF(s->accept_socket))

return;

socket_connection_unref(SOCKET(UNIT_DEREF(s->accept_socket)));

unit_ref_unset(&s->accept_socket);

}

static void service_stop_watchdog(Service *s) {

assert(s);

unit_unwatch_timer(UNIT(s), &s->watchdog_watch);

s->watchdog_timestamp.realtime = 0;

s->watchdog_timestamp.monotonic = 0;

}

static void service_enter_dead(Service *s, ServiceResult f, bool allow_restart);

static void service_handle_watchdog(Service *s) {

usec_t offset;

int r;

assert(s);

if (s->watchdog_usec == 0)

return;

offset = now(CLOCK_MONOTONIC) - s->watchdog_timestamp.monotonic;

if (offset >= s->watchdog_usec) {

log_error("%s watchdog timeout!", UNIT(s)->id);

service_enter_dead(s, SERVICE_FAILURE_WATCHDOG, true);

return;

}

r = unit_watch_timer(UNIT(s), s->watchdog_usec - offset, &s->watchdog_watch);

if (r < 0)

log_warning("%s failed to install watchdog timer: %s", UNIT(s)->id, strerror(-r));

}

static void service_reset_watchdog(Service *s) {

assert(s);

dual_timestamp_get(&s->watchdog_timestamp);

service_handle_watchdog(s);

}

static void service_done(Unit *u) {

Service *s = SERVICE(u);

assert(s);

free(s->pid_file);

s->pid_file = NULL;

#ifdef HAVE_SYSV_COMPAT

free(s->sysv_runlevels);

s->sysv_runlevels = NULL;

#endif

free(s->status_text);

s->status_text = NULL;

exec_context_done(&s->exec_context);

exec_command_free_array(s->exec_command, _SERVICE_EXEC_COMMAND_MAX);

s->control_command = NULL;

s->main_command = NULL;

/* This will leak a process, but at least no memory or any of

service_unwatch_main_pid(s);

service_unwatch_control_pid(s);

service_unwatch_pid_file(s);

if (s->bus_name) {

unit_unwatch_bus_name(u, s->bus_name);

free(s->bus_name);

s->bus_name = NULL;

}

service_close_socket_fd(s);

service_connection_unref(s);

unit_ref_unset(&s->accept_socket);

service_stop_watchdog(s);

unit_unwatch_timer(u, &s->timer_watch);

}

#ifdef HAVE_SYSV_COMPAT

static char *sysv_translate_name(const char *name) {

char *r;

if (!(r = new(char, strlen(name) + sizeof(".service"))))

return NULL;

#if defined(TARGET_DEBIAN) || defined(TARGET_UBUNTU) || defined(TARGET_ANGSTROM)

if (endswith(name, ".sh"))

/* Drop Debian-style .sh suffix */

strcpy(stpcpy(r, name) - 3, ".service");

#endif

#ifdef TARGET_SUSE

if (startswith(name, "boot."))

/* Drop SuSE-style boot. prefix */

strcpy(stpcpy(r, name + 5), ".service");

#endif

#ifdef TARGET_FRUGALWARE

if (startswith(name, "rc."))

/* Drop Frugalware-style rc. prefix */

strcpy(stpcpy(r, name + 3), ".service");

#endif

else

/* Normal init scripts */

strcpy(stpcpy(r, name), ".service");

return r;

}

static int sysv_translate_facility(const char *name, const char *filename, char **_r) {

/* We silently ignore the $ prefix here. According to the LSB

static const char * const table[] = {

/* LSB defined facilities */

"local_fs", SPECIAL_LOCAL_FS_TARGET,

#if defined(TARGET_MANDRIVA) || defined(TARGET_MAGEIA)

#else

/* Due to unfortunate name selection in Mandriva,

"network", SPECIAL_NETWORK_TARGET,

#endif

"named", SPECIAL_NSS_LOOKUP_TARGET,

"portmap", SPECIAL_RPCBIND_TARGET,

"remote_fs", SPECIAL_REMOTE_FS_TARGET,

"syslog", SPECIAL_SYSLOG_TARGET,

"time", SPECIAL_TIME_SYNC_TARGET,

/* common extensions */

"mail-transfer-agent", SPECIAL_MAIL_TRANSFER_AGENT_TARGET,

"x-display-manager", SPECIAL_DISPLAY_MANAGER_SERVICE,

"null", NULL,

#if defined(TARGET_DEBIAN) || defined(TARGET_UBUNTU) || defined(TARGET_ANGSTROM)

"mail-transport-agent", SPECIAL_MAIL_TRANSFER_AGENT_TARGET,

#endif

#ifdef TARGET_FEDORA

"MTA", SPECIAL_MAIL_TRANSFER_AGENT_TARGET,

"smtpdaemon", SPECIAL_MAIL_TRANSFER_AGENT_TARGET,

"httpd", SPECIAL_HTTP_DAEMON_TARGET,

#endif

#ifdef TARGET_SUSE

"smtp", SPECIAL_MAIL_TRANSFER_AGENT_TARGET,

#endif

};

unsigned i;

char *r;

const char *n;

assert(name);

assert(_r);

n = *name == '$' ? name + 1 : name;

for (i = 0; i < ELEMENTSOF(table); i += 2) {

if (!streq(table[i], n))

continue;

if (!table[i+1])

return 0;

if (!(r = strdup(table[i+1])))

return -ENOMEM;

goto finish;

}

/* If we don't know this name, fallback heuristics to figure

if (*name == '$') {

if (!unit_prefix_is_valid(n))

return -EINVAL;

/* Facilities starting with $ are most likely targets */

r = unit_name_build(n, NULL, ".target");

} else if (filename && streq(name, filename))

/* Names equaling the file name of the services are redundant */

return 0;

else

/* Everything else we assume to be normal service names */

r = sysv_translate_name(n);

if (!r)

return -ENOMEM;

finish:

*_r = r;

return 1;

}

static int sysv_fix_order(Service *s) {

Unit *other;

int r;

assert(s);

if (s->sysv_start_priority < 0)

return 0;

/* For each pair of services where at least one lacks a LSB

LIST_FOREACH(units_by_type, other, UNIT(s)->manager->units_by_type[UNIT_SERVICE]) {

Service *t;

UnitDependency d;

bool special_s, special_t;

t = SERVICE(other);

if (s == t)

continue;

if (UNIT(t)->load_state != UNIT_LOADED)

continue;

if (t->sysv_start_priority < 0)

continue;

/* If both units have modern headers we don't care

if ((UNIT(s)->fragment_path || s->sysv_has_lsb) &&

(UNIT(t)->fragment_path || t->sysv_has_lsb))

continue;

special_s = s->sysv_runlevels && !chars_intersect(RUNLEVELS_UP, s->sysv_runlevels);

special_t = t->sysv_runlevels && !chars_intersect(RUNLEVELS_UP, t->sysv_runlevels);

if (special_t && !special_s)

d = UNIT_AFTER;

else if (special_s && !special_t)

d = UNIT_BEFORE;

else if (t->sysv_start_priority < s->sysv_start_priority)

d = UNIT_AFTER;

else if (t->sysv_start_priority > s->sysv_start_priority)

d = UNIT_BEFORE;

else

continue;

/* FIXME: Maybe we should compare the name here lexicographically? */

if ((r = unit_add_dependency(UNIT(s), d, UNIT(t), true)) < 0)

return r;

}

return 0;

}

static ExecCommand *exec_command_new(const char *path, const char *arg1) {

ExecCommand *c;

if (!(c = new0(ExecCommand, 1)))

return NULL;

if (!(c->path = strdup(path))) {

free(c);

return NULL;

}

if (!(c->argv = strv_new(path, arg1, NULL))) {

free(c->path);

free(c);

return NULL;

}

return c;

}

static int sysv_exec_commands(Service *s) {

ExecCommand *c;

assert(s);

assert(s->is_sysv);

assert(UNIT(s)->source_path);

c = exec_command_new(UNIT(s)->source_path, "start");

if (!c)

return -ENOMEM;

exec_command_append_list(s->exec_command+SERVICE_EXEC_START, c);

c = exec_command_new(UNIT(s)->source_path, "stop");

if (!c)

return -ENOMEM;

exec_command_append_list(s->exec_command+SERVICE_EXEC_STOP, c);

c = exec_command_new(UNIT(s)->source_path, "reload");

if (!c)

return -ENOMEM;

exec_command_append_list(s->exec_command+SERVICE_EXEC_RELOAD, c);

return 0;

}

static int service_load_sysv_path(Service *s, const char *path) {

FILE *f;

Unit *u;

unsigned line = 0;

int r;

enum {

NORMAL,

DESCRIPTION,

LSB,

LSB_DESCRIPTION

} state = NORMAL;

char *short_description = NULL, *long_description = NULL, *chkconfig_description = NULL, *description;

struct stat st;

assert(s);

assert(path);

u = UNIT(s);

f = fopen(path, "re");

if (!f) {

r = errno == ENOENT ? 0 : -errno;

goto finish;

}

zero(st);

if (fstat(fileno(f), &st) < 0) {

r = -errno;

goto finish;

}

free(u->source_path);

u->source_path = strdup(path);

if (!u->source_path) {

r = -ENOMEM;

goto finish;

}

u->source_mtime = timespec_load(&st.st_mtim);

if (null_or_empty(&st)) {

u->load_state = UNIT_MASKED;

r = 0;

goto finish;

}

s->is_sysv = true;

while (!feof(f)) {

char l[LINE_MAX], *t;

if (!fgets(l, sizeof(l), f)) {

if (feof(f))

break;

r = -errno;

log_error("Failed to read configuration file '%s': %s", path, strerror(-r));

goto finish;

}

line++;

t = strstrip(l);

if (*t != '#')

continue;

if (state == NORMAL && streq(t, "### BEGIN INIT INFO")) {

state = LSB;

s->sysv_has_lsb = true;

continue;

}

if ((state == LSB_DESCRIPTION || state == LSB) && streq(t, "### END INIT INFO")) {

state = NORMAL;

continue;

}

t++;

t += strspn(t, WHITESPACE);

if (state == NORMAL) {

/* Try to parse Red Hat style chkconfig headers */

if (startswith_no_case(t, "chkconfig:")) {

int start_priority;

char runlevels[16], *k;

state = NORMAL;

if (sscanf(t+10, "%15s %i %*i",

runlevels,

&start_priority) != 2) {

log_warning("[%s:%u] Failed to parse chkconfig line. Ignoring.", path, line);

continue;

}

/* A start priority gathered from the

if (start_priority < 0 || start_priority > 99)

log_warning("[%s:%u] Start priority out of range. Ignoring.", path, line);

else

s->sysv_start_priority = start_priority;

char_array_0(runlevels);

k = delete_chars(runlevels, WHITESPACE "-");

if (k[0]) {

char *d;

if (!(d = strdup(k))) {

r = -ENOMEM;

goto finish;

}

free(s->sysv_runlevels);

s->sysv_runlevels = d;

}

} else if (startswith_no_case(t, "description:")) {

size_t k = strlen(t);

char *d;

const char *j;

if (t[k-1] == '\\') {

state = DESCRIPTION;

t[k-1] = 0;

}

if ((j = strstrip(t+12)) && *j) {

if (!(d = strdup(j))) {

r = -ENOMEM;

goto finish;

}

} else

d = NULL;

free(chkconfig_description);

chkconfig_description = d;

} else if (startswith_no_case(t, "pidfile:")) {

char *fn;

state = NORMAL;

fn = strstrip(t+8);

if (!path_is_absolute(fn)) {

log_warning("[%s:%u] PID file not absolute. Ignoring.", path, line);

continue;

}

if (!(fn = strdup(fn))) {

r = -ENOMEM;

goto finish;

}

free(s->pid_file);

s->pid_file = fn;

}

} else if (state == DESCRIPTION) {

/* Try to parse Red Hat style description

size_t k = strlen(t);

char *j;

if (t[k-1] == '\\')

t[k-1] = 0;

else

state = NORMAL;

if ((j = strstrip(t)) && *j) {

char *d = NULL;

if (chkconfig_description)

d = strjoin(chkconfig_description, " ", j, NULL);

else

d = strdup(j);

if (!d) {

r = -ENOMEM;

goto finish;

}

free(chkconfig_description);

chkconfig_description = d;

}

} else if (state == LSB || state == LSB_DESCRIPTION) {

if (startswith_no_case(t, "Provides:")) {

char *i, *w;

size_t z;

state = LSB;

FOREACH_WORD_QUOTED(w, z, t+9, i) {

char *n, *m;

if (!(n = strndup(w, z))) {

r = -ENOMEM;

goto finish;

}

r = sysv_translate_facility(n, path_get_file_name(path), &m);

free(n);

if (r < 0)

goto finish;

if (r == 0)

continue;

if (unit_name_to_type(m) == UNIT_SERVICE)

r = unit_add_name(u, m);

else

/* NB: SysV targets

r = unit_add_two_dependencies_by_name(u, UNIT_BEFORE, UNIT_WANTS, m, NULL, true);

if (r < 0)

log_error("[%s:%u] Failed to add LSB Provides name %s, ignoring: %s", path, line, m, strerror(-r));

free(m);

}

} else if (startswith_no_case(t, "Required-Start:") ||

startswith_no_case(t, "Should-Start:") ||

startswith_no_case(t, "X-Start-Before:") ||

startswith_no_case(t, "X-Start-After:")) {

char *i, *w;

size_t z;

state = LSB;

FOREACH_WORD_QUOTED(w, z, strchr(t, ':')+1, i) {

char *n, *m;

if (!(n = strndup(w, z))) {

r = -ENOMEM;

goto finish;

}

r = sysv_translate_facility(n, path_get_file_name(path), &m);

if (r < 0) {

log_error("[%s:%u] Failed to translate LSB dependency %s, ignoring: %s", path, line, n, strerror(-r));

free(n);

continue;

}

free(n);

if (r == 0)

continue;

r = unit_add_dependency_by_name(u, startswith_no_case(t, "X-Start-Before:") ? UNIT_BEFORE : UNIT_AFTER, m, NULL, true);

if (r < 0)

log_error("[%s:%u] Failed to add dependency on %s, ignoring: %s", path, line, m, strerror(-r));

free(m);

}

} else if (startswith_no_case(t, "Default-Start:")) {

char *k, *d;

state = LSB;

k = delete_chars(t+14, WHITESPACE "-");

if (k[0] != 0) {

if (!(d = strdup(k))) {

r = -ENOMEM;

goto finish;

}

free(s->sysv_runlevels);

s->sysv_runlevels = d;

}

} else if (startswith_no_case(t, "Description:")) {

char *d, *j;

state = LSB_DESCRIPTION;

if ((j = strstrip(t+12)) && *j) {

if (!(d = strdup(j))) {

r = -ENOMEM;

goto finish;

}

} else

d = NULL;

free(long_description);

long_description = d;

} else if (startswith_no_case(t, "Short-Description:")) {

char *d, *j;

state = LSB;

if ((j = strstrip(t+18)) && *j) {

if (!(d = strdup(j))) {

r = -ENOMEM;

goto finish;

}

} else

d = NULL;

free(short_description);

short_description = d;

} else if (state == LSB_DESCRIPTION) {

if (startswith(l, "#\t") || startswith(l, "# ")) {

char *j;

if ((j = strstrip(t)) && *j) {

char *d = NULL;

if (long_description)

d = strjoin(long_description, " ", t, NULL);

else

d = strdup(j);

if (!d) {

r = -ENOMEM;

goto finish;

}

free(long_description);

long_description = d;

}

} else

state = LSB;

}

}

}

if ((r = sysv_exec_commands(s)) < 0)

goto finish;

if (s->sysv_runlevels &&

chars_intersect(RUNLEVELS_BOOT, s->sysv_runlevels) &&

chars_intersect(RUNLEVELS_UP, s->sysv_runlevels)) {

/* Service has both boot and "up" runlevels

delete_chars(s->sysv_runlevels, RUNLEVELS_UP);

}

if (s->sysv_runlevels && !chars_intersect(RUNLEVELS_UP, s->sysv_runlevels)) {

/* If there a runlevels configured for this service

UNIT(s)->default_dependencies = false;

/* Don't timeout special services during boot (like fsck) */

s->timeout_usec = 0;

} else

s->timeout_usec = DEFAULT_SYSV_TIMEOUT_USEC;

/* Special setting for all SysV services */

s->type = SERVICE_FORKING;

s->remain_after_exit = !s->pid_file;

s->guess_main_pid = false;

s->restart = SERVICE_RESTART_NO;

s->exec_context.ignore_sigpipe = false;

s->kill_context.kill_mode = KILL_PROCESS;

/* We use the long description only if

if (short_description)

description = short_description;

else if (chkconfig_description)

description = chkconfig_description;

else if (long_description)

description = long_description;

else

description = NULL;

if (description) {

char *d;

if (!(d = strappend(s->sysv_has_lsb ? "LSB: " : "SYSV: ", description))) {

r = -ENOMEM;

goto finish;

}

u->description = d;

}

/* The priority that has been set in /etc/rcN.d/ hierarchies

if (s->sysv_start_priority_from_rcnd >= 0)

s->sysv_start_priority = s->sysv_start_priority_from_rcnd;

u->load_state = UNIT_LOADED;

r = 0;

finish:

if (f)

fclose(f);

free(short_description);

free(long_description);

free(chkconfig_description);

return r;

}

static int service_load_sysv_name(Service *s, const char *name) {

char **p;

assert(s);

assert(name);

/* For SysV services we strip the boot.*, rc.* and *.sh

#if defined(TARGET_DEBIAN) || defined(TARGET_UBUNTU) || defined(TARGET_ANGSTROM)

if (endswith(name, ".sh.service"))

return -ENOENT;

#endif

#ifdef TARGET_SUSE

if (startswith(name, "boot."))

return -ENOENT;

#endif

#ifdef TARGET_FRUGALWARE

if (startswith(name, "rc."))

return -ENOENT;

#endif

STRV_FOREACH(p, UNIT(s)->manager->lookup_paths.sysvinit_path) {

char *path;

int r;

path = strjoin(*p, "/", name, NULL);

if (!path)

return -ENOMEM;

assert(endswith(path, ".service"));

path[strlen(path)-8] = 0;

r = service_load_sysv_path(s, path);

#if defined(TARGET_DEBIAN) || defined(TARGET_UBUNTU) || defined(TARGET_ANGSTROM)

if (r >= 0 && UNIT(s)->load_state == UNIT_STUB) {

/* Try Debian style *.sh source'able init scripts */

strcat(path, ".sh");

r = service_load_sysv_path(s, path);

}

#endif

free(path);

#ifdef TARGET_SUSE

if (r >= 0 && UNIT(s)->load_state == UNIT_STUB) {

/* Try SUSE style boot.* init scripts */

path = strjoin(*p, "/boot.", name, NULL);

if (!path)

return -ENOMEM;

/* Drop .service suffix */

path[strlen(path)-8] = 0;

r = service_load_sysv_path(s, path);

free(path);

}

#endif

#ifdef TARGET_FRUGALWARE

if (r >= 0 && UNIT(s)->load_state == UNIT_STUB) {

/* Try Frugalware style rc.* init scripts */

path = strjoin(*p, "/rc.", name, NULL);

if (!path)

return -ENOMEM;

/* Drop .service suffix */

path[strlen(path)-8] = 0;

r = service_load_sysv_path(s, path);

free(path);

}

#endif

if (r < 0)

return r;

if ((UNIT(s)->load_state != UNIT_STUB))

break;

}

return 0;

}

static int service_load_sysv(Service *s) {

const char *t;

Iterator i;

int r;

assert(s);

/* Load service data from SysV init scripts, preferably with

if (strv_isempty(UNIT(s)->manager->lookup_paths.sysvinit_path))

return 0;

if ((t = UNIT(s)->id))

if ((r = service_load_sysv_name(s, t)) < 0)

return r;

if (UNIT(s)->load_state == UNIT_STUB)

SET_FOREACH(t, UNIT(s)->names, i) {

if (t == UNIT(s)->id)

continue;

if ((r = service_load_sysv_name(s, t)) < 0)

return r;

if (UNIT(s)->load_state != UNIT_STUB)

break;

}

return 0;

}

#endif

static int fsck_fix_order(Service *s) {

Unit *other;

int r;

assert(s);

if (s->fsck_passno <= 0)

return 0;

/* For each pair of services where both have an fsck priority

LIST_FOREACH(units_by_type, other, UNIT(s)->manager->units_by_type[UNIT_SERVICE]) {

Service *t;

UnitDependency d;

t = SERVICE(other);

if (s == t)

continue;

if (UNIT(t)->load_state != UNIT_LOADED)

continue;

if (t->fsck_passno <= 0)

continue;

if (t->fsck_passno < s->fsck_passno)

d = UNIT_AFTER;

else if (t->fsck_passno > s->fsck_passno)

d = UNIT_BEFORE;

else

continue;

if ((r = unit_add_dependency(UNIT(s), d, UNIT(t), true)) < 0)

return r;

}

return 0;

}

static int service_verify(Service *s) {

assert(s);

if (UNIT(s)->load_state != UNIT_LOADED)

return 0;

if (!s->exec_command[SERVICE_EXEC_START]) {

log_error("%s lacks ExecStart setting. Refusing.", UNIT(s)->id);

return -EINVAL;

}

if (s->type != SERVICE_ONESHOT &&

s->exec_command[SERVICE_EXEC_START]->command_next) {

log_error("%s has more than one ExecStart setting, which is only allowed for Type=oneshot services. Refusing.", UNIT(s)->id);

return -EINVAL;

}

if (s->type == SERVICE_ONESHOT &&

s->exec_command[SERVICE_EXEC_RELOAD]) {

log_error("%s has an ExecReload setting, which is not allowed for Type=oneshot services. Refusing.", UNIT(s)->id);

return -EINVAL;

}

if (s->type == SERVICE_DBUS && !s->bus_name) {

log_error("%s is of type D-Bus but no D-Bus service name has been specified. Refusing.", UNIT(s)->id);

return -EINVAL;

}

if (s->bus_name && s->type != SERVICE_DBUS)

log_warning("%s has a D-Bus service name specified, but is not of type dbus. Ignoring.", UNIT(s)->id);

if (s->exec_context.pam_name && s->kill_context.kill_mode != KILL_CONTROL_GROUP) {

log_error("%s has PAM enabled. Kill mode must be set to 'control-group'. Refusing.", UNIT(s)->id);

return -EINVAL;

}

return 0;

}

static int service_add_default_dependencies(Service *s) {

int r;

assert(s);

/* Add a number of automatic dependencies useful for the

/* First, pull in base system */

if (UNIT(s)->manager->running_as == MANAGER_SYSTEM) {

if ((r = unit_add_two_dependencies_by_name(UNIT(s), UNIT_AFTER, UNIT_REQUIRES, SPECIAL_BASIC_TARGET, NULL, true)) < 0)

return r;

} else if (UNIT(s)->manager->running_as == MANAGER_USER) {

if ((r = unit_add_two_dependencies_by_name(UNIT(s), UNIT_AFTER, UNIT_REQUIRES, SPECIAL_SOCKETS_TARGET, NULL, true)) < 0)

return r;

}

/* Second, activate normal shutdown */

return unit_add_two_dependencies_by_name(UNIT(s), UNIT_BEFORE, UNIT_CONFLICTS, SPECIAL_SHUTDOWN_TARGET, NULL, true);

}

static void service_fix_output(Service *s) {

assert(s);

/* If nothing has been explicitly configured, patch default

if (s->exec_context.std_error == EXEC_OUTPUT_INHERIT &&

s->exec_context.std_output == EXEC_OUTPUT_INHERIT &&

s->exec_context.std_input == EXEC_INPUT_NULL)

s->exec_context.std_error = UNIT(s)->manager->default_std_error;

if (s->exec_context.std_output == EXEC_OUTPUT_INHERIT &&

s->exec_context.std_input == EXEC_INPUT_NULL)

s->exec_context.std_output = UNIT(s)->manager->default_std_output;

}

static int service_load(Unit *u) {

int r;

Service *s = SERVICE(u);

assert(s);

/* Load a .service file */

if ((r = unit_load_fragment(u)) < 0)

return r;

#ifdef HAVE_SYSV_COMPAT

/* Load a classic init script as a fallback, if we couldn't find anything */

if (u->load_state == UNIT_STUB)

if ((r = service_load_sysv(s)) < 0)

return r;

#endif

/* Still nothing found? Then let's give up */

if (u->load_state == UNIT_STUB)

return -ENOENT;

/* We were able to load something, then let's add in the

if ((r = unit_load_dropin(unit_follow_merge(u))) < 0)

return r;

/* This is a new unit? Then let's add in some extras */

if (u->load_state == UNIT_LOADED) {

if (s->type == _SERVICE_TYPE_INVALID)

s->type = s->bus_name ? SERVICE_DBUS : SERVICE_SIMPLE;

/* Oneshot services have disabled timeout by default */

if (s->type == SERVICE_ONESHOT && !s->timeout_defined)

s->timeout_usec = 0;

service_fix_output(s);

if ((r = unit_add_exec_dependencies(u, &s->exec_context)) < 0)

return r;

if ((r = unit_add_default_cgroups(u)) < 0)

return r;

#ifdef HAVE_SYSV_COMPAT

if ((r = sysv_fix_order(s)) < 0)

return r;

#endif

if ((r = fsck_fix_order(s)) < 0)

return r;

if (s->bus_name)

if ((r = unit_watch_bus_name(u, s->bus_name)) < 0)

return r;

if (s->type == SERVICE_NOTIFY && s->notify_access == NOTIFY_NONE)

s->notify_access = NOTIFY_MAIN;

if (s->watchdog_usec > 0 && s->notify_access == NOTIFY_NONE)

s->notify_access = NOTIFY_MAIN;

if (s->type == SERVICE_DBUS || s->bus_name)

if ((r = unit_add_two_dependencies_by_name(u, UNIT_AFTER, UNIT_REQUIRES, SPECIAL_DBUS_SOCKET, NULL, true)) < 0)

return r;

if (UNIT(s)->default_dependencies)

if ((r = service_add_default_dependencies(s)) < 0)

return r;

r = unit_patch_working_directory(UNIT(s), &s->exec_context);

if (r < 0)

return r;

}

return service_verify(s);

}

static void service_dump(Unit *u, FILE *f, const char *prefix) {

ServiceExecCommand c;

Service *s = SERVICE(u);

const char *prefix2;

char *p2;

assert(s);

p2 = strappend(prefix, "\t");

prefix2 = p2 ? p2 : prefix;

fprintf(f,

"%sService State: %s\n"

"%sResult: %s\n"

"%sReload Result: %s\n"

"%sPermissionsStartOnly: %s\n"

"%sRootDirectoryStartOnly: %s\n"

"%sRemainAfterExit: %s\n"

"%sGuessMainPID: %s\n"

"%sType: %s\n"

"%sRestart: %s\n"

"%sNotifyAccess: %s\n",

prefix, service_state_to_string(s->state),

prefix, service_result_to_string(s->result),

prefix, service_result_to_string(s->reload_result),

prefix, yes_no(s->permissions_start_only),

prefix, yes_no(s->root_directory_start_only),

prefix, yes_no(s->remain_after_exit),

prefix, yes_no(s->guess_main_pid),

prefix, service_type_to_string(s->type),

prefix, service_restart_to_string(s->restart),

prefix, notify_access_to_string(s->notify_access));

if (s->control_pid > 0)

fprintf(f,

"%sControl PID: %lu\n",

prefix, (unsigned long) s->control_pid);

if (s->main_pid > 0)

fprintf(f,

"%sMain PID: %lu\n"

"%sMain PID Known: %s\n"

"%sMain PID Alien: %s\n",

prefix, (unsigned long) s->main_pid,

prefix, yes_no(s->main_pid_known),

prefix, yes_no(s->main_pid_alien));

if (s->pid_file)

fprintf(f,

"%sPIDFile: %s\n",

prefix, s->pid_file);

if (s->bus_name)

fprintf(f,

"%sBusName: %s\n"

"%sBus Name Good: %s\n",

prefix, s->bus_name,

prefix, yes_no(s->bus_name_good));

kill_context_dump(&s->kill_context, f, prefix);

exec_context_dump(&s->exec_context, f, prefix);

for (c = 0; c < _SERVICE_EXEC_COMMAND_MAX; c++) {

if (!s->exec_command[c])

continue;

fprintf(f, "%s-> %s:\n",

prefix, service_exec_command_to_string(c));

exec_command_dump_list(s->exec_command[c], f, prefix2);

}

#ifdef HAVE_SYSV_COMPAT

if (s->is_sysv)

fprintf(f,

"%sSysV Init Script has LSB Header: %s\n"

"%sSysVEnabled: %s\n",

prefix, yes_no(s->sysv_has_lsb),

prefix, yes_no(s->sysv_enabled));

if (s->sysv_start_priority >= 0)

fprintf(f,

"%sSysVStartPriority: %i\n",

prefix, s->sysv_start_priority);

if (s->sysv_runlevels)

fprintf(f, "%sSysVRunLevels: %s\n",

prefix, s->sysv_runlevels);

#endif

if (s->fsck_passno > 0)

fprintf(f,

"%sFsckPassNo: %i\n",

prefix, s->fsck_passno);

if (s->status_text)

fprintf(f, "%sStatus Text: %s\n",

prefix, s->status_text);

free(p2);

}

static int service_load_pid_file(Service *s, bool may_warn) {

char *k;

int r;

pid_t pid;

assert(s);

if (!s->pid_file)

return -ENOENT;

if ((r = read_one_line_file(s->pid_file, &k)) < 0) {

if (may_warn)

log_info("PID file %s not readable (yet?) after %s.",

s->pid_file, service_state_to_string(s->state));

return r;

}

r = parse_pid(k, &pid);

free(k);

if (r < 0)

return r;

if (kill(pid, 0) < 0 && errno != EPERM) {

if (may_warn)

log_info("PID %lu read from file %s does not exist.",

(unsigned long) pid, s->pid_file);

return -ESRCH;

}

if (s->main_pid_known) {

if (pid == s->main_pid)

return 0;

log_debug("Main PID changing: %lu -> %lu",

(unsigned long) s->main_pid, (unsigned long) pid);

service_unwatch_main_pid(s);

s->main_pid_known = false;

} else

log_debug("Main PID loaded: %lu", (unsigned long) pid);

if ((r = service_set_main_pid(s, pid)) < 0)

return r;

if ((r = unit_watch_pid(UNIT(s), pid)) < 0)

/* FIXME: we need to do something here */

return r;

return 0;

}

static int service_search_main_pid(Service *s) {

pid_t pid;

int r;

assert(s);

/* If we know it anyway, don't ever fallback to unreliable

if (s->main_pid_known)

return 0;

if (!s->guess_main_pid)

return 0;

assert(s->main_pid <= 0);

if ((pid = cgroup_bonding_search_main_pid_list(UNIT(s)->cgroup_bondings)) <= 0)

return -ENOENT;

log_debug("Main PID guessed: %lu", (unsigned long) pid);

if ((r = service_set_main_pid(s, pid)) < 0)

return r;

if ((r = unit_watch_pid(UNIT(s), pid)) < 0)

/* FIXME: we need to do something here */

return r;

return 0;

}

static void service_notify_sockets_dead(Service *s, bool failed_permanent) {

Iterator i;

Unit *u;

assert(s);

/* Notifies all our sockets when we die */

if (s->socket_fd >= 0)

return;

SET_FOREACH(u, UNIT(s)->dependencies[UNIT_TRIGGERED_BY], i)

if (u->type == UNIT_SOCKET)

socket_notify_service_dead(SOCKET(u), failed_permanent);

return;

}

static void service_set_state(Service *s, ServiceState state) {

ServiceState old_state;

const UnitActiveState *table;

assert(s);

table = s->type == SERVICE_IDLE ? state_translation_table_idle : state_translation_table;

old_state = s->state;

s->state = state;

service_unwatch_pid_file(s);

if (state != SERVICE_START_PRE &&

state != SERVICE_START &&

state != SERVICE_START_POST &&

state != SERVICE_RELOAD &&

state != SERVICE_STOP &&

state != SERVICE_STOP_SIGTERM &&

state != SERVICE_STOP_SIGKILL &&

state != SERVICE_STOP_POST &&

state != SERVICE_FINAL_SIGTERM &&

state != SERVICE_FINAL_SIGKILL &&

state != SERVICE_AUTO_RESTART)

unit_unwatch_timer(UNIT(s), &s->timer_watch);

if (state != SERVICE_START &&

state != SERVICE_START_POST &&

state != SERVICE_RUNNING &&

state != SERVICE_RELOAD &&

state != SERVICE_STOP &&

state != SERVICE_STOP_SIGTERM &&

state != SERVICE_STOP_SIGKILL) {

service_unwatch_main_pid(s);

s->main_command = NULL;

}

if (state != SERVICE_START_PRE &&

state != SERVICE_START &&

state != SERVICE_START_POST &&

state != SERVICE_RELOAD &&

state != SERVICE_STOP &&

state != SERVICE_STOP_SIGTERM &&

state != SERVICE_STOP_SIGKILL &&

state != SERVICE_STOP_POST &&

state != SERVICE_FINAL_SIGTERM &&

state != SERVICE_FINAL_SIGKILL) {

service_unwatch_control_pid(s);

s->control_command = NULL;

s->control_command_id = _SERVICE_EXEC_COMMAND_INVALID;

}

if (state == SERVICE_DEAD ||

state == SERVICE_STOP ||

state == SERVICE_STOP_SIGTERM ||

state == SERVICE_STOP_SIGKILL ||

state == SERVICE_STOP_POST ||

state == SERVICE_FINAL_SIGTERM ||

state == SERVICE_FINAL_SIGKILL ||

state == SERVICE_FAILED ||

state == SERVICE_AUTO_RESTART)

service_notify_sockets_dead(s, false);

if (state != SERVICE_START_PRE &&

state != SERVICE_START &&

state != SERVICE_START_POST &&

state != SERVICE_RUNNING &&

state != SERVICE_RELOAD &&

state != SERVICE_STOP &&

state != SERVICE_STOP_SIGTERM &&

state != SERVICE_STOP_SIGKILL &&

state != SERVICE_STOP_POST &&

state != SERVICE_FINAL_SIGTERM &&

state != SERVICE_FINAL_SIGKILL &&

!(state == SERVICE_DEAD && UNIT(s)->job)) {

service_close_socket_fd(s);

service_connection_unref(s);

}

if (state == SERVICE_STOP)

service_stop_watchdog(s);

/* For the inactive states unit_notify() will trim the cgroup,

if (state == SERVICE_EXITED && UNIT(s)->manager->n_reloading <= 0)

cgroup_bonding_trim_list(UNIT(s)->cgroup_bondings, true);

if (old_state != state)

log_debug("%s changed %s -> %s", UNIT(s)->id, service_state_to_string(old_state), service_state_to_string(state));

unit_notify(UNIT(s), table[old_state], table[state], s->reload_result == SERVICE_SUCCESS);

s->reload_result = SERVICE_SUCCESS;

}

static int service_coldplug(Unit *u) {

Service *s = SERVICE(u);

int r;

assert(s);

assert(s->state == SERVICE_DEAD);

if (s->deserialized_state != s->state) {

if (s->deserialized_state == SERVICE_START_PRE ||

s->deserialized_state == SERVICE_START ||

s->deserialized_state == SERVICE_START_POST ||

s->deserialized_state == SERVICE_RELOAD ||

s->deserialized_state == SERVICE_STOP ||

s->deserialized_state == SERVICE_STOP_SIGTERM ||

s->deserialized_state == SERVICE_STOP_SIGKILL ||

s->deserialized_state == SERVICE_STOP_POST ||

s->deserialized_state == SERVICE_FINAL_SIGTERM ||

s->deserialized_state == SERVICE_FINAL_SIGKILL ||

s->deserialized_state == SERVICE_AUTO_RESTART) {

if (s->deserialized_state == SERVICE_AUTO_RESTART || s->timeout_usec > 0) {

usec_t k;

k = s->deserialized_state == SERVICE_AUTO_RESTART ? s->restart_usec : s->timeout_usec;

if ((r = unit_watch_timer(UNIT(s), k, &s->timer_watch)) < 0)

return r;

}

}

if ((s->deserialized_state == SERVICE_START &&

(s->type == SERVICE_FORKING ||

s->type == SERVICE_DBUS ||

s->type == SERVICE_ONESHOT ||

s->type == SERVICE_NOTIFY)) ||

s->deserialized_state == SERVICE_START_POST ||

s->deserialized_state == SERVICE_RUNNING ||

s->deserialized_state == SERVICE_RELOAD ||

s->deserialized_state == SERVICE_STOP ||

s->deserialized_state == SERVICE_STOP_SIGTERM ||

s->deserialized_state == SERVICE_STOP_SIGKILL)

if (s->main_pid > 0)

if ((r = unit_watch_pid(UNIT(s), s->main_pid)) < 0)

return r;

if (s->deserialized_state == SERVICE_START_PRE ||

s->deserialized_state == SERVICE_START ||

s->deserialized_state == SERVICE_START_POST ||

s->deserialized_state == SERVICE_RELOAD ||

s->deserialized_state == SERVICE_STOP ||

s->deserialized_state == SERVICE_STOP_SIGTERM ||

s->deserialized_state == SERVICE_STOP_SIGKILL ||

s->deserialized_state == SERVICE_STOP_POST ||

s->deserialized_state == SERVICE_FINAL_SIGTERM ||

s->deserialized_state == SERVICE_FINAL_SIGKILL)

if (s->control_pid > 0)

if ((r = unit_watch_pid(UNIT(s), s->control_pid)) < 0)

return r;

if (s->deserialized_state == SERVICE_START_POST ||

s->deserialized_state == SERVICE_RUNNING)

service_handle_watchdog(s);

service_set_state(s, s->deserialized_state);

}

return 0;

}

static int service_collect_fds(Service *s, int **fds, unsigned *n_fds) {

Iterator i;

int r;

int *rfds = NULL;

unsigned rn_fds = 0;

Unit *u;

assert(s);

assert(fds);

assert(n_fds);

if (s->socket_fd >= 0)

return 0;

SET_FOREACH(u, UNIT(s)->dependencies[UNIT_TRIGGERED_BY], i) {

int *cfds;

unsigned cn_fds;

Socket *sock;

if (u->type != UNIT_SOCKET)

continue;

sock = SOCKET(u);

if ((r = socket_collect_fds(sock, &cfds, &cn_fds)) < 0)

goto fail;

if (!cfds)

continue;

if (!rfds) {

rfds = cfds;

rn_fds = cn_fds;

} else {

int *t;

if (!(t = new(int, rn_fds+cn_fds))) {

free(cfds);

r = -ENOMEM;

goto fail;

}

memcpy(t, rfds, rn_fds * sizeof(int));

memcpy(t+rn_fds, cfds, cn_fds * sizeof(int));

free(rfds);

free(cfds);

rfds = t;

rn_fds = rn_fds+cn_fds;

}

}

*fds = rfds;

*n_fds = rn_fds;

return 0;

fail:

free(rfds);

return r;

}

static int service_spawn(

Service *s,

ExecCommand *c,

bool timeout,

bool pass_fds,

bool apply_permissions,

bool apply_chroot,

bool apply_tty_stdin,

bool set_notify_socket,

bool is_control,

pid_t *_pid) {

pid_t pid;

int r;

int *fds = NULL, *fdsbuf = NULL;

unsigned n_fds = 0, n_env = 0;

char **argv = NULL, **final_env = NULL, **our_env = NULL;

assert(s);

assert(c);

assert(_pid);

if (pass_fds ||

s->exec_context.std_input == EXEC_INPUT_SOCKET ||

s->exec_context.std_output == EXEC_OUTPUT_SOCKET ||

s->exec_context.std_error == EXEC_OUTPUT_SOCKET) {

if (s->socket_fd >= 0) {

fds = &s->socket_fd;

n_fds = 1;

} else {

if ((r = service_collect_fds(s, &fdsbuf, &n_fds)) < 0)

goto fail;

fds = fdsbuf;

}

}

if (timeout && s->timeout_usec) {

if ((r = unit_watch_timer(UNIT(s), s->timeout_usec, &s->timer_watch)) < 0)

goto fail;

} else

unit_unwatch_timer(UNIT(s), &s->timer_watch);

if (!(argv = unit_full_printf_strv(UNIT(s), c->argv))) {

r = -ENOMEM;

goto fail;

}

if (!(our_env = new0(char*, 4))) {

r = -ENOMEM;

goto fail;

}

if (set_notify_socket)

if (asprintf(our_env + n_env++, "NOTIFY_SOCKET=%s", UNIT(s)->manager->notify_socket) < 0) {

r = -ENOMEM;

goto fail;

}

if (s->main_pid > 0)

if (asprintf(our_env + n_env++, "MAINPID=%lu", (unsigned long) s->main_pid) < 0) {

r = -ENOMEM;

goto fail;

}

if (s->watchdog_usec > 0)

if (asprintf(our_env + n_env++, "WATCHDOG_USEC=%llu", (unsigned long long) s->watchdog_usec) < 0) {

r = -ENOMEM;

goto fail;

}

if (!(final_env = strv_env_merge(2,

UNIT(s)->manager->environment,

our_env,

NULL))) {

r = -ENOMEM;

goto fail;

}

r = exec_spawn(c,

argv,

&s->exec_context,

fds, n_fds,

final_env,

apply_permissions,

apply_chroot,

apply_tty_stdin,

UNIT(s)->manager->confirm_spawn,

UNIT(s)->cgroup_bondings,

UNIT(s)->cgroup_attributes,

is_control ? "control" : NULL,

UNIT(s)->id,

s->type == SERVICE_IDLE ? UNIT(s)->manager->idle_pipe : NULL,

&pid);

if (r < 0)

goto fail;

if ((r = unit_watch_pid(UNIT(s), pid)) < 0)

/* FIXME: we need to do something here */

goto fail;

free(fdsbuf);

strv_free(argv);

strv_free(our_env);

strv_free(final_env);

*_pid = pid;

return 0;

fail:

free(fdsbuf);

strv_free(argv);

strv_free(our_env);

strv_free(final_env);

if (timeout)

unit_unwatch_timer(UNIT(s), &s->timer_watch);

return r;

}

static int main_pid_good(Service *s) {

assert(s);

/* Returns 0 if the pid is dead, 1 if it is good, -1 if we

/* If we know the pid file, then lets just check if it is

if (s->main_pid_known) {

/* If it's an alien child let's check if it is still

if (s->main_pid_alien)

return kill(s->main_pid, 0) >= 0 || errno != ESRCH;

/* .. otherwise assume we'll get a SIGCHLD for it,

return s->main_pid > 0;

}

/* We don't know the pid */

return -EAGAIN;

}

static int control_pid_good(Service *s) {

assert(s);

return s->control_pid > 0;

}

static int cgroup_good(Service *s) {

int r;

assert(s);

if ((r = cgroup_bonding_is_empty_list(UNIT(s)->cgroup_bondings)) < 0)

return r;

return !r;

}

static void service_enter_dead(Service *s, ServiceResult f, bool allow_restart) {

int r;

assert(s);

if (f != SERVICE_SUCCESS)

s->result = f;

service_set_state(s, s->result != SERVICE_SUCCESS ? SERVICE_FAILED : SERVICE_DEAD);

if (allow_restart &&

!s->forbid_restart &&

(s->restart == SERVICE_RESTART_ALWAYS ||

(s->restart == SERVICE_RESTART_ON_SUCCESS && s->result == SERVICE_SUCCESS) ||

(s->restart == SERVICE_RESTART_ON_FAILURE && s->result != SERVICE_SUCCESS) ||

(s->restart == SERVICE_RESTART_ON_ABORT && (s->result == SERVICE_FAILURE_SIGNAL ||

s->result == SERVICE_FAILURE_CORE_DUMP)))) {

r = unit_watch_timer(UNIT(s), s->restart_usec, &s->timer_watch);

if (r < 0)

goto fail;

service_set_state(s, SERVICE_AUTO_RESTART);

}

s->forbid_restart = false;

return;

fail:

log_warning("%s failed to run install restart timer: %s", UNIT(s)->id, strerror(-r));

service_enter_dead(s, SERVICE_FAILURE_RESOURCES, false);

}

static void service_enter_signal(Service *s, ServiceState state, ServiceResult f);

static void service_enter_stop_post(Service *s, ServiceResult f) {

int r;

assert(s);

if (f != SERVICE_SUCCESS)

s->result = f;

service_unwatch_control_pid(s);

if ((s->control_command = s->exec_command[SERVICE_EXEC_STOP_POST])) {

s->control_command_id = SERVICE_EXEC_STOP_POST;

r = service_spawn(s,

s->control_command,

true,

false,

!s->permissions_start_only,

!s->root_directory_start_only,

true,

false,

true,

&s->control_pid);

if (r < 0)

goto fail;

service_set_state(s, SERVICE_STOP_POST);

} else

service_enter_signal(s, SERVICE_FINAL_SIGTERM, SERVICE_SUCCESS);

return;

fail:

log_warning("%s failed to run 'stop-post' task: %s", UNIT(s)->id, strerror(-r));

service_enter_signal(s, SERVICE_FINAL_SIGTERM, SERVICE_FAILURE_RESOURCES);

}

static void service_enter_signal(Service *s, ServiceState state, ServiceResult f) {

int r;

Set *pid_set = NULL;

bool wait_for_exit = false;

assert(s);

if (f != SERVICE_SUCCESS)

s->result = f;

if (s->kill_context.kill_mode != KILL_NONE) {

int sig = (state == SERVICE_STOP_SIGTERM || state == SERVICE_FINAL_SIGTERM) ? s->kill_context.kill_signal : SIGKILL;

if (s->main_pid > 0) {

if (kill_and_sigcont(s->main_pid, sig) < 0 && errno != ESRCH)

log_warning("Failed to kill main process %li: %m", (long) s->main_pid);

else

wait_for_exit = !s->main_pid_alien;

}

if (s->control_pid > 0) {

if (kill_and_sigcont(s->control_pid, sig) < 0 && errno != ESRCH)

log_warning("Failed to kill control process %li: %m", (long) s->control_pid);

else

wait_for_exit = true;

}

if (s->kill_context.kill_mode == KILL_CONTROL_GROUP) {

pid_set = set_new(trivial_hash_func, trivial_compare_func);

if (!pid_set) {

r = -ENOMEM;

goto fail;

}

/* Exclude the main/control pids from being killed via the cgroup */

if (s->main_pid > 0)

if ((r = set_put(pid_set, LONG_TO_PTR(s->main_pid))) < 0)

goto fail;

if (s->control_pid > 0)

if ((r = set_put(pid_set, LONG_TO_PTR(s->control_pid))) < 0)

goto fail;

r = cgroup_bonding_kill_list(UNIT(s)->cgroup_bondings, sig, true, false, pid_set, NULL);

if (r < 0) {

if (r != -EAGAIN && r != -ESRCH && r != -ENOENT)

log_warning("Failed to kill control group: %s", strerror(-r));

} else if (r > 0)

wait_for_exit = true;

set_free(pid_set);

pid_set = NULL;

}

}

if (wait_for_exit) {

if (s->timeout_usec > 0)

if ((r = unit_watch_timer(UNIT(s), s->timeout_usec, &s->timer_watch)) < 0)

goto fail;

service_set_state(s, state);

} else if (state == SERVICE_STOP_SIGTERM || state == SERVICE_STOP_SIGKILL)

service_enter_stop_post(s, SERVICE_SUCCESS);

else

service_enter_dead(s, SERVICE_SUCCESS, true);

return;

fail:

log_warning("%s failed to kill processes: %s", UNIT(s)->id, strerror(-r));

if (state == SERVICE_STOP_SIGTERM || state == SERVICE_STOP_SIGKILL)

service_enter_stop_post(s, SERVICE_FAILURE_RESOURCES);

else

service_enter_dead(s, SERVICE_FAILURE_RESOURCES, true);

if (pid_set)

set_free(pid_set);

}

static void service_enter_stop(Service *s, ServiceResult f) {

int r;

assert(s);

if (f != SERVICE_SUCCESS)

s->result = f;

service_unwatch_control_pid(s);

if ((s->control_command = s->exec_command[SERVICE_EXEC_STOP])) {

s->control_command_id = SERVICE_EXEC_STOP;

r = service_spawn(s,

s->control_command,

true,

false,

!s->permissions_start_only,

!s->root_directory_start_only,

false,

false,

true,

&s->control_pid);

if (r < 0)

goto fail;

service_set_state(s, SERVICE_STOP);

} else

service_enter_signal(s, SERVICE_STOP_SIGTERM, SERVICE_SUCCESS);

return;

fail:

log_warning("%s failed to run 'stop' task: %s", UNIT(s)->id, strerror(-r));

service_enter_signal(s, SERVICE_STOP_SIGTERM, SERVICE_FAILURE_RESOURCES);

}

static void service_enter_running(Service *s, ServiceResult f) {

int main_pid_ok, cgroup_ok;

assert(s);

if (f != SERVICE_SUCCESS)

s->result = f;

main_pid_ok = main_pid_good(s);

cgroup_ok = cgroup_good(s);

if ((main_pid_ok > 0 || (main_pid_ok < 0 && cgroup_ok != 0)) &&

(s->bus_name_good || s->type != SERVICE_DBUS))

service_set_state(s, SERVICE_RUNNING);

else if (s->remain_after_exit)

service_set_state(s, SERVICE_EXITED);

else

service_enter_stop(s, SERVICE_SUCCESS);

}

static void service_enter_start_post(Service *s) {

int r;

assert(s);

service_unwatch_control_pid(s);

if (s->watchdog_usec > 0)

service_reset_watchdog(s);

if ((s->control_command = s->exec_command[SERVICE_EXEC_START_POST])) {

s->control_command_id = SERVICE_EXEC_START_POST;

r = service_spawn(s,

s->control_command,

true,

false,

!s->permissions_start_only,

!s->root_directory_start_only,

false,

false,

true,

&s->control_pid);

if (r < 0)

goto fail;

service_set_state(s, SERVICE_START_POST);

} else

service_enter_running(s, SERVICE_SUCCESS);

return;

fail:

log_warning("%s failed to run 'start-post' task: %s", UNIT(s)->id, strerror(-r));

service_enter_stop(s, SERVICE_FAILURE_RESOURCES);

}

static void service_enter_start(Service *s) {

pid_t pid;

int r;

ExecCommand *c;

assert(s);

assert(s->exec_command[SERVICE_EXEC_START]);

assert(!s->exec_command[SERVICE_EXEC_START]->command_next || s->type == SERVICE_ONESHOT);

if (s->type == SERVICE_FORKING)

service_unwatch_control_pid(s);

else

service_unwatch_main_pid(s);

/* We want to ensure that nobody leaks processes from

cgroup_bonding_kill_list(UNIT(s)->cgroup_bondings, SIGKILL, true, true, NULL, "control");

if (s->type == SERVICE_FORKING) {

s->control_command_id = SERVICE_EXEC_START;

c = s->control_command = s->exec_command[SERVICE_EXEC_START];

s->main_command = NULL;

} else {

s->control_command_id = _SERVICE_EXEC_COMMAND_INVALID;

s->control_command = NULL;

c = s->main_command = s->exec_command[SERVICE_EXEC_START];

}

r = service_spawn(s,

c,

s->type == SERVICE_FORKING || s->type == SERVICE_DBUS || s->type == SERVICE_NOTIFY || s->type == SERVICE_ONESHOT,

true,

true,

true,

true,

s->notify_access != NOTIFY_NONE,

false,

&pid);

if (r < 0)

goto fail;

if (s->type == SERVICE_SIMPLE || s->type == SERVICE_IDLE) {

/* For simple services we immediately start

service_set_main_pid(s, pid);

service_enter_start_post(s);

} else if (s->type == SERVICE_FORKING) {

/* For forking services we wait until the start

s->control_pid = pid;

service_set_state(s, SERVICE_START);

} else if (s->type == SERVICE_ONESHOT ||

s->type == SERVICE_DBUS ||

s->type == SERVICE_NOTIFY) {

/* For oneshot services we wait until the start

/* For D-Bus services we know the main pid right away,

service_set_main_pid(s, pid);

service_set_state(s, SERVICE_START);

} else

assert_not_reached("Unknown service type");

return;

fail:

log_warning("%s failed to run 'start' task: %s", UNIT(s)->id, strerror(-r));

service_enter_signal(s, SERVICE_FINAL_SIGTERM, SERVICE_FAILURE_RESOURCES);

}

static void service_enter_start_pre(Service *s) {

int r;

assert(s);

service_unwatch_control_pid(s);

if ((s->control_command = s->exec_command[SERVICE_EXEC_START_PRE])) {

/* Before we start anything, let's clear up what might

cgroup_bonding_kill_list(UNIT(s)->cgroup_bondings, SIGKILL, true, true, NULL, "control");

s->control_command_id = SERVICE_EXEC_START_PRE;

r = service_spawn(s,

s->control_command,

true,

false,

!s->permissions_start_only,

!s->root_directory_start_only,

true,

false,

true,

&s->control_pid);

if (r < 0)

goto fail;

service_set_state(s, SERVICE_START_PRE);

} else

service_enter_start(s);

return;

fail:

log_warning("%s failed to run 'start-pre' task: %s", UNIT(s)->id, strerror(-r));

service_enter_dead(s, SERVICE_FAILURE_RESOURCES, true);

}

static void service_enter_restart(Service *s) {

int r;

DBusError error;

assert(s);

dbus_error_init(&error);

if (UNIT(s)->job && UNIT(s)->job->type == JOB_STOP) {

/* Don't restart things if we are going down anyway */

log_info("Stop job pending for unit, delaying automatic restart.");

r = unit_watch_timer(UNIT(s), s->restart_usec, &s->timer_watch);

if (r < 0)

goto fail;

return;

}

/* Any units that are bound to this service must also be

r = manager_add_job(UNIT(s)->manager, JOB_RESTART, UNIT(s), JOB_FAIL, false, &error, NULL);

if (r < 0)

goto fail;

/* Note that we stay in the SERVICE_AUTO_RESTART state here,

log_debug("%s scheduled restart job.", UNIT(s)->id);

return;

fail:

log_warning("%s failed to schedule restart job: %s", UNIT(s)->id, bus_error(&error, -r));

service_enter_dead(s, SERVICE_FAILURE_RESOURCES, false);

dbus_error_free(&error);

}

static void service_enter_reload(Service *s) {

int r;

assert(s);

service_unwatch_control_pid(s);

if ((s->control_command = s->exec_command[SERVICE_EXEC_RELOAD])) {

s->control_command_id = SERVICE_EXEC_RELOAD;

r = service_spawn(s,

s->control_command,

true,

false,

!s->permissions_start_only,

!s->root_directory_start_only,

false,

false,

true,

&s->control_pid);

if (r < 0)

goto fail;

service_set_state(s, SERVICE_RELOAD);

} else

service_enter_running(s, SERVICE_SUCCESS);

return;

fail:

log_warning("%s failed to run 'reload' task: %s", UNIT(s)->id, strerror(-r));

s->reload_result = SERVICE_FAILURE_RESOURCES;

service_enter_running(s, SERVICE_SUCCESS);

}

static void service_run_next_control(Service *s) {

int r;

assert(s);

assert(s->control_command);

assert(s->control_command->command_next);

assert(s->control_command_id != SERVICE_EXEC_START);

s->control_command = s->control_command->command_next;

service_unwatch_control_pid(s);

r = service_spawn(s,

s->control_command,

true,

false,

!s->permissions_start_only,

!s->root_directory_start_only,

s->control_command_id == SERVICE_EXEC_START_PRE ||

s->control_command_id == SERVICE_EXEC_STOP_POST,

false,

true,

&s->control_pid);

if (r < 0)

goto fail;

return;

fail:

log_warning("%s failed to run next control task: %s", UNIT(s)->id, strerror(-r));

if (s->state == SERVICE_START_PRE)

service_enter_signal(s, SERVICE_FINAL_SIGTERM, SERVICE_FAILURE_RESOURCES);

else if (s->state == SERVICE_STOP)

service_enter_signal(s, SERVICE_STOP_SIGTERM, SERVICE_FAILURE_RESOURCES);

else if (s->state == SERVICE_STOP_POST)

service_enter_dead(s, SERVICE_FAILURE_RESOURCES, true);

else if (s->state == SERVICE_RELOAD) {

s->reload_result = SERVICE_FAILURE_RESOURCES;

service_enter_running(s, SERVICE_SUCCESS);

} else

service_enter_stop(s, SERVICE_FAILURE_RESOURCES);

}

static void service_run_next_main(Service *s) {

pid_t pid;

int r;

assert(s);

assert(s->main_command);

assert(s->main_command->command_next);

assert(s->type == SERVICE_ONESHOT);

s->main_command = s->main_command->command_next;

service_unwatch_main_pid(s);

r = service_spawn(s,

s->main_command,

true,

true,

true,

true,

true,

s->notify_access != NOTIFY_NONE,

false,

&pid);

if (r < 0)

goto fail;

service_set_main_pid(s, pid);

return;

fail:

log_warning("%s failed to run next main task: %s", UNIT(s)->id, strerror(-r));

service_enter_stop(s, SERVICE_FAILURE_RESOURCES);

}

static int service_start_limit_test(Service *s) {

assert(s);

if (ratelimit_test(&s->start_limit))

return 0;

switch (s->start_limit_action) {

case SERVICE_START_LIMIT_NONE:

log_warning("%s start request repeated too quickly, refusing to start.", UNIT(s)->id);

break;

case SERVICE_START_LIMIT_REBOOT: {

DBusError error;

int r;

dbus_error_init(&error);

log_warning("%s start request repeated too quickly, rebooting.", UNIT(s)->id);

r = manager_add_job_by_name(UNIT(s)->manager, JOB_START, SPECIAL_REBOOT_TARGET, JOB_REPLACE, true, &error, NULL);

if (r < 0) {

log_error("Failed to reboot: %s.", bus_error(&error, r));

dbus_error_free(&error);

}

break;

}

case SERVICE_START_LIMIT_REBOOT_FORCE:

log_warning("%s start request repeated too quickly, forcibly rebooting.", UNIT(s)->id);

UNIT(s)->manager->exit_code = MANAGER_REBOOT;

break;

case SERVICE_START_LIMIT_REBOOT_IMMEDIATE:

log_warning("%s start request repeated too quickly, rebooting immediately.", UNIT(s)->id);

reboot(RB_AUTOBOOT);

break;

default:

log_error("start limit action=%i", s->start_limit_action);

assert_not_reached("Unknown StartLimitAction.");

}

return -ECANCELED;

}

static int service_start(Unit *u) {

Service *s = SERVICE(u);

int r;

assert(s);

/* We cannot fulfill this request right now, try again later

if (s->state == SERVICE_STOP ||

s->state == SERVICE_STOP_SIGTERM ||

s->state == SERVICE_STOP_SIGKILL ||

s->state == SERVICE_STOP_POST ||

s->state == SERVICE_FINAL_SIGTERM ||

s->state == SERVICE_FINAL_SIGKILL)

return -EAGAIN;

/* Already on it! */

if (s->state == SERVICE_START_PRE ||

s->state == SERVICE_START ||

s->state == SERVICE_START_POST)

return 0;

/* A service that will be restarted must be stopped first to

if (s->state == SERVICE_AUTO_RESTART)

return -EAGAIN;

assert(s->state == SERVICE_DEAD || s->state == SERVICE_FAILED);

/* Make sure we don't enter a busy loop of some kind. */

r = service_start_limit_test(s);

if (r < 0) {

service_notify_sockets_dead(s, true);

return r;

}

s->result = SERVICE_SUCCESS;

s->reload_result = SERVICE_SUCCESS;

s->main_pid_known = false;

s->main_pid_alien = false;

s->forbid_restart = false;

service_enter_start_pre(s);

return 0;

}

static int service_stop(Unit *u) {

Service *s = SERVICE(u);

assert(s);

/* Don't create restart jobs from here. */

s->forbid_restart = true;

/* Already on it */

if (s->state == SERVICE_STOP ||

s->state == SERVICE_STOP_SIGTERM ||

s->state == SERVICE_STOP_SIGKILL ||

s->state == SERVICE_STOP_POST ||

s->state == SERVICE_FINAL_SIGTERM ||

s->state == SERVICE_FINAL_SIGKILL)

return 0;

/* A restart will be scheduled or is in progress. */

if (s->state == SERVICE_AUTO_RESTART) {

service_set_state(s, SERVICE_DEAD);

return 0;

}

/* If there's already something running we go directly into

if (s->state == SERVICE_START_PRE ||

s->state == SERVICE_START ||

s->state == SERVICE_START_POST ||

s->state == SERVICE_RELOAD) {

service_enter_signal(s, SERVICE_STOP_SIGTERM, SERVICE_SUCCESS);

return 0;

}

assert(s->state == SERVICE_RUNNING ||

s->state == SERVICE_EXITED);

service_enter_stop(s, SERVICE_SUCCESS);

return 0;

}

static int service_reload(Unit *u) {

Service *s = SERVICE(u);

assert(s);

assert(s->state == SERVICE_RUNNING || s->state == SERVICE_EXITED);

service_enter_reload(s);

return 0;

}

static bool service_can_reload(Unit *u) {

Service *s = SERVICE(u);

assert(s);

return !!s->exec_command[SERVICE_EXEC_RELOAD];

}

static int service_serialize(Unit *u, FILE *f, FDSet *fds) {

Service *s = SERVICE(u);

assert(u);

assert(f);

assert(fds);

unit_serialize_item(u, f, "state", service_state_to_string(s->state));

unit_serialize_item(u, f, "result", service_result_to_string(s->result));

unit_serialize_item(u, f, "reload-result", service_result_to_string(s->reload_result));

if (s->control_pid > 0)

unit_serialize_item_format(u, f, "control-pid", "%lu", (unsigned long) s->control_pid);

if (s->main_pid_known && s->main_pid > 0)

unit_serialize_item_format(u, f, "main-pid", "%lu", (unsigned long) s->main_pid);

unit_serialize_item(u, f, "main-pid-known", yes_no(s->main_pid_known));

if (s->status_text)

unit_serialize_item(u, f, "status-text", s->status_text);

/* FIXME: There's a minor uncleanliness here: if there are

if (s->control_command_id >= 0)

unit_serialize_item(u, f, "control-command", service_exec_command_to_string(s->control_command_id));

if (s->socket_fd >= 0) {

int copy;

if ((copy = fdset_put_dup(fds, s->socket_fd)) < 0)

return copy;

unit_serialize_item_format(u, f, "socket-fd", "%i", copy);

}

if (s->main_exec_status.pid > 0) {

unit_serialize_item_format(u, f, "main-exec-status-pid", "%lu", (unsigned long) s->main_exec_status.pid);

dual_timestamp_serialize(f, "main-exec-status-start", &s->main_exec_status.start_timestamp);

dual_timestamp_serialize(f, "main-exec-status-exit", &s->main_exec_status.exit_timestamp);

if (dual_timestamp_is_set(&s->main_exec_status.exit_timestamp)) {

unit_serialize_item_format(u, f, "main-exec-status-code", "%i", s->main_exec_status.code);

unit_serialize_item_format(u, f, "main-exec-status-status", "%i", s->main_exec_status.status);

}

}

if (dual_timestamp_is_set(&s->watchdog_timestamp))

dual_timestamp_serialize(f, "watchdog-timestamp", &s->watchdog_timestamp);

return 0;

}

static int service_deserialize_item(Unit *u, const char *key, const char *value, FDSet *fds) {

Service *s = SERVICE(u);

assert(u);

assert(key);

assert(value);

assert(fds);

if (streq(key, "state")) {

ServiceState state;

if ((state = service_state_from_string(value)) < 0)

log_debug("Failed to parse state value %s", value);

else

s->deserialized_state = state;

} else if (streq(key, "result")) {

ServiceResult f;

f = service_result_from_string(value);

if (f < 0)

log_debug("Failed to parse result value %s", value);

else if (f != SERVICE_SUCCESS)

s->result = f;

} else if (streq(key, "reload-result")) {

ServiceResult f;

f = service_result_from_string(value);

if (f < 0)

log_debug("Failed to parse reload result value %s", value);

else if (f != SERVICE_SUCCESS)

s->reload_result = f;

} else if (streq(key, "control-pid")) {

pid_t pid;

if (parse_pid(value, &pid) < 0)

log_debug("Failed to parse control-pid value %s", value);

else

s->control_pid = pid;

} else if (streq(key, "main-pid")) {

pid_t pid;

if (parse_pid(value, &pid) < 0)

log_debug("Failed to parse main-pid value %s", value);

else

service_set_main_pid(s, (pid_t) pid);

} else if (streq(key, "main-pid-known")) {

int b;

if ((b = parse_boolean(value)) < 0)

log_debug("Failed to parse main-pid-known value %s", value);

else

s->main_pid_known = b;

} else if (streq(key, "status-text")) {

char *t;

if ((t = strdup(value))) {

free(s->status_text);

s->status_text = t;

}

} else if (streq(key, "control-command")) {

ServiceExecCommand id;

if ((id = service_exec_command_from_string(value)) < 0)

log_debug("Failed to parse exec-command value %s", value);

else {

s->control_command_id = id;

s->control_command = s->exec_command[id];

}

} else if (streq(key, "socket-fd")) {

int fd;

if (safe_atoi(value, &fd) < 0 || fd < 0 || !fdset_contains(fds, fd))

log_debug("Failed to parse socket-fd value %s", value);

else {

if (s->socket_fd >= 0)

close_nointr_nofail(s->socket_fd);

s->socket_fd = fdset_remove(fds, fd);

}

} else if (streq(key, "main-exec-status-pid")) {

pid_t pid;

if (parse_pid(value, &pid) < 0)

log_debug("Failed to parse main-exec-status-pid value %s", value);

else

s->main_exec_status.pid = pid;

} else if (streq(key, "main-exec-status-code")) {

int i;

if (safe_atoi(value, &i) < 0)

log_debug("Failed to parse main-exec-status-code value %s", value);

else

s->main_exec_status.code = i;

} else if (streq(key, "main-exec-status-status")) {

int i;

if (safe_atoi(value, &i) < 0)

log_debug("Failed to parse main-exec-status-status value %s", value);

else

s->main_exec_status.status = i;

} else if (streq(key, "main-exec-status-start"))

dual_timestamp_deserialize(value, &s->main_exec_status.start_timestamp);

else if (streq(key, "main-exec-status-exit"))

dual_timestamp_deserialize(value, &s->main_exec_status.exit_timestamp);

else if (streq(key, "watchdog-timestamp"))

dual_timestamp_deserialize(value, &s->watchdog_timestamp);

else

log_debug("Unknown serialization key '%s'", key);

return 0;

}

static UnitActiveState service_active_state(Unit *u) {

const UnitActiveState *table;

assert(u);

table = SERVICE(u)->type == SERVICE_IDLE ? state_translation_table_idle : state_translation_table;

return table[SERVICE(u)->state];

}

static const char *service_sub_state_to_string(Unit *u) {

assert(u);

return service_state_to_string(SERVICE(u)->state);

}

static bool service_check_gc(Unit *u) {

Service *s = SERVICE(u);

assert(s);

/* Never clean up services that still have a process around,

if (cgroup_good(s) > 0 ||

main_pid_good(s) > 0 ||

control_pid_good(s) > 0)

return true;

#ifdef HAVE_SYSV_COMPAT

if (s->is_sysv)

return true;

#endif

return false;

}

static bool service_check_snapshot(Unit *u) {

Service *s = SERVICE(u);

assert(s);

return !s->got_socket_fd;

}

static int service_retry_pid_file(Service *s) {

int r;

assert(s->pid_file);

assert(s->state == SERVICE_START || s->state == SERVICE_START_POST);

r = service_load_pid_file(s, false);

if (r < 0)

return r;

service_unwatch_pid_file(s);

service_enter_running(s, SERVICE_SUCCESS);

return 0;

}

static int service_watch_pid_file(Service *s) {

int r;

log_debug("Setting watch for %s's PID file %s", UNIT(s)->id, s->pid_file_pathspec->path);

r = path_spec_watch(s->pid_file_pathspec, UNIT(s));

if (r < 0)

goto fail;

/* the pidfile might have appeared just before we set the watch */

service_retry_pid_file(s);

return 0;

fail:

log_error("Failed to set a watch for %s's PID file %s: %s",

UNIT(s)->id, s->pid_file_pathspec->path, strerror(-r));

service_unwatch_pid_file(s);

return r;

}

static int service_demand_pid_file(Service *s) {

PathSpec *ps;

assert(s->pid_file);

assert(!s->pid_file_pathspec);

ps = new0(PathSpec, 1);

if (!ps)

return -ENOMEM;

ps->path = strdup(s->pid_file);

if (!ps->path) {

free(ps);

return -ENOMEM;

}

path_kill_slashes(ps->path);

/* PATH_CHANGED would not be enough. There are daemons (sendmail) that

ps->type = PATH_MODIFIED;

ps->inotify_fd = -1;

s->pid_file_pathspec = ps;

return service_watch_pid_file(s);

}

static void service_fd_event(Unit *u, int fd, uint32_t events, Watch *w) {

Service *s = SERVICE(u);

assert(s);

assert(fd >= 0);

assert(s->state == SERVICE_START || s->state == SERVICE_START_POST);

assert(s->pid_file_pathspec);

assert(path_spec_owns_inotify_fd(s->pid_file_pathspec, fd));

log_debug("inotify event for %s", u->id);

if (path_spec_fd_event(s->pid_file_pathspec, events) < 0)

goto fail;

if (service_retry_pid_file(s) == 0)

return;

if (service_watch_pid_file(s) < 0)

goto fail;

return;

fail:

service_unwatch_pid_file(s);

service_enter_signal(s, SERVICE_STOP_SIGTERM, SERVICE_FAILURE_RESOURCES);

}

static void service_sigchld_event(Unit *u, pid_t pid, int code, int status) {

Service *s = SERVICE(u);

ServiceResult f;

assert(s);

assert(pid >= 0);

if (UNIT(s)->fragment_path ? is_clean_exit(code, status) : is_clean_exit_lsb(code, status))

f = SERVICE_SUCCESS;

else if (code == CLD_EXITED)

f = SERVICE_FAILURE_EXIT_CODE;

else if (code == CLD_KILLED)

f = SERVICE_FAILURE_SIGNAL;

else if (code == CLD_DUMPED)

f = SERVICE_FAILURE_CORE_DUMP;

else

assert_not_reached("Unknown code");

if (s->main_pid == pid) {

/* Forking services may occasionally move to a new PID.

if (service_load_pid_file(s, false) == 0)

return;

s->main_pid = 0;

exec_status_exit(&s->main_exec_status, &s->exec_context, pid, code, status);

/* If this is not a forking service than the main

if (s->main_command) {

s->main_command->exec_status = s->main_exec_status;

if (s->main_command->ignore)

f = SERVICE_SUCCESS;

}

log_full(f == SERVICE_SUCCESS ? LOG_DEBUG : LOG_NOTICE,

"%s: main process exited, code=%s, status=%i", u->id, sigchld_code_to_string(code), status);

if (f != SERVICE_SUCCESS)

s->result = f;

if (s->main_command &&

s->main_command->command_next &&

f == SERVICE_SUCCESS) {

/* There is another command to *

log_debug("%s running next main command for state %s", u->id, service_state_to_string(s->state));

service_run_next_main(s);

} else {

/* The service exited, so the service is officially

s->main_command = NULL;

switch (s->state) {

case SERVICE_START_POST:

case SERVICE_RELOAD:

case SERVICE_STOP:

/* Need to wait until the operation is

break;

case SERVICE_START:

if (s->type == SERVICE_ONESHOT) {

/* This was our main goal, so let's go on */

if (f == SERVICE_SUCCESS)

service_enter_start_post(s);

else

service_enter_signal(s, SERVICE_FINAL_SIGTERM, f);

break;

} else {

assert(s->type == SERVICE_DBUS || s->type == SERVICE_NOTIFY);

/* Fall through */

}

case SERVICE_RUNNING:

service_enter_running(s, f);

break;

case SERVICE_STOP_SIGTERM:

case SERVICE_STOP_SIGKILL:

if (!control_pid_good(s))

service_enter_stop_post(s, f);

/* If there is still a control process, wait for that first */

break;

default:

assert_not_reached("Uh, main process died at wrong time.");

}

}

} else if (s->control_pid == pid) {

s->control_pid = 0;

if (s->control_command) {

exec_status_exit(&s->control_command->exec_status, &s->exec_context, pid, code, status);

if (s->control_command->ignore)

f = SERVICE_SUCCESS;

}

log_full(f == SERVICE_SUCCESS ? LOG_DEBUG : LOG_NOTICE,

"%s: control process exited, code=%s status=%i", u->id, sigchld_code_to_string(code), status);

if (f != SERVICE_SUCCESS)

s->result = f;

/* Immediately get rid of the cgroup, so that the

cgroup_bonding_kill_list(UNIT(s)->cgroup_bondings, SIGKILL, true, true, NULL, "control");

if (s->control_command &&

s->control_command->command_next &&

f == SERVICE_SUCCESS) {

/* There is another command to *

log_debug("%s running next control command for state %s", u->id, service_state_to_string(s->state));

service_run_next_control(s);

} else {

/* No further commands for this step, so let's

s->control_command = NULL;

s->control_command_id = _SERVICE_EXEC_COMMAND_INVALID;

log_debug("%s got final SIGCHLD for state %s", u->id, service_state_to_string(s->state));

switch (s->state) {

case SERVICE_START_PRE:

if (f == SERVICE_SUCCESS)

service_enter_start(s);

else

service_enter_signal(s, SERVICE_FINAL_SIGTERM, f);

break;

case SERVICE_START:

assert(s->type == SERVICE_FORKING);

if (f != SERVICE_SUCCESS) {

service_enter_signal(s, SERVICE_FINAL_SIGTERM, f);

break;

}

if (s->pid_file) {

bool has_start_post;

int r;

/* Let's try to load the pid file here if we can.

has_start_post = !!s->exec_command[SERVICE_EXEC_START_POST];

r = service_load_pid_file(s, !has_start_post);

if (!has_start_post && r < 0) {

r = service_demand_pid_file(s);

if (r < 0 || !cgroup_good(s))

service_enter_signal(s, SERVICE_FINAL_SIGTERM, SERVICE_FAILURE_RESOURCES);

break;

}

} else

service_search_main_pid(s);

service_enter_start_post(s);

break;

case SERVICE_START_POST:

if (f != SERVICE_SUCCESS) {

service_enter_stop(s, f);

break;

}

if (s->pid_file) {

int r;

r = service_load_pid_file(s, true);

if (r < 0) {

r = service_demand_pid_file(s);

if (r < 0 || !cgroup_good(s))

service_enter_stop(s, SERVICE_FAILURE_RESOURCES);

break;

}

} else

service_search_main_pid(s);

service_enter_running(s, SERVICE_SUCCESS);

break;

case SERVICE_RELOAD:

if (f == SERVICE_SUCCESS) {

service_load_pid_file(s, true);

service_search_main_pid(s);

}

s->reload_result = f;

service_enter_running(s, SERVICE_SUCCESS);

break;

case SERVICE_STOP:

service_enter_signal(s, SERVICE_STOP_SIGTERM, f);

break;

case SERVICE_STOP_SIGTERM:

case SERVICE_STOP_SIGKILL:

if (main_pid_good(s) <= 0)