| |
| #pragma once |
| |
| #include <stdbool.h> |
| #include <stdio.h> |
| |
| #include "sd-bus.h" |
| #include "sd-event.h" |
| |
| #include "cgroup-util.h" |
| #include "fdset.h" |
| #include "hashmap.h" |
| #include "ip-address-access.h" |
| #include "list.h" |
| #include "ratelimit.h" |
| |
| struct libmnt_monitor; |
| typedef struct Unit Unit; |
| |
| |
| #define MANAGER_MAX_NAMES 131072 |
| |
| typedef struct Manager Manager; |
| |
| typedef enum ManagerState { |
| MANAGER_INITIALIZING, |
| MANAGER_STARTING, |
| MANAGER_RUNNING, |
| MANAGER_DEGRADED, |
| MANAGER_MAINTENANCE, |
| MANAGER_STOPPING, |
| _MANAGER_STATE_MAX, |
| _MANAGER_STATE_INVALID = -1 |
| } ManagerState; |
| |
| typedef enum ManagerExitCode { |
| MANAGER_OK, |
| MANAGER_EXIT, |
| MANAGER_RELOAD, |
| MANAGER_REEXECUTE, |
| MANAGER_REBOOT, |
| MANAGER_POWEROFF, |
| MANAGER_HALT, |
| MANAGER_KEXEC, |
| MANAGER_SWITCH_ROOT, |
| _MANAGER_EXIT_CODE_MAX, |
| _MANAGER_EXIT_CODE_INVALID = -1 |
| } ManagerExitCode; |
| |
| typedef enum StatusType { |
| STATUS_TYPE_EPHEMERAL, |
| STATUS_TYPE_NORMAL, |
| STATUS_TYPE_EMERGENCY, |
| } StatusType; |
| |
| typedef enum ManagerTimestamp { |
| MANAGER_TIMESTAMP_FIRMWARE, |
| MANAGER_TIMESTAMP_LOADER, |
| MANAGER_TIMESTAMP_KERNEL, |
| MANAGER_TIMESTAMP_INITRD, |
| MANAGER_TIMESTAMP_USERSPACE, |
| MANAGER_TIMESTAMP_FINISH, |
| |
| MANAGER_TIMESTAMP_SECURITY_START, |
| MANAGER_TIMESTAMP_SECURITY_FINISH, |
| MANAGER_TIMESTAMP_GENERATORS_START, |
| MANAGER_TIMESTAMP_GENERATORS_FINISH, |
| MANAGER_TIMESTAMP_UNITS_LOAD_START, |
| MANAGER_TIMESTAMP_UNITS_LOAD_FINISH, |
| _MANAGER_TIMESTAMP_MAX, |
| _MANAGER_TIMESTAMP_INVALID = -1, |
| } ManagerTimestamp; |
| |
| #include "execute.h" |
| #include "job.h" |
| #include "path-lookup.h" |
| #include "show-status.h" |
| #include "unit-name.h" |
| |
| enum { |
| |
| MANAGER_TEST_RUN_MINIMAL = 1 << 1, |
| MANAGER_TEST_RUN_BASIC = 1 << 2, |
| MANAGER_TEST_RUN_ENV_GENERATORS = 1 << 3, |
| MANAGER_TEST_RUN_GENERATORS = 1 << 4, |
| MANAGER_TEST_FULL = MANAGER_TEST_RUN_BASIC | MANAGER_TEST_RUN_ENV_GENERATORS | MANAGER_TEST_RUN_GENERATORS, |
| }; |
| assert_cc((MANAGER_TEST_FULL & UINT8_MAX) == MANAGER_TEST_FULL); |
| |
| struct Manager { |
| |
| |
| |
| |
| |
| Hashmap *units; |
| Hashmap *units_by_invocation_id; |
| Hashmap *jobs; |
| |
| |
| |
| LIST_HEAD(Unit, units_by_type[_UNIT_TYPE_MAX]); |
| |
| |
| LIST_HEAD(Unit, load_queue); |
| |
| |
| LIST_HEAD(Job, run_queue); |
| |
| |
| |
| |
| |
| LIST_HEAD(Unit, dbus_unit_queue); |
| LIST_HEAD(Job, dbus_job_queue); |
| |
| |
| LIST_HEAD(Unit, cleanup_queue); |
| |
| |
| LIST_HEAD(Unit, gc_unit_queue); |
| LIST_HEAD(Job, gc_job_queue); |
| |
| |
| LIST_HEAD(Unit, cgroup_realize_queue); |
| |
| |
| LIST_HEAD(Unit, cgroup_empty_queue); |
| |
| |
| LIST_HEAD(Unit, target_deps_queue); |
| |
| sd_event *event; |
| |
| |
| |
| |
| |
| |
| |
| |
| Hashmap *watch_pids; |
| |
| |
| Set *startup_units; |
| |
| |
| Set *failed_units; |
| |
| sd_event_source *run_queue_event_source; |
| |
| char *notify_socket; |
| int notify_fd; |
| sd_event_source *notify_event_source; |
| |
| int cgroups_agent_fd; |
| sd_event_source *cgroups_agent_event_source; |
| |
| int signal_fd; |
| sd_event_source *signal_event_source; |
| |
| sd_event_source *sigchld_event_source; |
| |
| int time_change_fd; |
| sd_event_source *time_change_event_source; |
| |
| sd_event_source *timezone_change_event_source; |
| |
| sd_event_source *jobs_in_progress_event_source; |
| |
| int user_lookup_fds[2]; |
| sd_event_source *user_lookup_event_source; |
| |
| sd_event_source *sync_bus_names_event_source; |
| |
| UnitFileScope unit_file_scope; |
| LookupPaths lookup_paths; |
| Set *unit_path_cache; |
| |
| char **environment; |
| |
| usec_t runtime_watchdog; |
| usec_t shutdown_watchdog; |
| |
| dual_timestamp timestamps[_MANAGER_TIMESTAMP_MAX]; |
| |
| struct udev* udev; |
| |
| |
| struct udev_monitor* udev_monitor; |
| sd_event_source *udev_event_source; |
| Hashmap *devices_by_sysfs; |
| |
| |
| struct libmnt_monitor *mount_monitor; |
| sd_event_source *mount_event_source; |
| |
| |
| FILE *proc_swaps; |
| sd_event_source *swap_event_source; |
| Hashmap *swaps_by_devnode; |
| |
| |
| sd_bus *api_bus, *system_bus; |
| Set *private_buses; |
| int private_listen_fd; |
| sd_event_source *private_listen_event_source; |
| |
| |
| |
| |
| |
| sd_bus_track *subscribed; |
| char **deserialized_subscribed; |
| |
| |
| |
| sd_bus_message *pending_reload_message; |
| |
| Hashmap *watch_bus; |
| |
| bool send_reloading_done; |
| |
| uint32_t current_job_id; |
| uint32_t default_unit_job_id; |
| |
| |
| int dev_autofs_fd; |
| |
| |
| Hashmap *cgroup_unit; |
| CGroupMask cgroup_supported; |
| char *cgroup_root; |
| |
| |
| int cgroup_inotify_fd; |
| sd_event_source *cgroup_inotify_event_source; |
| Hashmap *cgroup_inotify_wd_unit; |
| |
| |
| sd_event_source *cgroup_empty_event_source; |
| |
| |
| |
| int pin_cgroupfs_fd; |
| |
| unsigned gc_marker; |
| |
| |
| usec_t etc_localtime_mtime; |
| bool etc_localtime_accessible:1; |
| |
| |
| ManagerExitCode exit_code:5; |
| |
| bool dispatching_load_queue:1; |
| bool dispatching_dbus_queue:1; |
| |
| bool taint_usr:1; |
| |
| |
| bool ready_sent:1; |
| |
| |
| bool taint_logged:1; |
| |
| |
| bool sysctl_pid_max_changed:1; |
| |
| unsigned test_run_flags:8; |
| |
| |
| |
| |
| uint8_t return_value; |
| |
| ShowStatus show_status; |
| char *confirm_spawn; |
| bool no_console_output; |
| bool service_watchdogs; |
| |
| ExecOutput default_std_output, default_std_error; |
| |
| usec_t default_restart_usec, default_timeout_start_usec, default_timeout_stop_usec; |
| |
| usec_t default_start_limit_interval; |
| unsigned default_start_limit_burst; |
| |
| bool default_cpu_accounting; |
| bool default_memory_accounting; |
| bool default_io_accounting; |
| bool default_blockio_accounting; |
| bool default_tasks_accounting; |
| bool default_ip_accounting; |
| |
| uint64_t default_tasks_max; |
| usec_t default_timer_accuracy_usec; |
| |
| int original_log_level; |
| LogTarget original_log_target; |
| bool log_level_overridden:1; |
| bool log_target_overridden:1; |
| |
| struct rlimit *rlimit[_RLIMIT_MAX]; |
| |
| |
| int n_reloading; |
| |
| |
| Set *pending_finished_jobs; |
| |
| unsigned n_installed_jobs; |
| unsigned n_failed_jobs; |
| |
| |
| unsigned n_running_jobs; |
| unsigned n_on_console; |
| unsigned jobs_in_progress_iteration; |
| |
| |
| int have_ask_password; |
| int ask_password_inotify_fd; |
| sd_event_source *ask_password_event_source; |
| |
| |
| int idle_pipe[4]; |
| sd_event_source *idle_pipe_event_source; |
| |
| char *switch_root; |
| char *switch_root_init; |
| |
| |
| |
| |
| Hashmap *units_requiring_mounts_for; |
| |
| |
| Hashmap *polkit_registry; |
| |
| |
| Hashmap *dynamic_users; |
| |
| |
| Hashmap *uid_refs; |
| Hashmap *gid_refs; |
| |
| |
| Hashmap *exec_runtime_by_id; |
| |
| |
| RateLimit ctrl_alt_del_ratelimit; |
| EmergencyAction cad_burst_action; |
| |
| const char *unit_log_field; |
| const char *unit_log_format_string; |
| |
| const char *invocation_log_field; |
| const char *invocation_log_format_string; |
| |
| int first_boot; |
| |
| |
| char *prefix[_EXEC_DIRECTORY_TYPE_MAX]; |
| |
| |
| |
| unsigned sigchldgen; |
| unsigned notifygen; |
| }; |
| |
| #define MANAGER_IS_SYSTEM(m) ((m)->unit_file_scope == UNIT_FILE_SYSTEM) |
| #define MANAGER_IS_USER(m) ((m)->unit_file_scope != UNIT_FILE_SYSTEM) |
| |
| #define MANAGER_IS_RELOADING(m) ((m)->n_reloading > 0) |
| |
| #define MANAGER_IS_FINISHED(m) (dual_timestamp_is_set((m)->timestamps + MANAGER_TIMESTAMP_FINISH)) |
| |
| |
| #define MANAGER_IS_RUNNING(m) ((m)->exit_code == MANAGER_OK) |
| |
| int manager_new(UnitFileScope scope, unsigned test_run_flags, Manager **m); |
| Manager* manager_free(Manager *m); |
| DEFINE_TRIVIAL_CLEANUP_FUNC(Manager*, manager_free); |
| |
| int manager_startup(Manager *m, FILE *serialization, FDSet *fds); |
| |
| Job *manager_get_job(Manager *m, uint32_t id); |
| Unit *manager_get_unit(Manager *m, const char *name); |
| |
| int manager_get_job_from_dbus_path(Manager *m, const char *s, Job **_j); |
| |
| int manager_load_unit_prepare(Manager *m, const char *name, const char *path, sd_bus_error *e, Unit **_ret); |
| int manager_load_unit(Manager *m, const char *name, const char *path, sd_bus_error *e, Unit **_ret); |
| int manager_load_startable_unit_or_warn(Manager *m, const char *name, const char *path, Unit **ret); |
| int manager_load_unit_from_dbus_path(Manager *m, const char *s, sd_bus_error *e, Unit **_u); |
| |
| int manager_add_job(Manager *m, JobType type, Unit *unit, JobMode mode, sd_bus_error *e, Job **_ret); |
| int manager_add_job_by_name(Manager *m, JobType type, const char *name, JobMode mode, sd_bus_error *e, Job **_ret); |
| int manager_add_job_by_name_and_warn(Manager *m, JobType type, const char *name, JobMode mode, Job **ret); |
| int manager_propagate_reload(Manager *m, Unit *unit, JobMode mode, sd_bus_error *e); |
| |
| void manager_dump_units(Manager *s, FILE *f, const char *prefix); |
| void manager_dump_jobs(Manager *s, FILE *f, const char *prefix); |
| void manager_dump(Manager *s, FILE *f, const char *prefix); |
| int manager_get_dump_string(Manager *m, char **ret); |
| |
| void manager_clear_jobs(Manager *m); |
| |
| unsigned manager_dispatch_load_queue(Manager *m); |
| |
| int manager_environment_add(Manager *m, char **minus, char **plus); |
| int manager_set_default_rlimits(Manager *m, struct rlimit **default_rlimit); |
| |
| int manager_loop(Manager *m); |
| |
| int manager_open_serialization(Manager *m, FILE **_f); |
| |
| int manager_serialize(Manager *m, FILE *f, FDSet *fds, bool switching_root); |
| int manager_deserialize(Manager *m, FILE *f, FDSet *fds); |
| |
| int manager_reload(Manager *m); |
| |
| void manager_reset_failed(Manager *m); |
| |
| void manager_send_unit_audit(Manager *m, Unit *u, int type, bool success); |
| void manager_send_unit_plymouth(Manager *m, Unit *u); |
| |
| bool manager_unit_inactive_or_pending(Manager *m, const char *name); |
| |
| void manager_check_finished(Manager *m); |
| |
| void manager_recheck_dbus(Manager *m); |
| void manager_recheck_journal(Manager *m); |
| |
| void manager_set_show_status(Manager *m, ShowStatus mode); |
| void manager_set_first_boot(Manager *m, bool b); |
| |
| void manager_status_printf(Manager *m, StatusType type, const char *status, const char *format, ...) _printf_(4,5); |
| void manager_flip_auto_status(Manager *m, bool enable); |
| |
| Set *manager_get_units_requiring_mounts_for(Manager *m, const char *path); |
| |
| ManagerState manager_state(Manager *m); |
| |
| int manager_update_failed_units(Manager *m, Unit *u, bool failed); |
| |
| void manager_unref_uid(Manager *m, uid_t uid, bool destroy_now); |
| int manager_ref_uid(Manager *m, uid_t uid, bool clean_ipc); |
| |
| void manager_unref_gid(Manager *m, gid_t gid, bool destroy_now); |
| int manager_ref_gid(Manager *m, gid_t gid, bool destroy_now); |
| |
| void manager_vacuum_uid_refs(Manager *m); |
| void manager_vacuum_gid_refs(Manager *m); |
| |
| void manager_serialize_uid_refs(Manager *m, FILE *f); |
| void manager_deserialize_uid_refs_one(Manager *m, const char *value); |
| |
| void manager_serialize_gid_refs(Manager *m, FILE *f); |
| void manager_deserialize_gid_refs_one(Manager *m, const char *value); |
| |
| char *manager_taint_string(Manager *m); |
| |
| void manager_ref_console(Manager *m); |
| void manager_unref_console(Manager *m); |
| |
| void manager_override_log_level(Manager *m, int level); |
| void manager_restore_original_log_level(Manager *m); |
| |
| void manager_override_log_target(Manager *m, LogTarget target); |
| void manager_restore_original_log_target(Manager *m); |
| |
| const char *manager_state_to_string(ManagerState m) _const_; |
| ManagerState manager_state_from_string(const char *s) _pure_; |
| |
| const char *manager_get_confirm_spawn(Manager *m); |
| bool manager_is_confirm_spawn_disabled(Manager *m); |
| void manager_disable_confirm_spawn(void); |
| |
| const char *manager_timestamp_to_string(ManagerTimestamp m) _const_; |
| ManagerTimestamp manager_timestamp_from_string(const char *s) _pure_; |