1 /*-*- Mode: C; c-basic-offset: 8 -*-*/
12 NameType name_type_from_string(const char *n) {
14 static const char* suffixes[_NAME_TYPE_MAX] = {
15 [NAME_SERVICE] = ".service",
16 [NAME_TIMER] = ".timer",
17 [NAME_SOCKET] = ".socket",
18 [NAME_MILESTONE] = ".milestone",
19 [NAME_DEVICE] = ".device",
20 [NAME_MOUNT] = ".mount",
21 [NAME_AUTOMOUNT] = ".automount",
22 [NAME_SNAPSHOT] = ".snapshot",
27 for (t = 0; t < _NAME_TYPE_MAX; t++)
28 if (endswith(n, suffixes[t]))
31 return _NAME_TYPE_INVALID;
36 "abcdefghijklmnopqrstuvwxyz" \
37 "ABCDEFGHIJKLMNOPQRSTUVWXYZ" \
40 bool name_is_valid(const char *n) {
46 t = name_type_from_string(n);
47 if (t < 0 || t >= _NAME_TYPE_MAX)
50 if (!(e = strrchr(n, '.')))
53 for (i = n; i < e; i++)
54 if (!strchr(VALID_CHARS, *i))
60 Name *name_new(Manager *m) {
65 if (!(n = new0(Name, 1)))
68 if (!(n->meta.names = set_new(string_hash_func, string_compare_func))) {
73 /* Not much initialization happening here at this time */
75 n->meta.type = _NAME_TYPE_INVALID;
76 n->meta.state = NAME_STUB;
78 /* We don't link the name here, that is left for name_link() */
83 int name_link_names(Name *n) {
93 /* Link all names that aren't linked yet */
95 SET_FOREACH(t, n->meta.names, state)
96 if ((r = hashmap_put(n->meta.manager->names, t, n)) < 0) {
98 if (r == -EEXIST && hashmap_get(n->meta.manager->names, t) == n)
107 int name_link(Name *n) {
111 assert(!set_isempty(n->meta.names));
112 assert(!n->meta.linked);
114 n->meta.linked = true;
116 if ((r = name_link_names(n) < 0)) {
120 /* Rollback the registered names */
121 SET_FOREACH(t, n->meta.names, state)
122 hashmap_remove(n->meta.manager->names, t);
124 n->meta.linked = false;
128 if (n->meta.state == NAME_STUB)
129 LIST_PREPEND(Meta, n->meta.manager->load_queue, &n->meta);
134 static void bidi_set_free(Name *name, Set *s) {
140 /* Frees the set and makes sure we are dropped from the
141 * inverse pointers */
143 SET_FOREACH(other, s, state) {
146 for (d = 0; d < _NAME_DEPENDENCY_MAX; d++)
147 set_remove(other->meta.dependencies[d], name);
153 void name_free(Name *name) {
159 /* Detach from next 'bigger' objects */
160 if (name->meta.linked) {
164 SET_FOREACH(t, name->meta.names, state)
165 assert_se(hashmap_remove(name->meta.manager->names, t) == name);
167 if (name->meta.state == NAME_STUB)
168 LIST_REMOVE(Meta, name->meta.manager->load_queue, &name->meta);
171 /* Free data and next 'smaller' objects */
173 job_free(name->meta.job);
175 for (d = 0; d < _NAME_DEPENDENCY_MAX; d++)
176 bidi_set_free(name, name->meta.dependencies[d]);
178 switch (name->meta.type) {
182 Socket *s = SOCKET(name);
184 for (i = 0; i < s->n_fds; i++)
185 close_nointr(s->fds[i]);
190 Device *d = DEVICE(name);
197 Mount *m = MOUNT(name);
203 case NAME_AUTOMOUNT: {
204 Automount *a = AUTOMOUNT(name);
214 free(name->meta.description);
216 while ((t = set_steal_first(name->meta.names)))
218 set_free(name->meta.names);
223 bool name_is_ready(Name *name) {
227 if (name->meta.state != NAME_LOADED)
230 assert(name->meta.type < _NAME_TYPE_MAX);
232 switch (name->meta.type) {
234 Service *s = SERVICE(name);
237 s->state == SERVICE_RUNNING ||
238 s->state == SERVICE_RELOAD_PRE ||
239 s->state == SERVICE_RELOAD ||
240 s->state == SERVICE_RELOAD_POST;
244 Timer *t = TIMER(name);
247 t->state == TIMER_WAITING ||
248 t->state == TIMER_RUNNING;
252 Socket *s = SOCKET(name);
255 s->state == SOCKET_LISTENING ||
256 s->state == SOCKET_RUNNING;
260 return MILESTONE(name)->state == MILESTONE_ACTIVE;
263 return DEVICE(name)->state == DEVICE_AVAILABLE;
266 return MOUNT(name)->state == MOUNT_MOUNTED;
268 case NAME_AUTOMOUNT: {
269 Automount *a = AUTOMOUNT(name);
272 a->state == AUTOMOUNT_WAITING ||
273 a->state == AUTOMOUNT_RUNNING;
277 return SNAPSHOT(name)->state == SNAPSHOT_ACTIVE;
281 case _NAME_TYPE_INVALID:
285 assert_not_reached("Unknown name type.");
289 static int ensure_in_set(Set **s, void *data) {
296 if (!(*s = set_new(trivial_hash_func, trivial_compare_func)))
299 if ((r = set_put(*s, data) < 0))
306 int name_augment(Name *n) {
313 /* Adds in the missing links to make all dependencies bidirectional */
315 SET_FOREACH(other, n->meta.dependencies[NAME_BEFORE], state)
316 if ((r = ensure_in_set(&other->meta.dependencies[NAME_AFTER], n) < 0))
318 SET_FOREACH(other, n->meta.dependencies[NAME_AFTER], state)
319 if ((r = ensure_in_set(&other->meta.dependencies[NAME_BEFORE], n) < 0))
322 SET_FOREACH(other, n->meta.dependencies[NAME_CONFLICTS], state)
323 if ((r = ensure_in_set(&other->meta.dependencies[NAME_CONFLICTS], n) < 0))
326 SET_FOREACH(other, n->meta.dependencies[NAME_REQUIRES], state)
327 if ((r = ensure_in_set(&other->meta.dependencies[NAME_REQUIRED_BY], n) < 0))
329 SET_FOREACH(other, n->meta.dependencies[NAME_REQUISITE], state)
330 if ((r = ensure_in_set(&other->meta.dependencies[NAME_REQUIRED_BY], n) < 0))
333 SET_FOREACH(other, n->meta.dependencies[NAME_WANTS], state)
334 if ((r = ensure_in_set(&other->meta.dependencies[NAME_WANTED_BY], n) < 0))
336 SET_FOREACH(other, n->meta.dependencies[NAME_SOFT_REQUIRES], state)
337 if ((r = ensure_in_set(&other->meta.dependencies[NAME_WANTED_BY], n) < 0))
339 SET_FOREACH(other, n->meta.dependencies[NAME_SOFT_REQUISITE], state)
340 if ((r = ensure_in_set(&other->meta.dependencies[NAME_WANTED_BY], n) < 0))
346 static int ensure_merge(Set **s, Set *other) {
352 return set_merge(*s, other);
354 if (!(*s = set_copy(other)))
360 int name_merge(Name *name, Name *other) {
367 assert(name->meta.manager == other->meta.manager);
369 if (name->meta.type != other->meta.type)
372 if (other->meta.state != NAME_STUB)
376 if ((r = ensure_merge(&name->meta.names, other->meta.names)) < 0)
379 /* Merge dependencies */
380 for (d = 0; d < _NAME_DEPENDENCY_MAX; d++)
381 if ((r = ensure_merge(&name->meta.dependencies[d], other->meta.dependencies[d])) < 0)
384 if (name->meta.linked)
385 if ((r = name_link_names(name)) < 0)
391 const char* name_id(Name *n) {
394 return set_first(n->meta.names);
397 void name_dump(Name *n, FILE *f) {
399 static const char* const state_table[_NAME_STATE_MAX] = {
400 [NAME_STUB] = "stub",
401 [NAME_LOADED] = "loaded",
402 [NAME_FAILED] = "failed"
405 static const char* const socket_state_table[_SOCKET_STATE_MAX] = {
406 [SOCKET_DEAD] = "dead",
407 [SOCKET_BEFORE] = "before",
408 [SOCKET_START_PRE] = "start-pre",
409 [SOCKET_START] = "start",
410 [SOCKET_START_POST] = "start-post",
411 [SOCKET_LISTENING] = "listening",
412 [SOCKET_RUNNING] = "running",
413 [SOCKET_STOP_PRE] = "stop-pre",
414 [SOCKET_STOP] = "stop",
415 [SOCKET_STOP_POST] = "stop-post",
416 [SOCKET_MAINTAINANCE] = "maintainance"
426 "\tDescription: %s\n"
429 n->meta.description ? n->meta.description : name_id(n),
430 state_table[n->meta.state]);
432 fprintf(f, "\tNames: ");
433 SET_FOREACH(t, n->meta.names, state)
434 fprintf(f, "%s ", t);
437 switch (n->meta.type) {
443 if ((r = address_print(&n->socket.address, &s)) < 0)
448 fprintf(f, "\t%s in state %s\n", t, socket_state_table[n->socket.state]);
459 job_dump(n->meta.job, f);