bidirectional messages implemented, updated the example code

[profile/ivi/message-port.git] / examples / test-app.c

diff --git a/examples/test-app.c b/examples/test-app.c
index 4abf38b..44d9498 100644 (file)
--- a/examples/test-app.c
+++ b/examples/test-app.c
@@ -1,7 +1,9 @@
 #include <glib.h>
 #include <unistd.h>
+#include <stdlib.h>
 #include <message-port.h>
 #include <bundle.h>
+#include "common/log.h"
 
 GMainLoop *__loop = NULL;
 
@@ -10,14 +12,29 @@ static void _dump_data (const char *key, const int type, const bundle_keyval_t *
     gchar *val = NULL;
     size_t size;
     bundle_keyval_get_basic_val ((bundle_keyval_t*)kv, (void**)&val, &size);
-    g_print ("       %s - %s\n", key, val);
+    DBG ("       %s - %s", key, val);
 }
 
-void (_on_got_message)(int port_id, const char* remote_app_id, const char* remote_port, gboolean trusted_message, bundle* data)
+void (_on_child_got_message)(int port_id, const char* remote_app_id, const char* remote_port, gboolean trusted_message, bundle* data)
 {
     gchar *name = NULL;
     messageport_get_local_port_name (port_id, &name),
-    g_print ("SERVER: GOT MESSAGE at prot %s FROM :'%s' - '%s\n", name,
+    DBG ("CHILD: GOT MESSAGE at prot %s FROM :'%s' - '%s", name,
+        remote_app_id ? remote_app_id : "unknwon app", remote_port ? remote_port : "unknwon");
+    g_free (name);
+    g_assert (data);
+
+    bundle_foreach (data, _dump_data, NULL);
+    g_main_loop_quit (__loop);
+}
+
+void (_on_parent_got_message)(int port_id, const char* remote_app_id, const char* remote_port, gboolean trusted_message, bundle* data)
+{
+    gchar *name = NULL;
+    gboolean found = FALSE;
+    bundle *b = NULL;
+    messageport_get_local_port_name (port_id, &name),
+    DBG ("PARENT: GOT MESSAGE at prot %s FROM :'%s' - '%s", name,
         remote_app_id ? remote_app_id : "unknwon app", remote_port ? remote_port : "unknwon");
     g_free (name);
 
@@ -25,12 +42,47 @@ void (_on_got_message)(int port_id, const char* remote_app_id, const char* remot
 
     bundle_foreach (data, _dump_data, NULL);
 
-    g_main_loop_quit (__loop);
+    messageport_error_e res = trusted_message ? messageport_check_trusted_remote_port (remote_app_id, remote_port, &found)
+                                              : messageport_check_remote_port (remote_app_id, remote_port, &found);
+    if (!found) {
+        DBG ("PARENT: Could not found remote port (%d)", res);
+        exit (-1);
+    }
+
+    DBG ("PARENT: Found remote prot");
+
+    bundle *reply = bundle_create ();
+
+    bundle_add (reply, "Results", "GOT_IT");
+
+    DBG ("PARENT: Sending reply ....");
+    res = messageport_send_message (remote_app_id, remote_port, reply);
+    bundle_free (reply);
+    if (res != MESSAGEPORT_ERROR_NONE)
+    {
+        DBG ("PARENT: Faile to send message to server : %d", res);
+    }
+    else DBG ("PARENT: Data sent successfully");
+
+}
+
+int _register_test_port (const gchar *port_name, messageport_message_cb cb)
+{
+    int port_id = messageport_register_local_port (port_name, cb);
+
+    if (port_id > MESSAGEPORT_ERROR_NONE) {
+        gchar *name = NULL;
+        messageport_get_local_port_name (port_id, &name); 
+        g_free (name);
+    }
+    else {
+        DBG ("Failed to register port : %d", port_id);
+    }
+    return port_id;
 }
 
 int main (int argc, char *argv[])
 {
-    const gchar *port_name = "test_port";
     pid_t child_pid;
 
     __loop = g_main_loop_new (NULL, FALSE);
@@ -41,49 +93,38 @@ int main (int argc, char *argv[])
     }
     else if (child_pid > 0)  {
         /* prent process : server port */
-        int port_id = messageport_register_local_port (port_name, _on_got_message);
-
-        if (port_id > MESSAGEPORT_ERROR_NONE) {
-            gchar *name = NULL;
-            messageport_get_local_port_name (port_id, &name); 
-            g_print ("Registerd Port : %s(Id: %d)\n", name, port_id);
-            g_free (name);
-        }
-        else {
-            g_print ("Failed to register port : %d \n", port_id);
-            return -1;
-        }
+       int port_id =  _register_test_port ("test_parent_port", _on_parent_got_message);
+       DBG ("PARENT ; registered port %d", port_id);
+       
     }
     else {
         /* child process */
+        int port_id = _register_test_port ("test_child_port", _on_child_got_message);
+        DBG ("CHILD ; registered port %d", port_id);
         /* sleep sometime till server port is ready */
         sleep (5);
-        gchar *app_id = g_strdup_printf ("%d", getppid());
+        gchar *parent_app_id = g_strdup_printf ("%d", getppid());
         gboolean found;
-        messageport_error_e res = messageport_check_remote_port (app_id, port_name, &found);
+        messageport_error_e res = messageport_check_remote_port (parent_app_id, "test_parent_port", &found);
 
         if (!found) {
-            g_print ("CHILD : Could not found remote port (%d)", res);
+            DBG ("CHILD : Could not found remote port (%d)", res);
             return -1;
         }
 
-        g_print ("CHILD : Found remote prot\n");
+        DBG ("CHILD : Found remote prot..., sending data to remote port (%s:%s)", parent_app_id, "test_parent_port");
 
         bundle *b = bundle_create ();
-
         bundle_add (b, "Name", "Amarnath");
         bundle_add (b, "Email", "amarnath.valluri@intel.com");
 
-        g_print ("CHILD : Sending data ....\n");
-        res = messageport_send_message (app_id, port_name, b);
+        res = messageport_send_bidirectional_message(port_id, parent_app_id, "test_parent_port", b);
         bundle_free (b);
         if (res != MESSAGEPORT_ERROR_NONE)
         {
-            g_print ("CHILD: Faile to send message to server : %d", res);
+            DBG ("CHILD: Fail to send message to server : %d", res);
         }
-        else g_print ("CHILD : Data sent successfully");
-
-        exit (0);
+        else DBG ("CHILD : Data sent successfully");
     }
 
     g_main_loop_run (__loop);