mesh: Add finalization of a newly created node 16/235116/1
authorInga Stotland <inga.stotland@intel.com>
Fri, 22 May 2020 00:34:55 +0000 (17:34 -0700)
committerAbhay Agarwal <ay.agarwal@samsung.com>
Thu, 28 May 2020 11:27:22 +0000 (16:57 +0530)
When a new node is created as a result of successful completion
of either Join() or Create() or Import() methods and has been
confirmed via successful token delivery to the application,
clean up node's D-Bus resources (application path, element paths, etc)
that have been gathered during the initial GetMAnagedObjects() call.
Also, remove the agent instance associaed with the new node.

These resources will be re-populated after the Attach() call
verifies the node's integrity.

Change-Id: Icaf8b5f6d747cb82ac6443550393dc00d36af2e2
Signed-off-by: Abhay Agarwal <ay.agarwal@samsung.com>
mesh/mesh.c
mesh/node.c
mesh/node.h

index fec472c..32540cc 100644 (file)
@@ -448,7 +448,7 @@ static void prov_join_complete_reply_cb(struct l_dbus_message *message,
                failed = true;
 
        if (!failed)
-               node_attach_io(join_pending->node, mesh.io);
+               node_finalize_new_node(join_pending->node, mesh.io);
 
        free_pending_join_call(failed);
 }
@@ -692,7 +692,7 @@ static void create_join_complete_reply_cb(struct l_dbus_message *message,
                return;
        }
 
-       node_attach_io(node, mesh.io);
+       node_finalize_new_node(node, mesh.io);
 }
 
 static void create_node_ready_cb(void *user_data, int status,
index 077187e..809485a 100644 (file)
@@ -992,12 +992,6 @@ static void attach_io(void *a, void *b)
                mesh_net_attach(node->net, io);
 }
 
-/* Register callback for the node's io */
-void node_attach_io(struct mesh_node *node, struct mesh_io *io)
-{
-       attach_io(node, io);
-}
-
 /* Register callbacks for all nodes io */
 void node_attach_io_all(struct mesh_io *io)
 {
@@ -1467,7 +1461,6 @@ static void get_managed_objects_cb(struct l_dbus_message *msg, void *user_data)
        const char *path;
        struct mesh_node *node = req->node;
        struct node_import *import;
-       void *agent = NULL;
        bool have_app = false;
        unsigned int num_ele;
        struct keyring_net_key net_key;
@@ -1515,13 +1508,11 @@ static void get_managed_objects_cb(struct l_dbus_message *msg, void *user_data)
                                const char *sender;
 
                                sender = l_dbus_message_get_sender(msg);
-                               agent = mesh_agent_create(path, sender,
+                               node->agent = mesh_agent_create(path, sender,
                                                                &properties);
-                               if (!agent)
+                               if (!node->agent)
                                        goto fail;
 
-                               node->agent = agent;
-
                        } else if (!strcmp(MESH_PROVISIONER_INTERFACE,
                                                                interface)) {
                                node->provisioner = true;
@@ -1629,9 +1620,6 @@ static void get_managed_objects_cb(struct l_dbus_message *msg, void *user_data)
        }
 
 fail:
-       if (agent)
-               mesh_agent_remove(agent);
-
        /* Handle failed requests */
        if (node)
                node_remove(node);
@@ -2348,3 +2336,26 @@ bool node_load_from_storage(const char *storage_dir)
 {
        return mesh_config_load_nodes(storage_dir, init_from_storage, NULL);
 }
+
+/*
+ * This is called for a new node that:
+ *         - has been created as a result of successful completion of Join()
+ *           or Create() or Import() methods
+ *     and
+ *         - has been confirmed via successful token delivery to the application
+ *
+ * After a node has been created, the information gathered during initial
+ * GetManagedObjects() call is cleared. The subsequent call to Attach() would
+ * verify node's integrity and re-initialize node's D-Bus resources.
+ */
+void node_finalize_new_node(struct mesh_node *node, struct mesh_io *io)
+{
+       if (!node)
+               return;
+
+       free_node_dbus_resources(node);
+       mesh_agent_remove(node->agent);
+
+       /* Register callback for the node's io */
+       attach_io(node, io);
+}
index 38aea13..3019d31 100644 (file)
@@ -100,3 +100,4 @@ struct mesh_config *node_config_get(struct mesh_node *node);
 struct mesh_agent *node_get_agent(struct mesh_node *node);
 const char *node_get_storage_dir(struct mesh_node *node);
 bool node_load_from_storage(const char *storage_dir);
+void node_finalize_new_node(struct mesh_node *node, struct mesh_io *io);