Converted test for recursive mutex_t
authorTobias Brunner <tobias@strongswan.org>
Wed, 27 Mar 2013 08:16:59 +0000 (09:16 +0100)
committerTobias Brunner <tobias@strongswan.org>
Tue, 11 Jun 2013 09:03:11 +0000 (11:03 +0200)
src/libcharon/plugins/unit_tester/Makefile.am
src/libcharon/plugins/unit_tester/tests.h
src/libcharon/plugins/unit_tester/tests/test_mutex.c [deleted file]
src/libstrongswan/tests/Makefile.am
src/libstrongswan/tests/test_runner.c
src/libstrongswan/tests/test_runner.h
src/libstrongswan/tests/test_threading.c [new file with mode: 0644]

index db11d93..84628b5 100644 (file)
@@ -16,7 +16,6 @@ libstrongswan_unit_tester_la_SOURCES = \
        tests/test_curl.c \
        tests/test_mysql.c \
        tests/test_sqlite.c \
-       tests/test_mutex.c \
        tests/test_rsa_gen.c \
        tests/test_cert.c \
        tests/test_med_db.c \
index 4fd358e..bcb82c3 100644 (file)
@@ -22,7 +22,6 @@ DEFINE_TEST("auth cfg", test_auth_cfg, FALSE)
 DEFINE_TEST("CURL get", test_curl_get, FALSE)
 DEFINE_TEST("MySQL operations", test_mysql, FALSE)
 DEFINE_TEST("SQLite operations", test_sqlite, FALSE)
-DEFINE_TEST("mutex primitive", test_mutex, FALSE)
 DEFINE_TEST("RSA key generation", test_rsa_gen, FALSE)
 DEFINE_TEST("RSA subjectPublicKeyInfo loading", test_rsa_load_any, FALSE)
 DEFINE_TEST("X509 certificate", test_cert_x509, FALSE)
diff --git a/src/libcharon/plugins/unit_tester/tests/test_mutex.c b/src/libcharon/plugins/unit_tester/tests/test_mutex.c
deleted file mode 100644 (file)
index 77085cb..0000000
+++ /dev/null
@@ -1,100 +0,0 @@
-/*
- * Copyright (C) 2008 Martin Willi
- * Hochschule fuer Technik Rapperswil
- *
- * 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 2 of the License, or (at your
- * option) any later version.  See <http://www.fsf.org/copyleft/gpl.txt>.
- *
- * 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.
- */
-
-#include <library.h>
-#include <threading/mutex.h>
-
-#include <unistd.h>
-#include <sched.h>
-#include <pthread.h>
-
-
-static mutex_t *mutex;
-
-static int locked = 0;
-
-static bool failed = FALSE;
-
-static pthread_barrier_t barrier;
-
-static void* run(void* null)
-{
-       int i;
-
-       /* wait for all threads before getting in action */
-       pthread_barrier_wait(&barrier);
-
-       for (i = 0; i < 100; i++)
-       {
-               mutex->lock(mutex);
-               mutex->lock(mutex);
-               mutex->lock(mutex);
-               locked++;
-               sched_yield();
-               if (locked > 1)
-               {
-                       failed = TRUE;
-               }
-               locked--;
-               mutex->unlock(mutex);
-               mutex->unlock(mutex);
-               mutex->unlock(mutex);
-       }
-       return NULL;
-}
-
-#define THREADS 20
-
-/*******************************************************************************
- * mutex test
- ******************************************************************************/
-bool test_mutex()
-{
-       int i;
-       pthread_t threads[THREADS];
-
-       mutex = mutex_create(MUTEX_TYPE_RECURSIVE);
-
-       for (i = 0; i < 10; i++)
-       {
-               mutex->lock(mutex);
-               mutex->unlock(mutex);
-       }
-       for (i = 0; i < 10; i++)
-       {
-               mutex->lock(mutex);
-       }
-       for (i = 0; i < 10; i++)
-       {
-               mutex->unlock(mutex);
-       }
-
-       pthread_barrier_init(&barrier, NULL, THREADS);
-
-       for (i = 0; i < THREADS; i++)
-       {
-               pthread_create(&threads[i], NULL, run, NULL);
-       }
-       for (i = 0; i < THREADS; i++)
-       {
-               pthread_join(threads[i], NULL);
-       }
-       pthread_barrier_destroy(&barrier);
-
-       mutex->destroy(mutex);
-
-       return !failed;
-}
-
index bb1ce91..fbcedda 100644 (file)
@@ -5,7 +5,8 @@ check_PROGRAMS = $(TESTS)
 test_runner_SOURCES = \
   test_runner.c test_runner.h \
   test_linked_list.c test_enumerator.c test_linked_list_enumerator.c \
