Branch data Line data Source code
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 : : #if G_GNUC_CHECK_VERSION (4, 0)
19 : : /* Increase the alignment of GTest to check whether
20 : : * G_TYPE_CHECK_INSTANCE_CAST() would trigger a "-Wcast-align=strict" warning.
21 : : * That would happen, when trying to cast a "GObject*" to "GTest*", if latter
22 : : * has larger alignment.
23 : : *
24 : : * Note that merely adding a int64 field to GTest does not increase the
25 : : * alignment above 4 bytes on i386, hence use the __attribute__((__aligned__())).
26 : : */
27 : : #define _GTest_increase_alignment __attribute__((__aligned__(__alignof(gint64))))
28 : : #else
29 : : #define _GTest_increase_alignment
30 : : #endif
31 : :
32 : : struct _GTest
33 : : {
34 : : GObject object;
35 : :
36 : : /* See _GTest_increase_alignment. */
37 : : long double increase_alignment2;
38 : : } _GTest_increase_alignment;
39 : :
40 : : struct _GTestClass
41 : : {
42 : : GObjectClass parent_class;
43 : : };
44 : :
45 : : static GType my_test_get_type (void);
46 : : static gint stopping; /* (atomic) */
47 : :
48 : : static void my_test_class_init (GTestClass * klass);
49 : : static void my_test_init (GTest * test);
50 : : static void my_test_dispose (GObject * object);
51 : :
52 : : static GObjectClass *parent_class = NULL;
53 : :
54 : : static GType
55 : 2 : my_test_get_type (void)
56 : : {
57 : : static GType test_type = 0;
58 : :
59 : 2 : if (!test_type) {
60 : 1 : const GTypeInfo test_info = {
61 : : sizeof (GTestClass),
62 : : NULL,
63 : : NULL,
64 : : (GClassInitFunc) my_test_class_init,
65 : : NULL,
66 : : NULL,
67 : : sizeof (GTest),
68 : : 0,
69 : : (GInstanceInitFunc) my_test_init,
70 : : NULL
71 : : };
72 : :
73 : 1 : test_type = g_type_register_static (G_TYPE_OBJECT, "GTest",
74 : : &test_info, 0);
75 : : }
76 : 2 : return test_type;
77 : : }
78 : :
79 : : static void
80 : 1 : my_test_class_init (GTestClass * klass)
81 : : {
82 : : GObjectClass *gobject_class;
83 : :
84 : 1 : gobject_class = (GObjectClass *) klass;
85 : 1 : parent_class = g_type_class_ref (G_TYPE_OBJECT);
86 : :
87 : 1 : gobject_class->dispose = my_test_dispose;
88 : 1 : }
89 : :
90 : : static void
91 : 2 : my_test_init (GTest * test)
92 : : {
93 : 2 : g_test_message ("init %p\n", test);
94 : 2 : }
95 : :
96 : : static void
97 : 2 : my_test_dispose (GObject * object)
98 : : {
99 : : GTest *test;
100 : :
101 : 2 : test = MY_TEST (object);
102 : :
103 : 2 : g_test_message ("dispose %p!\n", test);
104 : :
105 : 2 : G_OBJECT_CLASS (parent_class)->dispose (object);
106 : 2 : }
107 : :
108 : : static void
109 : 12731824 : my_test_do_refcount (GTest * test)
110 : : {
111 : 12731824 : g_object_ref (test);
112 : 12731824 : g_object_unref (test);
113 : 12731824 : }
114 : :
115 : : static gpointer
116 : 10 : run_thread (GTest * test)
117 : : {
118 : 10 : gint i = 1;
119 : :
120 : 12731834 : while (!g_atomic_int_get (&stopping)) {
121 : 12731824 : my_test_do_refcount (test);
122 : 12731824 : if ((i++ % 10000) == 0) {
123 : 1269 : g_thread_yield (); /* force context switch */
124 : : }
125 : : }
126 : :
127 : 10 : return NULL;
128 : : }
129 : :
130 : : static void
131 : 1 : test_refcount_object_basics (void)
132 : : {
133 : : guint i;
134 : : GTest *test1, *test2;
135 : : GArray *test_threads;
136 : 1 : const guint n_threads = 5;
137 : :
138 : 1 : test1 = g_object_new (G_TYPE_TEST, NULL);
139 : 1 : test2 = g_object_new (G_TYPE_TEST, NULL);
140 : :
141 : 1 : test_threads = g_array_new (FALSE, FALSE, sizeof (GThread *));
142 : :
143 : 1 : g_atomic_int_set (&stopping, 0);
144 : :
145 : 6 : for (i = 0; i < n_threads; i++) {
146 : : GThread *thread;
147 : :
148 : 5 : thread = g_thread_new (NULL, (GThreadFunc) run_thread, test1);
149 : 5 : g_array_append_val (test_threads, thread);
150 : :
151 : 5 : thread = g_thread_new (NULL, (GThreadFunc) run_thread, test2);
152 : 5 : g_array_append_val (test_threads, thread);
153 : : }
154 : :
155 : 1 : g_usleep (5000000);
156 : 1 : g_atomic_int_set (&stopping, 1);
157 : :
158 : : /* join all threads */
159 : 11 : for (i = 0; i < 2 * n_threads; i++) {
160 : : GThread *thread;
161 : :
162 : 10 : thread = g_array_index (test_threads, GThread *, i);
163 : 10 : g_thread_join (thread);
164 : : }
165 : :
166 : 1 : g_object_unref (test1);
167 : 1 : g_object_unref (test2);
168 : 1 : g_array_unref (test_threads);
169 : 1 : }
170 : :
171 : : int
172 : 1 : main (int argc, gchar *argv[])
173 : : {
174 : 1 : g_log_set_always_fatal (G_LOG_LEVEL_WARNING |
175 : 1 : G_LOG_LEVEL_CRITICAL |
176 : 1 : g_log_set_always_fatal (G_LOG_FATAL_MASK));
177 : :
178 : 1 : g_test_init (&argc, &argv, NULL);
179 : :
180 : 1 : g_test_add_func ("/gobject/refcount/object-basics", test_refcount_object_basics);
181 : :
182 : 1 : return g_test_run ();
183 : : }
|
