#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
#include <sys/mman.h>
#include "libmicro.h"
typedef struct {
int ts_once;
int ts_id;
int ts_us0;
int ts_us1;
int ts_them0;
int ts_them1;
} tsd_t;
static int nthreads;
static int opts = 0;
static int nlocks;
static pthread_mutex_t *locks;
int
benchmark_init()
{
lm_tsdsize = sizeof (tsd_t);
(void) sprintf(lm_optstr, "s");
lm_defN = "cscd_mutex";
(void) sprintf(lm_usage,
" [-s] (force PTHREAD_PROCESS_SHARED)\n"
"notes: thread cascade using pthread_mutexes\n");
return (0);
}
int
benchmark_optswitch(int opt, char *optarg)
{
switch (opt) {
case 's':
opts = 1;
break;
default:
return (-1);
}
return (0);
}
int
benchmark_initrun()
{
int i;
int e = 0;
pthread_mutexattr_t ma;
nthreads = lm_optP * lm_optT;
nlocks = nthreads * 2;
locks = (pthread_mutex_t *)mmap(NULL,
nlocks * sizeof (pthread_mutex_t),
PROT_READ | PROT_WRITE,
MAP_ANON | MAP_SHARED,
-1, 0L);
if (locks == MAP_FAILED) {
return (1);
}
(void) pthread_mutexattr_init(&ma);
if (lm_optP > 1 || opts) {
(void) pthread_mutexattr_setpshared(&ma,
PTHREAD_PROCESS_SHARED);
} else {
(void) pthread_mutexattr_setpshared(&ma,
PTHREAD_PROCESS_PRIVATE);
}
for (i = 0; i < nlocks; i++) {
(void) pthread_mutex_init(&locks[i], &ma);
}
return (e);
}
int
block(int index)
{
return (pthread_mutex_lock(&locks[index]) == -1);
}
int
unblock(int index)
{
return (pthread_mutex_unlock(&locks[index]) == -1);
}
int
benchmark_initbatch(void *tsd)
{
tsd_t *ts = (tsd_t *)tsd;
int e = 0;
if (ts->ts_once == 0) {
int us, them;
#if !defined(__APPLE__)
us = (getpindex() * lm_optT) + gettindex();
#else
us = gettsdindex(tsd);
#endif
them = (us + 1) % (lm_optP * lm_optT);
ts->ts_id = us;
ts->ts_us0 = (us * 2);
ts->ts_us1 = (us * 2) + 1;
if (us < nthreads - 1) {
ts->ts_them0 = (them * 2);
ts->ts_them1 = (them * 2) + 1;
} else {
ts->ts_them0 = (them * 2) + 1;
ts->ts_them1 = (them * 2);
}
ts->ts_once = 1;
}
e += block(ts->ts_them0);
return (e);
}
int
benchmark(void *tsd, result_t *res)
{
tsd_t *ts = (tsd_t *)tsd;
int i;
int e = 0;
e += block(ts->ts_us0);
for (i = 0; i < lm_optB; i += 2) {
e += unblock(ts->ts_us0);
e += block(ts->ts_them1);
e += unblock(ts->ts_them0);
e += block(ts->ts_us1);
e += unblock(ts->ts_us1);
e += block(ts->ts_them0);
e += unblock(ts->ts_them1);
e += block(ts->ts_us0);
}
e += unblock(ts->ts_them0);
e += unblock(ts->ts_us0);
res->re_count = i;
res->re_errors = e;
return (0);
}