From 59aca76bf032c9810a821142208efe12f082e901 Mon Sep 17 00:00:00 2001 From: Brian Gix Date: Tue, 16 Jun 2020 11:14:36 -0700 Subject: [PATCH] mesh: Add deferral of Attach() and Leave() if busy We require the successful return of JoinComplete() method before handling subsequent Attach() or Leave() method calls. To simplify the construction of Applications, we will accept one of these calls up to 1 second prior to receiving the final return status of JoinComplete, which tells us that the Application is ready to use the node. If the node is still not ready after the deferral, Attach and/or Leave will fail. Change-Id: I874b8f8243d17f862fbaa0f7b91b7b1fc627c137 Signed-off-by: anuj.bhumiya --- mesh/mesh.c | 54 ++++++++++++++++++++++++++++++++++++++++++++++++++++-- 1 file changed, 52 insertions(+), 2 deletions(-) diff --git a/mesh/mesh.c b/mesh/mesh.c index b785460..084419d 100644 --- a/mesh/mesh.c +++ b/mesh/mesh.c @@ -103,6 +103,10 @@ static struct l_queue *pending_queue; static const char *storage_dir; +/* Forward static decalrations */ +static void def_attach(struct l_timeout *timeout, void *user_data); +static void def_leave(struct l_timeout *timeout, void *user_data); + static bool simple_match(const void *a, const void *b) { return a == b; @@ -633,12 +637,26 @@ static struct l_dbus_message *attach_call(struct l_dbus *dbus, uint64_t token; const char *app_path, *sender; struct l_dbus_message *pending_msg; + struct mesh_node *node; l_debug("Attach"); if (!l_dbus_message_get_arguments(msg, "ot", &app_path, &token)) return dbus_error(msg, MESH_ERROR_INVALID_ARGS, NULL); + node = node_find_by_token(token); + if (!node) + return dbus_error(msg, MESH_ERROR_NOT_FOUND, "Attach failed"); + + if (node_is_busy(node)) { + if (user_data) + return dbus_error(msg, MESH_ERROR_BUSY, NULL); + + /* Try once more in 1 second */ + l_timeout_create(1, def_attach, l_dbus_message_ref(msg), NULL); + return NULL; + } + sender = l_dbus_message_get_sender(msg); pending_msg = l_dbus_message_ref(msg); @@ -649,6 +667,19 @@ static struct l_dbus_message *attach_call(struct l_dbus *dbus, return NULL; } +static void def_attach(struct l_timeout *timeout, void *user_data) +{ + struct l_dbus *dbus = dbus_get_bus(); + struct l_dbus_message *msg = user_data; + struct l_dbus_message *reply; + + l_timeout_remove(timeout); + + reply = attach_call(dbus, msg, (void *) true); + l_dbus_send(dbus, reply); + l_dbus_message_unref(msg); +} + static struct l_dbus_message *leave_call(struct l_dbus *dbus, struct l_dbus_message *msg, void *user_data) @@ -665,14 +696,33 @@ static struct l_dbus_message *leave_call(struct l_dbus *dbus, if (!node) return dbus_error(msg, MESH_ERROR_NOT_FOUND, NULL); - if (node_is_busy(node)) - return dbus_error(msg, MESH_ERROR_BUSY, NULL); + if (node_is_busy(node)) { + if (user_data) + return dbus_error(msg, MESH_ERROR_BUSY, NULL); + + /* Try once more in 1 second */ + l_timeout_create(1, def_leave, l_dbus_message_ref(msg), NULL); + return NULL; + } node_remove(node); return l_dbus_message_new_method_return(msg); } +static void def_leave(struct l_timeout *timeout, void *user_data) +{ + struct l_dbus *dbus = dbus_get_bus(); + struct l_dbus_message *msg = user_data; + struct l_dbus_message *reply; + + l_timeout_remove(timeout); + + reply = leave_call(dbus, msg, (void *) true); + l_dbus_send(dbus, reply); + l_dbus_message_unref(msg); +} + #ifdef TIZEN_FEATURE_BLUEZ_MODIFY static struct l_dbus_message *release_call(struct l_dbus *dbus, struct l_dbus_message *msg, -- 2.7.4