Menu
▾
▴
[cutter-commit 04394] clear-code/cutter@f220bcb [master] Remove thread test samples
|
From: Kouhei S. <nul...@cl...> - 2013-05-17 12:59:36
|
Kouhei Sutou 2013-05-17 21:58:56 +0900 (Fri, 17 May 2013) New Revision: f220bcbad459b08ce2b75fc73173877904cfd489 https://github.com/clear-code/cutter/commit/f220bcbad459b08ce2b75fc73173877904cfd489 Message: Remove thread test samples Because we can't maintain it. Removed files: sample/glib/thread-test.c sample/glib/thread.c Modified files: sample/glib/Makefile.am Modified: sample/glib/Makefile.am (+0 -3) =================================================================== --- sample/glib/Makefile.am 2013-05-17 21:57:29 +0900 (e1392fa) +++ sample/glib/Makefile.am 2013-05-17 21:58:56 +0900 (c8a9f6b) @@ -20,7 +20,6 @@ noinst_LTLIBRARIES = \ test_base64.la \ test_iochannel.la \ test_keyfile.la \ - test_thread.la \ test_utf8_pointer.la \ test_utf8_validate.la \ test_uri.la @@ -45,8 +44,6 @@ test_base64_la_SOURCES = base64.c test_iochannel_la_SOURCES = iochannel.c test_keyfile_la_SOURCES = keyfile.c test_regex_la_SOURCES = regex.c -test_thread_la_SOURCES = thread.c -test_thread_la_CFLAGS = $(AM_CFLAGS) $(NO_STRICT_ALIASING_CFLAGS) test_uri_la_SOURCES = uri.c test_utf8_pointer_la_SOURCES = utf8-pointer.c test_utf8_validate_la_SOURCES = utf8-validate.c Deleted: sample/glib/thread-test.c (+0 -162) 100644 =================================================================== --- sample/glib/thread-test.c 2013-05-17 21:57:29 +0900 (c13d51d) +++ /dev/null @@ -1,162 +0,0 @@ -#undef G_DISABLE_ASSERT -#undef G_LOG_DOMAIN - -#include <glib.h> - -/* GStaticPrivate */ - -#define THREADS 10 - -static GStaticMutex test_g_static_private_mutex = G_STATIC_MUTEX_INIT; -static guint test_g_static_private_counter = 0; -static guint test_g_static_private_ready = 0; - -static gpointer -test_g_static_private_constructor (void) -{ - g_static_mutex_lock (&test_g_static_private_mutex); - test_g_static_private_counter++; - g_static_mutex_unlock (&test_g_static_private_mutex); - return g_new (guint,1); -} - -static void -test_g_static_private_destructor (gpointer data) -{ - g_static_mutex_lock (&test_g_static_private_mutex); - test_g_static_private_counter--; - g_static_mutex_unlock (&test_g_static_private_mutex); - g_free (data); -} - - -static gpointer -test_g_static_private_thread (gpointer data) -{ -GStaticPrivate test_g_static_private_private1 = G_STATIC_PRIVATE_INIT; -GStaticPrivate test_g_static_private_private2 = G_STATIC_PRIVATE_INIT; - guint number = GPOINTER_TO_INT (data); - guint i; - guint *private1, *private2; - for (i = 0; i < 10; i++) - { - number = number * 11 + 1; /* A very simple and bad RNG ;-) */ - private1 = g_static_private_get (&test_g_static_private_private1); - if (!private1 || number % 7 > 3) - { - private1 = test_g_static_private_constructor (); - g_static_private_set (&test_g_static_private_private1, private1, - test_g_static_private_destructor); - } - *private1 = number; - private2 = g_static_private_get (&test_g_static_private_private2); - if (!private2 || number % 13 > 5) - { - private2 = test_g_static_private_constructor (); - g_static_private_set (&test_g_static_private_private2, private2, - test_g_static_private_destructor); - } - *private2 = number * 2; - g_usleep (G_USEC_PER_SEC / 5); - g_assert (number == *private1); - g_assert (number * 2 == *private2); - } - g_static_mutex_lock (&test_g_static_private_mutex); - test_g_static_private_ready++; - g_static_mutex_unlock (&test_g_static_private_mutex); - - /* Busy wait is not nice but that's just a test */ - while (test_g_static_private_ready != 0) - g_usleep (G_USEC_PER_SEC / 5); - - /* Reuse the static private */ - g_static_private_free (&test_g_static_private_private2); - g_static_private_init (&test_g_static_private_private2); - - for (i = 0; i < 10; i++) - { - private2 = g_static_private_get (&test_g_static_private_private2); - number = number * 11 + 1; /* A very simple and bad RNG ;-) */ - if (!private2 || number % 13 > 5) - { - private2 = test_g_static_private_constructor (); - g_static_private_set (&test_g_static_private_private2, private2, - test_g_static_private_destructor); - } - *private2 = number * 2; - g_usleep (G_USEC_PER_SEC / 5); - g_assert (number * 2 == *private2); - } - - return GINT_TO_POINTER (GPOINTER_TO_INT (data) * 3); -} - -static void -test_g_static_private (void) -{ - GThread *threads[THREADS]; - guint i; - - test_g_static_private_ready = 0; - - for (i = 0; i < THREADS; i++) - { - threads[i] = g_thread_create (test_g_static_private_thread, - GINT_TO_POINTER (i), TRUE, NULL); - } - - /* Busy wait is not nice but that's just a test */ - while (test_g_static_private_ready != THREADS) - g_usleep (G_USEC_PER_SEC / 5); - - test_g_static_private_ready = 0; - - for (i = 0; i < THREADS; i++) - g_assert (GPOINTER_TO_INT (g_thread_join (threads[i])) == i * 3); - - g_assert (test_g_static_private_counter == 0); -} - -static gpointer -test (gpointer data) -{ - test_g_static_private (); - return data; -} - -static gpointer -hoge (gpointer data) -{ - return data; -} - -int -main (int argc, - char *argv[]) -{ - GError *error = NULL; - GList *threads = NULL, *node; - int i; - GThread *t; - - g_thread_init (NULL); - - for (i = 0; i < 100; i++) - { - GThread *thread; - thread = g_thread_create(hoge, NULL, TRUE, &error); - threads = g_list_append(threads, thread); - } - - t = g_thread_create(test, NULL, TRUE, NULL); - threads = g_list_append(threads, t); - - for (node = threads; node; node = g_list_next(node)) - { - GThread *thread = node->data; - - g_thread_join(thread); - } - - return 0; -} Deleted: sample/glib/thread.c (+0 -416) 100644 =================================================================== --- sample/glib/thread.c 2013-05-17 21:57:29 +0900 (79aa962) +++ /dev/null @@ -1,416 +0,0 @@ -#include <cutter.h> - -#include <glib.h> - -#if defined(G_THREADS_ENABLED) && ! defined(G_THREADS_IMPL_NONE) -void test_g_mutex (void); -void test_g_static_rec_mutex (void); -void test_g_static_private (void); -void test_g_static_rw_lock (void); -void test_g_thread_once (void); - -void -setup (void) -{ - g_thread_use_default_impl = FALSE; -} - -typedef struct _TestData -{ - gint number; - guint unsigned_number; - CutTestContext *test_context; -} TestData; - -/* GMutex */ -static GMutex* test_g_mutex_mutex = NULL; -static guint test_g_mutex_int = 0; -static gboolean test_g_mutex_thread_ready; -G_LOCK_DEFINE_STATIC (test_g_mutex); - -static gpointer -test_g_mutex_thread (gpointer user_data) -{ - TestData *data = user_data; - - cut_set_current_test_context (data->test_context); - cut_assert_equal_int (42, data->number); - cut_assert_false (g_mutex_trylock (test_g_mutex_mutex)); - cut_assert_false (G_TRYLOCK (test_g_mutex)); - test_g_mutex_thread_ready = TRUE; - g_mutex_lock (test_g_mutex_mutex); - cut_assert_equal_int (42, test_g_mutex_int); - g_mutex_unlock (test_g_mutex_mutex); - - return GINT_TO_POINTER (41); -} - -void -test_g_mutex (void) -{ - GThread *thread; - TestData test_data; - test_g_mutex_mutex = g_mutex_new (); - - cut_assert_true (g_mutex_trylock (test_g_mutex_mutex)); - cut_assert_true (G_TRYLOCK (test_g_mutex)); - test_g_mutex_thread_ready = FALSE; - test_data.number = 42; - test_data.test_context = cut_get_current_test_context (); - thread = g_thread_create (test_g_mutex_thread, &test_data, TRUE, NULL); - /* This busy wait is only for testing purposes and not an example of - * good code!*/ - while (!test_g_mutex_thread_ready) - g_usleep (G_USEC_PER_SEC / 5); - test_g_mutex_int = 42; - G_UNLOCK (test_g_mutex); - g_mutex_unlock (test_g_mutex_mutex); - cut_assert_equal_int (41, GPOINTER_TO_INT (g_thread_join (thread))); - g_mutex_free (test_g_mutex_mutex); -} - -/* GStaticRecMutex */ - -static GStaticRecMutex test_g_static_rec_mutex_mutex = G_STATIC_REC_MUTEX_INIT; -static guint test_g_static_rec_mutex_int = 0; -static gboolean test_g_static_rec_mutex_thread_ready; - -static gpointer -test_g_static_rec_mutex_thread (gpointer user_data) -{ - TestData *data = user_data; - - cut_set_current_test_context (data->test_context); - - cut_assert_equal_int (42, data->number); - cut_assert_false (g_static_rec_mutex_trylock (&test_g_static_rec_mutex_mutex)); - test_g_static_rec_mutex_thread_ready = TRUE; - g_static_rec_mutex_lock (&test_g_static_rec_mutex_mutex); - g_static_rec_mutex_lock (&test_g_static_rec_mutex_mutex); - cut_assert_equal_int (42, test_g_static_rec_mutex_int); - test_g_static_rec_mutex_thread_ready = FALSE; - g_static_rec_mutex_unlock (&test_g_static_rec_mutex_mutex); - g_static_rec_mutex_unlock (&test_g_static_rec_mutex_mutex); - - g_thread_exit (GINT_TO_POINTER (43)); - - cut_fail("Never reached here"); - return NULL; -} - -void -test_g_static_rec_mutex (void) -{ - GThread *thread; - TestData test_data; - - cut_assert_true (g_static_rec_mutex_trylock (&test_g_static_rec_mutex_mutex)); - test_g_static_rec_mutex_thread_ready = FALSE; - test_data.number = 42; - test_data.test_context = cut_get_current_test_context (); - thread = g_thread_create (test_g_static_rec_mutex_thread, - &test_data, TRUE, NULL); - /* This busy wait is only for testing purposes and not an example of - * good code!*/ - while (!test_g_static_rec_mutex_thread_ready) - g_usleep (G_USEC_PER_SEC / 5); - - cut_assert_true (g_static_rec_mutex_trylock (&test_g_static_rec_mutex_mutex)); - test_g_static_rec_mutex_int = 41; - g_static_rec_mutex_unlock (&test_g_static_rec_mutex_mutex); - test_g_static_rec_mutex_int = 42; - g_static_rec_mutex_unlock (&test_g_static_rec_mutex_mutex); - - /* This busy wait is only for testing purposes and not an example of - * good code!*/ - while (test_g_static_rec_mutex_thread_ready) - g_usleep (G_USEC_PER_SEC / 5); - - g_static_rec_mutex_lock (&test_g_static_rec_mutex_mutex); - test_g_static_rec_mutex_int = 0; - g_static_rec_mutex_unlock (&test_g_static_rec_mutex_mutex); - - cut_assert_equal_int (43, GPOINTER_TO_INT (g_thread_join (thread))); -} - -/* GStaticPrivate */ - -#define THREADS 10 - -static GStaticPrivate test_g_static_private_private1 = G_STATIC_PRIVATE_INIT; -static GStaticPrivate test_g_static_private_private2 = G_STATIC_PRIVATE_INIT; -static GStaticMutex test_g_static_private_mutex = G_STATIC_MUTEX_INIT; -static guint test_g_static_private_counter = 0; -static guint test_g_static_private_ready = 0; - -static gpointer -test_g_static_private_constructor (void) -{ - g_static_mutex_lock (&test_g_static_private_mutex); - test_g_static_private_counter++; - g_static_mutex_unlock (&test_g_static_private_mutex); - return g_new (guint,1); -} - -static void -test_g_static_private_destructor (gpointer data) -{ - g_static_mutex_lock (&test_g_static_private_mutex); - test_g_static_private_counter--; - g_static_mutex_unlock (&test_g_static_private_mutex); - g_free (data); -} - - -static gpointer -test_g_static_private_thread (gpointer user_data) -{ - TestData *data = user_data; - guint number; - guint i; - guint *private1, *private2; - - cut_set_current_test_context (data->test_context); - number = data->unsigned_number; - - for (i = 0; i < 10; i++) - { - number = number * 11 + 1; /* A very simple and bad RNG ;-) */ - private1 = g_static_private_get (&test_g_static_private_private1); - if (!private1 || number % 7 > 3) - { - private1 = test_g_static_private_constructor (); - g_static_private_set (&test_g_static_private_private1, private1, - test_g_static_private_destructor); - } - *private1 = number; - private2 = g_static_private_get (&test_g_static_private_private2); - if (!private2 || number % 13 > 5) - { - private2 = test_g_static_private_constructor (); - g_static_private_set (&test_g_static_private_private2, private2, - test_g_static_private_destructor); - } - *private2 = number * 2; - g_usleep (G_USEC_PER_SEC / 5); - cut_assert_equal_int (number, *private1); - cut_assert_equal_int (number * 2, *private2); - } - g_static_mutex_lock (&test_g_static_private_mutex); - test_g_static_private_ready++; - g_static_mutex_unlock (&test_g_static_private_mutex); - - /* Busy wait is not nice but that's just a test */ - while (test_g_static_private_ready != 0) - g_usleep (G_USEC_PER_SEC / 5); - - for (i = 0; i < 10; i++) - { - private2 = g_static_private_get (&test_g_static_private_private2); - number = number * 11 + 1; /* A very simple and bad RNG ;-) */ - if (!private2 || number % 13 > 5) - { - private2 = test_g_static_private_constructor (); - g_static_private_set (&test_g_static_private_private2, private2, - test_g_static_private_destructor); - } - *private2 = number * 2; - g_usleep (G_USEC_PER_SEC / 5); - cut_assert_equal_int (number * 2, *private2); - } - - return GINT_TO_POINTER (data->unsigned_number * 3); -} - -void -test_g_static_private (void) -{ - GThread *threads[THREADS]; - TestData data[THREADS]; - guint i; - - test_g_static_private_ready = 0; - - for (i = 0; i < THREADS; i++) - { - data[i].unsigned_number = i; - data[i].test_context = cut_get_current_test_context (); - threads[i] = g_thread_create (test_g_static_private_thread, - &(data[i]), TRUE, NULL); - } - - /* Busy wait is not nice but that's just a test */ - while (test_g_static_private_ready != THREADS) - g_usleep (G_USEC_PER_SEC / 5); - - /* Reuse the static private */ - g_static_private_free (&test_g_static_private_private2); - g_static_private_init (&test_g_static_private_private2); - - test_g_static_private_ready = 0; - - for (i = 0; i < THREADS; i++) - cut_assert_equal_int (i * 3, GPOINTER_TO_INT (g_thread_join (threads[i]))); - - cut_assert_equal_int (0, test_g_static_private_counter); -} - -/* GStaticRWLock */ - -/* -1 = writing; >0 = # of readers */ -static gint test_g_static_rw_lock_state = 0; -G_LOCK_DEFINE (test_g_static_rw_lock_state); - -static gboolean test_g_static_rw_lock_run = TRUE; -static GStaticRWLock test_g_static_rw_lock_lock = G_STATIC_RW_LOCK_INIT; - -static gpointer -test_g_static_rw_lock_thread (gpointer data) -{ - cut_set_current_test_context (data); - while (test_g_static_rw_lock_run) - { - if (g_random_double() > .2) /* I'm a reader */ - { - - if (g_random_double() > .2) /* I'll block */ - g_static_rw_lock_reader_lock (&test_g_static_rw_lock_lock); - else /* I'll only try */ - if (!g_static_rw_lock_reader_trylock (&test_g_static_rw_lock_lock)) - continue; - G_LOCK (test_g_static_rw_lock_state); - cut_assert_operator_int (test_g_static_rw_lock_state, >=, 0); - test_g_static_rw_lock_state++; - G_UNLOCK (test_g_static_rw_lock_state); - - g_usleep (g_random_int_range (20,1000)); - - G_LOCK (test_g_static_rw_lock_state); - test_g_static_rw_lock_state--; - G_UNLOCK (test_g_static_rw_lock_state); - - g_static_rw_lock_reader_unlock (&test_g_static_rw_lock_lock); - } - else /* I'm a writer */ - { - - if (g_random_double() > .2) /* I'll block */ - g_static_rw_lock_writer_lock (&test_g_static_rw_lock_lock); - else /* I'll only try */ - if (!g_static_rw_lock_writer_trylock (&test_g_static_rw_lock_lock)) - continue; - G_LOCK (test_g_static_rw_lock_state); - cut_assert_equal_int (0, test_g_static_rw_lock_state); - test_g_static_rw_lock_state = -1; - G_UNLOCK (test_g_static_rw_lock_state); - - g_usleep (g_random_int_range (20,1000)); - - G_LOCK (test_g_static_rw_lock_state); - test_g_static_rw_lock_state = 0; - G_UNLOCK (test_g_static_rw_lock_state); - - g_static_rw_lock_writer_unlock (&test_g_static_rw_lock_lock); - } - } - return NULL; -} - -void -test_g_static_rw_lock (void) -{ - GThread *threads[THREADS]; - guint i; - for (i = 0; i < THREADS; i++) - { - threads[i] = g_thread_create (test_g_static_rw_lock_thread, - cut_get_current_test_context (), TRUE, NULL); - } - g_usleep (G_USEC_PER_SEC * 5); - test_g_static_rw_lock_run = FALSE; - for (i = 0; i < THREADS; i++) - { - g_thread_join (threads[i]); - } - cut_assert_equal_int (0, test_g_static_rw_lock_state); -} - -#define G_ONCE_SIZE 100 -#define G_ONCE_THREADS 10 - -G_LOCK_DEFINE (test_g_once); -static guint test_g_once_guint_array[G_ONCE_SIZE]; -static GOnce test_g_once_array[G_ONCE_SIZE]; - -static gpointer -test_g_once_init_func(gpointer arg) -{ - guint *count = arg; - g_usleep (g_random_int_range (20,1000)); - (*count)++; - g_usleep (g_random_int_range (20,1000)); - return arg; -} - -static gpointer -test_g_once_thread (gpointer user_data) -{ - TestData *data = user_data; - guint i; - - cut_set_current_test_context (data->test_context); - G_LOCK (test_g_once); - /* Don't start before all threads are created */ - G_UNLOCK (test_g_once); - for (i = 0; i < 1000; i++) - { - guint pos = g_random_int_range (0, G_ONCE_SIZE); - gpointer ret = g_once (test_g_once_array + pos, test_g_once_init_func, - test_g_once_guint_array + pos); - cut_assert_equal_pointer (ret, test_g_once_guint_array + pos); - } - - /* Make sure, that all counters are touched at least once */ - for (i = 0; i < G_ONCE_SIZE; i++) - { - gpointer ret = g_once (test_g_once_array + i, test_g_once_init_func, - test_g_once_guint_array + i); - cut_assert_equal_pointer (ret, test_g_once_guint_array + i); - } - - return NULL; -} - -void -test_g_thread_once (void) -{ - static GOnce once_init = G_ONCE_INIT; - GThread *threads[G_ONCE_THREADS]; - TestData data[G_ONCE_THREADS]; - guint i; - for (i = 0; i < G_ONCE_SIZE; i++) - { - test_g_once_array[i] = once_init; - test_g_once_guint_array[i] = i; - } - G_LOCK (test_g_once); - for (i = 0; i < G_ONCE_THREADS; i++) - { - data[i].unsigned_number = i % 2; - data[i].test_context = cut_get_current_test_context (); - threads[i] = g_thread_create (test_g_once_thread, &(data[i]), TRUE, NULL); - } - G_UNLOCK (test_g_once); - for (i = 0; i < G_ONCE_THREADS; i++) - { - g_thread_join (threads[i]); - } - - for (i = 0; i < G_ONCE_SIZE; i++) - { - cut_assert_equal_int (i + 1, test_g_once_guint_array[i]); - } -} - -#endif - |
