aboutsummaryrefslogtreecommitdiffstats
path: root/libempathy/empathy-tp-tube.c
diff options
context:
space:
mode:
authorXavier Claessens <xclaesse@src.gnome.org>2008-04-20 05:04:27 +0800
committerXavier Claessens <xclaesse@src.gnome.org>2008-04-20 05:04:27 +0800
commitca6d0efe52f210a779fa1ceac42c8feff3ade07b (patch)
tree44be7939a1eb65018a37a92e9ffd0c883b142f0e /libempathy/empathy-tp-tube.c
parent236262c25f3660c7ed891eaafc89f7eeebfdc5c7 (diff)
downloadgsoc2013-empathy-ca6d0efe52f210a779fa1ceac42c8feff3ade07b.tar
gsoc2013-empathy-ca6d0efe52f210a779fa1ceac42c8feff3ade07b.tar.gz
gsoc2013-empathy-ca6d0efe52f210a779fa1ceac42c8feff3ade07b.tar.bz2
gsoc2013-empathy-ca6d0efe52f210a779fa1ceac42c8feff3ade07b.tar.lz
gsoc2013-empathy-ca6d0efe52f210a779fa1ceac42c8feff3ade07b.tar.xz
gsoc2013-empathy-ca6d0efe52f210a779fa1ceac42c8feff3ade07b.tar.zst
gsoc2013-empathy-ca6d0efe52f210a779fa1ceac42c8feff3ade07b.zip
Call ListTubes in EmpathyTpTube's constructor to avoid races
svn path=/trunk/; revision=986
Diffstat (limited to 'libempathy/empathy-tp-tube.c')
-rw-r--r--libempathy/empathy-tp-tube.c163
1 files changed, 67 insertions, 96 deletions
diff --git a/libempathy/empathy-tp-tube.c b/libempathy/empathy-tp-tube.c
index 78b517a82..aed218d3b 100644
--- a/libempathy/empathy-tp-tube.c
+++ b/libempathy/empathy-tp-tube.c
@@ -143,21 +143,6 @@ tp_tube_set_property (GObject *object,
case PROP_ID:
priv->id = g_value_get_uint (value);
break;
- case PROP_INITIATOR:
- priv->initiator = g_value_get_uint (value);
- break;
- case PROP_TYPE:
- priv->type = g_value_get_uint (value);
- break;
- case PROP_SERVICE:
- priv->service = g_value_dup_string (value);
- break;
- case PROP_PARAMETERS:
- priv->parameters = g_value_dup_boxed (value);
- break;
- case PROP_STATE:
- priv->state = g_value_get_uint (value);
- break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
@@ -211,34 +196,67 @@ tp_tube_constructor (GType type,
{
GObject *self;
EmpathyTpTubePriv *priv;
- TpConnection *connection;
- MissionControl *mc;
- McAccount *account;
+ GPtrArray *tubes;
+ guint i;
+ GError *error = NULL;
self = G_OBJECT_CLASS (empathy_tp_tube_parent_class)->constructor (
type, n_props, props);
priv = GET_PRIV (self);
- g_object_get (priv->channel, "connection", &connection, NULL);
- mc = empathy_mission_control_new ();
- account = mission_control_get_account_for_tpconnection (mc, connection, NULL);
-
- priv->factory = empathy_contact_factory_new ();
- priv->initiator_contact = empathy_contact_factory_get_from_handle (priv->factory,
- account, priv->initiator);
- g_object_ref (priv->initiator_contact);
-
g_signal_connect (priv->channel, "invalidated",
G_CALLBACK (tp_tube_invalidated_cb), self);
-
tp_cli_channel_type_tubes_connect_to_tube_closed (priv->channel,
tp_tube_closed_cb, NULL, NULL, self, NULL);
tp_cli_channel_type_tubes_connect_to_tube_state_changed (priv->channel,
tp_tube_state_changed_cb, NULL, NULL, self, NULL);
- g_object_unref (connection);
- g_object_unref (mc);
- g_object_unref (account);
+ /* FIXME: It is absolutely not opimized to list all tubes to get information
+ * about our tube, but we don't really have the choice to avoid races. */
+ if (!tp_cli_channel_type_tubes_run_list_tubes (priv->channel, -1, &tubes,
+ &error, NULL))
+ {
+ empathy_debug (DEBUG_DOMAIN, "Couldn't list tubes: %s",
+ error->message);
+ g_clear_error (&error);
+ return self;
+ }
+
+ for (i = 0; i < tubes->len; i++)
+ {
+ GValueArray *values;
+ guint id;
+
+ values = g_ptr_array_index (tubes, i);
+ id = g_value_get_uint (g_value_array_get_nth (values, 0));
+
+ if (id == priv->id)
+ {
+ TpConnection *connection;
+ MissionControl *mc;
+ McAccount *account;
+
+ g_object_get (priv->channel, "connection", &connection, NULL);
+ mc = empathy_mission_control_new ();
+ account = mission_control_get_account_for_tpconnection (mc,
+ connection, NULL);
+
+ priv->initiator = g_value_get_uint (g_value_array_get_nth (values, 1));
+ priv->type = g_value_get_uint (g_value_array_get_nth (values, 2));
+ priv->service = g_value_dup_string (g_value_array_get_nth (values, 3));
+ priv->parameters = g_value_dup_boxed (g_value_array_get_nth (values, 4));
+ priv->state = g_value_get_uint (g_value_array_get_nth (values, 5));
+ priv->initiator_contact = empathy_contact_factory_get_from_handle (
+ priv->factory, account, priv->initiator);
+
+ g_object_unref (connection);
+ g_object_unref (mc);
+ g_object_unref (account);
+ }
+
+ g_value_array_free (values);
+ }
+ g_ptr_array_free (tubes, TRUE);
return self;
}
@@ -291,33 +309,33 @@ empathy_tp_tube_class_init (EmpathyTpTubeClass *klass)
g_object_class_install_property (object_class, PROP_INITIATOR,
g_param_spec_uint ("initiator", "initiator", "initiator",
- 0, G_MAXUINT, 0, G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY |
- G_PARAM_STATIC_NAME | G_PARAM_STATIC_NICK | G_PARAM_STATIC_BLURB));
+ 0, G_MAXUINT, 0, G_PARAM_READABLE | G_PARAM_STATIC_NAME |
+ G_PARAM_STATIC_NICK | G_PARAM_STATIC_BLURB));
g_object_class_install_property (object_class, PROP_TYPE,
g_param_spec_uint ("type", "type", "type", 0, G_MAXUINT, 0,
- G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY | G_PARAM_STATIC_NAME |
- G_PARAM_STATIC_NICK | G_PARAM_STATIC_BLURB));
+ G_PARAM_READABLE | G_PARAM_STATIC_NAME | G_PARAM_STATIC_NICK |
+ G_PARAM_STATIC_BLURB));
g_object_class_install_property (object_class, PROP_SERVICE,
g_param_spec_string ("service", "service", "service", NULL,
- G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY | G_PARAM_STATIC_NAME |
- G_PARAM_STATIC_NICK | G_PARAM_STATIC_BLURB));
+ G_PARAM_READABLE | G_PARAM_STATIC_NAME | G_PARAM_STATIC_NICK |
+ G_PARAM_STATIC_BLURB));
g_object_class_install_property (object_class, PROP_PARAMETERS,
g_param_spec_boxed ("parameters", "parameters", "parameters",
- G_TYPE_HASH_TABLE, G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY |
- G_PARAM_STATIC_NAME | G_PARAM_STATIC_NICK | G_PARAM_STATIC_BLURB));
+ G_TYPE_HASH_TABLE, G_PARAM_READABLE | G_PARAM_STATIC_NAME |
+ G_PARAM_STATIC_NICK | G_PARAM_STATIC_BLURB));
g_object_class_install_property (object_class, PROP_STATE,
g_param_spec_uint ("state", "state", "state", 0, G_MAXUINT, 0,
- G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY |
- G_PARAM_STATIC_NAME | G_PARAM_STATIC_NICK | G_PARAM_STATIC_BLURB));
+ G_PARAM_READABLE | G_PARAM_STATIC_NAME | G_PARAM_STATIC_NICK |
+ G_PARAM_STATIC_BLURB));
g_object_class_install_property (object_class, PROP_INITIATOR_CONTACT,
g_param_spec_object ("initiator-contact", "initiator contact",
"initiator contact", EMPATHY_TYPE_CONTACT, G_PARAM_READABLE |
- G_PARAM_STATIC_NAME | G_PARAM_STATIC_NICK | G_PARAM_STATIC_BLURB));
+ G_PARAM_STATIC_NAME | G_PARAM_STATIC_NICK | G_PARAM_STATIC_BLURB));
signals[DESTROY] = g_signal_new ("destroy",
G_TYPE_FROM_CLASS (klass),
@@ -330,58 +348,20 @@ empathy_tp_tube_class_init (EmpathyTpTubeClass *klass)
}
static void
-empathy_tp_tube_init (EmpathyTpTube *tp_tubes)
+empathy_tp_tube_init (EmpathyTpTube *tube)
{
+ EmpathyTpTubePriv *priv = GET_PRIV (tube);
+
+ priv->factory = empathy_contact_factory_new ();
}
EmpathyTpTube *
empathy_tp_tube_new (TpChannel *channel, guint tube_id)
{
- EmpathyTpTube *tube = NULL;
- GPtrArray *tubes;
- guint i;
- GError *error = NULL;
-
g_return_val_if_fail (TP_IS_CHANNEL (channel), NULL);
- if (!tp_cli_channel_type_tubes_run_list_tubes (channel, -1, &tubes,
- &error, NULL))
- {
- empathy_debug (DEBUG_DOMAIN, "Couldn't list tubes: %s",
- error->message);
- g_clear_error (&error);
- return NULL;
- }
-
- for (i = 0; i < tubes->len; i++)
- {
- GValueArray *values;
- guint id;
-
- values = g_ptr_array_index (tubes, i);
- id = g_value_get_uint (g_value_array_get_nth (values, 0));
-
- if (id != tube_id)
- {
- g_value_array_free (values);
- continue;
- }
-
- tube = g_object_new (EMPATHY_TYPE_TP_TUBE,
- "channel", channel,
- "id", id,
- "initiator", g_value_get_uint (g_value_array_get_nth (values, 1)),
- "type", g_value_get_uint (g_value_array_get_nth (values, 2)),
- "service", g_value_get_string (g_value_array_get_nth (values, 3)),
- "parameters", g_value_get_boxed (g_value_array_get_nth (values, 4)),
- "state", g_value_get_uint (g_value_array_get_nth (values, 5)),
- NULL);
-
- g_value_array_free (values);
- }
- g_ptr_array_free (tubes, TRUE);
-
- return tube;
+ return g_object_new (EMPATHY_TYPE_TP_TUBE,
+ "channel", channel, "id", tube_id, NULL);
}
EmpathyTpTube *
@@ -452,16 +432,7 @@ empathy_tp_tube_new_stream_tube (EmpathyContact *contact,
empathy_debug (DEBUG_DOMAIN, "Stream tube id=%d offered", id);
- /* FIXME: We shouldn't assume state is remote-pending */
- tube = g_object_new (EMPATHY_TYPE_TP_TUBE,
- "channel", channel,
- "id", id,
- "initiator", empathy_contact_get_handle (contact),
- "type", type,
- "service", service,
- "parameters", control_param,
- "state", TP_TUBE_STATE_REMOTE_PENDING,
- NULL);
+ tube = empathy_tp_tube_new (channel, id);
g_object_unref (channel);
g_free (object_path);