From 46dab95383d42b0691d41b96cc43c131695308c9 Mon Sep 17 00:00:00 2001 From: Yoann Vandoorselaere Date: Wed, 1 Oct 2008 03:39:40 +0200 Subject: [PATCH] Tests for module 'cond'. --- ChangeLog | 5 ++ modules/cond-tests | 14 ++++ tests/test-cond.c | 207 +++++++++++++++++++++++++++++++++++++++++++++++++++++ 3 files changed, 226 insertions(+) create mode 100644 modules/cond-tests create mode 100644 tests/test-cond.c diff --git a/ChangeLog b/ChangeLog index 900a2493b..6b9cddc95 100644 --- a/ChangeLog +++ b/ChangeLog @@ -1,4 +1,9 @@ 2008-09-30 Yoann Vandoorselaere + + * modules/cond-tests: New file. + * tests/test-cond.c: New file. + +2008-09-30 Yoann Vandoorselaere Bruno Haible * modules/cond (Dependencies): Add errno, time. diff --git a/modules/cond-tests b/modules/cond-tests new file mode 100644 index 000000000..6b4c45e2c --- /dev/null +++ b/modules/cond-tests @@ -0,0 +1,14 @@ +Files: +tests/test-cond.c + +Depends-on: +lock +thread +yield +gettimeofday +sleep + +Makefile.am: +TESTS += test-cond +check_PROGRAMS += test-cond +test_cond_LDADD = $(LDADD) @LIBMULTITHREAD@ @YIELD_LIB@ diff --git a/tests/test-cond.c b/tests/test-cond.c new file mode 100644 index 000000000..4981708a5 --- /dev/null +++ b/tests/test-cond.c @@ -0,0 +1,207 @@ +/* Test of condition variables in multithreaded situations. + Copyright (C) 2008 Free Software Foundation, Inc. + + This program is free software: you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 3 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program. If not, see . */ + +#include + +#if USE_POSIX_THREADS || USE_SOLARIS_THREADS || USE_PTH_THREADS || USE_WIN32_THREADS + +/* Which tests to perform. + Uncomment some of these, to verify that all tests crash if no locking + is enabled. */ +#define DO_TEST_COND 1 +#define DO_TEST_TIMEDCOND 1 + + +/* Whether to help the scheduler through explicit yield(). + Uncomment this to see if the operating system has a fair scheduler. */ +#define EXPLICIT_YIELD 1 + +/* Whether to print debugging messages. */ +#define ENABLE_DEBUGGING 0 + +#include +#include +#include +#include + +#include "glthread/cond.h" +#include "glthread/lock.h" +#include "glthread/thread.h" +#include "glthread/yield.h" + +#if ENABLE_DEBUGGING +# define dbgprintf printf +#else +# define dbgprintf if (0) printf +#endif + +#if EXPLICIT_YIELD +# define yield() gl_thread_yield () +#else +# define yield() +#endif + + +/* + * Condition check + */ +#include +static int cond_value = 0; +gl_cond_define_initialized(static, condtest) +gl_lock_define_initialized(static, lockcond) + +static void * +cond_routine (void *arg) +{ + gl_lock_lock (lockcond); + while (!cond_value) + { + gl_cond_wait (condtest, lockcond); + } + gl_lock_unlock (lockcond); + + cond_value = 2; + + return NULL; +} + +void +test_cond () +{ + int remain = 2; + gl_thread_t thread; + + cond_value = 0; + + thread = gl_thread_create (cond_routine, NULL); + do + { + yield (); + remain = sleep (remain); + } + while (remain); + + /* signal condition */ + gl_lock_lock (lockcond); + cond_value = 1; + gl_cond_signal (condtest); + gl_lock_unlock (lockcond); + + gl_thread_join (thread, NULL); + + if (cond_value != 2) + abort (); +} + + +/* + * Timed Condition check + */ +static int cond_timeout; + +static void +get_ts (struct timespec *ts) +{ + struct timeval now; + + gettimeofday (&now, NULL); + + ts->tv_sec = now.tv_sec + 1; + ts->tv_nsec = now.tv_usec * 1000; +} + +static void * +timedcond_routine (void *arg) +{ + int ret; + struct timespec ts; + + gl_lock_lock (lockcond); + while (!cond_value) + { + get_ts (&ts); + ret = glthread_cond_timedwait (&condtest, &lockcond, &ts); + if (ret == ETIMEDOUT) + cond_timeout = 1; + } + gl_lock_unlock (lockcond); + + return NULL; +} + +static void +test_timedcond (void) +{ + int remain = 2; + gl_thread_t thread; + + cond_value = cond_timeout = 0; + + thread = gl_thread_create (timedcond_routine, NULL); + + remain = 2; + do + { + yield (); + remain = sleep (remain); + } + while (remain); + + /* signal condition */ + gl_lock_lock (lockcond); + cond_value = 1; + gl_cond_signal (condtest); + gl_lock_unlock (lockcond); + + gl_thread_join (thread, NULL); + + if (!cond_timeout) + abort (); +} + +int +main () +{ +#if TEST_PTH_THREADS + if (!pth_init ()) + abort (); +#endif + +#if DO_TEST_COND + printf ("Starting test_cond ..."); fflush (stdout); + test_cond (); + printf (" OK\n"); fflush (stdout); +#endif +#if DO_TEST_TIMEDCOND + printf ("Starting test_timedcond ..."); fflush (stdout); + test_timedcond (); + printf (" OK\n"); fflush (stdout); +#endif + + return 0; +} + +#else + +/* No multithreading available. */ + +int +main () +{ + return 77; +} + +#endif -- 2.11.0