X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=test%2Ftest-service.c;h=7181fa38c42e0d5384f4ad0dc7bc63f4b2448dbc;hb=7d9239c9c78cb6d0b9c282376fcf3cda1de23209;hp=f8f8b92a0dcee666e767ca25c614e508db4ce378;hpb=96f6740f2fbc16c7ee220d3d5abdc94e22da78f3;p=platform%2Fupstream%2Fdbus.git diff --git a/test/test-service.c b/test/test-service.c index f8f8b92..7181fa3 100644 --- a/test/test-service.c +++ b/test/test-service.c @@ -1,8 +1,13 @@ +#include #include "test-utils.h" +#ifdef HAVE_UNISTD_H +#include +#endif static DBusLoop *loop; static dbus_bool_t already_quit = FALSE; +static dbus_bool_t hello_from_self_reply_received = FALSE; static void quit (void) @@ -17,10 +22,160 @@ quit (void) static void die (const char *message) { - fprintf (stderr, "*** %s", message); + fprintf (stderr, "*** test-service: %s", message); exit (1); } +static void +check_hello_from_self_reply (DBusPendingCall *pcall, + void *user_data) +{ + DBusMessage *reply; + DBusMessage *echo_message, *echo_reply = NULL; + DBusError error; + DBusConnection *connection; + + int type; + + dbus_error_init (&error); + + connection = dbus_bus_get (DBUS_BUS_STARTER, &error); + if (connection == NULL) + { + fprintf (stderr, "*** Failed to open connection to activating message bus: %s\n", + error.message); + dbus_error_free (&error); + die("no memory"); + } + + + echo_message = (DBusMessage *)user_data; + + reply = dbus_pending_call_steal_reply (pcall); + + type = dbus_message_get_type (reply); + + if (type == DBUS_MESSAGE_TYPE_METHOD_RETURN) + { + const char *s; + printf ("Reply from HelloFromSelf received\n"); + + if (!dbus_message_get_args (echo_message, + &error, + DBUS_TYPE_STRING, &s, + DBUS_TYPE_INVALID)) + { + echo_reply = dbus_message_new_error (echo_message, + error.name, + error.message); + + if (echo_reply == NULL) + die ("No memory\n"); + + } + else + { + echo_reply = dbus_message_new_method_return (echo_message); + if (echo_reply == NULL) + die ("No memory\n"); + + if (!dbus_message_append_args (echo_reply, + DBUS_TYPE_STRING, &s, + DBUS_TYPE_INVALID)) + die ("No memory"); + } + + if (!dbus_connection_send (connection, echo_reply, NULL)) + die ("No memory\n"); + + dbus_message_unref (echo_reply); + } + else if (type == DBUS_MESSAGE_TYPE_ERROR) + { + dbus_set_error_from_message (&error, reply); + printf ("Error type in reply: %s\n", error.message); + + if (strcmp (error.name, DBUS_ERROR_NO_MEMORY) != 0) + { + echo_reply = dbus_message_new_error (echo_reply, + error.name, + error.message); + + if (echo_reply == NULL) + die ("No memory\n"); + + if (!dbus_connection_send (connection, echo_reply, NULL)) + die ("No memory\n"); + + dbus_message_unref (echo_reply); + } + dbus_error_free (&error); + } + else + _dbus_assert_not_reached ("Unexpected message received\n"); + + hello_from_self_reply_received = TRUE; + + dbus_message_unref (reply); + dbus_message_unref (echo_message); + dbus_pending_call_unref (pcall); + dbus_connection_unref (connection); +} + +static DBusHandlerResult +handle_run_hello_from_self (DBusConnection *connection, + DBusMessage *message) +{ + DBusError error; + DBusMessage *reply, *self_message; + DBusPendingCall *pcall; + char *s; + + _dbus_verbose ("sending reply to Echo method\n"); + + dbus_error_init (&error); + + if (!dbus_message_get_args (message, + &error, + DBUS_TYPE_STRING, &s, + DBUS_TYPE_INVALID)) + { + reply = dbus_message_new_error (message, + error.name, + error.message); + + if (reply == NULL) + die ("No memory\n"); + + if (!dbus_connection_send (connection, reply, NULL)) + die ("No memory\n"); + + dbus_message_unref (reply); + + return DBUS_HANDLER_RESULT_NOT_YET_HANDLED; + } + printf ("Sending HelloFromSelf\n"); + + _dbus_verbose ("*** Sending message to self\n"); + self_message = dbus_message_new_method_call ("org.freedesktop.DBus.TestSuiteEchoService", + "/org/freedesktop/TestSuite", + "org.freedesktop.TestSuite", + "HelloFromSelf"); + + if (self_message == NULL) + die ("No memory"); + + if (!dbus_connection_send_with_reply (connection, self_message, &pcall, -1)) + die("No memory"); + + dbus_message_ref (message); + if (!dbus_pending_call_set_notify (pcall, check_hello_from_self_reply, (void *)message, NULL)) + die("No memory"); + + printf ("Sent HelloFromSelf\n"); + return DBUS_HANDLER_RESULT_HANDLED; +} + static DBusHandlerResult handle_echo (DBusConnection *connection, DBusMessage *message) @@ -58,7 +213,7 @@ handle_echo (DBusConnection *connection, die ("No memory\n"); if (!dbus_message_append_args (reply, - DBUS_TYPE_STRING, s, + DBUS_TYPE_STRING, &s, DBUS_TYPE_INVALID)) die ("No memory"); @@ -67,13 +222,67 @@ handle_echo (DBusConnection *connection, fprintf (stderr, "Echo service echoed string: \"%s\"\n", s); - dbus_free (s); + dbus_message_unref (reply); + + return DBUS_HANDLER_RESULT_HANDLED; +} + +static DBusHandlerResult +handle_delay_echo (DBusConnection *connection, + DBusMessage *message) +{ + DBusError error; + DBusMessage *reply; + char *s; + + _dbus_verbose ("sleeping for a short time\n"); + + _dbus_sleep_milliseconds (50); + + _dbus_verbose ("sending reply to DelayEcho method\n"); + + dbus_error_init (&error); + + if (!dbus_message_get_args (message, + &error, + DBUS_TYPE_STRING, &s, + DBUS_TYPE_INVALID)) + { + reply = dbus_message_new_error (message, + error.name, + error.message); + + if (reply == NULL) + die ("No memory\n"); + + if (!dbus_connection_send (connection, reply, NULL)) + die ("No memory\n"); + + dbus_message_unref (reply); + + return DBUS_HANDLER_RESULT_NOT_YET_HANDLED; + } + + reply = dbus_message_new_method_return (message); + if (reply == NULL) + die ("No memory\n"); + + if (!dbus_message_append_args (reply, + DBUS_TYPE_STRING, &s, + DBUS_TYPE_INVALID)) + die ("No memory"); + + if (!dbus_connection_send (connection, reply, NULL)) + die ("No memory\n"); + + fprintf (stderr, "DelayEcho service echoed string: \"%s\"\n", s); dbus_message_unref (reply); return DBUS_HANDLER_RESULT_HANDLED; } + static void path_unregistered_func (DBusConnection *connection, void *user_data) @@ -92,9 +301,12 @@ path_message_func (DBusConnection *connection, return handle_echo (connection, message); else if (dbus_message_is_method_call (message, "org.freedesktop.TestSuite", + "DelayEcho")) + return handle_delay_echo (connection, message); + else if (dbus_message_is_method_call (message, + "org.freedesktop.TestSuite", "Exit")) { - dbus_connection_disconnect (connection); quit (); return DBUS_HANDLER_RESULT_HANDLED; } @@ -104,6 +316,7 @@ path_message_func (DBusConnection *connection, { /* Emit the Foo signal */ DBusMessage *signal; + double v_DOUBLE; _dbus_verbose ("emitting signal Foo\n"); @@ -112,9 +325,10 @@ path_message_func (DBusConnection *connection, "Foo"); if (signal == NULL) die ("No memory\n"); - + + v_DOUBLE = 42.6; if (!dbus_message_append_args (signal, - DBUS_TYPE_DOUBLE, 42.6, + DBUS_TYPE_DOUBLE, &v_DOUBLE, DBUS_TYPE_INVALID)) die ("No memory"); @@ -123,6 +337,29 @@ path_message_func (DBusConnection *connection, return DBUS_HANDLER_RESULT_HANDLED; } + + else if (dbus_message_is_method_call (message, + "org.freedesktop.TestSuite", + "RunHelloFromSelf")) + { + return handle_run_hello_from_self (connection, message); + } + else if (dbus_message_is_method_call (message, + "org.freedesktop.TestSuite", + "HelloFromSelf")) + { + DBusMessage *reply; + printf ("Received the HelloFromSelf message\n"); + + reply = dbus_message_new_method_return (message); + if (reply == NULL) + die ("No memory"); + + if (!dbus_connection_send (connection, reply, NULL)) + die ("No memory"); + + return DBUS_HANDLER_RESULT_HANDLED; + } else return DBUS_HANDLER_RESULT_NOT_YET_HANDLED; } @@ -143,10 +380,9 @@ filter_func (DBusConnection *connection, void *user_data) { if (dbus_message_is_signal (message, - DBUS_INTERFACE_ORG_FREEDESKTOP_LOCAL, + DBUS_INTERFACE_LOCAL, "Disconnected")) { - dbus_connection_disconnect (connection); quit (); return DBUS_HANDLER_RESULT_HANDLED; } @@ -160,12 +396,44 @@ int main (int argc, char **argv) { - DBusConnection *connection; DBusError error; int result; - + DBusConnection *connection; + const char *name; + dbus_bool_t do_fork; + + if (argc != 3) + { + name = "org.freedesktop.DBus.TestSuiteEchoService"; + do_fork = FALSE; + } + else + { + name = argv[1]; +#ifndef DBUS_WIN + do_fork = strcmp (argv[2], "fork") == 0; +#else + do_fork = FALSE; +#endif + } + + /* The bare minimum for simulating a program "daemonizing"; the intent + * is to test services which move from being legacy init scripts to + * activated services. + * https://bugzilla.redhat.com/show_bug.cgi?id=545267 + */ +#ifndef DBUS_WIN + if (do_fork) + { + pid_t pid = fork (); + if (pid != 0) + exit (0); + sleep (1); + } +#endif + dbus_error_init (&error); - connection = dbus_bus_get (DBUS_BUS_ACTIVATION, &error); + connection = dbus_bus_get (DBUS_BUS_STARTER, &error); if (connection == NULL) { fprintf (stderr, "*** Failed to open connection to activating message bus: %s\n", @@ -188,11 +456,19 @@ main (int argc, if (!dbus_connection_register_object_path (connection, echo_path, &echo_vtable, - NULL)) + (void*) 0xdeadbeef)) die ("No memory"); - result = dbus_bus_acquire_service (connection, "org.freedesktop.DBus.TestSuiteEchoService", - 0, &error); + { + void *d; + if (!dbus_connection_get_object_path_data (connection, echo_path, &d)) + die ("No memory"); + if (d != (void*) 0xdeadbeef) + die ("dbus_connection_get_object_path_data() doesn't seem to work right\n"); + } + + result = dbus_bus_request_name (connection, name, + 0, &error); if (dbus_error_is_set (&error)) { fprintf (stderr, "Error %s\n", error.message); @@ -202,9 +478,16 @@ main (int argc, exit (1); } + if (result != DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER) + { + fprintf (stderr, "Unable to acquire service: code %d\n", result); + _dbus_verbose ("*** Failed to acquire service: %d\n", result); + exit (1); + } + _dbus_verbose ("*** Test service entering main loop\n"); _dbus_loop_run (loop); - + test_connection_shutdown (loop, connection); dbus_connection_remove_filter (connection, filter_func, NULL);