#include <sys/types.h>
#include <sys/wait.h>
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include "libmicro.h"
typedef struct {
int ts_once;
int *ts_pids;
} tsd_t;
static int opte = 0;
static barrier_t *b;
int
benchmark_init()
{
lm_tsdsize = sizeof (tsd_t);
(void) sprintf(lm_optstr, "e");
(void) sprintf(lm_usage,
" [-e] (uses _exit() rather than exit())"
"notes: measures exit()\n");
return (0);
}
int
benchmark_optswitch(int opt, char *optarg)
{
switch (opt) {
case 'e':
opte = 1;
break;
default:
return (-1);
}
return (0);
}
int
benchmark_initrun()
{
b = barrier_create(lm_optP * lm_optT * (lm_optB + 1), 0);
return (0);
}
int
benchmark_finirun()
{
(void) barrier_destroy(b);
return (0);
}
int
benchmark_initbatch(void *tsd)
{
tsd_t *ts = (tsd_t *)tsd;
int i;
int errors = 0;
if (ts->ts_once++ == 0) {
ts->ts_pids = (int *)malloc(lm_optB * sizeof (pid_t));
if (ts->ts_pids == NULL) {
errors ++;
}
}
for (i = 0; i < lm_optB; i++) {
ts->ts_pids[i] = fork();
switch (ts->ts_pids[i]) {
case 0:
(void) barrier_queue(b, NULL);
if (opte)
_exit(0);
exit(0);
break;
case -1:
errors ++;
break;
default:
continue;
}
}
return (errors);
}
int
benchmark(void *tsd, result_t *res)
{
int i;
(void) barrier_queue(b, NULL);
for (i = 0; i < lm_optB; i++) {
switch (waitpid((pid_t)-1, NULL, 0)) {
case 0:
continue;
case -1:
res->re_errors++;
}
}
res->re_count = i;
return (0);
}