-  test_chunk.c test_hashtable.c test_identification.c
+  test_chunk.c test_hashtable.c test_identification.c \
+  test_threading.c
 
 
 test_runner_CFLAGS = \
index 03287e5..7dc40ff 100644 (file)
@@ -38,6 +38,7 @@ int main()
        srunner_add_suite(sr, linked_list_enumerator_suite_create());
        srunner_add_suite(sr, hashtable_suite_create());
        srunner_add_suite(sr, identification_suite_create());
+       srunner_add_suite(sr, threading_suite_create());
 
        srunner_run_all(sr, CK_NORMAL);
        nf = srunner_ntests_failed(sr);
index 7593c6a..8ec40a7 100644 (file)
@@ -24,5 +24,6 @@ Suite *linked_list_suite_create();
 Suite *linked_list_enumerator_suite_create();
 Suite *hashtable_suite_create();
 Suite *identification_suite_create();
+Suite *threading_suite_create();
 
 #endif /** TEST_RUNNER_H_ */
diff --git a/src/libstrongswan/tests/test_threading.c b/src/libstrongswan/tests/test_threading.c
new file mode 100644 (file)
index 0000000..1ffbcb6
--- /dev/null
@@ -0,0 +1,109 @@
+/*
+ * Copyright (C) 2013 Tobias Brunner
+ * Copyright (C) 2008 Martin Willi
+ * Hochschule fuer Technik Rapperswil
+ *
+ * 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 2 of the License, or (at your
+ * option) any later version.  See <http://www.fsf.org/copyleft/gpl.txt>.
+ *
+ * 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.
+ */
+
+#include <check.h>
+#include <sched.h>
+#include <pthread.h>
+
+#include <threading/mutex.h>
+
+/*******************************************************************************
+ * recursive mutex test
+ */
+
+#define THREADS 20
+
+static mutex_t *mutex;
+
+static pthread_barrier_t mutex_barrier;
+
+static int mutex_locked = 0;
+
+static void *mutex_run(void *data)
+{
+       int i;
+
+       /* wait for all threads before getting in action */
+       pthread_barrier_wait(&mutex_barrier);
+
+       for (i = 0; i < 100; i++)
+       {
+               mutex->lock(mutex);
+               mutex->lock(mutex);
+               mutex->lock(mutex);
+               mutex_locked++;
+               sched_yield();
+               if (mutex_locked > 1)
+               {
+                       fail("two threads locked the mutex concurrently");
+               }
+               mutex_locked--;
+               mutex->unlock(mutex);
+               mutex->unlock(mutex);
+               mutex->unlock(mutex);
+       }
+       return NULL;
+}
+
+START_TEST(test_mutex)
+{
+       pthread_t threads[THREADS];
+       int i;
+
+       mutex = mutex_create(MUTEX_TYPE_RECURSIVE);
+
+       for (i = 0; i < 10; i++)
+       {
+               mutex->lock(mutex);
+               mutex->unlock(mutex);
+       }
+       for (i = 0; i < 10; i++)
+       {
+               mutex->lock(mutex);
+       }
+       for (i = 0; i < 10; i++)
+       {
+               mutex->unlock(mutex);
+       }
+
+       pthread_barrier_init(&mutex_barrier, NULL, THREADS);
+       for (i = 0; i < THREADS; i++)
+       {
+               pthread_create(&threads[i], NULL, mutex_run, NULL);
+       }
+       for (i = 0; i < THREADS; i++)
+       {
+               pthread_join(threads[i], NULL);
+       }
+       pthread_barrier_destroy(&mutex_barrier);
+
+       mutex->destroy(mutex);
+}
+END_TEST
+
+Suite *threading_suite_create()
+{
+       Suite *s;
+       TCase *tc;
+
+       s = suite_create("threading");
+
+       tc = tcase_create("recursive mutex");
+       tcase_add_test(tc, test_mutex);
+       suite_add_tcase(s, tc);
+
+       return s;
+}