X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?p=elogind.git;a=blobdiff_plain;f=unit.h;h=9def661ce1f07fcb9120dc9a3d46f83ec80cabd5;hp=7803f3183cc9f7332f8d4f0ef4d140b18ec351a1;hb=bbd671356647d9d2c7d6c2c0401e907e169c7576;hpb=87f0e418cf2c58b3201d06a60e3696ec672d2662 diff --git a/unit.h b/unit.h index 7803f3183..9def661ce 100644 --- a/unit.h +++ b/unit.h @@ -3,6 +3,25 @@ #ifndef foounithfoo #define foounithfoo +/*** + This file is part of systemd. + + Copyright 2010 Lennart Poettering + + systemd is free software; you can redistribute it and/or modify it + under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + systemd is distributed in the hope that it will be useful, but + WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + General Public License for more details. + + You should have received a copy of the GNU General Public License + along with systemd; If not, see . +***/ + #include #include @@ -14,19 +33,24 @@ typedef enum UnitLoadState UnitLoadState; typedef enum UnitActiveState UnitActiveState; typedef enum UnitDependency UnitDependency; -#include "job.h" -#include "manager.h" #include "set.h" #include "util.h" #include "list.h" #include "socket-util.h" #include "execute.h" -#include "util.h" -#define UNIT_NAME_MAX 32 +#define UNIT_NAME_MAX 128 #define DEFAULT_TIMEOUT_USEC (20*USEC_PER_SEC) #define DEFAULT_RESTART_USEC (100*USEC_PER_MSEC) +typedef enum KillMode { + KILL_CONTROL_GROUP = 0, + KILL_PROCESS_GROUP, + KILL_PROCESS, + _KILL_MODE_MAX, + _KILL_MODE_INVALID = -1 +} KillMode; + enum UnitType { UNIT_SERVICE = 0, UNIT_TIMER, @@ -37,14 +61,16 @@ enum UnitType { UNIT_AUTOMOUNT, UNIT_SNAPSHOT, _UNIT_TYPE_MAX, - _UNIT_TYPE_INVALID = -1, + _UNIT_TYPE_INVALID = -1 }; enum UnitLoadState { UNIT_STUB, UNIT_LOADED, UNIT_FAILED, - _UNIT_LOAD_STATE_MAX + UNIT_MERGED, + _UNIT_LOAD_STATE_MAX, + _UNIT_LOAD_STATE_INVALID = -1 }; enum UnitActiveState { @@ -53,7 +79,8 @@ enum UnitActiveState { UNIT_INACTIVE, UNIT_ACTIVATING, UNIT_DEACTIVATING, - _UNIT_ACTIVE_STATE_MAX + _UNIT_ACTIVE_STATE_MAX, + _UNIT_ACTIVE_STATE_INVALID = -1 }; static inline bool UNIT_IS_ACTIVE_OR_RELOADING(UnitActiveState t) { @@ -92,10 +119,16 @@ enum UnitDependency { _UNIT_DEPENDENCY_INVALID = -1 }; +#include "manager.h" +#include "job.h" +#include "cgroup.h" + struct Meta { Manager *manager; + UnitType type; UnitLoadState load_state; + Unit *merged_into; char *id; /* One name is special because we use it for identification. Points to an entry in the names set */ @@ -103,18 +136,40 @@ struct Meta { Set *dependencies[_UNIT_DEPENDENCY_MAX]; char *description; + char *fragment_path; /* if loaded from a config file this is the primary path to it */ /* If there is something to do with this unit, then this is * the job for it */ Job *job; bool in_load_queue:1; + bool in_dbus_queue:1; + bool in_cleanup_queue:1; + bool sent_dbus_new_signal:1; + + /* If we go down, pull down everything that depends on us, too */ + bool recursive_stop; + + /* Garbage collect us we nobody wants or requires us anymore */ + bool stop_when_unneeded; usec_t active_enter_timestamp; usec_t active_exit_timestamp; + /* Counterparts in the cgroup filesystem */ + CGroupBonding *cgroup_bondings; + /* Load queue */ LIST_FIELDS(Meta, load_queue); + + /* Per type list */ + LIST_FIELDS(Meta, units_per_type); + + /* D-Bus queue */ + LIST_FIELDS(Meta, dbus_queue); + + /* Cleanup queue */ + LIST_FIELDS(Meta, cleanup_queue); }; #include "service.h" @@ -141,8 +196,9 @@ union Unit { struct UnitVTable { const char *suffix; - int (*init)(Unit *u); + int (*init)(Unit *u, UnitLoadState *new_state); void (*done)(Unit *u); + int (*coldplug)(Unit *u); void (*dump)(Unit *u, FILE *f, const char *prefix); @@ -156,11 +212,21 @@ struct UnitVTable { * a simpler one that the engine can understand */ UnitActiveState (*active_state)(Unit *u); - void (*fd_event)(Unit *u, int fd, uint32_t events); + void (*fd_event)(Unit *u, int fd, uint32_t events, Watch *w); void (*sigchld_event)(Unit *u, pid_t pid, int code, int status); - void (*timer_event)(Unit *u, int id, uint64_t n_elapsed); + void (*timer_event)(Unit *u, uint64_t n_elapsed, Watch *w); + + void (*cgroup_notify_empty)(Unit *u); - void (*retry)(Unit *u); + /* This is called for each unit type and should be used to + * enumerate existing devices and load them. However, + * everything that is loaded here should still stay in + * inactive state. It is the job of the coldplug() call above + * to put the units into the initial state. */ + int (*enumerate)(Manager *m); + + /* Type specific cleanups. */ + void (*shutdown)(Manager *m); }; extern const UnitVTable * const unit_vtable[_UNIT_TYPE_MAX]; @@ -197,17 +263,37 @@ void unit_free(Unit *u); int unit_add_name(Unit *u, const char *name); int unit_add_dependency(Unit *u, UnitDependency d, Unit *other); +int unit_add_dependency_by_name(Unit *u, UnitDependency d, const char *name); +int unit_add_dependency_by_name_inverse(Unit *u, UnitDependency d, const char *name); + +int unit_add_exec_dependencies(Unit *u, ExecContext *c); + +int unit_add_cgroup(Unit *u, CGroupBonding *b); +int unit_add_cgroup_from_text(Unit *u, const char *name); +int unit_add_default_cgroup(Unit *u); +CGroupBonding* unit_get_default_cgroup(Unit *u); + +int unit_choose_id(Unit *u, const char *name); +int unit_set_description(Unit *u, const char *description); void unit_add_to_load_queue(Unit *u); +void unit_add_to_dbus_queue(Unit *u); +void unit_add_to_cleanup_queue(Unit *u); int unit_merge(Unit *u, Unit *other); +int unit_merge_by_name(Unit *u, const char *other); -int unit_load_fragment_and_dropin(Unit *u); +Unit *unit_follow_merge(Unit *u); + +int unit_load_fragment_and_dropin(Unit *u, UnitLoadState *new_state); +int unit_load_fragment_and_dropin_optional(Unit *u, UnitLoadState *new_state); int unit_load(Unit *unit); const char* unit_id(Unit *u); const char *unit_description(Unit *u); +bool unit_has_name(Unit *u, const char *name); + UnitActiveState unit_active_state(Unit *u); void unit_dump(Unit *u, FILE *f, const char *prefix); @@ -221,15 +307,36 @@ int unit_reload(Unit *u); void unit_notify(Unit *u, UnitActiveState os, UnitActiveState ns); -int unit_watch_fd(Unit *u, int fd, uint32_t events); -void unit_unwatch_fd(Unit *u, int fd); +int unit_watch_fd(Unit *u, int fd, uint32_t events, Watch *w); +void unit_unwatch_fd(Unit *u, Watch *w); int unit_watch_pid(Unit *u, pid_t pid); void unit_unwatch_pid(Unit *u, pid_t pid); -int unit_watch_timer(Unit *u, usec_t delay, int *id); -void unit_unwatch_timer(Unit *u, int *id); +int unit_watch_timer(Unit *u, usec_t delay, Watch *w); +void unit_unwatch_timer(Unit *u, Watch *w); bool unit_job_is_applicable(Unit *u, JobType j); +int set_unit_path(const char *p); + +char *unit_name_escape_path(const char *path, const char *suffix); + +char *unit_dbus_path(Unit *u); + +const char *unit_type_to_string(UnitType i); +UnitType unit_type_from_string(const char *s); + +const char *unit_load_state_to_string(UnitLoadState i); +UnitLoadState unit_load_state_from_string(const char *s); + +const char *unit_active_state_to_string(UnitActiveState i); +UnitActiveState unit_active_state_from_string(const char *s); + +const char *unit_dependency_to_string(UnitDependency i); +UnitDependency unit_dependency_from_string(const char *s); + +const char *kill_mode_to_string(KillMode k); +KillMode kill_mode_from_string(const char *s); + #endif