shaba/systemd
1
0
Fork 0
mirror of https://github.com/systemd/systemd.git synced 2024-12-26 03:22:00 +03:00
Code

logind: send out PropertyChanged signals where appropriate

Browse Source
This commit is contained in:
Lennart Poettering 2011-06-21 21:46:13 +02:00
parent da11939561
commit 9418f14772
12 changed files with 217 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/logind-dbus.c
View File

@ -604,3 +604,25 @@ oom:
const DBusObjectPathVTable bus_manager_vtable = {
.message_function = manager_message_handler
};
int manager_send_changed(Manager *manager, const char *properties) {
DBusMessage *m;
int r = -ENOMEM;
assert(manager);
m = bus_properties_changed_new("/org/freedesktop/login1", "org.freedesktop.login1.Manager", properties);
if (!m)
goto finish;
if (!dbus_connection_send(manager->bus, m, NULL))
goto finish;
r = 0;
finish:
if (m)
dbus_message_unref(m);
return r;
}

28
src/logind-seat-dbus.c
View File

@ -370,3 +370,31 @@ finish:
return r;
}
int seat_send_changed(Seat *s, const char *properties) {
DBusMessage *m;
int r = -ENOMEM;
char *p = NULL;
assert(s);
p = seat_bus_path(s);
if (!p)
return -ENOMEM;
m = bus_properties_changed_new(p, "org.freedesktop.login1.Seat", properties);
if (!m)
goto finish;
if (!dbus_connection_send(s->manager->bus, m, NULL))
goto finish;
r = 0;
finish:
if (m)
dbus_message_unref(m);
free(p);
return r;
}

53
src/logind-seat.c
View File

@ -226,8 +226,33 @@ int seat_apply_acls(Seat *s, Session *old_active) {
return r;
}
int seat_set_active(Seat *s, Session *session) {
Session *old_active;
assert(s);
assert(session);
assert(session->seat == s);
if (session == s->active)
return 0;
old_active = s->active;
s->active = session;
seat_apply_acls(s, old_active);
if (session && session->started)
session_send_changed(session, "Active\0");
if (!session || session->started)
seat_send_changed(s, "ActiveSession\0");
return 0;
}
int seat_active_vt_changed(Seat *s, int vtnr) {
Session *i, *new_active = NULL, *old_active;
Session *i, *new_active = NULL;
int r;
assert(s);
assert(vtnr >= 1);
@ -243,16 +268,10 @@ int seat_active_vt_changed(Seat *s, int vtnr) {
break;
}
if (new_active == s->active)
return 0;
old_active = s->active;
s->active = new_active;
seat_apply_acls(s, old_active);
r = seat_set_active(s, new_active);
manager_spawn_autovt(s->manager, vtnr);
return 0;
return r;
}
int seat_read_active_vt(Seat *s) {
@ -361,17 +380,19 @@ int seat_attach_session(Seat *s, Session *session) {
assert(session);
assert(!session->seat);
if (!seat_is_vtconsole(s)) {
if (s->sessions)
return -EEXIST;
assert(!s->active);
s->active = session;
}
if (!seat_is_vtconsole(s) && s->sessions)
return -EEXIST;
session->seat = s;
LIST_PREPEND(Session, sessions_by_seat, s->sessions, session);
seat_send_changed(s, "Sessions\0");
if (!seat_is_vtconsole(s)) {
assert(!s->active);
seat_set_active(s, session);
}
return 0;
}

2
src/logind-seat.h
View File

@ -54,6 +54,7 @@ int seat_save(Seat *s);
int seat_load(Seat *s);
int seat_apply_acls(Seat *s, Session *old_active);
int seat_set_active(Seat *s, Session *session);
int seat_active_vt_changed(Seat *s, int vtnr);
int seat_read_active_vt(Seat *s);
@ -75,5 +76,6 @@ char *seat_bus_path(Seat *s);
extern const DBusObjectPathVTable bus_seat_vtable;
int seat_send_signal(Seat *s, bool new_seat);
int seat_send_changed(Seat *s, const char *properties);
#endif

28
src/logind-session-dbus.c
View File

@ -419,3 +419,31 @@ finish:
return r;
}
int session_send_changed(Session *s, const char *properties) {
DBusMessage *m;
int r = -ENOMEM;
char *p = NULL;
assert(s);
p = session_bus_path(s);
if (!p)
return -ENOMEM;
m = bus_properties_changed_new(p, "org.freedesktop.login1.Session", properties);
if (!m)
goto finish;
if (!dbus_connection_send(s->manager->bus, m, NULL))
goto finish;
r = 0;
finish:
if (m)
dbus_message_unref(m);
free(p);
return r;
}

59
src/logind-session.c
View File

