aboutsummaryrefslogtreecommitdiff
path: root/src/backend-dbus
diff options
context:
space:
mode:
authorCharles Kerr <charles.kerr@canonical.com>2013-06-28 09:48:54 -0500
committerCharles Kerr <charles.kerr@canonical.com>2013-06-28 09:48:54 -0500
commit69bf3537b0fe5aa00d015c7339ce20e9c2b80d1f (patch)
tree4923176fe32ec90282614a8453786a6288feaf6f /src/backend-dbus
parent3bd279a7de3b32bc33ab2f80d4eae0ecfe83dd38 (diff)
downloadayatana-indicator-session-69bf3537b0fe5aa00d015c7339ce20e9c2b80d1f.tar.gz
ayatana-indicator-session-69bf3537b0fe5aa00d015c7339ce20e9c2b80d1f.tar.bz2
ayatana-indicator-session-69bf3537b0fe5aa00d015c7339ce20e9c2b80d1f.zip
finish up backend-dbus/users.c: fix an unref bug when creating user proxies. fix an async race condition where we emitted change events for users before their proxy objects had finished being asynchronously constructed.
Diffstat (limited to 'src/backend-dbus')
-rw-r--r--src/backend-dbus/users.c118
1 files changed, 54 insertions, 64 deletions
diff --git a/src/backend-dbus/users.c b/src/backend-dbus/users.c
index 1db5ac1..b5a6d32 100644
--- a/src/backend-dbus/users.c
+++ b/src/backend-dbus/users.c
@@ -41,6 +41,8 @@ struct _IndicatorSessionUsersDbusPriv
gboolean is_live;
GCancellable * cancellable;
+
+ guint update_list_tag;
};
typedef IndicatorSessionUsersDbusPriv priv_t;
@@ -53,29 +55,6 @@ G_DEFINE_TYPE (IndicatorSessionUsersDbus,
****
***/
-/* returns true if the fields indicate this is the 'live cd' user */
-static gboolean
-is_live_user (guint uid, const char * username)
-{
- return uid==999 && !g_strcmp0 (username, "ubuntu");
-}
-
-/* returns true if this is a user who should be listed in the session indicator */
-static gboolean
-is_public_user (IndicatorSessionUsersDbus * self G_GNUC_UNUSED,
- AccountsUser * au)
-{
- gboolean is_public;
-
- /* the 'live session' user is the only system account we'll show */
- if (is_live_user (accounts_user_get_uid(au), accounts_user_get_user_name(au)))
- is_public = TRUE;
- else
- is_public = !accounts_user_get_system_account (au);
-
- return is_public;
-}
-
/* get our private org.freedesktop.Accounts.User proxy for the given uid */
static AccountsUser *
get_user_for_uid (IndicatorSessionUsersDbus * self, guint uid)
@@ -85,50 +64,30 @@ get_user_for_uid (IndicatorSessionUsersDbus * self, guint uid)
return g_hash_table_lookup (p->uid_to_account, GUINT_TO_POINTER(uid));
}
-/* returns true if this is a uid that should be listed in the session indicator */
static gboolean
-is_public_uid (IndicatorSessionUsersDbus * self, guint uid)
+is_tracked_uid (IndicatorSessionUsersDbus * self, guint uid)
{
- AccountsUser * au;
- gboolean is_public;
-
- if ((au = get_user_for_uid (self, uid)))
- {
- is_public = is_public_user (self, au);
- }
- else
- {
- /* making a guess to serve until the user's proxy object is ready.
- assuming that 999 is a 'live session' user, <999 is system account */
- is_public = uid >= 999;
- }
-
- return is_public;
+ return get_user_for_uid (self, uid) != NULL;
}
-/***
-****
-***/
-
static void
-emit_user_added (IndicatorSessionUsersDbus * self, guint uid)
+emit_user_added (IndicatorSessionUsersDbus * self, guint32 uid)
{
- if (is_public_uid (self, uid))
+ if (is_tracked_uid (self, uid))
indicator_session_users_added (INDICATOR_SESSION_USERS(self), uid);
}
static void
-emit_user_changed (IndicatorSessionUsersDbus * self, guint uid)
+emit_user_changed (IndicatorSessionUsersDbus * self, guint32 uid)
{
- if (is_public_uid (self, uid))
+ if (is_tracked_uid (self, uid))
indicator_session_users_changed (INDICATOR_SESSION_USERS(self), uid);
}
static void
-emit_user_removed (IndicatorSessionUsersDbus * self, guint uid)
+emit_user_removed (IndicatorSessionUsersDbus * self, guint32 uid)
{
- if (is_public_uid (self, uid))
- indicator_session_users_removed (INDICATOR_SESSION_USERS(self), uid);
+ indicator_session_users_removed (INDICATOR_SESSION_USERS(self), uid);
}
/***
@@ -259,18 +218,13 @@ track_user (IndicatorSessionUsersDbus * self,
AccountsUser * user)
{
const guint32 uid = accounts_user_get_uid (user);
- const gpointer uid_key = GUINT_TO_POINTER (uid);
priv_t * p = self->priv;
gulong id;
- gboolean already_had_user;
-
- g_return_if_fail (is_public_user (self, user));
-
- already_had_user = g_hash_table_contains (p->uid_to_account, uid_key);
+ const gboolean already_had_user = is_tracked_uid (self, uid);
id = g_signal_connect (user, "changed", G_CALLBACK(on_user_changed), self);
object_add_connection (G_OBJECT(user), id);
- g_hash_table_insert (p->uid_to_account, uid_key, user);
+ g_hash_table_insert (p->uid_to_account, GUINT_TO_POINTER (uid), user);
if (already_had_user)
emit_user_changed (self, uid);
@@ -321,13 +275,13 @@ on_user_proxy_ready (GObject * o G_GNUC_UNUSED,
g_error_free (err);
}
- else if (is_public_user (self, user))
+ else if (!accounts_user_get_system_account (user))
{
track_user (self, user);
}
else
{
- g_object_unref (self);
+ g_object_unref (user);
}
}
@@ -456,12 +410,11 @@ on_login1_manager_session_list_ready (GObject * o,
{
set_active_uid (self, uid);
- if (is_live_user (uid, user_name))
+ if ((uid==999) && !g_strcmp0 (user_name, "ubuntu"))
is_live_session = TRUE;
}
- if (is_public_uid (self, uid))
- g_hash_table_add (logins, GINT_TO_POINTER(uid));
+ g_hash_table_add (logins, GINT_TO_POINTER(uid));
}
set_is_live_session_flag (self, is_live_session);
@@ -485,8 +438,35 @@ update_session_list (IndicatorSessionUsersDbus * self)
}
}
+static gboolean
+on_update_session_list_timer (gpointer gself)
+{
+ IndicatorSessionUsersDbus * self = INDICATOR_SESSION_USERS_DBUS (gself);
+
+ update_session_list (self);
+
+ self->priv->update_list_tag = 0;
+ return G_SOURCE_REMOVE;
+}
+
+/* A dead session can still show up in list-sessions for a few seconds.
+ So just to be safe, queue up a rebuild for a few seconds from now */
static void
-set_login1_manager (IndicatorSessionUsersDbus * self, Login1Manager * login1_manager)
+update_session_list_twice (IndicatorSessionUsersDbus * self)
+{
+ priv_t * p = self->priv;
+
+ update_session_list (self);
+
+ if (p->update_list_tag == 0)
+ p->update_list_tag = g_timeout_add_seconds (5,
+ on_update_session_list_timer,
+ self);
+}
+
+static void
+set_login1_manager (IndicatorSessionUsersDbus * self,
+ Login1Manager * login1_manager)
{
priv_t * p = self->priv;
@@ -504,7 +484,11 @@ set_login1_manager (IndicatorSessionUsersDbus * self, Login1Manager * login1_man
g_signal_connect_swapped (login1_manager, "session-new",
G_CALLBACK(update_session_list), self);
g_signal_connect_swapped (login1_manager, "session-removed",
+ G_CALLBACK(update_session_list_twice), self);
+ g_signal_connect_swapped (login1_manager, "user-new",
G_CALLBACK(update_session_list), self);
+ g_signal_connect_swapped (login1_manager, "user-removed",
+ G_CALLBACK(update_session_list_twice), self);
update_session_list (self);
}
}
@@ -632,6 +616,12 @@ my_dispose (GObject * o)
IndicatorSessionUsersDbus * self = INDICATOR_SESSION_USERS_DBUS (o);
priv_t * p = self->priv;
+ if (p->update_list_tag != 0)
+ {
+ g_source_remove (p->update_list_tag);
+ p->update_list_tag = 0;
+ }
+
if (p->cancellable)
{
g_cancellable_cancel (p->cancellable);