gobject/tests/objects-refcount1.c

   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 my_test_get_type (void)
  56 {
  57   static GType test_type = 0;
  58
  59   if (!test_type) {
  60     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     test_type = g_type_register_static (G_TYPE_OBJECT, "GTest",
  74         &test_info, 0);
  75   }
  76   return test_type;
  77 }
  78
  79 static void
  80 my_test_class_init (GTestClass * klass)
  81 {
  82   GObjectClass *gobject_class;
  83
  84   gobject_class = (GObjectClass *) klass;
  85   parent_class = g_type_class_ref (G_TYPE_OBJECT);
  86
  87   gobject_class->dispose = my_test_dispose;
  88 }
  89
  90 static void
  91 my_test_init (GTest * test)
  92 {
  93   g_test_message ("init %p\n", test);
  94 }
  95
  96 static void
  97 my_test_dispose (GObject * object)
  98 {
  99   GTest *test;
 100
 101   test = MY_TEST (object);
 102
 103   g_test_message ("dispose %p!\n", test);
 104
 105   G_OBJECT_CLASS (parent_class)->dispose (object);
 106 }
 107
 108 static void
 109 my_test_do_refcount (GTest * test)
 110 {
 111   g_object_ref (test);
 112   g_object_unref (test);
 113 }
 114
 115 static gpointer
 116 run_thread (GTest * test)
 117 {
 118   gint i = 1;
 119
 120   while (!g_atomic_int_get (&stopping)) {
 121     my_test_do_refcount (test);
 122     if ((i++ % 10000) == 0) {
 123         g_thread_yield (); /* force context switch */
 124     }
 125   }
 126
 127   return NULL;
 128 }
 129
 130 static void
 131 test_refcount_object_basics (void)
 132 {
 133   guint i;
 134   GTest *test1, *test2;
 135   GArray *test_threads;
 136   const guint n_threads = 5;
 137
 138   test1 = g_object_new (G_TYPE_TEST, NULL);
 139   test2 = g_object_new (G_TYPE_TEST, NULL);
 140
 141   test_threads = g_array_new (FALSE, FALSE, sizeof (GThread *));
 142
 143   g_atomic_int_set (&stopping, 0);
 144
 145   for (i = 0; i < n_threads; i++) {
 146     GThread *thread;
 147
 148     thread = g_thread_new (NULL, (GThreadFunc) run_thread, test1);
 149     g_array_append_val (test_threads, thread);
 150
 151     thread = g_thread_new (NULL, (GThreadFunc) run_thread, test2);
 152     g_array_append_val (test_threads, thread);
 153   }
 154
 155   g_usleep (5000000);
 156   g_atomic_int_set (&stopping, 1);
 157
 158   /* join all threads */
 159   for (i = 0; i < 2 * n_threads; i++) {
 160     GThread *thread;
 161
 162     thread = g_array_index (test_threads, GThread *, i);
 163     g_thread_join (thread);
 164   }
 165
 166   g_object_unref (test1);
 167   g_object_unref (test2);
 168   g_array_unref (test_threads);
 169 }
 170
 171 int
 172 main (int argc, gchar *argv[])
 173 {
 174   g_log_set_always_fatal (G_LOG_LEVEL_WARNING |
 175                           G_LOG_LEVEL_CRITICAL |
 176                           g_log_set_always_fatal (G_LOG_FATAL_MASK));
 177
 178   g_test_init (&argc, &argv, NULL);
 179
 180   g_test_add_func ("/gobject/refcount/object-basics", test_refcount_object_basics);
 181
 182   return g_test_run ();
 183 }