zehortigoza pushed a commit to branch master.
commit 36b71d867c6f6280af0955ae04e326afbecb7c22
Author: José Roberto de Souza <[email protected]>
Date: Fri Aug 23 16:54:12 2013 -0300
eldbus: Send property changed signals before close connection
---
src/lib/eldbus/eldbus_core.c | 7 ++
src/lib/eldbus/eldbus_service.c | 207 +++++++++++++++++++++-------------------
2 files changed, 115 insertions(+), 99 deletions(-)
diff --git a/src/lib/eldbus/eldbus_core.c b/src/lib/eldbus/eldbus_core.c
index 3b1e6af..509c2ea 100644
--- a/src/lib/eldbus/eldbus_core.c
+++ b/src/lib/eldbus/eldbus_core.c
@@ -1135,6 +1135,13 @@ _eldbus_connection_free(Eldbus_Connection *conn)
conn->refcount = 1;
eldbus_cbs_free_dispatch(&(conn->cbs_free), conn);
+ /**
+ * Flush all messages in outgoing queue, also this will send all
+ * ObjectManager and Property changed signals of all paths that
+ * this connection is server.
+ */
+ dbus_connection_flush(conn->dbus_conn);
+
EINA_INLIST_FOREACH_SAFE(conn->pendings, list, p)
eldbus_pending_cancel(p);
diff --git a/src/lib/eldbus/eldbus_service.c b/src/lib/eldbus/eldbus_service.c
index 40a86b0..9402e33 100644
--- a/src/lib/eldbus/eldbus_service.c
+++ b/src/lib/eldbus/eldbus_service.c
@@ -974,6 +974,101 @@ fail:
return NULL;
}
+static Eina_Bool
+_idler_propschanged(void *data)
+{
+ Eldbus_Service_Interface *iface = data;
+ Eldbus_Message *msg;
+ Eldbus_Message_Iter *main_iter, *dict, *array_invalidate;
+ Eina_Hash *added = NULL;
+ Property *prop;
+
+ iface->idler_propschanged = NULL;
+
+ added = eina_hash_string_small_new(NULL);
+ msg = eldbus_message_signal_new(iface->obj->path, properties_iface->name,
+ properties_iface->signals[0].name);
+ EINA_SAFETY_ON_NULL_GOTO(msg, error);
+
+ main_iter = eldbus_message_iter_get(msg);
+ if (!eldbus_message_iter_arguments_append(main_iter, "sa{sv}", iface->name,
&dict))
+ {
+ eldbus_message_unref(msg);
+ goto error;
+ }
+
+ if (!iface->props_changed)
+ goto invalidate;
+ while ((prop = eina_array_pop(iface->props_changed)))
+ {
+ Eldbus_Message_Iter *entry, *var;
+ Eldbus_Message *error_reply = NULL;
+ Eina_Bool ret;
+ Eldbus_Property_Get_Cb getter = NULL;
+
+ if (eina_hash_find(added, prop->property->name))
+ continue;
+ eina_hash_add(added, prop->property->name, prop);
+
+ if (prop->property->get_func)
+ getter = prop->property->get_func;
+ else if (iface->get_func)
+ getter = iface->get_func;
+
+ if (!getter || prop->is_invalidate)
+ continue;
+
+ EINA_SAFETY_ON_FALSE_GOTO(
+ eldbus_message_iter_arguments_append(dict, "{sv}", &entry),
error);
+
+ eldbus_message_iter_basic_append(entry, 's', prop->property->name);
+ var = eldbus_message_iter_container_new(entry, 'v',
+ prop->property->type);
+
+ ret = getter(iface, prop->property->name, var, NULL, &error_reply);
+ if (!ret)
+ {
+ eldbus_message_unref(msg);
+ if (error_reply)
+ {
+ ERR("Error reply was set without pass any input message.");
+ eldbus_message_unref(error_reply);
+ }
+ ERR("Getter of property %s returned error.",
prop->property->name);
+ goto error;
+ }
+
+ eldbus_message_iter_container_close(entry, var);
+ eldbus_message_iter_container_close(dict, entry);
+ }
+invalidate:
+ eldbus_message_iter_container_close(main_iter, dict);
+
+ eldbus_message_iter_arguments_append(main_iter, "as", &array_invalidate);
+
+ if (!iface->prop_invalidated)
+ goto end;
+ while ((prop = eina_array_pop(iface->prop_invalidated)))
+ {
+ if (!prop->is_invalidate)
+ continue;
+ eldbus_message_iter_basic_append(array_invalidate, 's',
+ prop->property->name);
+ }
+end:
+ eldbus_message_iter_container_close(main_iter, array_invalidate);
+
+ eldbus_service_signal_send(iface, msg);
+error:
+ if (added)
+ eina_hash_free(added);
+ if (iface->props_changed)
+ eina_array_flush(iface->props_changed);
+ if (iface->prop_invalidated)
+ eina_array_flush(iface->prop_invalidated);
+ return ECORE_CALLBACK_CANCEL;
+}
+
static void
_interface_free(Eldbus_Service_Interface *interface)
{
@@ -985,6 +1080,15 @@ _interface_free(Eldbus_Service_Interface *interface)
interface == objmanager)
return;
+ /**
+ * flush props changes before remove interface
+ */
+ if (interface->idler_propschanged)
+ {
+ ecore_idler_del(interface->idler_propschanged);
+ _idler_propschanged(interface);
+ }
+
eina_hash_free(interface->methods);
while ((sig = eina_array_pop(interface->sign_of_signals)))
eina_stringshare_del(sig);
@@ -992,8 +1096,6 @@ _interface_free(Eldbus_Service_Interface *interface)
eina_hash_free(interface->properties);
if (interface->props_changed)
eina_array_free(interface->props_changed);
- if (interface->idler_propschanged)
- ecore_idler_del(interface->idler_propschanged);
if (interface->prop_invalidated)
eina_array_free(interface->prop_invalidated);
@@ -1031,8 +1133,10 @@ _object_free(Eldbus_Service_Object *obj)
/* Flush ObjectManager interface before the entire object goes away */
if (obj->idler_iface_changed)
- ecore_idler_del(obj->idler_iface_changed);
- _object_manager_changes_process(obj);
+ {
+ ecore_idler_del(obj->idler_iface_changed);
+ _object_manager_changes_process(obj);
+ }
iterator = eina_hash_iterator_data_new(obj->interfaces);
EINA_ITERATOR_FOREACH(iterator, iface)
@@ -1256,101 +1360,6 @@ eldbus_service_object_data_del(Eldbus_Service_Interface
*iface, const char *key)
return eldbus_data_del(&(((Eldbus_Service_Object *)iface->obj)->data), key);
}
-static Eina_Bool
-_idler_propschanged(void *data)
-{
- Eldbus_Service_Interface *iface = data;
- Eldbus_Message *msg;
- Eldbus_Message_Iter *main_iter, *dict, *array_invalidate;
- Eina_Hash *added = NULL;
- Property *prop;
-
- iface->idler_propschanged = NULL;
-
- added = eina_hash_string_small_new(NULL);
- msg = eldbus_message_signal_new(iface->obj->path, properties_iface->name,
- properties_iface->signals[0].name);
- EINA_SAFETY_ON_NULL_GOTO(msg, error);
-
- main_iter = eldbus_message_iter_get(msg);
- if (!eldbus_message_iter_arguments_append(main_iter, "sa{sv}", iface->name,
&dict))
- {
- eldbus_message_unref(msg);
- goto error;
- }
-
- if (!iface->props_changed)
- goto invalidate;
- while ((prop = eina_array_pop(iface->props_changed)))
- {
- Eldbus_Message_Iter *entry, *var;
- Eldbus_Message *error_reply = NULL;
- Eina_Bool ret;
- Eldbus_Property_Get_Cb getter = NULL;
-
- if (eina_hash_find(added, prop->property->name))
- continue;
- eina_hash_add(added, prop->property->name, prop);
-
- if (prop->property->get_func)
- getter = prop->property->get_func;
- else if (iface->get_func)
- getter = iface->get_func;
-
- if (!getter || prop->is_invalidate)
- continue;
-
- EINA_SAFETY_ON_FALSE_GOTO(
- eldbus_message_iter_arguments_append(dict, "{sv}", &entry),
error);
-
- eldbus_message_iter_basic_append(entry, 's', prop->property->name);
- var = eldbus_message_iter_container_new(entry, 'v',
- prop->property->type);
-
- ret = getter(iface, prop->property->name, var, NULL, &error_reply);
- if (!ret)
- {
- eldbus_message_unref(msg);
- if (error_reply)
- {
- ERR("Error reply was set without pass any input message.");
- eldbus_message_unref(error_reply);
- }
- ERR("Getter of property %s returned error.",
prop->property->name);
- goto error;
- }
-
- eldbus_message_iter_container_close(entry, var);
- eldbus_message_iter_container_close(dict, entry);
- }
-invalidate:
- eldbus_message_iter_container_close(main_iter, dict);
-
- eldbus_message_iter_arguments_append(main_iter, "as", &array_invalidate);
-
- if (!iface->prop_invalidated)
- goto end;
- while ((prop = eina_array_pop(iface->prop_invalidated)))
- {
- if (!prop->is_invalidate)
- continue;
- eldbus_message_iter_basic_append(array_invalidate, 's',
- prop->property->name);
- }
-end:
- eldbus_message_iter_container_close(main_iter, array_invalidate);
-
- eldbus_service_signal_send(iface, msg);
-error:
- if (added)
- eina_hash_free(added);
- if (iface->props_changed)
- eina_array_flush(iface->props_changed);
- if (iface->prop_invalidated)
- eina_array_flush(iface->prop_invalidated);
- return ECORE_CALLBACK_CANCEL;
-}
-
EAPI Eina_Bool
eldbus_service_property_changed(const Eldbus_Service_Interface *interface,
const char *name)
{
--
------------------------------------------------------------------------------
Introducing Performance Central, a new site from SourceForge and
AppDynamics. Performance Central is your source for news, insights,
analysis and resources for efficient Application Performance Management.
Visit us today!
http://pubads.g.doubleclick.net/gampad/clk?id=48897511&iu=/4140/ostg.clktrk
