Add functionality to support sending reply at specific point

store GDBusMethodInvocation object with 'req_key' in 'req_table'
pkgmgr-server calls '__return_value_to_caller' after job finished

Change-Id: I026fceca63648b5dd7e9d4e8a1182c32869c1dca
Signed-off-by: Sangyoon Jang <s89.jang@samsung.com>

diff --git a/include/pkgmgr-server.h b/include/pkgmgr-server.h
index 69cca87..6bdafe2 100644 (file)
--- a/include/pkgmgr-server.h
+++ b/include/pkgmgr-server.h
@@ -77,6 +77,7 @@ typedef struct backend_info_t {
 char *_get_backend_cmd(char *type);
 
 gboolean queue_job(void *data);
+int __return_value_to_caller(const char *req_key, GVariant *result);
 int __init_request_handler(void);
 void __fini_request_handler(void);
 

diff --git a/src/request.c b/src/request.c
index 9e59939..cbce8dd 100644 (file)
--- a/src/request.c
+++ b/src/request.c
@@ -95,6 +95,7 @@ static const char instropection_xml[] =
 static GDBusNodeInfo *instropection_data;
 static guint reg_id;
 static guint owner_id;
+static GHashTable *req_table;
 
 static char *__generate_reqkey(const char *pkgid)
 {
@@ -553,6 +554,23 @@ static void __handle_method_call(GDBusConnection *connection,
                g_idle_add(queue_job, NULL);
 }
 
+int __return_value_to_caller(const char *req_key, GVariant *result)
+{
+       GDBusMethodInvocation *invocation;
+
+       invocation = (GDBusMethodInvocation *)g_hash_table_lookup(req_table,
+                       (gpointer)req_key);
+       if (invocation == NULL) {
+               ERR("no such request id");
+               return -1;
+       }
+
+       g_dbus_method_invocation_return_value(invocation, result);
+       g_hash_table_remove(req_table, (gpointer)req_key);
+
+       return 0;
+}
+
 static const GDBusInterfaceVTable interface_vtable =
 {
        __handle_method_call,
@@ -598,11 +616,17 @@ int __init_request_handler(void)
                        G_BUS_NAME_OWNER_FLAGS_NONE, __on_bus_acquired,
                        __on_name_acquired, __on_name_lost, NULL, NULL);
 
+       req_table = g_hash_table_new_full(g_str_hash, g_str_equal,
+                       free, NULL);
+       if (req_table == NULL)
+               return -1;
+
        return 0;
 }
 
 void __fini_request_handler(void)
 {
+       g_hash_table_destroy(req_table);
        g_bus_unown_name(owner_id);
        g_dbus_node_info_unref(instropection_data);
 }