@ -76,8 +76,12 @@ void session_free(Session *s) {
s->user->display = NULL;
}
if (s->seat)
if (s->seat) {
if (s->seat->active == s)
s->seat->active = NULL;
LIST_REMOVE(Session, sessions_by_seat, s->seat->sessions, s);
}
free(s->cgroup_path);
strv_free(s->controllers);
@ -229,7 +233,7 @@ int session_load(Session *s) {
s->kill_processes = k;
}
if (seat) {
if (seat && !s->seat) {
Seat *o;
o = hashmap_get(s->manager->seats, seat);
@ -430,6 +434,9 @@ int session_start(Session *s) {
assert(s);
assert(s->user);
if (s->started)
return 0;
/* Create cgroup */
r = session_create_cgroup(s);
if (r < 0)
@ -443,8 +450,19 @@ int session_start(Session *s) {
dual_timestamp_get(&s->timestamp);
s->started = true;
session_send_signal(s, true);
if (s->seat) {
if (s->seat->active == s)
seat_send_changed(s->seat, "Sessions\0ActiveSession\0");
else
seat_send_changed(s->seat, "Sessions\0");
}
user_send_changed(s->user, "Sessions\0");
return 0;
}
@ -521,7 +539,8 @@ int session_stop(Session *s) {
assert(s);
session_send_signal(s, false);
if (!s->started)
return 0;
/* Kill cgroup */
k = session_kill_cgroup(s);
@ -534,6 +553,19 @@ int session_stop(Session *s) {
unlink(s->state_file);
session_add_to_gc_queue(s);
session_send_signal(s, false);
if (s->seat) {
if (s->seat->active == s)
seat_set_active(s->seat, NULL);
seat_send_changed(s->seat, "Sessions\0");
}
user_send_changed(s->user, "Sessions\0");
s->started = false;
return r;
}
@ -607,6 +639,27 @@ void session_set_idle_hint(Session *s, bool b) {
s->idle_hint = b;
dual_timestamp_get(&s->idle_hint_timestamp);
session_send_changed(s,
"IdleHint\0"
"IdleSinceHint\0"
"IdleSinceHintMonotonic\0");
if (s->seat)
seat_send_changed(s->seat,
"IdleHint\0"
"IdleSinceHint\0"
"IdleSinceHintMonotonic\0");
user_send_changed(s->user,
"IdleHint\0"
"IdleSinceHint\0"
"IdleSinceHintMonotonic\0");
manager_send_changed(s->manager,
"IdleHint\0"
"IdleSinceHint\0"
"IdleSinceHintMonotonic\0");
}
int session_check_gc(Session *s) {

2
src/logind-session.h
View File

@ -72,6 +72,7 @@ struct Session {
bool kill_processes;
bool in_gc_queue:1;
bool started:1;
LIST_FIELDS(Session, sessions_by_user);
LIST_FIELDS(Session, sessions_by_seat);
@ -97,6 +98,7 @@ char *session_bus_path(Session *s);
extern const DBusObjectPathVTable bus_session_vtable;
int session_send_signal(Session *s, bool new_session);
int session_send_changed(Session *s, const char *properties);
const char* session_type_to_string(SessionType t);
SessionType session_type_from_string(const char *s);

28
src/logind-user-dbus.c
View File

@ -353,3 +353,31 @@ finish:
return r;
}
int user_send_changed(User *u, const char *properties) {
DBusMessage *m;
int r = -ENOMEM;
char *p = NULL;
assert(u);
p = user_bus_path(u);
if (!p)
return -ENOMEM;
m = bus_properties_changed_new(p, "org.freedesktop.login1.User", properties);
if (!m)
goto finish;
if (!dbus_connection_send(u->manager->bus, m, NULL))
goto finish;
r = 0;
finish:
if (m)
dbus_message_unref(m);
free(p);
return r;
}

10
src/logind-user.c
View File

@ -260,6 +260,9 @@ int user_start(User *u) {
assert(u);
if (u->started)
return 0;
/* Make XDG_RUNTIME_DIR */
r = user_mkdir_runtime_path(u);
if (r < 0)
@ -280,6 +283,8 @@ int user_start(User *u) {
dual_timestamp_get(&u->timestamp);
u->started = true;
user_send_signal(u, true);
return 0;
@ -361,6 +366,9 @@ int user_stop(User *u) {
int r = 0, k;
assert(u);
if (!u->started)
return 0;
LIST_FOREACH(sessions_by_user, s, u->sessions) {
k = session_stop(s);
if (k < 0)
@ -387,6 +395,8 @@ int user_stop(User *u) {
unlink(u->state_file);
user_add_to_gc_queue(u);
u->started = false;
return r;
}

2
src/logind-user.h
View File

@ -55,6 +55,7 @@ struct User {
dual_timestamp timestamp;
bool in_gc_queue:1;
bool started:1;
LIST_HEAD(Session, sessions);
LIST_FIELDS(User, gc_queue);
@ -76,6 +77,7 @@ char *user_bus_path(User *s);
extern const DBusObjectPathVTable bus_user_vtable;
int user_send_signal(User *u, bool new_user);
int user_send_changed(User *u, const char *properties);
const char* user_state_to_string(UserState s);
UserState user_state_from_string(const char *s);

1
src/logind.c
View File

@ -890,7 +890,6 @@ int manager_get_idle_hint(Manager *m, dual_timestamp *t) {
return idle_hint;
}
int manager_startup(Manager *m) {
int r;
Seat *seat;

2
src/logind.h
View File

@ -114,4 +114,6 @@ bool x11_display_is_local(const char *display);
extern const DBusObjectPathVTable bus_manager_vtable;
int manager_send_changed(Manager *manager, const char *properties);
#endif