Branch data Line data Source code
1 : : /* Test case for GNOME #651133
2 : : *
3 : : * Copyright (C) 2008-2010 Red Hat, Inc.
4 : : * Copyright (C) 2011 Nokia Corporation
5 : : *
6 : : * SPDX-License-Identifier: LGPL-2.1-or-later
7 : : *
8 : : * This library is free software; you can redistribute it and/or
9 : : * modify it under the terms of the GNU Lesser General Public
10 : : * License as published by the Free Software Foundation; either
11 : : * version 2.1 of the License, or (at your option) any later version.
12 : : *
13 : : * This library is distributed in the hope that it will be useful,
14 : : * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 : : * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16 : : * Lesser General Public License for more details.
17 : : *
18 : : * You should have received a copy of the GNU Lesser General
19 : : * Public License along with this library; if not, see <http://www.gnu.org/licenses/>.
20 : : *
21 : : * Author: Simon McVittie <simon.mcvittie@collabora.co.uk>
22 : : */
23 : :
24 : : #include <config.h>
25 : :
26 : : #include <unistd.h>
27 : : #include <string.h>
28 : :
29 : : #include <gio/gio.h>
30 : :
31 : : #include "gdbusprivate.h"
32 : : #include "gdbus-tests.h"
33 : :
34 : : #define MY_NAME "com.example.Test.Myself"
35 : : /* This many threads create and destroy GDBusProxy instances, in addition
36 : : * to the main thread processing their NameOwnerChanged signals.
37 : : * N_THREADS_MAX is used with "-m slow", N_THREADS otherwise.
38 : : */
39 : : #define N_THREADS_MAX 10
40 : : #define N_THREADS 2
41 : : /* This many GDBusProxy instances are created by each thread. */
42 : : #define N_REPEATS 100
43 : : /* The main thread requests/releases a name this many times as rapidly as
44 : : * possible, before performing one "slow" cycle that waits for each method
45 : : * call result (and therefore, due to D-Bus total ordering, all previous
46 : : * method calls) to prevent requests from piling up infinitely. The more calls
47 : : * are made rapidly, the better we reproduce bugs.
48 : : */
49 : : #define N_RAPID_CYCLES 50
50 : :
51 : : static GMainLoop *loop;
52 : :
53 : : static gpointer
54 : 2 : run_proxy_thread (gpointer data)
55 : : {
56 : 2 : GDBusConnection *connection = data;
57 : : int i;
58 : :
59 : 2 : g_assert (g_main_context_get_thread_default () == NULL);
60 : :
61 : 202 : for (i = 0; i < N_REPEATS; i++)
62 : : {
63 : : GDBusProxy *proxy;
64 : 200 : GError *error = NULL;
65 : : GVariant *ret;
66 : :
67 : 200 : if (g_test_verbose ())
68 : 0 : g_printerr (".");
69 : :
70 : 200 : proxy = g_dbus_proxy_new_sync (connection,
71 : : G_DBUS_PROXY_FLAGS_DO_NOT_AUTO_START |
72 : : G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES,
73 : : NULL,
74 : : MY_NAME,
75 : : "/com/example/TestObject",
76 : : "com.example.Frob",
77 : : NULL,
78 : : &error);
79 : 200 : g_assert_no_error (error);
80 : 200 : g_assert (proxy != NULL);
81 : 200 : g_dbus_proxy_set_default_timeout (proxy, G_MAXINT);
82 : :
83 : 200 : ret = g_dbus_proxy_call_sync (proxy, "StupidMethod", NULL,
84 : : G_DBUS_CALL_FLAGS_NO_AUTO_START, -1,
85 : : NULL, NULL);
86 : : /*
87 : : * we expect this to fail - if we have the name at the moment, we called
88 : : * an unimplemented method, and if not, there was nothing to call
89 : : */
90 : 200 : g_assert (ret == NULL);
91 : :
92 : : /*
93 : : * this races with the NameOwnerChanged signal being emitted in an
94 : : * idle
95 : : */
96 : 200 : g_object_unref (proxy);
97 : : }
98 : :
99 : 2 : g_main_loop_quit (loop);
100 : 2 : return NULL;
101 : : }
102 : :
103 : : static void release_name (GDBusConnection *connection, gboolean wait);
104 : :
105 : : static void
106 : 56 : request_name_cb (GObject *source,
107 : : GAsyncResult *res,
108 : : gpointer user_data)
109 : : {
110 : 56 : GDBusConnection *connection = G_DBUS_CONNECTION (source);
111 : 56 : GError *error = NULL;
112 : : GVariant *var;
113 : : GVariant *child;
114 : :
115 : 56 : var = g_dbus_connection_call_finish (connection, res, &error);
116 : 56 : g_assert_no_error (error);
117 : 56 : child = g_variant_get_child_value (var, 0);
118 : 56 : g_assert_cmpuint (g_variant_get_uint32 (child),
119 : : ==, DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER);
120 : :
121 : 56 : release_name (connection, TRUE);
122 : 56 : g_variant_unref (child);
123 : 56 : g_variant_unref (var);
124 : 56 : }
125 : :
126 : : static void
127 : 2857 : request_name (GDBusConnection *connection,
128 : : gboolean wait)
129 : : {
130 : 2857 : g_dbus_connection_call (connection,
131 : : DBUS_SERVICE_DBUS,
132 : : DBUS_PATH_DBUS,
133 : : DBUS_INTERFACE_DBUS,
134 : : "RequestName",
135 : : g_variant_new ("(su)", MY_NAME, 0),
136 : : G_VARIANT_TYPE ("(u)"),
137 : : G_DBUS_CALL_FLAGS_NONE,
138 : : -1,
139 : : NULL,
140 : : wait ? request_name_cb : NULL,
141 : : NULL);
142 : 2857 : }
143 : :
144 : : static void
145 : 56 : release_name_cb (GObject *source,
146 : : GAsyncResult *res,
147 : : gpointer user_data)
148 : : {
149 : 56 : GDBusConnection *connection = G_DBUS_CONNECTION (source);
150 : 56 : GError *error = NULL;
151 : : GVariant *var;
152 : : GVariant *child;
153 : : int i;
154 : :
155 : 56 : var = g_dbus_connection_call_finish (connection, res, &error);
156 : 56 : g_assert_no_error (error);
157 : 56 : child = g_variant_get_child_value (var, 0);
158 : 56 : g_assert_cmpuint (g_variant_get_uint32 (child),
159 : : ==, DBUS_RELEASE_NAME_REPLY_RELEASED);
160 : :
161 : : /* generate some rapid NameOwnerChanged signals to try to trigger crashes */
162 : 2856 : for (i = 0; i < N_RAPID_CYCLES; i++)
163 : : {
164 : 2800 : request_name (connection, FALSE);
165 : 2800 : release_name (connection, FALSE);
166 : : }
167 : :
168 : : /* wait for dbus-daemon to catch up */
169 : 56 : request_name (connection, TRUE);
170 : 56 : g_variant_unref (child);
171 : 56 : g_variant_unref (var);
172 : 56 : }
173 : :
174 : : static void
175 : 2856 : release_name (GDBusConnection *connection,
176 : : gboolean wait)
177 : : {
178 : 2856 : g_dbus_connection_call (connection,
179 : : DBUS_SERVICE_DBUS,
180 : : DBUS_PATH_DBUS,
181 : : DBUS_INTERFACE_DBUS,
182 : : "ReleaseName",
183 : : g_variant_new ("(s)", MY_NAME),
184 : : G_VARIANT_TYPE ("(u)"),
185 : : G_DBUS_CALL_FLAGS_NONE,
186 : : -1,
187 : : NULL,
188 : : wait ? release_name_cb : NULL,
189 : : NULL);
190 : 2856 : }
191 : :
192 : : static void
193 : 1 : test_proxy (void)
194 : : {
195 : : GDBusConnection *connection;
196 : 1 : GError *error = NULL;
197 : : GThread *proxy_threads[N_THREADS_MAX];
198 : : int i;
199 : : int n_threads;
200 : :
201 : 1 : if (g_test_slow ())
202 : 0 : n_threads = N_THREADS_MAX;
203 : : else
204 : 1 : n_threads = N_THREADS;
205 : :
206 : 1 : session_bus_up ();
207 : :
208 : 1 : loop = g_main_loop_new (NULL, TRUE);
209 : :
210 : 1 : connection = g_bus_get_sync (G_BUS_TYPE_SESSION,
211 : : NULL,
212 : : &error);
213 : 1 : g_assert_no_error (error);
214 : :
215 : 1 : request_name (connection, TRUE);
216 : :
217 : 3 : for (i = 0; i < n_threads; i++)
218 : : {
219 : 2 : proxy_threads[i] = g_thread_new ("run-proxy",
220 : : run_proxy_thread, connection);
221 : : }
222 : :
223 : 1 : g_main_loop_run (loop);
224 : :
225 : 3 : for (i = 0; i < n_threads; i++)
226 : : {
227 : 2 : g_thread_join (proxy_threads[i]);
228 : : }
229 : :
230 : 1 : g_object_unref (connection);
231 : 1 : g_main_loop_unref (loop);
232 : :
233 : : /* TODO: should call session_bus_down() but that requires waiting
234 : : * for all the outstanding method calls to complete...
235 : : */
236 : 1 : if (g_test_verbose ())
237 : 0 : g_printerr ("\n");
238 : 1 : }
239 : :
240 : : int
241 : 1 : main (int argc,
242 : : char *argv[])
243 : : {
244 : 1 : g_test_init (&argc, &argv, G_TEST_OPTION_ISOLATE_DIRS, NULL);
245 : :
246 : 1 : g_test_dbus_unset ();
247 : :
248 : 1 : g_test_add_func ("/gdbus/proxy/vs-threads", test_proxy);
249 : :
250 : 1 : return g_test_run();
251 : : }
|
