linux-bluetooth.vger.kernel.org archive mirror
 help / color / mirror / Atom feed
* [PATCH] gatt-database: Fix GATT object ordering
@ 2016-03-03 22:55 Olivier Martin
  2016-03-04 15:14 ` Luiz Augusto von Dentz
  0 siblings, 1 reply; 2+ messages in thread
From: Olivier Martin @ 2016-03-03 22:55 UTC (permalink / raw)
  To: linux-bluetooth; +Cc: olivier.martin.fr, Olivier Martin

There is no guarantee the objects returned by GetManagedObjects
are ordered in the required order which is Service, Characteristic
Descriptor due to their respective dependencies.

This change ensures the objects are processed in the correct order.
---
 src/gatt-database.c | 109 +++++++++++++++++++++++++++++++++++++---------------
 1 file changed, 79 insertions(+), 30 deletions(-)

diff --git a/src/gatt-database.c b/src/gatt-database.c
index d906e2b..dc020b8 100644
--- a/src/gatt-database.c
+++ b/src/gatt-database.c
@@ -89,6 +89,7 @@ struct gatt_app {
 	GDBusClient *client;
 	bool failed;
 	struct queue *services;
+	struct queue *proxy_objects;
 };
 
 struct external_service {
@@ -360,11 +361,19 @@ static void service_free(void *data)
 	free(service);
 }
 
+static void proxy_object_free(void *data)
+{
+	struct GDBusProxy *proxy = data;
+
+	g_dbus_proxy_unref(proxy);
+}
+
 static void app_free(void *data)
 {
 	struct gatt_app *app = data;
 
 	queue_destroy(app->services, service_free);
+	queue_destroy(app->proxy_objects, proxy_object_free);
 
 	if (app->client) {
 		g_dbus_client_set_disconnect_watch(app->client, NULL, NULL);
@@ -1428,39 +1437,12 @@ static void proxy_added_cb(GDBusProxy *proxy, void *user_data)
 	if (app->failed)
 		return;
 
+	queue_push_tail(app->proxy_objects, g_dbus_proxy_ref(proxy));
+
 	iface = g_dbus_proxy_get_interface(proxy);
 	path = g_dbus_proxy_get_path(proxy);
 
-	if (g_strcmp0(iface, GATT_SERVICE_IFACE) == 0) {
-		struct external_service *service;
-
-		service = create_service(app, proxy, path);
-		if (!service) {
-			app->failed = true;
-			return;
-		}
-	} else if (g_strcmp0(iface, GATT_CHRC_IFACE) == 0) {
-		struct external_chrc *chrc;
-
-		chrc = chrc_create(app, proxy, path);
-		if (!chrc) {
-			app->failed = true;
-			return;
-		}
-	} else if (g_strcmp0(iface, GATT_DESC_IFACE) == 0) {
-		struct external_desc *desc;
-
-		desc = desc_create(app, proxy);
-		if (!desc) {
-			app->failed = true;
-			return;
-		}
-	} else {
-		DBG("Ignoring unrelated interface: %s", iface);
-		return;
-	}
-
-	DBG("Object added: path: %s, iface: %s", path, iface);
+	DBG("Object received: %s, iface: %s", path, iface);
 }
 
 static void proxy_removed_cb(GDBusProxy *proxy, void *user_data)
@@ -2139,12 +2121,78 @@ static bool database_add_app(struct gatt_app *app)
 	return true;
 }
 
+void register_service(void *data, void *user_data) {
+	struct gatt_app *app = user_data;
+	GDBusProxy *proxy = data;
+        const char *iface = g_dbus_proxy_get_interface(proxy);
+        const char *path = g_dbus_proxy_get_path(proxy);
+
+        if (g_strcmp0(iface, GATT_SERVICE_IFACE) == 0) {
+                struct external_service *service;
+
+                service = create_service(app, proxy, path);
+                if (!service) {
+                        app->failed = true;
+                        return;
+                }
+        }
+}
+
+void register_characteristic(void *data, void *user_data) {
+        struct gatt_app *app = user_data;
+        GDBusProxy *proxy = data;
+        const char *iface = g_dbus_proxy_get_interface(proxy);
+        const char *path = g_dbus_proxy_get_path(proxy);
+
+	if (g_strcmp0(iface, GATT_CHRC_IFACE) == 0) {
+                struct external_chrc *chrc;
+
+                chrc = chrc_create(app, proxy, path);
+                if (!chrc) {
+                        app->failed = true;
+                        return;
+                }
+        }
+}
+
+void register_descriptor(void *data, void *user_data) {
+        struct gatt_app *app = user_data;
+        GDBusProxy *proxy = data;
+        const char *iface = g_dbus_proxy_get_interface(proxy);
+        const char *path = g_dbus_proxy_get_path(proxy);
+
+	if (g_strcmp0(iface, GATT_DESC_IFACE) == 0) {
+                struct external_desc *desc;
+
+                desc = desc_create(app, proxy);
+                if (!desc) {
+                        app->failed = true;
+                        return;
+                }
+        }
+}
+
 static void client_ready_cb(GDBusClient *client, void *user_data)
 {
 	struct gatt_app *app = user_data;
 	DBusMessage *reply;
 	bool fail = false;
 
+	/*
+	 * Process received objects
+	 */
+	if (queue_isempty(app->proxy_objects)) {
+		error("No object received");
+                fail = true;
+                reply = btd_error_failed(app->reg,
+                                        "No object received");
+                goto reply;
+	}
+
+	queue_foreach(app->proxy_objects, register_service, app);
+	queue_foreach(app->proxy_objects, register_characteristic, app);
+	queue_foreach(app->proxy_objects, register_descriptor, app);
+
 	if (!app->services || app->failed) {
 		error("No valid external GATT objects found");
 		fail = true;
@@ -2198,6 +2246,7 @@ static struct gatt_app *create_app(DBusConnection *conn, DBusMessage *msg,
 		goto fail;
 
 	app->services = queue_new();
+	app->proxy_objects = queue_new();
 	app->reg = dbus_message_ref(msg);
 
 	g_dbus_client_set_disconnect_watch(app->client, client_disconnect_cb,
-- 
2.1.4


^ permalink raw reply related	[flat|nested] 2+ messages in thread

end of thread, other threads:[~2016-03-04 15:14 UTC | newest]

Thread overview: 2+ messages (download: mbox.gz follow: Atom feed
-- links below jump to the message on this page --
2016-03-03 22:55 [PATCH] gatt-database: Fix GATT object ordering Olivier Martin
2016-03-04 15:14 ` Luiz Augusto von Dentz

This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).