Revision: 56587
http://sourceforge.net/p/brlcad/code/56587
Author: ejno
Date: 2013-08-05 17:23:39 +0000 (Mon, 05 Aug 2013)
Log Message:
-----------
add a test of libbu semaphore locking
Modified Paths:
--------------
brlcad/trunk/src/libbu/tests/CMakeLists.txt
Added Paths:
-----------
brlcad/trunk/src/libbu/tests/bu_semaphore.c
Modified: brlcad/trunk/src/libbu/tests/CMakeLists.txt
===================================================================
--- brlcad/trunk/src/libbu/tests/CMakeLists.txt 2013-08-05 16:44:10 UTC (rev
56586)
+++ brlcad/trunk/src/libbu/tests/CMakeLists.txt 2013-08-05 17:23:39 UTC (rev
56587)
@@ -300,6 +300,12 @@
add_test(bu_gettime_test tester_bu_timer)
#
+# ************ bu_semaphore.c tests *************
+#
+BRLCAD_ADDEXEC(tester_bu_semaphore bu_semaphore.c libbu NO_INSTALL LOCAL)
+add_test(bu_semaphore_test tester_bu_semaphore)
+
+#
# ************ vls_vprintf.c tests *************
#
BRLCAD_ADDEXEC(tester_bu_vls_vprintf bu_vls_vprintf.c libbu NO_INSTALL)
Added: brlcad/trunk/src/libbu/tests/bu_semaphore.c
===================================================================
--- brlcad/trunk/src/libbu/tests/bu_semaphore.c (rev 0)
+++ brlcad/trunk/src/libbu/tests/bu_semaphore.c 2013-08-05 17:23:39 UTC (rev
56587)
@@ -0,0 +1,192 @@
+/* B U _ S E M A P H O R E . C
+ * BRL-CAD
+ *
+ * Copyright (c) 2013 United States Government as represented by
+ * the U.S. Army Research Laboratory.
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public License
+ * version 2.1 as published by the Free Software Foundation.
+ *
+ * This library 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
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this file; see the file named COPYING for more
+ * information.
+ */
+/** @file bu_semaphore.c
+ *
+ * Tests libbu semaphore locking.
+ *
+ */
+
+
+#include "common.h"
+#include "bu.h"
+
+
+#ifdef HAVE_UNISTD_H
+#include <unistd.h>
+#include <signal.h>
+
+
+static void
+_exit_alarm_handler(int sig)
+{
+ if (sig == SIGALRM) exit(0);
+}
+
+
+int
+set_exit_alarm(unsigned seconds)
+{
+ signal(SIGALRM, _exit_alarm_handler);
+ alarm(seconds);
+ return 1;
+}
+
+
+#else
+#include <windows.h>
+
+
+static void CALLBACK
+_exit_alarm_handler(UINT UNUSED(uTimerID), UINT UNUSED(uMsg), DWORD_PTR
UNUSED(dwUser),
+ DWORD_PTR UNUSED(dw1), DWORD_PTR UNUSED(dw2))
+{
+ exit(0);
+}
+
+
+int
+set_exit_alarm(unsigned seconds)
+{
+ return !!timeSetEvent(seconds*1000, 100,
(LPTIMECALLBACK)_exit_alarm_handler, NULL, TIME_ONESHOT);
+}
+
+
+#endif
+
+
+const int SEM = BU_SEM_LAST+1;
+
+
+static int
+repeat_test(unsigned long reps)
+{
+ unsigned long i;
+
+ for (i = 0; i < reps; i++) bu_semaphore_init(SEM+1);
+ for (i = 0; i < reps; i++) bu_semaphore_free();
+
+ return 1;
+}
+
+
+
+static int
+single_thread_test()
+{
+ if (!set_exit_alarm(1)) {
+ bu_log("failed to start alarm; skipping single-thread bu_semaphore
test");
+ return 1;
+ }
+
+ bu_semaphore_init(SEM+1);
+ bu_semaphore_acquire(SEM);
+ bu_semaphore_acquire(SEM);
+ bu_semaphore_free();
+
+ bu_log("single-thread bu_semaphore test failed");
+ return 0;
+}
+
+
+struct increment_thread_args { int *parallel, *running; unsigned long reps,
*counter; };
+static void
+increment_thread(int ncpu, genptr_t pargs)
+{
+ struct increment_thread_args *args = pargs;
+ unsigned long i;
+
+ (void)ncpu;
+
+ if (*args->running) *args->parallel = 1;
+ *args->running = 1;
+
+ for (i = 0; i < args->reps; i++) {
+ bu_semaphore_acquire(SEM);
+ ++*args->counter;
+ bu_semaphore_release(SEM);
+ }
+ *args->running = 0;
+}
+
+
+static int
+parallel_test(unsigned long reps)
+{
+ const int nthreads = bu_avail_cpus();
+
+
+ struct increment_thread_args args;
+ unsigned long counter = 0, expected = reps*nthreads;
+ int parallel = 0, running = 0;
+ args.parallel = ∥
+ args.running = &running;
+ args.reps = reps;
+ args.counter = &counter;
+
+ bu_semaphore_init(SEM+1);
+ bu_parallel(increment_thread, nthreads, &args);
+ bu_semaphore_free();
+
+ if (counter != expected) {
+ bu_log("parallel-increment bu_semaphore test failed: counter is %lu,
expected %lu\n", counter, expected);
+ return 0;
+ }
+
+ if ((nthreads > 1) && !parallel) {
+ bu_log("parallel-increment bu_semaphore test invalid: threads did not
run in parallel\n");
+ return 0;
+ }
+
+ return 1;
+}
+
+
+int
+main(int argc, char **argv)
+{
+ const char * const USAGE = "Usage: %s [-n reps]\n";
+
+
+ unsigned long nreps = 10000;
+ char c;
+ int success;
+
+ while ((c = bu_getopt(argc, argv, "n:")) != -1) {
+ switch (c) {
+ case 'n': nreps = strtoul(bu_optarg, NULL, 0); break;
+ default: bu_exit(1, USAGE, argv[0]);
+ }
+ }
+
+ success = repeat_test(nreps) && parallel_test(nreps);
+
+ return !(success && single_thread_test());
+}
+
+
+/*
+ * Local Variables:
+ * mode: C
+ * tab-width: 8
+ * indent-tabs-mode: t
+ * c-file-style: "stroustrup"
+ * End:
+ * ex: shiftwidth=4 tabstop=8
+ */
Property changes on: brlcad/trunk/src/libbu/tests/bu_semaphore.c
___________________________________________________________________
Added: svn:mime-type
## -0,0 +1 ##
+text/plain
\ No newline at end of property
Added: svn:eol-style
## -0,0 +1 ##
+native
\ No newline at end of property
This was sent by the SourceForge.net collaborative development platform, the
world's largest Open Source development site.
------------------------------------------------------------------------------
Get your SQL database under version control now!
Version control is standard for application code, but databases havent
caught up. So what steps can you take to put your SQL databases under
version control? Why should you start doing it? Read more to find out.
http://pubads.g.doubleclick.net/gampad/clk?id=49501711&iu=/4140/ostg.clktrk
_______________________________________________
BRL-CAD Source Commits mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/brlcad-commits
