1 /* Integration tests for the dbus-daemon
3 * Author: Simon McVittie <simon.mcvittie@collabora.co.uk>
4 * Copyright © 2010-2011 Nokia Corporation
6 * Permission is hereby granted, free of charge, to any person
7 * obtaining a copy of this software and associated documentation files
8 * (the "Software"), to deal in the Software without restriction,
9 * including without limitation the rights to use, copy, modify, merge,
10 * publish, distribute, sublicense, and/or sell copies of the Software,
11 * and to permit persons to whom the Software is furnished to do so,
12 * subject to the following conditions:
14 * The above copyright notice and this permission notice shall be
15 * included in all copies or substantial portions of the Software.
17 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
18 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
19 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
20 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
21 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
22 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
23 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
31 #include <dbus/dbus.h>
32 #include <dbus/dbus-glib-lowlevel.h>
50 DBusConnection *left_conn;
52 DBusConnection *right_conn;
53 gboolean right_conn_echo;
56 #define assert_no_error(e) _assert_no_error (e, __FILE__, __LINE__)
58 _assert_no_error (const DBusError *e,
62 if (G_UNLIKELY (dbus_error_is_set (e)))
63 g_error ("%s:%d: expected success but got error: %s: %s",
64 file, line, e->name, e->message);
68 spawn_dbus_daemon (gchar *binary,
79 "--print-address=1", /* stdout */
83 g_spawn_async_with_pipes (NULL, /* working directory */
86 G_SPAWN_DO_NOT_REAP_CHILD | G_SPAWN_SEARCH_PATH,
87 NULL, /* child_setup */
90 NULL, /* child's stdin = /dev/null */
92 NULL, /* child's stderr = our stderr */
94 g_assert_no_error (error);
96 address = g_string_new (NULL);
98 /* polling until the dbus-daemon writes out its address is a bit stupid,
99 * but at least it's simple, unlike dbus-launch... in principle we could
100 * use select() here, but life's too short */
107 bytes = read (address_fd, buf, sizeof (buf));
110 g_string_append_len (address, buf, bytes);
112 newline = strchr (address->str, '\n');
116 g_string_truncate (address, newline - address->str);
120 g_usleep (G_USEC_PER_SEC / 10);
123 return g_string_free (address, FALSE);
126 static DBusConnection *
127 connect_to_bus (const gchar *address)
129 DBusConnection *conn;
130 DBusError error = DBUS_ERROR_INIT;
133 conn = dbus_connection_open_private (address, &error);
134 assert_no_error (&error);
135 g_assert (conn != NULL);
137 ok = dbus_bus_register (conn, &error);
138 assert_no_error (&error);
140 g_assert (dbus_bus_get_unique_name (conn) != NULL);
142 dbus_connection_setup_with_g_main (conn, NULL);
146 static DBusHandlerResult
147 echo_filter (DBusConnection *connection,
148 DBusMessage *message,
152 DBusError error = DBUS_ERROR_INIT;
153 int *sleep_ms = user_data;
155 if (dbus_message_get_type (message) != DBUS_MESSAGE_TYPE_METHOD_CALL)
156 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
158 reply = dbus_message_new_method_return (message);
163 if (!dbus_connection_send (connection, reply, NULL))
166 dbus_message_unref (reply);
168 return DBUS_HANDLER_RESULT_HANDLED;
173 gconstpointer context G_GNUC_UNUSED)
180 dbus_error_init (&f->e);
182 dbus_daemon = g_strdup (g_getenv ("DBUS_TEST_DAEMON"));
184 if (dbus_daemon == NULL)
185 dbus_daemon = g_strdup ("dbus-daemon");
187 if (g_getenv ("DBUS_TEST_SYSCONFDIR") != NULL)
189 config = g_strdup_printf ("--config-file=%s/dbus-1/session.conf",
190 g_getenv ("DBUS_TEST_SYSCONFDIR"));
192 else if (g_getenv ("DBUS_TEST_DATA") != NULL)
194 config = g_strdup_printf (
195 "--config-file=%s/valid-config-files/session.conf",
196 g_getenv ("DBUS_TEST_DATA"));
200 config = g_strdup ("--session");
203 address = spawn_dbus_daemon (dbus_daemon, config, &f->daemon_pid);
205 g_free (dbus_daemon);
208 f->left_conn = connect_to_bus (address);
209 f->right_conn = connect_to_bus (address);
214 add_echo_filter (Fixture *f)
216 if (!dbus_connection_add_filter (f->right_conn, echo_filter, NULL, NULL))
219 f->right_conn_echo = TRUE;
223 pc_count (DBusPendingCall *pc,
226 guint *received_p = data;
232 test_echo (Fixture *f,
233 gconstpointer context G_GNUC_UNUSED)
245 g_test_timer_start ();
247 for (sent = 0; sent < count; sent++)
249 DBusMessage *m = dbus_message_new_method_call (
250 dbus_bus_get_unique_name (f->right_conn), "/",
251 "com.example", "Spam");
257 if (!dbus_connection_send_with_reply (f->left_conn, m, &pc,
258 DBUS_TIMEOUT_INFINITE) ||
262 if (dbus_pending_call_get_completed (pc))
263 pc_count (pc, &received);
264 else if (!dbus_pending_call_set_notify (pc, pc_count, &received,
268 dbus_pending_call_unref (pc);
269 dbus_message_unref (m);
272 while (received < count)
273 g_main_context_iteration (NULL, TRUE);
275 elapsed = g_test_timer_elapsed ();
277 g_test_maximized_result (count / elapsed, "%u messages / %f seconds",
282 teardown (Fixture *f,
283 gconstpointer context G_GNUC_UNUSED)
285 dbus_error_free (&f->e);
286 g_clear_error (&f->ge);
288 if (f->left_conn != NULL)
290 dbus_connection_close (f->left_conn);
291 dbus_connection_unref (f->left_conn);
295 if (f->right_conn != NULL)
297 if (f->right_conn_echo)
299 dbus_connection_remove_filter (f->right_conn, echo_filter, NULL);
300 f->right_conn_echo = FALSE;
303 dbus_connection_close (f->right_conn);
304 dbus_connection_unref (f->right_conn);
305 f->right_conn = NULL;
309 TerminateProcess (f->daemon_pid, 1);
311 kill (f->daemon_pid, SIGTERM);
314 g_spawn_close_pid (f->daemon_pid);
321 g_test_init (&argc, &argv, NULL);
322 g_test_bug_base ("https://bugs.freedesktop.org/show_bug.cgi?id=");
324 g_test_add ("/echo/session", Fixture, NULL, setup, test_echo, teardown);
326 return g_test_run ();