X-Git-Url: https://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=job.c;h=378a85df6708652bc6fc4e6dea9edc0ba7957aad;hb=94f043472a5af62dc9cd5767e89ba33872212d5e;hp=ff30864e438fd2a3e666babcc7057aae94c6a8a2;hpb=87f0e418cf2c58b3201d06a60e3696ec672d2662;p=elogind.git diff --git a/job.c b/job.c index ff30864e4..378a85df6 100644 --- a/job.c +++ b/job.c @@ -3,8 +3,13 @@ #include #include +#include "set.h" +#include "unit.h" #include "macro.h" -#include "job.h" +#include "strv.h" +#include "load-fragment.h" +#include "load-dropin.h" +#include "log.h" Job* job_new(Manager *m, JobType type, Unit *unit) { Job *j; @@ -108,30 +113,8 @@ void job_dependency_delete(Job *subject, Job *object, bool *matters) { job_dependency_free(l); } -const char* job_type_to_string(JobType t) { - - static const char* const job_type_table[_JOB_TYPE_MAX] = { - [JOB_START] = "start", - [JOB_VERIFY_ACTIVE] = "verify-active", - [JOB_STOP] = "stop", - [JOB_RELOAD] = "reload", - [JOB_RELOAD_OR_START] = "reload-or-start", - [JOB_RESTART] = "restart", - [JOB_TRY_RESTART] = "try-restart", - }; - - if (t < 0 || t >= _JOB_TYPE_MAX) - return "n/a"; - - return job_type_table[t]; -} - void job_dump(Job *j, FILE*f, const char *prefix) { - static const char* const job_state_table[_JOB_STATE_MAX] = { - [JOB_WAITING] = "waiting", - [JOB_RUNNING] = "running" - }; assert(j); assert(f); @@ -143,7 +126,7 @@ void job_dump(Job *j, FILE*f, const char *prefix) { "%s\tForced: %s\n", prefix, j->id, prefix, unit_id(j->unit), job_type_to_string(j->type), - prefix, job_state_table[j->state], + prefix, job_state_to_string(j->state), prefix, yes_no(j->forced)); } @@ -405,10 +388,18 @@ int job_finish_and_invalidate(Job *j, bool success) { assert(j); assert(j->installed); + log_debug("Job %s/%s finished, success=%s", unit_id(j->unit), job_type_to_string(j->type), yes_no(success)); + /* Patch restart jobs so that they become normal start jobs */ if (success && (j->type == JOB_RESTART || j->type == JOB_TRY_RESTART)) { + + log_debug("Converting job %s/%s → %s/%s", + unit_id(j->unit), job_type_to_string(j->type), + unit_id(j->unit), job_type_to_string(JOB_START)); + j->state = JOB_RUNNING; j->type = JOB_START; + job_schedule_run(j); return 0; } @@ -471,3 +462,22 @@ void job_schedule_run(Job *j) { LIST_PREPEND(Job, run_queue, j->manager->run_queue, j); j->in_run_queue = true; } + +static const char* const job_state_table[_JOB_STATE_MAX] = { + [JOB_WAITING] = "waiting", + [JOB_RUNNING] = "running" +}; + +DEFINE_STRING_TABLE_LOOKUP(job_state, JobState); + +static const char* const job_type_table[_JOB_TYPE_MAX] = { + [JOB_START] = "start", + [JOB_VERIFY_ACTIVE] = "verify-active", + [JOB_STOP] = "stop", + [JOB_RELOAD] = "reload", + [JOB_RELOAD_OR_START] = "reload-or-start", + [JOB_RESTART] = "restart", + [JOB_TRY_RESTART] = "try-restart", +}; + +DEFINE_STRING_TABLE_LOOKUP(job_type, JobType);