#include <glib.h>
#include <unistd.h>
#include <stdlib.h>
+#include <string.h>
#include <message-port.h>
#include <bundle.h>
+#include <unistd.h>
+
+int __pipe[2]; /* pipe between two process */
+const gchar *PARENT_TEST_PORT = "parent_test_port";
+const gchar *PARENT_TEST_TRUSTED_PORT = "parent_test_trusted_port";
+const gchar *CHILD_TEST_PORT = "child_test_port";
+const gchar *CHILD_TEST_TRUSTED_PORT = "child_test_trusted_port";
+
+struct AsyncTestData
+{
+ GMainLoop *m_loop;
+ gboolean result;
+} *__test_data = NULL;
+
+#define TEST_CASE(case) \
+do { \
+ if (case() != TRUE) { \
+ g_printerr ("%s: FAIL\n", #case); \
+ return -1; \
+ } \
+ else g_print ("%s: SUCCESS\n", #case); \
+}while (0)
+
+
+#define test_assert(expr, msg...) \
+do { \
+ if ((expr) == FALSE) {\
+ g_print ("%s +%d: assert(%s):%s\n", __FUNCTION__, __LINE__, #expr, ##msg); \
+ return FALSE; \
+ } \
+} while(0);
-GMainLoop *__loop = NULL;
static void _dump_data (const char *key, const int type, const bundle_keyval_t *kv, void *user_data)
{
gchar *val = NULL;
size_t size;
bundle_keyval_get_basic_val ((bundle_keyval_t*)kv, (void**)&val, &size);
- g_message (" %s - %s", key, val);
+ g_debug (" %s - %s", key, val);
}
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_message ("CHILD: GOT MESSAGE at prot '%s' FROM :'%s' - '%s", name,
+ g_debug ("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);
+
+ /* Write acknoledgement */
+ if (write (__pipe[1], "OK", strlen("OK") + 1) < 3) {
+ g_warning ("WRITE failed");
+ }
+
+ if (__test_data) {
+ __test_data->result = TRUE;
+ g_main_loop_quit (__test_data->m_loop);
+ }
}
void (_on_parent_got_message)(int port_id, const char* remote_app_id, const char* remote_port, gboolean trusted_message, bundle* data)
gboolean found = FALSE;
bundle *b = NULL;
messageport_get_local_port_name (port_id, &name),
- g_message ("PARENT: GOT MESSAGE at prot %s FROM :'%s' - '%s", name,
- remote_app_id ? remote_app_id : "unknwon app", remote_port ? remote_port : "unknwon");
+ g_debug ("PARENT: GOT MESSAGE at prot %s FROM :'%s' app - '%s' port", name,
+ remote_app_id ? remote_app_id : "unknwon", remote_port ? remote_port : "unknwon");
g_free (name);
g_assert (data);
bundle_foreach (data, _dump_data, NULL);
+ /* Write acknoledgement */
+ if ( write (__pipe[1], "OK", strlen("OK") + 1) < 3) {
+ g_warning ("WRITE failed");
+ }
+
+ /* check message is coming from remote port to send back to message,
+ * if not ignore */
+ if (!remote_app_id || !remote_port) {
+ return;
+ }
+
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) {
g_warning ("PARENT: Could not found remote port (%d)", res);
- exit (-1);
+ return ;
}
- g_message ("PARENT: Found remote prot");
+ g_debug ("PARENT: Found remote prot");
bundle *reply = bundle_create ();
bundle_add (reply, "Results", "GOT_IT");
- g_message ("PARENT: Sending reply ....");
+ g_debug ("PARENT: Sending reply ....");
res = trusted_message ? messageport_send_trusted_message (remote_app_id, remote_port, reply)
: messageport_send_message (remote_app_id, remote_port, reply);
bundle_free (reply);
{
g_warning ("PARENT: Faile to send message to server : %d", res);
}
- else g_message ("PARENT: Data sent successfully");
- g_main_loop_quit (__loop);
+ else g_debug ("PARENT: Data sent successfully");
+}
+
+int _register_test_port (const gchar *port_name, gboolean is_trusted, messageport_message_cb cb)
+{
+ int port_id = is_trusted ? messageport_register_trusted_local_port (port_name, cb)
+ : messageport_register_local_port (port_name, cb);
+ return port_id;
}
-int _register_test_port (const gchar *port_name, messageport_message_cb cb)
+static gboolean
+test_register_local_port ()
{
- int port_id = messageport_register_trusted_local_port (port_name, cb);
+ int port_id = _register_test_port (PARENT_TEST_PORT, FALSE, _on_parent_got_message);
- if (port_id > MESSAGEPORT_ERROR_NONE) {
- gchar *name = NULL;
- messageport_get_local_port_name (port_id, &name);
- g_free (name);
- }
- else {
- g_warning ("Failed to register port : %d", port_id);
+ test_assert (port_id >= 0, "Failed to register port '%s', error : %d", PARENT_TEST_PORT, port_id);
+
+ return TRUE;
+}
+
+static gboolean
+test_register_trusted_local_port()
+{
+ int port_id = _register_test_port (PARENT_TEST_TRUSTED_PORT, TRUE, _on_parent_got_message);
+
+ test_assert (port_id >= 0, "Failed to register port '%s', error : %d", PARENT_TEST_TRUSTED_PORT, port_id);
+
+ return TRUE;
+}
+
+static gboolean
+test_check_remote_port()
+{
+ const gchar remote_app_id[128];
+ gboolean found = FALSE;
+ messageport_error_e res;
+
+ g_sprintf (remote_app_id, "%d", getppid());
+
+ res = messageport_check_remote_port (remote_app_id, PARENT_TEST_PORT, &found);
+
+ test_assert (res == MESSAGEPORT_ERROR_NONE, "Fail to find remote port '%s' at app_id '%s', error: %d", PARENT_TEST_PORT, remote_app_id, res);
+
+ return TRUE;
+}
+
+static gboolean
+test_check_trusted_remote_port()
+{
+ const gchar remote_app_id[128];
+ gboolean found = FALSE;
+ messageport_error_e res;
+
+ g_sprintf (remote_app_id, "%d", getppid());
+
+ res = messageport_check_trusted_remote_port (remote_app_id, PARENT_TEST_TRUSTED_PORT, &found);
+ test_assert (res == MESSAGEPORT_ERROR_NONE, "Fail to find trusted remote port '%s' at app_id '%s', error: %d", PARENT_TEST_TRUSTED_PORT, remote_app_id, res);
+
+ return TRUE;
+}
+
+static gboolean
+test_send_message()
+{
+ messageport_error_e res;
+ const gchar remote_app_id[128];
+ bundle *b = bundle_create ();
+ bundle_add (b, "Name", "Amarnath");
+ bundle_add (b, "Email", "amarnath.valluri@intel.com");
+
+ g_sprintf (remote_app_id, "%d", getppid());
+ res = messageport_send_message (remote_app_id, PARENT_TEST_PORT, b);
+ bundle_free (b);
+ test_assert (res == MESSAGEPORT_ERROR_NONE, "Fail to send message to port '%s' at app_id : '%s', error : %d", PARENT_TEST_PORT, remote_app_id, res);
+
+ gchar result[32];
+
+ test_assert ((read (__pipe[0], &result, sizeof(result)) > 0), "Parent did not received the message");
+ test_assert ((g_strcmp0 (result, "OK") == 0), "Parent did not received the message");
+
+ return TRUE;
+}
+
+static gboolean
+test_send_trusted_message()
+{
+ messageport_error_e res;
+ const gchar remote_app_id[128];
+ bundle *b = bundle_create ();
+ bundle_add (b, "Name", "Amarnath");
+ bundle_add (b, "Email", "amarnath.valluri@intel.com");
+
+ g_sprintf (remote_app_id, "%d", getppid());
+ res = messageport_send_trusted_message (remote_app_id, PARENT_TEST_TRUSTED_PORT, b);
+ bundle_free (b);
+ test_assert (res == MESSAGEPORT_ERROR_NONE, "Fail to send message to port '%s' at app_id : '%s', error : %d", PARENT_TEST_PORT, remote_app_id, res);
+
+ gchar result[32];
+
+ test_assert( (read (__pipe[0], &result, sizeof(result)) > 0), "Parent did not received the message");
+ test_assert( (g_strcmp0 (result, "OK") == 0), "Parent did not received the message");
+
+ return TRUE;
+}
+
+static gboolean
+_update_test_result (gpointer data)
+{
+ if (__test_data) {
+ __test_data->result = FALSE;
+ g_main_loop_quit (__test_data->m_loop);
}
- return port_id;
+
+ return FALSE;
+}
+
+static gboolean
+test_send_bidirectional_message()
+{
+ messageport_error_e res;
+ int local_port_id = 0;
+ const gchar remote_app_id[128];
+ gchar result[32];
+ gboolean child_got_message = FALSE;
+ bundle *b = bundle_create ();
+ bundle_add (b, "Name", "Amarnath");
+ bundle_add (b, "Email", "amarnath.valluri@intel.com");
+
+ child_got_message = FALSE;
+
+ /* register local message port for return message */
+ test_assert ((local_port_id = _register_test_port (CHILD_TEST_PORT, FALSE, _on_child_got_message)) > 0,
+ "Fail to register message port");
+
+ g_sprintf (remote_app_id, "%d", getppid());
+ res = messageport_send_bidirectional_message (local_port_id, remote_app_id, PARENT_TEST_PORT, b);
+ bundle_free (b);
+ test_assert (res == MESSAGEPORT_ERROR_NONE,
+ "Fail to send message to port '%s' at app_id : '%s', error : %d", PARENT_TEST_PORT, remote_app_id, res);
+
+
+ test_assert( (read (__pipe[0], &result, sizeof(result)) > 0), "Parent did not received the message");
+ test_assert( (g_strcmp0 (result, "OK") == 0), "Parent did not received the message");
+
+ __test_data = g_new0 (struct AsyncTestData, 1);
+ __test_data->m_loop = g_main_loop_new (NULL, FALSE);
+ g_timeout_add_seconds (5, _update_test_result, NULL);
+
+ g_main_loop_run (__test_data->m_loop);
+ child_got_message = __test_data->result;
+
+ g_main_loop_unref (__test_data->m_loop);
+ g_free (__test_data);
+ __test_data = NULL;
+
+ test_assert (child_got_message == TRUE, "Child did not recieved reply");
+
+ return TRUE;
+}
+
+static gboolean
+test_send_bidirectional_trusted_message()
+{
+ messageport_error_e res;
+ int local_port_id = 0;
+ const gchar remote_app_id[128];
+ gchar result[32];
+ gboolean child_got_message = FALSE;
+ bundle *b = bundle_create ();
+ bundle_add (b, "Name", "Amarnath");
+ bundle_add (b, "Email", "amarnath.valluri@intel.com");
+
+ child_got_message = FALSE;
+
+ /* register local message port for return message */
+ test_assert ((local_port_id = _register_test_port (CHILD_TEST_TRUSTED_PORT, FALSE, _on_child_got_message)) > 0,
+ "Fail to register message port");
+
+ g_sprintf (remote_app_id, "%d", getppid());
+ res = messageport_send_bidirectional_trusted_message (local_port_id, remote_app_id, PARENT_TEST_TRUSTED_PORT, b);
+ bundle_free (b);
+ test_assert (res == MESSAGEPORT_ERROR_NONE,
+ "Fail to send message to port '%s' at app_id : '%s', error : %d", PARENT_TEST_TRUSTED_PORT, remote_app_id, res);
+
+
+ test_assert( (read (__pipe[0], &result, sizeof(result)) > 0), "Parent did not received the message");
+ test_assert( (g_strcmp0 (result, "OK") == 0), "Parent did not received the message");
+
+ __test_data = g_new0 (struct AsyncTestData, 1);
+ __test_data->m_loop = g_main_loop_new (NULL, FALSE);
+ g_timeout_add_seconds (5, _update_test_result, NULL);
+
+ g_main_loop_run (__test_data->m_loop);
+ child_got_message = __test_data->result;
+
+ g_main_loop_unref (__test_data->m_loop);
+ g_free (__test_data);
+ __test_data = NULL;
+
+ test_assert (child_got_message == TRUE, "Child did not recieved reply");
+
+ return TRUE;
+}
+
+static gboolean
+test_get_local_port_name()
+{
+ int local_port_id = 0;
+ messageport_error_e res;
+ gchar *port_name = NULL;
+
+ test_assert ((local_port_id = _register_test_port (CHILD_TEST_TRUSTED_PORT, FALSE, _on_child_got_message)) > 0,
+ "Fail to register test port : error : %d", local_port_id);
+
+ res = messageport_get_local_port_name (local_port_id, &port_name);
+ test_assert (res == MESSAGEPORT_ERROR_NONE, "Failed to get message port name, error: %d", res);
+
+ test_assert (g_strcmp0 (port_name, CHILD_TEST_TRUSTED_PORT) == 0, "Got wrong port name");
+
+ return TRUE;
+}
+
+static gboolean
+test_check_trusted_local_port ()
+{
+ int local_port_id = 0;
+ messageport_error_e res;
+ gboolean is_trusted;
+
+ test_assert ((local_port_id = _register_test_port (CHILD_TEST_PORT, FALSE, _on_child_got_message)) > 0,
+ "Fail to register test port : error : %d", local_port_id);
+
+ res = messageport_check_trusted_local_port (local_port_id, &is_trusted);
+ test_assert (res == MESSAGEPORT_ERROR_NONE, "Failed to get message port name, error: %d", res);
+ test_assert (is_trusted == FALSE, "Go FLSE for trusted port");
+
+ test_assert ((local_port_id = _register_test_port (CHILD_TEST_TRUSTED_PORT, TRUE, _on_child_got_message)) > 0,
+ "Fail to register test port : error : %d", local_port_id);
+
+ res = messageport_check_trusted_local_port (local_port_id, &is_trusted);
+ test_assert (res == MESSAGEPORT_ERROR_NONE, "Failed to get message port name, error: %d", res);
+ test_assert (is_trusted == TRUE, "Go TRUE for untrusted port");
+
+ return TRUE;
+}
+
+
+static gboolean
+_on_term (gpointer userdata)
+{
+ g_main_loop_quit ((GMainLoop *)userdata);
+
+ return FALSE;
}
int main (int argc, char *argv[])
{
pid_t child_pid;
- __loop = g_main_loop_new (NULL, FALSE);
+ if (pipe (__pipe)) {
+ g_warning ("Failed to open pipe");
+ return -1;
+ }
+
child_pid = fork ();
if (child_pid < 0) {
g_error ("Failed to fork ");
}
else if (child_pid > 0) {
- /* prent process : server port */
- int port_id = _register_test_port ("test_parent_port", _on_parent_got_message);
- if (port_id < 0) {
- g_warning ("PARENT: Exiting...");
- exit (-1);
- }
- else {
- g_message ("PARENT ; registered port %d", port_id);
- }
+ /* parent process */
+ GMainLoop *m_loop = g_main_loop_new (NULL, FALSE);
+ /* server ports */
+ TEST_CASE(test_register_local_port);
+ TEST_CASE(test_register_trusted_local_port);
+
+ g_unix_signal_add (SIGTERM, _on_term, m_loop);
+
+ g_main_loop_run (m_loop);
+ g_main_loop_unref (m_loop);
}
else {
/* child process */
- int port_id = _register_test_port ("test_child_port", _on_child_got_message);
- if (port_id < 0) {
- g_warning ("CHILD: Exiting...");
- exit (-1);
- }
- else g_message ("CHILD ; registered port %d", port_id);
-
- g_message("CHILD: Waiting for sometime to get server port ready....");
- /* sleep sometime till server port is ready */
+ /* sleep sometime till server ports are ready */
sleep (3);
- gchar *parent_app_id = g_strdup_printf ("%d", getppid());
- gboolean found;
- messageport_error_e res = messageport_check_trusted_remote_port (parent_app_id, "test_parent_port", &found);
-
- if (!found) {
- g_warning ("CHILD : Could not found remote port (%d)", res);
- exit(-1);
- }
-
- g_message ("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");
-
- res = messageport_send_bidirectional_trusted_message(port_id, parent_app_id, "test_parent_port", b);
- bundle_free (b);
- if (res != MESSAGEPORT_ERROR_NONE)
- {
- g_warning ("CHILD: Fail to send message to server : %d", res);
- exit (-1);
- }
- else g_message ("CHILD : Data sent successfully");
- }
-
- g_main_loop_run (__loop);
+ TEST_CASE(test_register_trusted_local_port);
+ TEST_CASE(test_check_remote_port);
+ TEST_CASE(test_check_trusted_remote_port);
+ TEST_CASE(test_send_message);
+ TEST_CASE(test_send_trusted_message);
+ TEST_CASE(test_send_bidirectional_message);
+ TEST_CASE(test_send_bidirectional_trusted_message);
+ TEST_CASE(test_get_local_port_name);
+ TEST_CASE(test_check_trusted_local_port);
- g_main_loop_unref (__loop);
+ /* end of tests */
+ kill(getppid(), SIGTERM);
- g_message ("TEST RSULT : SUCCESS");
+ }
return 0;
}
projects / platform / core / appfw / message-port-dbus.git / commitdiff