1 #include <glib.h>
2 #include <glib-object.h>
3
4 #ifdef G_OS_UNIX
5 #include <unistd.h>
6 #endif
7
8 #define G_TYPE_TEST (my_test_get_type ())
9 #define MY_TEST(test) (G_TYPE_CHECK_INSTANCE_CAST ((test), G_TYPE_TEST, GTest))
10 #define MY_IS_TEST(test) (G_TYPE_CHECK_INSTANCE_TYPE ((test), G_TYPE_TEST))
11 #define MY_TEST_CLASS(tclass) (G_TYPE_CHECK_CLASS_CAST ((tclass), G_TYPE_TEST, GTestClass))
12 #define MY_IS_TEST_CLASS(tclass) (G_TYPE_CHECK_CLASS_TYPE ((tclass), G_TYPE_TEST))
13 #define MY_TEST_GET_CLASS(test) (G_TYPE_INSTANCE_GET_CLASS ((test), G_TYPE_TEST, GTestClass))
14
15 typedef struct _GTest GTest;
16 typedef struct _GTestClass GTestClass;
17
18 struct _GTest
19 {
20 GObject object;
21
22 gint value;
23 };
24
25 struct _GTestClass
26 {
27 GObjectClass parent_class;
28
29 void (*test_signal1) (GTest * test, gint an_int);
30 void (*test_signal2) (GTest * test, gint an_int);
31 gchar * (*test_signal3) (GTest * test, gint an_int);
32 };
33
34 static GType my_test_get_type (void);
35 static gboolean stopping;
36
37 /* Element signals and args */
38 enum
39 {
40 TEST_SIGNAL1,
41 TEST_SIGNAL2,
42 TEST_SIGNAL3,
43 /* add more above */
44 LAST_SIGNAL
45 };
46
47 enum
48 {
49 ARG_0,
50 ARG_TEST_PROP
51 };
52
53 static void my_test_class_init (GTestClass * klass);
54 static void my_test_init (GTest * test);
55 static void my_test_dispose (GObject * object);
56
57 static void signal2_handler (GTest * test, gint anint);
58 static gchar * signal3_handler (GTest * test, gint anint);
59
60 static void my_test_set_property (GObject * object, guint prop_id,
61 const GValue * value, GParamSpec * pspec);
62 static void my_test_get_property (GObject * object, guint prop_id,
63 GValue * value, GParamSpec * pspec);
64
65 static GObjectClass *parent_class = NULL;
66
67 static guint my_test_signals[LAST_SIGNAL] = { 0 };
68
69 static GType
70 my_test_get_type (void)
71 {
72 static GType test_type = 0;
73
74 if (!test_type) {
75 const GTypeInfo test_info = {
76 sizeof (GTestClass),
77 NULL,
78 NULL,
79 (GClassInitFunc) my_test_class_init,
80 NULL,
81 NULL,
82 sizeof (GTest),
83 0,
84 (GInstanceInitFunc) my_test_init,
85 NULL
86 };
87
88 test_type = g_type_register_static (G_TYPE_OBJECT, "GTest",
89 &test_info, 0);
90 }
91 return test_type;
92 }
93
94 static void
95 my_test_class_init (GTestClass * klass)
96 {
97 GObjectClass *gobject_class;
98
99 gobject_class = (GObjectClass *) klass;
100
101 parent_class = g_type_class_ref (G_TYPE_OBJECT);
102
103 gobject_class->dispose = my_test_dispose;
104 gobject_class->set_property = my_test_set_property;
105 gobject_class->get_property = my_test_get_property;
106
107 my_test_signals[TEST_SIGNAL1] =
108 g_signal_new ("test-signal1", G_TYPE_FROM_CLASS (klass),
109 G_SIGNAL_RUN_LAST, G_STRUCT_OFFSET (GTestClass, test_signal1), NULL,
110 NULL, g_cclosure_marshal_VOID__INT, G_TYPE_NONE, 1, G_TYPE_INT);
111 my_test_signals[TEST_SIGNAL2] =
112 g_signal_new ("test-signal2", G_TYPE_FROM_CLASS (klass),
113 G_SIGNAL_RUN_LAST, G_STRUCT_OFFSET (GTestClass, test_signal2), NULL,
114 NULL, g_cclosure_marshal_VOID__INT, G_TYPE_NONE, 1, G_TYPE_INT);
115 my_test_signals[TEST_SIGNAL3] =
116 g_signal_new ("test-signal3", G_TYPE_FROM_CLASS (klass),
117 G_SIGNAL_RUN_LAST, G_STRUCT_OFFSET (GTestClass, test_signal3), NULL,
118 NULL, g_cclosure_marshal_generic, G_TYPE_STRING, 1, G_TYPE_INT);
119
120 g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_TEST_PROP,
121 g_param_spec_int ("test-prop", "Test Prop", "Test property",
122 0, 1, 0, G_PARAM_READWRITE));
123
124 klass->test_signal2 = signal2_handler;
125 klass->test_signal3 = signal3_handler;
126 }
127
128 static void
129 my_test_init (GTest * test)
130 {
131 g_test_message ("init %p\n", test);
132
133 test->value = 0;
134 }
135
136 static void
137 my_test_dispose (GObject * object)
138 {
139 GTest *test;
140
141 test = MY_TEST (object);
142
143 g_test_message ("dispose %p!\n", test);
144
145 G_OBJECT_CLASS (parent_class)->dispose (object);
146 }
147
148 static void
149 my_test_set_property (GObject * object, guint prop_id,
150 const GValue * value, GParamSpec * pspec)
151 {
152 GTest *test;
153
154 test = MY_TEST (object);
155
156 switch (prop_id) {
157 case ARG_TEST_PROP:
158 test->value = g_value_get_int (value);
159 break;
160 default:
161 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
162 break;
163 }
164 }
165
166 static void
167 my_test_get_property (GObject * object, guint prop_id,
168 GValue * value, GParamSpec * pspec)
169 {
170 GTest *test;
171
172 test = MY_TEST (object);
173
174 switch (prop_id) {
175 case ARG_TEST_PROP:
176 g_value_set_int (value, test->value);
177 break;
178 default:
179 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
180 break;
181 }
182 }
183
184 static void
185 my_test_do_signal1 (GTest * test)
186 {
187 g_signal_emit (G_OBJECT (test), my_test_signals[TEST_SIGNAL1], 0, 0);
188 }
189
190 static void
191 signal2_handler (GTest * test, gint anint)
192 {
193 }
194
195 static void
196 my_test_do_signal2 (GTest * test)
197 {
198 g_signal_emit (G_OBJECT (test), my_test_signals[TEST_SIGNAL2], 0, 0);
199 }
200
201 static gchar *
202 signal3_handler (GTest * test, gint anint)
203 {
204 return g_strdup ("test");
205 }
206
207 static void
208 my_test_do_signal3 (GTest * test)
209 {
210 gchar *res;
211
212 g_signal_emit (G_OBJECT (test), my_test_signals[TEST_SIGNAL3], 0, 0, &res);
213 g_assert (res);
214 g_free (res);
215 }
216
217 static void
218 my_test_do_prop (GTest * test)
219 {
220 test->value = g_random_int ();
221 g_object_notify (G_OBJECT (test), "test-prop");
222 }
223
224 static gpointer
225 run_thread (GTest * test)
226 {
227 gint i = 1;
228
229 while (!g_atomic_int_get (&stopping)) {
230 if (TESTNUM == 1)
231 my_test_do_signal1 (test);
232 if (TESTNUM == 2)
233 my_test_do_signal2 (test);
234 if (TESTNUM == 3)
235 my_test_do_prop (test);
236 if (TESTNUM == 4)
237 my_test_do_signal3 (test);
238 if ((i++ % 10000) == 0) {
239 g_thread_yield (); /* force context switch */
240 }
241 }
242
243 return NULL;
244 }
245
246 static void
247 notify (GObject *object, GParamSpec *spec, gpointer user_data)
248 {
249 gint value;
250
251 g_object_get (object, "test-prop", &value, NULL);
252 if (TESTNUM != 3)
253 g_assert_cmpint (value, ==, 0);
254 }
255
256 static void
257 test_refcount_signals (void)
258 {
259 gint i;
260 GTest *test1, *test2;
261 GArray *test_threads;
262 const gint n_threads = 1;
263
264 test1 = g_object_new (G_TYPE_TEST, NULL);
265 test2 = g_object_new (G_TYPE_TEST, NULL);
266
267 g_signal_connect (test1, "notify::test-prop", G_CALLBACK (notify), NULL);
268 g_signal_connect (test1, "test-signal1", G_CALLBACK (notify), NULL);
269 g_signal_connect (test1, "test-signal2", G_CALLBACK (notify), NULL);
270
271 test_threads = g_array_new (FALSE, FALSE, sizeof (GThread *));
272
273 stopping = FALSE;
274
275 for (i = 0; i < n_threads; i++) {
276 GThread *thread;
277
278 thread = g_thread_new (NULL, (GThreadFunc) run_thread, test1);
279 g_array_append_val (test_threads, thread);
280
281 thread = g_thread_new (NULL, (GThreadFunc) run_thread, test2);
282 g_array_append_val (test_threads, thread);
283 }
284 g_usleep (5000000);
285
286 g_atomic_int_set (&stopping, TRUE);
287
288 /* Join all threads */
289 for (i = 0; i < 2 * n_threads; i++) {
290 GThread *thread;
291
292 thread = g_array_index (test_threads, GThread *, i);
293 g_thread_join (thread);
294 }
295
296 g_array_free (test_threads, TRUE);
297 g_object_unref (test1);
298 g_object_unref (test2);
299 }
300
301 int
302 main (int argc, gchar *argv[])
303 {
304 g_log_set_always_fatal (G_LOG_LEVEL_WARNING |
305 G_LOG_LEVEL_CRITICAL |
306 g_log_set_always_fatal (G_LOG_FATAL_MASK));
307
308 g_test_init (&argc, &argv, NULL);
309
310 g_test_add_func ("/gobject/refcount/signals", test_refcount_signals);
311
312 return g_test_run ();
313 }