X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=src%2Flogin%2Flogind.c;h=bae9a95f38066868e3960d9b3ab412fcf1a60b72;hb=0d0f0c50d3a1d90f03972a6abb82e6413daaa583;hp=632987c8b379c5269d5b12f6e48ba3a5fa723999;hpb=6de0e0e500d9d534c6e4baab242fc2a146f021fa;p=elogind.git diff --git a/src/login/logind.c b/src/login/logind.c index 632987c8b..bae9a95f3 100644 --- a/src/login/logind.c +++ b/src/login/logind.c @@ -64,13 +64,16 @@ Manager *manager_new(void) { m->inhibitors = hashmap_new(string_hash_func, string_compare_func); m->buttons = hashmap_new(string_hash_func, string_compare_func); - m->cgroups = hashmap_new(string_hash_func, string_compare_func); + m->user_cgroups = hashmap_new(string_hash_func, string_compare_func); + m->session_cgroups = hashmap_new(string_hash_func, string_compare_func); + m->session_fds = hashmap_new(trivial_hash_func, trivial_compare_func); m->inhibitor_fds = hashmap_new(trivial_hash_func, trivial_compare_func); m->button_fds = hashmap_new(trivial_hash_func, trivial_compare_func); if (!m->devices || !m->seats || !m->sessions || !m->users || !m->inhibitors || !m->buttons || - !m->cgroups || !m->session_fds || !m->inhibitor_fds || !m->button_fds) { + !m->user_cgroups || !m->session_cgroups || + !m->session_fds || !m->inhibitor_fds || !m->button_fds) { manager_free(m); return NULL; } @@ -131,7 +134,9 @@ void manager_free(Manager *m) { hashmap_free(m->inhibitors); hashmap_free(m->buttons); - hashmap_free(m->cgroups); + hashmap_free(m->user_cgroups); + hashmap_free(m->session_cgroups); + hashmap_free(m->session_fds); hashmap_free(m->inhibitor_fds); hashmap_free(m->button_fds); @@ -274,7 +279,7 @@ int manager_add_user_by_name(Manager *m, const char *name, User **_user) { assert(m); assert(name); - r = get_user_creds(&name, &uid, &gid, NULL); + r = get_user_creds(&name, &uid, &gid, NULL, NULL); if (r < 0) return r; @@ -1008,17 +1013,15 @@ int manager_get_session_by_cgroup(Manager *m, const char *cgroup, Session **sess assert(cgroup); assert(session); - s = hashmap_get(m->cgroups, cgroup); + s = hashmap_get(m->session_cgroups, cgroup); if (s) { *session = s; return 1; } p = strdup(cgroup); - if (!p) { - log_error("Out of memory."); - return -ENOMEM; - } + if (!p) + return log_oom(); for (;;) { char *e; @@ -1032,7 +1035,7 @@ int manager_get_session_by_cgroup(Manager *m, const char *cgroup, Session **sess *e = 0; - s = hashmap_get(m->cgroups, p); + s = hashmap_get(m->session_cgroups, p); if (s) { free(p); *session = s; @@ -1041,6 +1044,45 @@ int manager_get_session_by_cgroup(Manager *m, const char *cgroup, Session **sess } } +int manager_get_user_by_cgroup(Manager *m, const char *cgroup, User **user) { + User *u; + char *p; + + assert(m); + assert(cgroup); + assert(user); + + u = hashmap_get(m->user_cgroups, cgroup); + if (u) { + *user = u; + return 1; + } + + p = strdup(cgroup); + if (!p) + return log_oom(); + + for (;;) { + char *e; + + e = strrchr(p, '/'); + if (!e || e == p) { + free(p); + *user = NULL; + return 0; + } + + *e = 0; + + u = hashmap_get(m->user_cgroups, p); + if (u) { + free(p); + *user = u; + return 1; + } + } +} + int manager_get_session_by_pid(Manager *m, pid_t pid, Session **session) { char *p; int r; @@ -1061,13 +1103,16 @@ int manager_get_session_by_pid(Manager *m, pid_t pid, Session **session) { void manager_cgroup_notify_empty(Manager *m, const char *cgroup) { Session *s; + User *u; int r; r = manager_get_session_by_cgroup(m, cgroup, &s); - if (r <= 0) - return; + if (r > 0) + session_add_to_gc_queue(s); - session_add_to_gc_queue(s); + r = manager_get_user_by_cgroup(m, cgroup, &u); + if (r > 0) + user_add_to_gc_queue(u); } static void manager_dispatch_other(Manager *m, int fd) { @@ -1127,8 +1172,7 @@ static int manager_connect_bus(Manager *m) { !dbus_connection_register_fallback(m->bus, "/org/freedesktop/login1/session", &bus_session_vtable, m) || !dbus_connection_register_fallback(m->bus, "/org/freedesktop/login1/user", &bus_user_vtable, m) || !dbus_connection_add_filter(m->bus, bus_message_filter, m, NULL)) { - log_error("Not enough memory"); - r = -ENOMEM; + r = log_oom(); goto fail; } @@ -1195,6 +1239,12 @@ static int manager_connect_console(Manager *m) { m->console_active_fd = open("/sys/class/tty/tty0/active", O_RDONLY|O_NOCTTY|O_CLOEXEC); if (m->console_active_fd < 0) { + + /* On some systems the device node /dev/tty0 may exist + * even though /sys/class/tty/tty0 does not. */ + if (errno == ENOENT) + return 0; + log_error("Failed to open /sys/class/tty/tty0/active: %m"); return -errno; } @@ -1556,8 +1606,7 @@ int main(int argc, char *argv[]) { m = manager_new(); if (!m) { - log_error("Out of memory"); - r = -ENOMEM; + r = log_oom(); goto finish; }