* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
*/
-#define _GNU_SOURCE
-#include "config.h"
#include <stdio.h>
#include <pthread.h>
#include <stdlib.h>
#ifndef DYNAMIC_LINK_TEST
#define _LGPL_SOURCE
-#else
-#define debug_yield_read()
#endif
#include <urcu.h>
#if HAVE_SCHED_SETAFFINITY
ret = pthread_mutex_lock(&affinity_mutex);
if (ret) {
+ errno = ret;
perror("Error in pthread mutex lock");
- exit(-1);
+ abort();
}
cpu = cpu_affinities[next_aff++];
ret = pthread_mutex_unlock(&affinity_mutex);
if (ret) {
+ errno = ret;
perror("Error in pthread mutex unlock");
- exit(-1);
+ abort();
}
CPU_ZERO(&mask);
CPU_SET(cpu, &mask);
static unsigned int nr_readers;
static unsigned int nr_writers;
-pthread_mutex_t rcu_copy_mutex = PTHREAD_MUTEX_INITIALIZER;
-
-void rcu_copy_mutex_lock(void)
+static void urcu_mutex_lock(pthread_mutex_t *lock)
{
int ret;
- ret = pthread_mutex_lock(&rcu_copy_mutex);
+
+ ret = pthread_mutex_lock(lock);
if (ret) {
+ errno = ret;
perror("Error in pthread mutex lock");
- exit(-1);
+ abort();
}
}
-void rcu_copy_mutex_unlock(void)
+static void urcu_mutex_unlock(pthread_mutex_t *lock)
{
int ret;
- ret = pthread_mutex_unlock(&rcu_copy_mutex);
+ ret = pthread_mutex_unlock(lock);
if (ret) {
+ errno = ret;
perror("Error in pthread mutex unlock");
- exit(-1);
+ abort();
}
}
}
for (;;) {
- pthread_mutex_lock(&per_thread_lock[tidx].lock);
- assert(test_array.a == 8);
+ int v;
+
+ urcu_mutex_lock(&per_thread_lock[tidx].lock);
+ v = test_array.a;
+ assert(v == 8);
if (caa_unlikely(rduration))
loop_sleep(rduration);
- pthread_mutex_unlock(&per_thread_lock[tidx].lock);
+ urcu_mutex_unlock(&per_thread_lock[tidx].lock);
URCU_TLS(nr_reads)++;
if (caa_unlikely(!test_duration_read()))
break;
for (;;) {
for (tidx = 0; tidx < nr_readers; tidx++) {
- pthread_mutex_lock(&per_thread_lock[tidx].lock);
+ urcu_mutex_lock(&per_thread_lock[tidx].lock);
}
test_array.a = 0;
test_array.a = 8;
if (caa_unlikely(wduration))
loop_sleep(wduration);
for (tidx = (long)nr_readers - 1; tidx >= 0; tidx--) {
- pthread_mutex_unlock(&per_thread_lock[tidx].lock);
+ urcu_mutex_unlock(&per_thread_lock[tidx].lock);
}
URCU_TLS(nr_writes)++;
if (caa_unlikely(!test_duration_write()))
printf("Usage : %s nr_readers nr_writers duration (s) <OPTIONS>\n",
argv[0]);
printf("OPTIONS:\n");
-#ifdef DEBUG_YIELD
- printf(" [-r] [-w] (yield reader and/or writer)\n");
-#endif
printf(" [-d delay] (writer period (us))\n");
printf(" [-c duration] (reader C.S. duration (in loops))\n");
printf(" [-e duration] (writer C.S. duration (in loops))\n");
if (argv[i][0] != '-')
continue;
switch (argv[i][1]) {
-#ifdef DEBUG_YIELD
- case 'r':
- yield_active |= YIELD_READ;
- break;
- case 'w':
- yield_active |= YIELD_WRITE;
- break;
-#endif
case 'a':
if (argc < i + 2) {
show_usage(argc, argv);
tot_nr_writes = calloc(nr_writers, sizeof(*tot_nr_writes));
per_thread_lock = calloc(nr_readers, sizeof(*per_thread_lock));
for (i = 0; i < nr_readers; i++) {
- err = pthread_mutex_init(&per_thread_lock[i].lock, NULL);
- if (err != 0)
- exit(1);
+ pthread_mutex_init(&per_thread_lock[i].lock, NULL);
}
next_aff = 0;