#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include "libmicro.h"
typedef struct {
int ts_once;
int *ts_fds;
} tsd_t;
#define DEFN 256
int
benchmark_init()
{
lm_tsdsize = sizeof (tsd_t);
lm_defB = 256;
(void) sprintf(lm_usage,
"notes: measures socketpair\n");
return (0);
}
int
benchmark_initrun()
{
(void) setfdlimit(lm_optB * lm_optT + 10);
return (0);
}
int
benchmark_initbatch(void *tsd)
{
int i;
tsd_t *ts = (tsd_t *)tsd;
if (ts->ts_once++ == 0) {
ts->ts_fds = (int *)malloc(lm_optB * sizeof (int));
if (ts->ts_fds == NULL) {
return (1);
}
for (i = 0; i < lm_optB; i++) {
ts->ts_fds[i] = -1;
}
}
return (0);
}
int
benchmark(void *tsd, result_t *res)
{
int i;
tsd_t *ts = (tsd_t *)tsd;
res->re_count = 0;
res->re_errors = 0;
for (i = 0; i < lm_optB; i += 2) {
if (socketpair(PF_UNIX, SOCK_STREAM, 0, &ts->ts_fds[i])
== -1) {
res->re_errors++;
}
}
res->re_count = i / 2;
return (0);
}
int
benchmark_finibatch(void *tsd)
{
int i;
tsd_t *ts = (tsd_t *)tsd;
for (i = 0; i < lm_optB; i++) {
(void) close(ts->ts_fds[i]);
}
return (0);
}