#include <sys/wait.h>
#include <unistd.h>
#include <stdio.h>
-#include <assert.h>
#include <pthread.h>
#include <errno.h>
#include <urcu/arch.h>
+#include <urcu/assert.h>
#include "thread-id.h"
static caa_cycles_t __attribute__((aligned(CAA_CACHE_LINE_SIZE))) *reader_time;
static caa_cycles_t __attribute__((aligned(CAA_CACHE_LINE_SIZE))) *writer_time;
+static
void *thr_reader(void *arg)
{
- int i, j;
caa_cycles_t time1, time2;
long tidx = (long)arg;
+ unsigned int i, j;
+ int ret;
printf("thread_begin %s, tid %lu\n",
"reader", urcu_get_thread_id());
time1 = caa_get_cycles();
for (i = 0; i < OUTER_READ_LOOP; i++) {
for (j = 0; j < INNER_READ_LOOP; j++) {
- pthread_mutex_lock(&per_thread_lock[tidx].lock);
- assert(test_array.a == 8);
- pthread_mutex_unlock(&per_thread_lock[tidx].lock);
+ ret = pthread_mutex_lock(&per_thread_lock[tidx].lock);
+ if (ret) {
+ perror("Error in pthread mutex lock");
+ exit(-1);
+ }
+ urcu_posix_assert(test_array.a == 8);
+ ret = pthread_mutex_unlock(&per_thread_lock[tidx].lock);
+ if (ret) {
+ perror("Error in pthread mutex unlock");
+ exit(-1);
+ }
}
}
time2 = caa_get_cycles();
}
+static
void *thr_writer(void *arg)
{
- int i, j;
- long tidx;
caa_cycles_t time1, time2;
+ unsigned int i, j;
+ long tidx;
+ int ret;
printf("thread_begin %s, tid %lu\n",
"writer", urcu_get_thread_id());
for (j = 0; j < INNER_WRITE_LOOP; j++) {
time1 = caa_get_cycles();
for (tidx = 0; tidx < NR_READ; tidx++) {
- pthread_mutex_lock(&per_thread_lock[tidx].lock);
+ ret = pthread_mutex_lock(&per_thread_lock[tidx].lock);
+ if (ret) {
+ perror("Error in pthread mutex lock");
+ exit(-1);
+ }
}
test_array.a = 8;
for (tidx = NR_READ - 1; tidx >= 0; tidx--) {
- pthread_mutex_unlock(&per_thread_lock[tidx].lock);
+ ret = pthread_mutex_unlock(&per_thread_lock[tidx].lock);
+ if (ret) {
+ perror("Error in pthread mutex unlock");
+ exit(-1);
+ }
}
time2 = caa_get_cycles();
writer_time[(unsigned long)arg] += time2 - time1;